worker

Documentation

Index

• type Onewayer
  • func (o *Onewayer) GetStatus() bool
  • func (o *Onewayer) SetCronner(pluginType string)
  • func (o *Onewayer) SetParter(pluginType string)
  • func (o *Onewayer) StartCronners()
  • func (o *Onewayer) StartParters()
  • func (o *Onewayer) StopCronners()
  • func (o *Onewayer) StopParters()
• type Worker
  • func InitWorker() Worker

Types

type Onewayer

type Onewayer struct {
	Inputs    []string
	Transits  []string
	Processes []string
	Outputs   []string
	Crons     []string
	// contains filtered or unexported fields
}

func (*Onewayer) GetStatus

func (o *Onewayer) GetStatus() bool

func (*Onewayer) SetCronner

func (o *Onewayer) SetCronner(pluginType string)

func (*Onewayer) SetParter

func (o *Onewayer) SetParter(pluginType string)

func (*Onewayer) StartCronners

func (o *Onewayer) StartCronners()

func (*Onewayer) StartParters

func (o *Onewayer) StartParters()

func (*Onewayer) StopCronners

func (o *Onewayer) StopCronners()

func (*Onewayer) StopParters

func (o *Onewayer) StopParters()

type Worker

type Worker interface {
	plug.PartUser
	plug.CronUser
	plug.Statuser
}

func InitWorker

func InitWorker() Worker