Documentation
¶
Index ¶
- type TaskService
- type TaskServiceImpl
- func (s TaskServiceImpl) Cancel(taskID string) error
- func (s TaskServiceImpl) Complete(taskID string, result string) error
- func (s TaskServiceImpl) Create(owner string, taskQueue string, timeout int32, retry int32, payload string) (string, error)
- func (s TaskServiceImpl) Delete(taskID string) error
- func (s TaskServiceImpl) Fail(taskID string) error
- func (s TaskServiceImpl) Select(taskID string) error
- func (s TaskServiceImpl) Timeout(taskID string) error
- type TaskServiceLocker
- func (l TaskServiceLocker) Cancel(taskID string) error
- func (l TaskServiceLocker) Complete(taskID string, result string) error
- func (l TaskServiceLocker) Create(owner string, taskQueue string, timeout int32, retry int32, payload string) (string, error)
- func (l TaskServiceLocker) Delete(taskID string) error
- func (l TaskServiceLocker) Fail(taskID string) error
- func (l TaskServiceLocker) Select(taskID string) error
- func (l TaskServiceLocker) Timeout(taskID string) error
- type TaskServiceLogger
- func (l TaskServiceLogger) Cancel(taskID string) error
- func (l TaskServiceLogger) Complete(taskID string, result string) error
- func (l TaskServiceLogger) Create(owner string, taskQueue string, timeout int32, retry int32, payload string) (string, error)
- func (l TaskServiceLogger) Delete(taskID string) error
- func (l TaskServiceLogger) Fail(taskID string) error
- func (l TaskServiceLogger) Select(taskID string) error
- func (l TaskServiceLogger) Timeout(taskID string) error
- type TaskTimeoutService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskService ¶
type TaskService interface {
Create(owner string, taskQueue string, timeout int32, retry int32, payload string) (string, error)
Select(taskID string) error
Fail(taskID string) error
Cancel(taskID string) error
Timeout(taskID string) error
Complete(taskID string, result string) error
Delete(taskID string) error
}
TaskService is a service to manage tasks
type TaskServiceImpl ¶
type TaskServiceImpl struct {
// contains filtered or unexported fields
}
TaskServiceImpl is an implementation of TaskService
func NewTaskService ¶
func NewTaskService(repository repository.TaskRepository, view view.TaskView, resultExpiration int) TaskServiceImpl
NewTaskService creates a new TaskService
func (TaskServiceImpl) Cancel ¶
func (s TaskServiceImpl) Cancel(taskID string) error
Cancel marks a task as canceled
func (TaskServiceImpl) Complete ¶
func (s TaskServiceImpl) Complete(taskID string, result string) error
Complete marks a task as completed
func (TaskServiceImpl) Create ¶
func (s TaskServiceImpl) Create(owner string, taskQueue string, timeout int32, retry int32, payload string) (string, error)
Create creates a new task from given arguments
func (TaskServiceImpl) Delete ¶
func (s TaskServiceImpl) Delete(taskID string) error
Delete deletes a task
func (TaskServiceImpl) Fail ¶
func (s TaskServiceImpl) Fail(taskID string) error
Fail marks a task as failed
func (TaskServiceImpl) Select ¶
func (s TaskServiceImpl) Select(taskID string) error
Select marks a task as selected
func (TaskServiceImpl) Timeout ¶
func (s TaskServiceImpl) Timeout(taskID string) error
Timeout marks a task as timedout
type TaskServiceLocker ¶
type TaskServiceLocker struct {
// contains filtered or unexported fields
}
func NewTaskServiceLocker ¶
func NewTaskServiceLocker(locker *redislock.Client, next TaskService) TaskServiceLocker
func (TaskServiceLocker) Cancel ¶
func (l TaskServiceLocker) Cancel(taskID string) error
func (TaskServiceLocker) Complete ¶
func (l TaskServiceLocker) Complete(taskID string, result string) error
func (TaskServiceLocker) Delete ¶
func (l TaskServiceLocker) Delete(taskID string) error
func (TaskServiceLocker) Fail ¶
func (l TaskServiceLocker) Fail(taskID string) error
func (TaskServiceLocker) Select ¶
func (l TaskServiceLocker) Select(taskID string) error
func (TaskServiceLocker) Timeout ¶
func (l TaskServiceLocker) Timeout(taskID string) error
type TaskServiceLogger ¶
type TaskServiceLogger struct {
// contains filtered or unexported fields
}
############################################################################
Logging Middleware
############################################################################
func NewTaskServiceLogger ¶
func NewTaskServiceLogger(logger log.Logger, next TaskService) TaskServiceLogger
func (TaskServiceLogger) Cancel ¶
func (l TaskServiceLogger) Cancel(taskID string) error
func (TaskServiceLogger) Complete ¶
func (l TaskServiceLogger) Complete(taskID string, result string) error
func (TaskServiceLogger) Delete ¶
func (l TaskServiceLogger) Delete(taskID string) error
func (TaskServiceLogger) Fail ¶
func (l TaskServiceLogger) Fail(taskID string) error
func (TaskServiceLogger) Select ¶
func (l TaskServiceLogger) Select(taskID string) error
func (TaskServiceLogger) Timeout ¶
func (l TaskServiceLogger) Timeout(taskID string) error
type TaskTimeoutService ¶
type TaskTimeoutService struct {
// contains filtered or unexported fields
}
TaskTimeoutService is a service to manage task timeouts
func NewTaskTimeoutService ¶
func NewTaskTimeoutService(service TaskService, view view.TaskView) TaskTimeoutService
NewTaskTimeoutService creates a new TaskTimeoutService
func (TaskTimeoutService) TimeoutTasks ¶
func (s TaskTimeoutService) TimeoutTasks() error
TimeoutTasks make all needed tasks to timeout
Source Files
Click to show internal directories.
Click to hide internal directories.