Documentation
¶
Index ¶
- Constants
- Variables
- type NotCompletedStatus
- type PanickedStatus
- type RecurringTaskDaemonCommand
- type RecurringTaskDaemonCommandResult
- type RecurringTaskDescriptor
- type RecurringTaskDescriptorHeap
- type RecurringTaskScheduler
- type RecurringTaskSpec
- type RecurringTaskTimeResolution
- type SimpleTaskRunner
- type TaskRunner
- type TaskStatus
Constants ¶
View Source
const ( Insert = iota Update TryPop Delete NoOp )
View Source
const ( Stopped = 0 Running = 1 )
View Source
const ( Nanosecond = RecurringTaskTimeResolution(0) Second = RecurringTaskTimeResolution(1) Minute = RecurringTaskTimeResolution(2) Hour = RecurringTaskTimeResolution(3) Day = RecurringTaskTimeResolution(4) Month = RecurringTaskTimeResolution(5) Year = RecurringTaskTimeResolution(6) )
Variables ¶
View Source
var NotCompleted = &NotCompletedStatus{}
Functions ¶
This section is empty.
Types ¶
type NotCompletedStatus ¶
type NotCompletedStatus struct{}
func (*NotCompletedStatus) Error ¶
func (_ *NotCompletedStatus) Error() string
type PanickedStatus ¶
type PanickedStatus struct {
// contains filtered or unexported fields
}
func (*PanickedStatus) Error ¶
func (panicked *PanickedStatus) Error() string
type RecurringTaskDaemonCommand ¶
type RecurringTaskDaemonCommand struct {
// contains filtered or unexported fields
}
type RecurringTaskDaemonCommandResult ¶
type RecurringTaskDaemonCommandResult struct {
// contains filtered or unexported fields
}
type RecurringTaskDescriptor ¶
type RecurringTaskDescriptor struct {
// contains filtered or unexported fields
}
type RecurringTaskDescriptorHeap ¶
type RecurringTaskDescriptorHeap []*RecurringTaskDescriptor
type RecurringTaskScheduler ¶
type RecurringTaskScheduler struct {
// contains filtered or unexported fields
}
func NewRecurringTaskScheduler ¶
func NewRecurringTaskScheduler(nowGetter func() time.Time, taskRunner TaskRunner) *RecurringTaskScheduler
func (*RecurringTaskScheduler) NoOp ¶
func (sched *RecurringTaskScheduler) NoOp()
func (*RecurringTaskScheduler) ProcessEvent ¶
func (sched *RecurringTaskScheduler) ProcessEvent()
func (*RecurringTaskScheduler) RegisterTask ¶
func (sched *RecurringTaskScheduler) RegisterTask(spec RecurringTaskSpec, task func(int64, time.Time, *RecurringTaskSpec) (interface{}, error)) (int64, error)
func (*RecurringTaskScheduler) RunNext ¶
func (sched *RecurringTaskScheduler) RunNext() (time.Duration, TaskStatus, error)
type RecurringTaskSpec ¶
type RecurringTaskSpec struct {
// contains filtered or unexported fields
}
type RecurringTaskTimeResolution ¶
type RecurringTaskTimeResolution int
type SimpleTaskRunner ¶
type SimpleTaskRunner struct{}
func (*SimpleTaskRunner) Run ¶
func (runner *SimpleTaskRunner) Run(task func() (interface{}, error)) (TaskStatus, error)
type TaskRunner ¶
type TaskRunner interface {
Run(func() (interface{}, error)) (TaskStatus, error)
}
type TaskStatus ¶
type TaskStatus interface {
Status() error
Result() interface{}
Poll()
}
Source Files
Click to show internal directories.
Click to hide internal directories.