tasks_manager

type ActionsInterface interface {
	// RunTask runs task or returns busy error
	RunTask(ctx context.Context, reqStorage logical.Storage, taskFunc func(ctx context.Context, storage logical.Storage) error) (string, error)

	// AddTask adds task to queue
	AddTask(ctx context.Context, reqStorage logical.Storage, taskFunc func(ctx context.Context, storage logical.Storage) error) (string, error)

	// AddOptionalTask adds task to queue if empty
	AddOptionalTask(ctx context.Context, reqStorage logical.Storage, taskFunc func(ctx context.Context, storage logical.Storage) error) (string, bool, error)
}

type Manager struct {
	Storage logical.Storage
	Worker  worker.Interface
	// contains filtered or unexported fields
}

type Task struct {
	UUID     string    `structs:"uuid" json:"uuid"`
	Status   string    `structs:"status" json:"status"`
	Reason   string    `structs:"reason" json:"reason"`
	Created  time.Time `structs:"created" json:"created"`
	Modified time.Time `structs:"modified" json:"modified"`
}