Documentation
¶
Index ¶
- type PubSub
- func (p *PubSub) Bind(dsn string) error
- func (p *PubSub) Close()
- func (p *PubSub) Consume() error
- func (p *PubSub) Dispatch()
- func (p *PubSub) ExchangeDeclare() error
- func (p *PubSub) Init(dsn string) error
- func (p *PubSub) Publish(ctx context.Context, uri string, action string) error
- func (p *PubSub) PublishWithKey(ctx context.Context, uri string, action string, key string) error
- func (p *PubSub) QueueBind(queues []string) error
- func (p *PubSub) QueueBindObservedQueues() error
- func (p *PubSub) QueueDeclare() error
- func (p *PubSub) RegisterObserver(key string, observer annotator.Annotator)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
PubSub implements a RabbitMQ publisher and receiver
func (*PubSub) ExchangeDeclare ¶
ExchangeDeclare used for global message subbing
func (*PubSub) PublishWithKey ¶
PublishWithKey a message to the exchange with a non-default key (ie. not annotation.<action>)
func (*PubSub) QueueBindObservedQueues ¶
QueueBindObservedQueues ...
func (*PubSub) QueueDeclare ¶
QueueDeclare used for global messages subbing
Source Files
Click to show internal directories.
Click to hide internal directories.