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 MachineryLogger
  • func (m *MachineryLogger) Fatal(args ...interface{})
  • func (m *MachineryLogger) Fatalf(format string, args ...interface{})
  • func (m *MachineryLogger) Fatalln(args ...interface{})
  • func (m *MachineryLogger) Panic(args ...interface{})
  • func (m *MachineryLogger) Panicf(format string, args ...interface{})
  • func (m *MachineryLogger) Panicln(args ...interface{})
  • func (m *MachineryLogger) Print(args ...interface{})
  • func (m *MachineryLogger) Printf(format string, args ...interface{})
  • func (m *MachineryLogger) Println(args ...interface{})
• type PreheatRequest
• type PreheatResponse
• type Queue
  • func GetCDNQueue(clusterID uint, hostname string) (Queue, error)
  • func GetSchedulerQueue(clusterID uint, 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 MachineryLogger

type MachineryLogger struct{}

func (*MachineryLogger) Fatal

func (m *MachineryLogger) Fatal(args ...interface{})

Fatal sends to logger.Fatal

func (*MachineryLogger) Fatalf

func (m *MachineryLogger) Fatalf(format string, args ...interface{})

Fatalf sends to logger.Fatalf

func (*MachineryLogger) Fatalln

func (m *MachineryLogger) Fatalln(args ...interface{})

Fatalln sends to logger.Fatal

func (*MachineryLogger) Panic

func (m *MachineryLogger) Panic(args ...interface{})

Panic sends to logger.Panic

func (*MachineryLogger) Panicf

func (m *MachineryLogger) Panicf(format string, args ...interface{})

Panicf sends to logger.Panic

func (*MachineryLogger) Panicln

func (m *MachineryLogger) Panicln(args ...interface{})

Panicln sends to logrus.Panic

func (*MachineryLogger) Print

func (m *MachineryLogger) Print(args ...interface{})

Print sends to logger.Info

func (*MachineryLogger) Printf

func (m *MachineryLogger) Printf(format string, args ...interface{})

Printf sends to logger.Infof

func (*MachineryLogger) Println

func (m *MachineryLogger) Println(args ...interface{})

Println sends to logger.Info

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(clusterID uint, hostname string) (Queue, error)

func GetSchedulerQueue

func GetSchedulerQueue(clusterID uint, hostname string) (Queue, error)

func (Queue) String

func (q Queue) String() string