The highest tagged major version is
Documentation
¶
Index ¶
- type AMQPConnector
- func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error
- func (ac *AMQPConnector) Connect(urls string, urlSeparator string, tlsConfig *tls.Config, ...) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, ...)
- func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error
- func (*AMQPConnector) InspectQueue(channel *amqp.Channel, queueName string) (*amqp.Queue, error)
- func (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error)
- type Backend
- type Broker
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConnector ¶
type AMQPConnector struct{}
AMQPConnector ...
func (*AMQPConnector) Close ¶
func (ac *AMQPConnector) Close(channel *amqp.Channel, conn *amqp.Connection) error
Close connection
func (*AMQPConnector) Connect ¶
func (ac *AMQPConnector) Connect(urls string, urlSeparator string, tlsConfig *tls.Config, exchange, exchangeType, queueName string, queueDurable, queueDelete bool, queueBindingKey string, exchangeDeclareArgs, queueDeclareArgs, queueBindingArgs amqp.Table) (*amqp.Connection, *amqp.Channel, amqp.Queue, <-chan amqp.Confirmation, <-chan *amqp.Error, error)
Connect opens a connection to RabbitMQ, declares an exchange, opens a channel, declares and binds the queue and enables publish notifications
func (*AMQPConnector) DeleteQueue ¶
func (ac *AMQPConnector) DeleteQueue(channel *amqp.Channel, queueName string) error
DeleteQueue deletes a queue by name
func (*AMQPConnector) InspectQueue ¶
InspectQueue provides information about a specific queue
type Backend ¶ added in v1.4.1
type Backend struct {
// contains filtered or unexported fields
}
Backend represents a base backend structure
func NewBackend ¶ added in v1.4.1
NewBackend creates new Backend instance
type Broker ¶ added in v1.4.1
type Broker struct {
// contains filtered or unexported fields
}
Broker represents a base broker structure
func (*Broker) AdjustRoutingKey ¶ added in v1.4.1
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) GetDelayedTasks ¶ added in v1.7.2
GetDelayedTasks returns a slice of task.Signatures that are scheduled, but not yet in the queue
func (*Broker) GetPendingTasks ¶ added in v1.4.1
GetPendingTasks returns a slice of task.Signatures waiting in the queue
func (*Broker) GetRegisteredTaskNames ¶ added in v1.4.1
GetRegisteredTaskNames returns registered tasks names
func (*Broker) GetRetryFunc ¶ added in v1.4.1
GetRetryFunc ...
func (*Broker) GetRetryStopChan ¶ added in v1.4.1
GetRetryStopChan ...
func (*Broker) GetStopChan ¶ added in v1.4.1
GetStopChan ...
func (*Broker) IsTaskRegistered ¶ added in v1.4.1
IsTaskRegistered returns true if the task is registered with this broker
func (*Broker) SetRegisteredTaskNames ¶ added in v1.4.1
SetRegisteredTaskNames sets registered task names
func (*Broker) StartConsuming ¶ added in v1.4.1
func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor)
StartConsuming is a common part of StartConsuming method
func (*Broker) StopConsuming ¶ added in v1.4.1
func (b *Broker) StopConsuming()
StopConsuming is a common part of StopConsuming
Source Files