worker

Documentation

Index

• type Syncer
  • func (r *Syncer) SetCronner(pluginType string)
  • func (r *Syncer) SetInteractor(pluginType string)
  • func (r *Syncer) SetStage(interfaceName string, stageIndex int, stageConfig interface{})
  • func (r *Syncer) StartCronners()
  • func (r *Syncer) StartInteractor()
  • func (r *Syncer) StopCronners()
  • func (r *Syncer) StopInteractor()
• type Worker
  • func InitWorker() Worker

Types

type Syncer

type Syncer struct {
	Interact string
	CronJobs []string
	// contains filtered or unexported fields
}

func (*Syncer) SetCronner

func (r *Syncer) SetCronner(pluginType string)

func (*Syncer) SetInteractor

func (r *Syncer) SetInteractor(pluginType string)

func (*Syncer) SetStage

func (r *Syncer) SetStage(interfaceName string, stageIndex int, stageConfig interface{})

func (*Syncer) StartCronners

func (r *Syncer) StartCronners()

func (*Syncer) StartInteractor

func (r *Syncer) StartInteractor()

func (*Syncer) StopCronners

func (r *Syncer) StopCronners()

func (*Syncer) StopInteractor

func (r *Syncer) StopInteractor()

type Worker

type Worker interface {
	plug.InteractUser
	plug.CronUser
}

func InitWorker

func InitWorker() Worker