queue

Jul 29, 2020

Changes in this version

+ type QueueMock struct

+ DequeueCount int

+ DequeueErr error

+ EnqueueCount int

+ EnqueueErr error

+ FailCount int

+ FailErr error

+ FinishCount int

+ FinishErr error

+ HeartbeatCount int

+ HeartbeatErr error

+ Queue chan Task

+ func (q *QueueMock) Dequeue(ctx context.Context, queue ...string) (*Task, error)

+ func (q *QueueMock) Enqueue(ctx context.Context, task TaskEnqueueRequest) error

+ func (q *QueueMock) Fail(ctx context.Context, taskID string, progress Progress) error

+ func (q *QueueMock) Finish(ctx context.Context, taskID string, progress Progress) error

+ func (q *QueueMock) Heartbeat(ctx context.Context, taskID string, progress Progress) error

+ type SchedulerMock struct

+ AssertCount int

+ AssertError error

+ EnsureCount int

+ EnsureError error

+ ScheduleCount int

+ ScheduleErr error

+ func (s *SchedulerMock) AssertSchedule(ctx context.Context, task TaskScheduleRequest) error

+ func (s *SchedulerMock) EnsureSchedule(ctx context.Context, builder cdb.SQLBuilder, task TaskScheduleRequest) error

+ func (s *SchedulerMock) Schedule(ctx context.Context, builder cdb.SQLBuilder, task TaskScheduleRequest) (err error)

Jul 29, 2020

Changes in this version

type Scheduler

+ AssertSchedule func(ctx context.Context, task TaskScheduleRequest) (err error)

Jul 27, 2020

Changes in this version

+ func SwitchMetricsServiceName(serviceName string)

Jul 17, 2020

Changes in this version

+ var ErrNotScheduled = errors.New("Task not currently scheduled")

+ var ErrTaskCancelled = errors.New("task has been cancelled")

+ var ErrTaskFailed = errors.New("task failed")

+ var ErrTaskFinished = errors.New("task has finished")

+ var ErrTaskNotFound = errors.New("task not found")

+ var ErrTaskNotRunning = errors.New("task has not started yet")

+ var ErrTaskQueueNotSpecified = errors.New("task queue name cannot be blank")

+ var ErrTaskTypeNotSpecified = errors.New("task type cannot be blank")

+ func SetupSchedulerMetrics(namespace string)

+ func SetupTaskQueueMetrics(namespace string)

+ type Dequeuer interface

+ Dequeue func(ctx context.Context, queue ...string) (*Task, error)

+ Fail func(ctx context.Context, taskID string, progress Progress) error

+ Finish func(ctx context.Context, taskID string, progress Progress) error

+ Heartbeat func(ctx context.Context, taskID string, progress Progress) error

+ func DequeuerWithMetrics(q Dequeuer) Dequeuer

+ type Progress []byte

+ type Queuer interface

+ Enqueue func(ctx context.Context, task TaskEnqueueRequest) error

+ func QueuerWithMetrics(q Queuer) Queuer

+ type References map[string]interface

+ func (a References) GetNamesAndValues() (keys []string, values []interface{})

+ type Scheduler interface

+ EnsureSchedule func(ctx context.Context, builder cdb.SQLBuilder, task TaskScheduleRequest) (err error)

+ Schedule func(ctx context.Context, builder cdb.SQLBuilder, task TaskScheduleRequest) error

+ func SchedulerWithMetrics(s Scheduler) Scheduler

+ type SchedulerMetricsType struct

+ ErrorCounter *prometheus.CounterVec

+ Labels []string

+ ScheduleCounter *prometheus.CounterVec

+ var SchedulerMetrics SchedulerMetricsType

+ type Spec []byte

+ type Task struct

+ CreatedAt time.Time

+ FinishedAt *time.Time

+ ID string

+ LastHeartbeatAt *time.Time

+ Progress Progress

+ StartedAt *time.Time

+ Status TaskStatus

+ UpdatedAt time.Time

+ type TaskBase struct

+ Queue string

+ Spec Spec

+ Type TaskType

+ type TaskEnqueueRequest struct

+ References References

+ type TaskQueueMetricsType struct

+ EnqueueDuration *prometheus.HistogramVec

+ Labels []string

+ TaskCounter *prometheus.CounterVec

+ var TaskQueueMetrics TaskQueueMetricsType

+ type TaskScheduleRequest struct

+ CronSchedule string

+ References References

+ type TaskStatus string

+ const Cancelled

+ const Failed

+ const Finished

+ const Running

+ const Waiting

+ type TaskType string

+ func (t TaskType) String() string