pkg

type CronTrigger struct {
	Expression string `json:"expression"`
	// contains filtered or unexported fields
}

type ExecuteOnceTrigger struct {
	FireAt time.Time `json:"fire_at"`
}

type Scheduler struct {
	ScheduleWindow *time.Duration
	RunnerWindow   *time.Duration
	CleanupWindow  *time.Duration
	Handler        func(taskInstance TaskInstance) error
	// contains filtered or unexported fields
}

type StoreInterface interface {
	Initialize() error
	UpsertTaskDefinition(definition TaskDefinition) error
	ListTaskDefinitions(offset, limit int, metadataQuery interface{}) ([]TaskDefinition, error)
	GetTaskDefinition(id *uuid.UUID) (TaskDefinition, error)
	GetTaskDefinitions(ids []*uuid.UUID) ([]TaskDefinition, error)
	DeleteTaskDefinition(id *uuid.UUID) error
	DeleteTaskDefinitions(ids []*uuid.UUID) error
	DeleteTaskDefinitionsByMetadata(metadataQuery interface{}) error
	UpsertTaskInstance(taskInstance TaskInstance) error
	GetTaskInstance(id *uuid.UUID) (TaskInstance, error)
	ListTaskInstances(offset, limit int) ([]TaskInstance, error)
	DeleteTaskInstance(id *uuid.UUID) error
	GetTaskDefinitionsToSchedule(limit time.Time) ([]TaskDefinition, error)
	GetTaskInstancesToRun(limit time.Time) ([]TaskInstance, error)
	// markTaskInstanceComplete() should also mark the task definition complete, if the definition is non-recurring
	MarkTaskInstanceComplete(instance TaskInstance) error
	DeleteCompletedTaskInstances() error
	DeleteCompletedTaskDefinitions() error
}

type TaskDefinition struct {
	Id                 *uuid.UUID
	Metadata           interface{}         `json:"metadata"`
	ExpireAfter        time.Duration       `json:"expire_after"`
	NextFireTime       *time.Time          `json:"next_fire_time"`
	ExecuteOnceTrigger *ExecuteOnceTrigger `json:"execute_once_trigger"`
	CronTrigger        *CronTrigger        `json:"cron_trigger"`
	CompletedAt        *time.Time          `json:"completed_at"`
	Recurring          bool                `json:"recurring"`
	TaskInstances      []TaskInstance      `json:"task_instances" gorm:"foreignKey:Id"`
}

type TaskInstance struct {
	Id             *uuid.UUID     `json:"id"`
	ExpiresAt      *time.Time     `json:"expires_at"`
	ExecuteAt      *time.Time     `json:"execute_at"`
	StartedAt      *time.Time     `json:"started_at"`
	CompletedAt    *time.Time     `json:"completed_at"`
	TaskDefinition TaskDefinition `json:"task_definition"`
}

type TriggerInterface interface {
	GetFireTime(from time.Time) *time.Time
	IsRecurring() bool
}