job

Documentation

Index

• Variables
• type Job
  • func (j *Job) GetCurrentFunction() *function.Function
  • func (j *Job) IncrCurrentFunction() bool

Variables

var (
	ErrNotFound   = errors.New("not found")
	ErrReschedule = errors.New("reschedule")
	ErrAbort      = errors.New("abort")
)

Types

type Job

type Job struct {
	ID              uuid.UUID              `json:"job_id"`
	Name            string                 `json:"name"`
	Functions       []*function.Function   `json:"functions"`
	CurrentFunction int                    `json:"current_function"`
	Data            map[string]interface{} `json:"data"`
	CreatedAt       time.Time              `json:"created_at"`
	ScheduledAt     time.Time              `json:"scheduled_at"`
}

func (*Job) GetCurrentFunction

func (j *Job) GetCurrentFunction() *function.Function

func (*Job) IncrCurrentFunction

func (j *Job) IncrCurrentFunction() bool