worker

Documentation

Index

• Constants
• func Loop(ctx scope.Context, heim *proto.Heim, workerName, queueName string) error
• func Serve(ctx scope.Context, addr string)
• type Controller
  • func NewController(ctx scope.Context, heim *proto.Heim, workerName, queueName string) (*Controller, error)
• type EmailWorker
  • func (w *EmailWorker) Init(heim *proto.Heim) error
  • func (EmailWorker) JobType() jobs.JobType
  • func (EmailWorker) QueueName() string
  • func (w *EmailWorker) Work(ctx scope.Context, job *jobs.Job, payload interface{}) error
• type Worker

Constants

const (
	PollTime      = 2 * time.Second
	StatsInterval = 10 * time.Second
	StealChance   = 0.25
)

Functions

func Loop

func Loop(ctx scope.Context, heim *proto.Heim, workerName, queueName string) error

func Serve

func Serve(ctx scope.Context, addr string)

Types

type Controller

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

func NewController

func NewController(ctx scope.Context, heim *proto.Heim, workerName, queueName string) (*Controller, error)

type EmailWorker

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

func (*EmailWorker) Init

func (w *EmailWorker) Init(heim *proto.Heim) error

func (EmailWorker) JobType

func (EmailWorker) JobType() jobs.JobType

func (EmailWorker) QueueName

func (EmailWorker) QueueName() string

func (*EmailWorker) Work

func (w *EmailWorker) Work(ctx scope.Context, job *jobs.Job, payload interface{}) error

type Worker

type Worker interface {
	Init(heim *proto.Heim) error
	QueueName() string
	JobType() jobs.JobType
	Work(ctx scope.Context, job *jobs.Job, payload interface{}) error
}