sync

Documentation

Index

• func NewSpiderSyncService(opts ...Option) (svc2 interfaces.SpiderSyncService, err error)
• func ProvideSpiderSyncService(path string, opts ...Option) func() (svc interfaces.SpiderSyncService, err error)
• type Option
  • func WithConfigPath(path string) Option
  • func WithFsPathBase(path string) Option
  • func WithRepoPathBase(path string) Option
  • func WithWorkspacePathBase(path string) Option
• type Service
  • func (svc *Service) ForceGetFsService(id primitive.ObjectID) (fsSvc interfaces.SpiderFsService, err error)
  • func (svc *Service) GetConfigPath() (path string)
  • func (svc *Service) GetFsService(id primitive.ObjectID) (fsSvc interfaces.SpiderFsService, err error)
  • func (svc *Service) SetConfigPath(path string)
  • func (svc *Service) SetFsPathBase(path string)
  • func (svc *Service) SetRepoPathBase(path string)
  • func (svc *Service) SetWorkspacePathBase(path string)
  • func (svc *Service) SyncToFs(id primitive.ObjectID) (err error)
  • func (svc *Service) SyncToWorkspace(id primitive.ObjectID) (err error)

Functions

func NewSpiderSyncService

func NewSpiderSyncService(opts ...Option) (svc2 interfaces.SpiderSyncService, err error)

func ProvideSpiderSyncService

func ProvideSpiderSyncService(path string, opts ...Option) func() (svc interfaces.SpiderSyncService, err error)

Types

type Option

type Option func(svc interfaces.SpiderSyncService)

func WithConfigPath

func WithConfigPath(path string) Option

func WithFsPathBase

func WithFsPathBase(path string) Option

func WithRepoPathBase

func WithRepoPathBase(path string) Option

func WithWorkspacePathBase

func WithWorkspacePathBase(path string) Option

type Service

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

func (*Service) ForceGetFsService

func (svc *Service) ForceGetFsService(id primitive.ObjectID) (fsSvc interfaces.SpiderFsService, err error)

func (*Service) GetConfigPath

func (svc *Service) GetConfigPath() (path string)

func (*Service) GetFsService

func (svc *Service) GetFsService(id primitive.ObjectID) (fsSvc interfaces.SpiderFsService, err error)

func (*Service) SetConfigPath

func (svc *Service) SetConfigPath(path string)

func (*Service) SetFsPathBase

func (svc *Service) SetFsPathBase(path string)

func (*Service) SetRepoPathBase

func (svc *Service) SetRepoPathBase(path string)

func (*Service) SetWorkspacePathBase

func (svc *Service) SetWorkspacePathBase(path string)

func (*Service) SyncToFs

func (svc *Service) SyncToFs(id primitive.ObjectID) (err error)

SyncToFs sync from repo/workspace to fs

func (*Service) SyncToWorkspace

func (svc *Service) SyncToWorkspace(id primitive.ObjectID) (err error)

SyncToWorkspace sync from fs to workspace Useful for worker nodes to sync files from master or fs (filer)