Documentation
¶
Index ¶
- type CoordinatingTaskService
- func (s *CoordinatingTaskService) CancelRun(ctx context.Context, taskID, runID platform.ID) error
- func (s *CoordinatingTaskService) CreateTask(ctx context.Context, tc taskmodel.TaskCreate) (*taskmodel.Task, error)
- func (s *CoordinatingTaskService) DeleteTask(ctx context.Context, id platform.ID) error
- func (s *CoordinatingTaskService) ForceRun(ctx context.Context, taskID platform.ID, scheduledFor int64) (*taskmodel.Run, error)
- func (s *CoordinatingTaskService) RetryRun(ctx context.Context, taskID, runID platform.ID) (*taskmodel.Run, error)
- func (s *CoordinatingTaskService) UpdateTask(ctx context.Context, id platform.ID, upd taskmodel.TaskUpdate) (*taskmodel.Task, error)
- type Coordinator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CoordinatingTaskService ¶
type CoordinatingTaskService struct {
taskmodel.TaskService
// contains filtered or unexported fields
}
CoordinatingTaskService acts as a TaskService decorator that handles coordinating the api request with the required task control actions asynchronously via a message dispatcher
func New ¶
func New(service taskmodel.TaskService, coordinator Coordinator) *CoordinatingTaskService
New constructs a new coordinating task service
func (*CoordinatingTaskService) CreateTask ¶
func (s *CoordinatingTaskService) CreateTask(ctx context.Context, tc taskmodel.TaskCreate) (*taskmodel.Task, error)
CreateTask Creates a task in the existing task service and Publishes the change so any TaskD service can lease it.
func (*CoordinatingTaskService) DeleteTask ¶
DeleteTask delete the task and publishes the change, to allow the task owner to find out about this change faster.
func (*CoordinatingTaskService) ForceRun ¶
func (s *CoordinatingTaskService) ForceRun(ctx context.Context, taskID platform.ID, scheduledFor int64) (*taskmodel.Run, error)
ForceRun create the forced run in the task system and publish to the pubSub.
func (*CoordinatingTaskService) RetryRun ¶
func (s *CoordinatingTaskService) RetryRun(ctx context.Context, taskID, runID platform.ID) (*taskmodel.Run, error)
RetryRun calls retry on the task service and publishes the retry.
func (*CoordinatingTaskService) UpdateTask ¶
func (s *CoordinatingTaskService) UpdateTask(ctx context.Context, id platform.ID, upd taskmodel.TaskUpdate) (*taskmodel.Task, error)
UpdateTask Updates a task and publishes the change so the task owner can act on the update
type Coordinator ¶
type Coordinator interface {
TaskCreated(context.Context, *taskmodel.Task) error
TaskUpdated(ctx context.Context, from, to *taskmodel.Task) error
TaskDeleted(context.Context, platform.ID) error
RunCancelled(ctx context.Context, runID platform.ID) error
RunRetried(ctx context.Context, task *taskmodel.Task, run *taskmodel.Run) error
RunForced(ctx context.Context, task *taskmodel.Task, run *taskmodel.Run) error
}
Coordinator is a type which is used to react to task related actions
Source Files