server

Documentation

Index

• func CreateLocalFileMetaResponse(path string, ignores []string) (*protocol.SyncResponse, error)
• type ServiceProvider
  • func (s *ServiceProvider) Boot(app *glacier.Glacier)
  • func (s *ServiceProvider) Daemon(ctx context.Context, app *glacier.Glacier)
  • func (s *ServiceProvider) Register(app *container.Container)
• type SyncServer
  • func NewSyncServer(bufferSize int64, statusStore storage.JobStatusStore) *SyncServer
  • func (s *SyncServer) RelayInfo(ctx context.Context, req *protocol.RelayRequest) (*protocol.RelayResponse, error)
  • func (s *SyncServer) SyncFile(req *protocol.DownloadRequest, serv protocol.SyncService_SyncFileServer) error
  • func (s *SyncServer) SyncMeta(ctx context.Context, req *protocol.SyncRequest) (*protocol.SyncResponse, error)

Functions

func CreateLocalFileMetaResponse

func CreateLocalFileMetaResponse(path string, ignores []string) (*protocol.SyncResponse, error)

Types

type ServiceProvider

type ServiceProvider struct{}

func (*ServiceProvider) Boot

func (s *ServiceProvider) Boot(app *glacier.Glacier)

func (*ServiceProvider) Daemon

func (s *ServiceProvider) Daemon(ctx context.Context, app *glacier.Glacier)

func (*ServiceProvider) Register

func (s *ServiceProvider) Register(app *container.Container)

type SyncServer

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

SyncServer is a implement for Server side GRPC

func NewSyncServer

func NewSyncServer(bufferSize int64, statusStore storage.JobStatusStore) *SyncServer

NewSyncServer create a new SyncServer

func (*SyncServer) RelayInfo

func (s *SyncServer) RelayInfo(ctx context.Context, req *protocol.RelayRequest) (*protocol.RelayResponse, error)

RelayInfo 检查是否同步任务有更新

func (*SyncServer) SyncFile

func (s *SyncServer) SyncFile(req *protocol.DownloadRequest, serv protocol.SyncService_SyncFileServer) error

Download 文件下载服务

func (*SyncServer) SyncMeta

func (s *SyncServer) SyncMeta(ctx context.Context, req *protocol.SyncRequest) (*protocol.SyncResponse, error)

Sync 文件元信息同步