pkg

package

Go to main page

Versions in this module

v1

v1.1.0

May 24, 2023

v1.0.4

Nov 28, 2022

v1.0.3

Nov 22, 2022

Changes in this version

type Scheduler

+ func (s *Scheduler) DeleteTaskDefinitions(ids []*uuid.UUID) error

+ func (s *Scheduler) DeleteTaskDefinitionsByMetadataQuery(metadataQuery interface{}) error

+ func (s *Scheduler) GetTaskDefinitions(ids []*uuid.UUID) ([]TaskDefinition, error)

+ func (s *Scheduler) ListTaskDefinitions(skip, limit int, metadataQuery interface{}) ([]TaskDefinition, error)

+ func (s *Scheduler) UpsertTaskDefinition(task TaskDefinition) error

type StoreInterface

+ DeleteTaskDefinitions func(ids []*uuid.UUID) error

+ DeleteTaskDefinitionsByMetadata func(metadataQuery interface{}) error

+ GetTaskDefinitions func(ids []*uuid.UUID) ([]TaskDefinition, error)

+ UpsertTaskDefinition func(definition TaskDefinition) error

+ UpsertTaskInstance func(taskInstance TaskInstance) error

v1.0.2

Nov 10, 2022

Changes in this version

+ func ISONanoString(theTime time.Time) string

+ func StringPointer(theString string) *string

type CronTrigger

+ Expression string

+ func (t CronTrigger) GetFireTime(from time.Time) *time.Time

type ExecuteOnceTrigger

+ func (t ExecuteOnceTrigger) GetFireTime(from time.Time) *time.Time

type Scheduler

+ CleanupWindow *time.Duration

+ RunnerWindow *time.Duration

+ ScheduleWindow *time.Duration

+ func (s *Scheduler) CreateTaskDefinition(task TaskDefinition) error

+ func (s *Scheduler) DeleteTaskDefinition(id *uuid.UUID) error

+ func (s *Scheduler) Stop()

+ func (s *Scheduler) UpdateTaskDefinition(task TaskDefinition) error

type StoreInterface

+ CreateTaskDefinition func(taskDefinition TaskDefinition) error

+ CreateTaskInstance func(taskInstance TaskInstance) error

+ DeleteCompletedTaskDefinitions func() error

+ DeleteCompletedTaskInstances func() error

+ DeleteTaskDefinition func(id *uuid.UUID) error

+ DeleteTaskInstance func(id *uuid.UUID) error

+ GetTaskDefinition func(id *uuid.UUID) (TaskDefinition, error)

+ GetTaskDefinitionsToSchedule func(limit time.Time) ([]TaskDefinition, error)

+ GetTaskInstance func(id *uuid.UUID) (TaskInstance, error)

+ GetTaskInstancesToRun func(limit time.Time) ([]TaskInstance, error)

+ ListTaskDefinitions func(offset, limit int) ([]TaskDefinition, error)

+ ListTaskInstances func(offset, limit int) ([]TaskInstance, error)

+ MarkTaskInstanceComplete func(instance TaskInstance) error

+ UpdateTaskDefinition func(taskDefinition TaskDefinition) error

+ UpdateTaskInstance func(taskInstance TaskInstance) error

+ type TaskDefinition struct

+ CompletedAt *time.Time

+ CronTrigger *CronTrigger

+ ExecuteOnceTrigger *ExecuteOnceTrigger

+ ExpireAfter time.Duration

+ Id *uuid.UUID

+ Metadata interface{}

+ NextFireTime *time.Time

+ Recurring bool

+ TaskInstances []TaskInstance

+ func (t TaskDefinition) AsBytes() ([]byte, error)

+ func (t TaskDefinition) GetFireTimeFrom(from time.Time) *time.Time

+ func (t TaskDefinition) GetIdBytes() []byte

+ func (t TaskDefinition) GetNextFireTime() *time.Time

+ func (t TaskDefinition) GetTrigger() TriggerInterface

+ func (t TaskDefinition) IdString() string

+ type TaskInstance struct

+ CompletedAt *time.Time

+ ExecuteAt *time.Time

+ ExpiresAt *time.Time

+ Id *uuid.UUID

+ StartedAt *time.Time

+ TaskDefinition TaskDefinition

type TriggerInterface

+ GetFireTime func(from time.Time) *time.Time

v1.0.1

Oct 21, 2022

Changes in this version

+ type CronTrigger struct

+ func NewCronTrigger(cronExpression string) (*CronTrigger, error)

+ func (t CronTrigger) GetNextFireTime(task Task) *time.Time

+ func (t CronTrigger) IsRecurring() bool

type ExecuteOnceTrigger

+ func (t ExecuteOnceTrigger) IsRecurring() bool

type MemoryStore

+ func (m *MemoryStore) ScheduleTaskInScheduleTree(task Task)

type Task

+ CronTrigger *CronTrigger

+ InProgress bool

+ LastFireTime *time.Time

+ NextFireTime *time.Time

type TriggerInterface

+ IsRecurring func() bool

v1.0.0

Oct 19, 2022

Changes in this version

+ func GetScheduleTreeKey(task Task) string

+ func ScheduleTreeComparator(a, b interface{}) int

+ func TimeToString(theTime time.Time) string

+ type ExecuteOnceTrigger struct

+ FireAt time.Time

+ func NewExecuteOnceTrigger(fireAt time.Time) *ExecuteOnceTrigger

+ func (t ExecuteOnceTrigger) GetNextFireTime() *time.Time

+ type MemoryStore struct

+ func (m *MemoryStore) DeleteTask(id *uuid.UUID) error

+ func (m *MemoryStore) GetUpcomingTasks(limit time.Time) ([]Task, error)

+ func (m *MemoryStore) Initialize() error

+ func (m *MemoryStore) ScheduleTask(task Task) error

+ func (m *MemoryStore) UpdateTask(task Task) error

+ type Scheduler struct

+ Handler func(task Task) error

+ Window *time.Duration

+ func NewScheduler(window time.Duration, handler func(task Task) error, store StoreInterface) (*Scheduler, error)

+ func (s *Scheduler) DeleteTask(id *uuid.UUID) error

+ func (s *Scheduler) Run() error

+ func (s *Scheduler) ScheduleTask(task Task) error

+ func (s *Scheduler) UpdateTask(task Task) error

+ type StoreInterface interface

+ DeleteTask func(id *uuid.UUID) error

+ GetUpcomingTasks func(limit time.Time) ([]Task, error)

+ Initialize func() error

+ ScheduleTask func(task Task) error

+ UpdateTask func(task Task) error

+ func NewMemoryStore() StoreInterface

+ type Task struct

+ ExecuteOnceTrigger *ExecuteOnceTrigger

+ ExpireAfter *time.Duration

+ Id *uuid.UUID

+ InProgressAt *time.Time

+ Metadata interface{}

+ RetryOnError bool

+ func TaskFromBytes(bytes []byte) (Task, error)

+ func (t Task) AsBytes() ([]byte, error)

+ func (t Task) GetIdBytes() []byte

+ func (t Task) GetTrigger() TriggerInterface

+ func (t Task) IdString() string

+ type TriggerInterface interface

+ GetNextFireTime func() *time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL