faktory

Documentation

Index

• func NewFaktory(conf FaktoryConf) *faktoryClient
• type FaktoryClient
• type FaktoryConf
• type JobProcessor
• type SenderConf
• type WorkerConf

Functions

func NewFaktory

func NewFaktory(conf FaktoryConf) *faktoryClient

Types

type FaktoryClient

type FaktoryClient interface {
	service.Service

	Context() context.Context
	SetProcessor(jobNameProcessorMap map[string]JobProcessor)
	Push(job *faktory.Job) error
}

type FaktoryConf

type FaktoryConf struct {
	Url    string // tcp://:mypassword@faktory.example.com:7419
	Sender SenderConf
	Worker WorkerConf
}

docker exec -it faktory_container_name redis-cli -s /var/lib/faktory/db/redis.sock

type JobProcessor

type JobProcessor func(helper worker.Helper, args ...interface{}) error

type SenderConf

type SenderConf struct {
	PoolCapacity int `json:",default=1"`
}

type WorkerConf

type WorkerConf struct {
	Concurrency                int            `json:",default=20"`              // worker pool = concurrency + 2 github.com/contribsys/faktory_worker_go@v1.6.0/manager.go:137
	PullFromQueuesWithPriority map[string]int `json:",default={\"default\":1}"` // {"critical":3, "default":2, "bulk":1}
}