taskrunner

type Task interface {
	RemoveMeta(key string) error
	AddMeta(key string, val interface{}) error
	GetMeta(key string) (val interface{}, ok bool)

	Cancel()
	// contains filtered or unexported methods
}

type TaskManager interface {
	GO(ctx context.Context, fn runnable) (taskId string, err error)
	RestartTasksFromMetaKey(key string) (count int, err error)
	CancelTaskFromMetaKey(key string) (count int, err error)
	FindFromMetaKey(key string) (tasks []Task)
	IsOpen() bool
	GetTasksCount() int
}