job

Documentation

Index

• Constants
• func MarshalRequest(v interface{}) ([]machineryv1tasks.Arg, error)
• func UnmarshalRequest(data string, v interface{}) error
• func UnmarshalResponse(data []reflect.Value, v interface{}) error
• type Config
• type GroupJobState
• type Job
  • func New(cfg *Config, queue Queue) (*Job, error)
  • func (t *Job) GetGroupJobState(groupUUID string) (*GroupJobState, error)
  • func (t *Job) LaunchWorker(consumerTag string, concurrency int) error
  • func (t *Job) RegisterJob(namedJobFuncs map[string]interface{}) error
• type PreheatRequest
• type PreheatResponse
• type Queue
  • func GetCDNQueue(hostname string) (Queue, error)
  • func GetSchedulerQueue(hostname string) (Queue, error)
  • func (q Queue) String() string

Constants

const (
	GlobalQueue     = Queue("global")
	SchedulersQueue = Queue("schedulers")
	CDNsQueue       = Queue("cdns")
)

Queue Name

const (
	DefaultResultsExpireIn = 86400
)

const (
	PreheatJob = "preheat"
)

Job Name

Functions

func MarshalRequest

func MarshalRequest(v interface{}) ([]machineryv1tasks.Arg, error)

func UnmarshalRequest

func UnmarshalRequest(data string, v interface{}) error

func UnmarshalResponse

func UnmarshalResponse(data []reflect.Value, v interface{}) error

Types

type Config

type Config struct {
	Host      string
	Port      int
	Password  string
	BrokerDB  int
	BackendDB int
}

type GroupJobState

type GroupJobState struct {
	GroupUUID string
	State     string
	CreatedAt time.Time
}

type Job

type Job struct {
	Server *machinery.Server
	Worker *machinery.Worker
	Queue  Queue
}

func New

func New(cfg *Config, queue Queue) (*Job, error)

func (*Job) GetGroupJobState

func (t *Job) GetGroupJobState(groupUUID string) (*GroupJobState, error)

func (*Job) LaunchWorker

func (t *Job) LaunchWorker(consumerTag string, concurrency int) error

func (*Job) RegisterJob

func (t *Job) RegisterJob(namedJobFuncs map[string]interface{}) error

type PreheatRequest

type PreheatRequest struct {
	URL     string            `json:"url" validate:"required,url"`
	Tag     string            `json:"tag" validate:"required"`
	Digest  string            `json:"digest" validate:"omitempty"`
	Filter  string            `json:"filter" validate:"omitempty"`
	Headers map[string]string `json:"headers" validate:"omitempty"`
}

type PreheatResponse

type PreheatResponse struct {
}

type Queue

type Queue string

func GetCDNQueue

func GetCDNQueue(hostname string) (Queue, error)

func GetSchedulerQueue

func GetSchedulerQueue(hostname string) (Queue, error)

func (Queue) String

func (q Queue) String() string