server

Documentation

Index

• func NewSyncServer(configPath string) *syncServer
• func NextId() int64
• type ClientConfig
• type SyncServiceImpl
  • func NewSyncService(sync2 *syncServer) *SyncServiceImpl
  • func (s *SyncServiceImpl) Destroy()
  • func (s *SyncServiceImpl) GetNewUpdatesData(ctx context.Context, request *mtproto.NewUpdatesRequest) (reply *mtproto.Updates, err error)
  • func (s *SyncServiceImpl) PushUpdatesData(ctx context.Context, request *mtproto.UpdatesRequest) (reply *mtproto.VoidRsp, err error)
  • func (s *SyncServiceImpl) SyncUpdatesData(ctx context.Context, request *mtproto.UpdatesRequest) (reply *mtproto.ClientUpdatesState, err error)

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)