workflow

Documentation

Index

• Constants
• func DeleteJob(ctx context.Context, job *model.Job) error
• func GetInspector() *asynq.Inspector
• func GetJobsByState(ctx context.Context, state model.JobState) ([]*model.Job, error)
• func HandleCronTask(ctx context.Context, t *asynq.Task) error
• func HandleJobTask(ctx context.Context, t *asynq.Task) error
• func NewJobFSM(state model.JobState) *fsm.FSM
• func NewStepFSM(state model.StepState) *fsm.FSM
• func PushTask(t *Task) error
• func SyncJob(ctx context.Context, job *model.Job) error
• type CronTaskManager
  • func NewCronTaskManager() *CronTaskManager
  • func (c *CronTaskManager) Run()
  • func (c *CronTaskManager) Shutdown()
• type DatabaseProvider
  • func (d *DatabaseProvider) GetConfigs() ([]*asynq.PeriodicTaskConfig, error)
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Run()
  • func (m *Manager) Shutdown()
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Run()
  • func (q *Queue) Shutdown()
• type Task
  • func NewJobTask(job *model.Job) (*Task, error)

Constants

const (
	TypeCron = "cron"
	TypeJob  = "job"
)

Functions

func DeleteJob

func DeleteJob(ctx context.Context, job *model.Job) error

func GetInspector

func GetInspector() *asynq.Inspector

func GetJobsByState

func GetJobsByState(ctx context.Context, state model.JobState) ([]*model.Job, error)

func HandleCronTask

func HandleCronTask(ctx context.Context, t *asynq.Task) error

func HandleJobTask

func HandleJobTask(ctx context.Context, t *asynq.Task) error

func NewJobFSM

func NewJobFSM(state model.JobState) *fsm.FSM

func NewStepFSM

func NewStepFSM(state model.StepState) *fsm.FSM

func PushTask

func PushTask(t *Task) error

func SyncJob

func SyncJob(ctx context.Context, job *model.Job) error

Types

type CronTaskManager

type CronTaskManager struct {
	// contains filtered or unexported fields
}

func NewCronTaskManager

func NewCronTaskManager() *CronTaskManager

func (*CronTaskManager) Run

func (c *CronTaskManager) Run()

func (*CronTaskManager) Shutdown

func (c *CronTaskManager) Shutdown()

type DatabaseProvider

type DatabaseProvider struct{}

func (*DatabaseProvider) GetConfigs

func (d *DatabaseProvider) GetConfigs() ([]*asynq.PeriodicTaskConfig, error)

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

func (*Manager) Run

func (m *Manager) Run()

func (*Manager) Shutdown

func (m *Manager) Shutdown()

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) Run

func (q *Queue) Run()

func (*Queue) Shutdown

func (q *Queue) Shutdown()

type Task

type Task struct {
	ID    string
	Queue string
	Task  *asynq.Task
}

func NewJobTask

func NewJobTask(job *model.Job) (*Task, error)