worker

Documentation

Index

• type Worker
  • func New(s setting.Setting, runtime runtime.Runtime, ...) (*Worker, error)
  • func (w *Worker) Execute() error
  • func (w *Worker) Shutdown()
  • func (w *Worker) StartWorkflow(data []byte) error
  • func (w *Worker) StopWorkflow(wid uint64)

Types

type Worker

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

func New

func New(s setting.Setting, runtime runtime.Runtime, newEnvironment environment.NewEnvironment, busEvent bus.Bus) (*Worker, error)

func (*Worker) Execute

func (w *Worker) Execute() error

func (*Worker) Shutdown

func (w *Worker) Shutdown()

func (*Worker) StartWorkflow

func (w *Worker) StartWorkflow(data []byte) error

func (*Worker) StopWorkflow

func (w *Worker) StopWorkflow(wid uint64)