conductor

Documentation

Index

• func StartWorker(redisOpts asynq.RedisConnOpt, concurrency int, runner *tasks.EncoderRunner, ...)
• func WithLogger(logger logging.KVLogger) func(options *ConductorOptions)
• type Conductor
  • func NewConductor(redisOpts asynq.RedisConnOpt, incoming <-chan *manager.TranscodingRequest, ...) (*Conductor, error)
  • func (c *Conductor) DispatchNextTask() error
  • func (c *Conductor) ProcessNextResult() error
  • func (c *Conductor) PutLoad() error
  • func (c *Conductor) Start()
  • func (c *Conductor) Stop()
• type ConductorOptions

Functions

func StartWorker

func StartWorker(redisOpts asynq.RedisConnOpt, concurrency int, runner *tasks.EncoderRunner, log logging.Logger)

func WithLogger

func WithLogger(logger logging.KVLogger) func(options *ConductorOptions)

Types

type Conductor

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

func NewConductor

func NewConductor(
	redisOpts asynq.RedisConnOpt, incoming <-chan *manager.TranscodingRequest, library *library.Library,
	optionFuncs ...func(*ConductorOptions),
) (*Conductor, error)

func (*Conductor) DispatchNextTask

func (c *Conductor) DispatchNextTask() error

func (*Conductor) ProcessNextResult

func (c *Conductor) ProcessNextResult() error

func (*Conductor) PutLoad

func (c *Conductor) PutLoad() error

func (*Conductor) Start

func (c *Conductor) Start()

func (*Conductor) Stop

func (c *Conductor) Stop()

type ConductorOptions

type ConductorOptions struct {
	Logger logging.KVLogger
}