server

package
v0.0.0-...-11651c4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2018 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSyncServer

func NewSyncServer(configPath string) *syncServer

func NextId

func NextId() int64

Types

type ClientConfig

type ClientConfig struct {
	Name      string
	ProtoName string
	AddrList  []string
	EtcdAddrs []string
	Balancer  string
}

type SyncServiceImpl

type SyncServiceImpl struct {
	// contains filtered or unexported fields
}

func NewSyncService

func NewSyncService(sync2 *syncServer) *SyncServiceImpl

func (*SyncServiceImpl) Destroy

func (s *SyncServiceImpl) Destroy()

func (*SyncServiceImpl) GetNewUpdatesData

func (s *SyncServiceImpl) GetNewUpdatesData(ctx context.Context, request *mtproto.NewUpdatesRequest) (reply *mtproto.Updates, err error)

rpc GetNewUpdatesData(NewUpdatesRequest) returns (Updates);

func (*SyncServiceImpl) PushUpdatesData

func (s *SyncServiceImpl) PushUpdatesData(ctx context.Context, request *mtproto.UpdatesRequest) (reply *mtproto.VoidRsp, err error)

rpc PushUpdatesData(UpdatesRequest) returns (VoidRsp);

func (*SyncServiceImpl) SyncUpdatesData

func (s *SyncServiceImpl) SyncUpdatesData(ctx context.Context, request *mtproto.UpdatesRequest) (reply *mtproto.ClientUpdatesState, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL