handle

Documentation

Index

• Variables
• type Manager
  • func NewManager(ctx context.Context, config option.Config, store store.Storer, ...) *Manager
  • func (m *Manager) AnalystToExec(task *model.Task) error

Variables

var ErrCallback = fmt.Errorf("callback task to mq")

ErrCallback do not handle this task

Types

type Manager

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

Manager manager

func NewManager

func NewManager(ctx context.Context,
	config option.Config,
	store store.Storer,
	controllerManager *controller.Manager,
	startCh *channels.RingChannel) *Manager

NewManager now handle

func (*Manager) AnalystToExec

func (m *Manager) AnalystToExec(task *model.Task) error

AnalystToExec analyst exec