Documentation ¶
Index ¶
- Variables
- func Do(fn Func) error
- func PrefetchCount(prefetchCount int) withFunc
- func RetryCount(retryCount int) withFunc
- func RetryCountWithWait(retryCount int, retryInterval time.Duration) withFunc
- type Channel
- type Client
- func (c *Client) AddConsumer(queueName string) *Consumer
- func (c *Client) AddConsumerWithConsistentHashExchange(queueName string, routingKey string, exchangeName string) *Consumer
- func (c *Client) AddPublisher(ctx context.Context, exchangeName string, exchangeType ExchangeType, ...)
- func (c *Client) Exit(reason error) int
- func (c *Client) Publish(ctx context.Context, routingKey string, payload interface{}) error
- func (c *Client) RunConsumers(ctx context.Context) error
- func (c *Client) Shutdown(reason string)
- type Consumer
- func (c *Consumer) HandleConsumer(consumer handleConsumer) *Consumer
- func (c *Consumer) SubscriberExchange(routingKey string, exchangeType ExchangeType, exchangeName string) *Consumer
- func (c *Consumer) SubscriberExchangeWithArguments(routingKey string, exchangeType ExchangeType, exchangeName string, ...) *Consumer
- func (c *Consumer) WithSingleGoroutine(value bool) *Consumer
- type ConsumerBuilder
- type ExchangeType
- type Func
- type Message
- type MessageBroker
- type MessageBrokerParameter
- type Publisher
- type PublisherBuilder
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ERRORPREFIX = "_error" CONCURRENTLIMIT = 1 RETRYCOUNT = 0 PREFECTCOUNT = 1 )
Functions ¶
func PrefetchCount ¶
func PrefetchCount(prefetchCount int) withFunc
func RetryCount ¶
func RetryCount(retryCount int) withFunc
func RetryCountWithWait ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewRabbitMqClient ¶
func (*Client) AddConsumer ¶
func (*Client) AddConsumerWithConsistentHashExchange ¶
func (*Client) AddPublisher ¶
func (c *Client) AddPublisher(ctx context.Context, exchangeName string, exchangeType ExchangeType, payloads ...interface{})
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func (*Consumer) HandleConsumer ¶
func (*Consumer) SubscriberExchange ¶
func (c *Consumer) SubscriberExchange(routingKey string, exchangeType ExchangeType, exchangeName string) *Consumer
func (*Consumer) SubscriberExchangeWithArguments ¶
func (*Consumer) WithSingleGoroutine ¶
type ConsumerBuilder ¶
type ConsumerBuilder struct {
// contains filtered or unexported fields
}
type ExchangeType ¶
type ExchangeType int
const ( Direct ExchangeType = 1 Fanout ExchangeType = 2 Topic ExchangeType = 3 ConsistentHashing ExchangeType = 4 XDelayedMessage ExchangeType = 5 )
type MessageBroker ¶
type MessageBroker interface { CreateChannel() (*Channel, error) CreateConnection(ctx context.Context, parameters MessageBrokerParameter) error SignalConnectionStatus(status bool) SignalConnection() chan bool IsConnected() bool }
func NewMessageBroker ¶
func NewMessageBroker(logger log.Logger) MessageBroker
type MessageBrokerParameter ¶
type PublisherBuilder ¶
type PublisherBuilder struct {
// contains filtered or unexported fields
}
func (*PublisherBuilder) CreateChannel ¶
func (p *PublisherBuilder) CreateChannel()
func (*PublisherBuilder) SubscriberExchange ¶
func (p *PublisherBuilder) SubscriberExchange() *PublisherBuilder
Click to show internal directories.
Click to hide internal directories.