brokers

Dec 20, 2017

Changes in this version

+ type AWSSQSBroker struct

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

+ func (b *AWSSQSBroker) Publish(signature *tasks.Signature) error

+ func (b *AWSSQSBroker) StartConsuming(consumerTag string, concurrency int, taskProcessor TaskProcessor) (bool, error)

+ func (b *AWSSQSBroker) StopConsuming()

type Broker

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

type Interface

+ func NewAWSSQSBroker(cnf *config.Config) Interface

Dec 5, 2017

Changes in this version

+ func AdjustRoutingKey(b Interface, s *tasks.Signature)

+ func IsAMQP(b Interface) bool

type Broker

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

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

+ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor TaskProcessor) (bool, error)

+ func (b *Broker) StopConsuming()

type Interface

+ GetConfig func() *config.Config

Dec 4, 2017

Changes in this version

+ type ErrCouldNotUnmarshaTaskSignature struct

+ func NewErrCouldNotUnmarshaTaskSignature(msg []byte, err error) ErrCouldNotUnmarshaTaskSignature

+ func (e ErrCouldNotUnmarshaTaskSignature) Error() string

Aug 27, 2017

Changes in this version

+ type AMQPBroker struct

+ func (b *AMQPBroker) Publish(signature *tasks.Signature) error

+ func (b *AMQPBroker) StartConsuming(consumerTag string, concurrency int, taskProcessor TaskProcessor) (bool, error)

+ func (b *AMQPBroker) StopConsuming()

+ type Broker struct

+ func New(cnf *config.Config) Broker

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

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

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

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

+ type EagerBroker struct

+ func (eagerBroker *EagerBroker) AssignWorker(w TaskProcessor)

+ func (eagerBroker *EagerBroker) GetPendingTasks(queue string) ([]*tasks.Signature, error)

+ func (eagerBroker *EagerBroker) Publish(task *tasks.Signature) error

+ func (eagerBroker *EagerBroker) StartConsuming(consumerTag string, concurrency int, p TaskProcessor) (bool, error)

+ func (eagerBroker *EagerBroker) StopConsuming()

+ type EagerMode interface

+ AssignWorker func(p TaskProcessor)

+ type Interface interface

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

+ IsTaskRegistered func(name string) bool

+ Publish func(task *tasks.Signature) error

+ SetRegisteredTaskNames func(names []string)

+ StartConsuming func(consumerTag string, concurrency int, p TaskProcessor) (bool, error)

+ StopConsuming func()

+ func NewAMQPBroker(cnf *config.Config) Interface

+ func NewEagerBroker() Interface

+ func NewRedisBroker(cnf *config.Config, host, password, socketPath string, db int) Interface

+ type RedisBroker struct

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

+ func (b *RedisBroker) Publish(signature *tasks.Signature) error

+ func (b *RedisBroker) StartConsuming(consumerTag string, concurrency int, taskProcessor TaskProcessor) (bool, error)

+ func (b *RedisBroker) StopConsuming()

+ type TaskProcessor interface

+ Process func(signature *tasks.Signature) error