Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToTaskDefinitions ¶
func ToTaskDefinitions(models []TaskDefinition) ([]pkg.TaskDefinition, error)
func ToTaskInstances ¶
func ToTaskInstances(taskInstanceModels []TaskInstance) ([]pkg.TaskInstance, error)
Types ¶
type CronTrigger ¶
type CronTrigger struct {
Id string `json:"id" gorm:"primaryKey"`
CreatedAt int64 `json:"created_at,string" gorm:"autoCreateTime:nano"`
UpdatedAt int64 `json:"updated_at,string" gorm:"autoUpdateTime:nano"`
Expression string `json:"expression"`
TaskDefinitionId *uuid.UUID `json:"task_definition_id"`
TaskDefinition *TaskDefinition `json:"task"`
}
func GetCronTriggerModelFromTrigger ¶
func GetCronTriggerModelFromTrigger(trigger *pkg.CronTrigger) (*CronTrigger, error)
type ExecuteOnceTrigger ¶
type ExecuteOnceTrigger struct {
Id string `json:"id" gorm:"primaryKey"`
CreatedAt int64 `json:"created_at,string" gorm:"autoCreateTime:nano"`
UpdatedAt int64 `json:"updated_at,string" gorm:"autoUpdateTime:nano"`
FireAt time.Time `json:"fire_at"`
TaskDefinitionId *uuid.UUID `json:"task_definition_id"`
TaskDefinition *TaskDefinition `json:"task"`
}
func GetExecuteOnceTriggerModelFromTrigger ¶
func GetExecuteOnceTriggerModelFromTrigger(trigger *pkg.ExecuteOnceTrigger) (*ExecuteOnceTrigger, error)
type TaskDefinition ¶
type TaskDefinition struct {
Id *uuid.UUID `json:"id" gorm:"primaryKey"`
CreatedAt int64 `json:"created_at,string" gorm:"autoCreateTime:nano"`
UpdatedAt int64 `json:"updated_at,string" gorm:"autoUpdateTime:nano"`
Metadata gormjsonb.JSONB `json:"metadata" gorm:"type:jsonb"`
ExpireAfter *time.Duration `json:"expire_after"`
ExpireAfterInterval *string `json:"expire_after_interval"`
InProgress bool `json:"in_progress_at"`
LastFireTime *time.Time `json:"last_fire_time"`
NextFireTime *time.Time `json:"next_fire_time"`
ExecuteOnceTrigger *ExecuteOnceTrigger `json:"execute_once_trigger" gorm:"foreignKey:Id"`
CronTrigger *CronTrigger `json:"cron_trigger" gorm:"foreignKey:Id"`
CompletedAt *time.Time `json:"completed_at"`
TaskInstances []TaskInstance `json:"task_instances"`
Recurring bool
}
func GetTaskDefinitionModelFromTaskDefinition ¶
func GetTaskDefinitionModelFromTaskDefinition(task pkg.TaskDefinition) (*TaskDefinition, error)
func (*TaskDefinition) BeforeCreate ¶
func (t *TaskDefinition) BeforeCreate(tx *gorm.DB) error
func (TaskDefinition) ToTaskDefinition ¶
func (t TaskDefinition) ToTaskDefinition() (pkg.TaskDefinition, error)
type TaskInstance ¶
type TaskInstance struct {
Id *uuid.UUID `json:"id" gorm:"primaryKey"`
CreatedAt int64 `json:"created_at,string" gorm:"autoCreateTime:nano"`
UpdatedAt int64 `json:"updated_at,string" gorm:"autoUpdateTime:nano"`
ExpiresAt *time.Time `json:"expires_at"`
ExecuteAt *time.Time `json:"execute_at"`
StartedAt *time.Time `json:"started_at"`
CompletedAt *time.Time `json:"completed_at"`
TaskDefinitionId *uuid.UUID `json:"task_definition_id"`
TaskDefinition *TaskDefinition `json:"task_definition"`
}
func GetTaskInstanceModelFromTaskInstance ¶
func GetTaskInstanceModelFromTaskInstance(taskInstance pkg.TaskInstance) (*TaskInstance, error)
func (*TaskInstance) BeforeCreate ¶
func (t *TaskInstance) BeforeCreate(tx *gorm.DB) error
func (TaskInstance) ToTaskInstance ¶
func (t TaskInstance) ToTaskInstance() (pkg.TaskInstance, error)
Click to show internal directories.
Click to hide internal directories.