Documentation ¶
Index ¶
- func CreateLocalFileMetaResponse(path string, ignores []string) (*protocol.SyncResponse, error)
- type ServiceProvider
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 文件元信息同步
Click to show internal directories.
Click to hide internal directories.