common

Documentation

Index

• type Backend
  • func NewBackend(cnf *config.Config) Backend
  • func (b *Backend) GetConfig() *config.Config
• type Broker
  • func NewBroker(cnf *config.Config) Broker
  • func (b *Broker) AdjustCompleteRoutingKey(s *tasks.Signature)
  • func (b *Broker) AdjustRoutingKey(s *tasks.Signature)
  • func (b *Broker) GetConfig() *config.Config
  • func (b *Broker) GetDelayedTasks() ([]*tasks.Signature, error)
  • func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error)
  • func (b *Broker) GetRegisteredTaskNames() []string
  • func (b *Broker) GetRetry() bool
  • func (b *Broker) GetRetryFunc() func(chan int)
  • func (b *Broker) GetRetryStopChan() chan int
  • func (b *Broker) GetStopChan() chan int
  • func (b *Broker) IsTaskRegistered(name string) bool
  • func (b *Broker) Publish(signature *tasks.Signature) error
  • func (b *Broker) SetRegisteredTaskNames(names []string)
  • func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor)
  • func (b *Broker) StopConsuming()
• type RedisConnector
  • func (rc *RedisConnector) NewPool(socketPath, host, password string, db int, cnf *config.RedisConfig, ...) *redis.Pool

Types

type Backend

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

Backend represents a base backend structure

func NewBackend

func NewBackend(cnf *config.Config) Backend

NewBackend creates new Backend instance

func (*Backend) GetConfig

func (b *Backend) GetConfig() *config.Config

GetConfig returns config

type Broker

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

Broker represents a base broker structure

func NewBroker

func NewBroker(cnf *config.Config) Broker

NewBroker creates new Broker instance

func (*Broker) AdjustCompleteRoutingKey

func (b *Broker) AdjustCompleteRoutingKey(s *tasks.Signature)

func (*Broker) AdjustRoutingKey

func (b *Broker) AdjustRoutingKey(s *tasks.Signature)

AdjustRoutingKey makes sure the routing key is correct. If the routing key is an empty string: a) set it to binding key for direct exchange type b) set it to default queue name

func (*Broker) GetConfig

func (b *Broker) GetConfig() *config.Config

GetConfig returns config

func (*Broker) GetDelayedTasks

func (b *Broker) GetDelayedTasks() ([]*tasks.Signature, error)

GetDelayedTasks returns a slice of task.Signatures that are scheduled, but not yet in the queue

func (*Broker) GetPendingTasks

func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error)

GetPendingTasks returns a slice of task.Signatures waiting in the queue

func (*Broker) GetRegisteredTaskNames

func (b *Broker) GetRegisteredTaskNames() []string

GetRegisteredTaskNames returns registered tasks names

func (*Broker) GetRetry

func (b *Broker) GetRetry() bool

GetRetry ...

func (*Broker) GetRetryFunc

func (b *Broker) GetRetryFunc() func(chan int)

GetRetryFunc ...

func (*Broker) GetRetryStopChan

func (b *Broker) GetRetryStopChan() chan int

GetRetryStopChan ...

func (*Broker) GetStopChan

func (b *Broker) GetStopChan() chan int

GetStopChan ...

func (*Broker) IsTaskRegistered

func (b *Broker) IsTaskRegistered(name string) bool

IsTaskRegistered returns true if the task is registered with this broker

func (*Broker) Publish

func (b *Broker) Publish(signature *tasks.Signature) error

Publish places a new message on the default queue

func (*Broker) SetRegisteredTaskNames

func (b *Broker) SetRegisteredTaskNames(names []string)

SetRegisteredTaskNames sets registered task names

func (*Broker) StartConsuming

func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor)

StartConsuming is a common part of StartConsuming method

func (*Broker) StopConsuming

func (b *Broker) StopConsuming()

StopConsuming is a common part of StopConsuming

type RedisConnector

type RedisConnector struct{}

RedisConnector ...

func (*RedisConnector) NewPool

func (rc *RedisConnector) NewPool(socketPath, host, password string, db int, cnf *config.RedisConfig, tlsConfig *tls.Config) *redis.Pool

NewPool returns a new pool of Redis connections