model

Documentation

Index

• type JobFunction
• type Task
  • func NewTask(jobName string, args map[string]string) Task
  • func NewTaskFromJSON(jsonBytes []byte) (Task, error)

Types

type JobFunction

type JobFunction func(ctx context.Context, args map[string]string) error

JobFunction is the signature for functions that workers can call to asynchronously execute a job

type Task

type Task interface {
	GetID() string
	GetJobName() string
	GetArgs() map[string]string
	GetWorkerRejectionCount() int
	IncrementWorkerRejectionCount() int
	ToJSON() ([]byte, error)
}

Task is an interface to be implemented by types that represent a single asynchronous task

func NewTask

func NewTask(jobName string, args map[string]string) Task

NewTask returns a new task

func NewTaskFromJSON

func NewTaskFromJSON(jsonBytes []byte) (Task, error)

NewTaskFromJSON returns a new Task unmarshalled from the provided []byte