job

Documentation

Index

• type FileSyncJob
  • func NewFileSyncJob(group meta.FileSyncGroup) *FileSyncJob
  • func (job *FileSyncJob) AfterActions() []meta.SyncAction
  • func (job *FileSyncJob) BeforeActions() []meta.SyncAction
  • func (job *FileSyncJob) Decode(res []byte)
  • func (job *FileSyncJob) Encode() []byte
  • func (job *FileSyncJob) ErrorActions() []meta.SyncAction
  • func (job *FileSyncJob) Handle(ctx context.Context, rpcFactory rpc.Factory, col *collector.Collector) error
  • func (job *FileSyncJob) Init(settingFactory storage.SettingFactory, actionFactory action.Factory, ...)
  • func (job *FileSyncJob) RemoteServer() string
  • func (job *FileSyncJob) RemoteServerToken() string

Types

type FileSyncJob

type FileSyncJob struct {
	ID        string             `json:"id"`
	Name      string             `json:"name"`
	Payload   meta.FileSyncGroup `json:"payload"`
	CreatedAt time.Time          `json:"created_at"`
	// contains filtered or unexported fields
}

FileSyncJob is a job for file sync

func NewFileSyncJob

func NewFileSyncJob(group meta.FileSyncGroup) *FileSyncJob

NewFileSyncJob create a FileSyncJob

func (*FileSyncJob) AfterActions

func (job *FileSyncJob) AfterActions() []meta.SyncAction

func (*FileSyncJob) BeforeActions

func (job *FileSyncJob) BeforeActions() []meta.SyncAction

func (*FileSyncJob) Decode

func (job *FileSyncJob) Decode(res []byte)

func (*FileSyncJob) Encode

func (job *FileSyncJob) Encode() []byte

func (*FileSyncJob) ErrorActions

func (job *FileSyncJob) ErrorActions() []meta.SyncAction

func (*FileSyncJob) Handle

func (job *FileSyncJob) Handle(ctx context.Context, rpcFactory rpc.Factory, col *collector.Collector) error

func (*FileSyncJob) Init

func (job *FileSyncJob) Init(settingFactory storage.SettingFactory, actionFactory action.Factory, conf *config.Config)

func (*FileSyncJob) RemoteServer

func (job *FileSyncJob) RemoteServer() string

func (*FileSyncJob) RemoteServerToken

func (job *FileSyncJob) RemoteServerToken() string