executor

Documentation

Index

• type Manager
  • func NewManager(conf option.Config, statusManager *status.AppRuntimeSyncClient, ...) (Manager, error)
• type Worker

Types

type Manager

type Manager interface {
	AddTask(task task.Task) error
	RemoveTask(task task.Task)
	// Start starts the Manager sync loops.
	Start()
	Stop()
	TaskManager() *task.TaskManager
	GetWorker(taskID string, eventID string) (Worker, bool)
	WorkerCount() int
}

Manager Manager

func NewManager

func NewManager(conf option.Config, statusManager *status.AppRuntimeSyncClient, appmm appm.Manager) (Manager, error)

NewManager newManager

type Worker

type Worker interface {
	Start(wg sync.WaitGroup)
	Cancel() error
	RollBack() error
	Status() string
}

Worker 工作器