Versions in this module Expand all Collapse all v0 v0.0.1 Feb 15, 2020 Changes in this version + const PathCheckpoint + const PatternPathJobTopicData + const SpaceDefaultWorker + func NewFactoryRegistry() (factory *factoryRegistry) + type DataHandler func(jobID string, topic string, rowID string, value []byte) bool + type DataPath struct + JobID string + Topic string + func ParseDataPath(path string) (dataPath DataPath, err error) + func ParseDataPathBytes(path []byte) (dataPath DataPath, err error) + func (path DataPath) String() string + type Factory interface + Name func() string + NewWorker func(helper *Helper) (Worker, error) + Space func() string + type Helper struct + func NewHelper(space string, config common.DaemonConfig, logger log.Logger, job job.Job, ...) *Helper + func (helper *Helper) Config() common.DaemonConfig + func (helper *Helper) Debug(msg string, keyvals ...interface{}) + func (helper *Helper) DeleteData(topic string, rowID string) error + func (helper *Helper) Error(msg string, keyvals ...interface{}) + func (helper *Helper) GetCheckpoint(checkpoint interface{}) error + func (helper *Helper) GetData(topic string, rowID string) (data []byte, err error) + func (helper *Helper) GetDataList(topic string, handler DataHandler) error + func (helper *Helper) GetObject(topic string, rowID string, data interface{}) error + func (helper *Helper) GetRepository() Repository + func (helper *Helper) ID() string + func (helper *Helper) Info(msg string, keyvals ...interface{}) + func (helper *Helper) Job() job.Job + func (helper *Helper) PutCheckpoint(checkpoint interface{}) error + func (helper *Helper) PutData(topic string, rowID string, data []byte) error + func (helper *Helper) PutDataFullPath(fullPath string, data []byte) error + func (helper *Helper) PutObject(topic string, rowID string, data interface{}) error + func (helper *Helper) Space() string + type Manager struct + func NewManager(context common.Context, spaceRegistry types.SpaceRegistry) *Manager + func (manager *Manager) ContainsWorker(id string) bool + func (manager *Manager) GetRepository() Repository + func (manager *Manager) GetWorker(id string) Worker + func (manager *Manager) RegisterWorkerFactory(factory Factory) error + func (manager *Manager) SetJobs(jobs []job.Job) + func (manager *Manager) Start() + type Repository interface + DeleteData func(space string, jobID string, topic string, rowID string) error + DeleteDataFullPath func(space string, path string) error + GetCheckpoint func(jobID string, checkpoint interface{}) error + GetData func(space string, jobID string, topic string, rowID string) (data []byte, err error) + GetDataFullPath func(space string, path string) (data []byte, err error) + GetDataWithTopic func(space string, jobID string, topic string, handler DataHandler) error + GetObject func(space string, jobID string, topic string, rowID string, data interface{}) error + GetObjectFullPath func(space string, path string, data interface{}) (err error) + PutCheckpoint func(jobID string, checkpoint interface{}) error + PutData func(space string, jobID string, topic string, rowID string, data []byte) error + PutDataFullPath func(space string, path string, data []byte) error + PutObject func(space string, jobID string, topic string, rowID string, data interface{}) error + PutObjectFullPath func(space string, path string, data interface{}) error + func NewRepository(config common.DaemonConfig, logger log.Logger, client types.Client) Repository + type Worker interface + ID func() string + IsStarted func() bool + Start func() error + Stop func() error
Go to main page