dispatch

Documentation

Index

• Variables
• type Dispatcher
  • func Init(entry dentry.Manager, wfMgr workflow.Manager, notify *notify.Notify, ...) (*Dispatcher, error)
  • func (d *Dispatcher) Run(stopCh chan struct{})

Variables

var (
	ErrNeedRetry = fmt.Errorf("need retry")
)

Types

type Dispatcher

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

func Init

func Init(entry dentry.Manager, wfMgr workflow.Manager, notify *notify.Notify, recorder metastore.ScheduledTaskRecorder) (*Dispatcher, error)

func (*Dispatcher) Run

func (d *Dispatcher) Run(stopCh chan struct{})