Versions in this module Expand all Collapse all v0 v0.0.2 Jan 28, 2023 v0.0.1 Jan 17, 2023 Changes in this version + var ErrAmqpChannelInitTimeout = errors.New("amqp channel init timeout") + var ErrAmqpConnNil = errors.New("amqp conn nil") + var ErrAmqpConnTimeout = errors.New("amqp connect timeout") + var ErrAmqpReconn = errors.New("amqp reconnecting") + var ErrAmqpShutdown = errors.New("amqp shutdown") + type AMQPMsgHandler = func(amqp.Delivery) + type ClientOption func(*RabbitmqClient) + func WithClientOptionsChInitTimeout(t time.Duration) ClientOption + func WithClientOptionsConnTimeout(t time.Duration) ClientOption + func WithClientOptionsLogger(logger Logger) ClientOption + type ConsumerOption func(*consumerParams) + func WithConsumerOptionsArgs(args Table) ConsumerOption + func WithConsumerOptionsAutoAck(autoAck bool) ConsumerOption + func WithConsumerOptionsConsumerTag(consumerTag string) ConsumerOption + func WithConsumerOptionsExclusive(exclusive bool) ConsumerOption + func WithConsumerOptionsNoWait(noWait bool) ConsumerOption + type Delivery = amqp.Delivery + type ExchangeDeclareOption func(*exchangeParams) + func WithExchangeDeclareOptionsArgs(args Table) ExchangeDeclareOption + func WithExchangeDeclareOptionsAutoDelete(autoDelete bool) ExchangeDeclareOption + func WithExchangeDeclareOptionsDurable(durable bool) ExchangeDeclareOption + func WithExchangeDeclareOptionsInternal(internal bool) ExchangeDeclareOption + func WithExchangeDeclareOptionsNoWait(noWait bool) ExchangeDeclareOption + type ExchangeDeleteOption func(*exchangeDeleteParams) + func WithExchangeDeleteOptionsIfUnused(ifUnused bool) ExchangeDeleteOption + func WithExchangeDeleteOptionsNoWait(noWait bool) ExchangeDeleteOption + type Logger interface + Debug func(args ...interface{}) + Debugf func(template string, args ...interface{}) + Fatal func(args ...interface{}) + Fatalf func(template string, args ...interface{}) + Info func(args ...interface{}) + Infof func(template string, args ...interface{}) + Warn func(args ...interface{}) + Warnf func(template string, args ...interface{}) + type PublishOption func(*publishParams) + func WithPublishOptionsAppId(appId string) PublishOption + func WithPublishOptionsContentType(contentType string) PublishOption + func WithPublishOptionsDeliveryMode(deliveryMode uint8) PublishOption + func WithPublishOptionsHeader(headers Table) PublishOption + func WithPublishOptionsImmediate(immediate bool) PublishOption + func WithPublishOptionsMandatory(mandatory bool) PublishOption + func WithPublishOptionsMsgExpiration(expiration string) PublishOption + func WithPublishOptionsMsgId(msgId string) PublishOption + func WithPublishOptionsMsgType(msgType string) PublishOption + func WithPublishOptionsPriority(priority uint8) PublishOption + func WithPublishOptionsUserId(userId string) PublishOption + type Publishing = amqp.Publishing + type QueueBindOption func(*queueBindParams) + func WithQueueBindOptionsArgs(args Table) QueueBindOption + func WithQueueBindOptionsNoWait(noWait bool) QueueBindOption + type QueueDeclareOption func(*queueParams) + func WithQueueDeclareOptionsArgs(args Table) QueueDeclareOption + func WithQueueDeclareOptionsAutoDelete(autoDelete bool) QueueDeclareOption + func WithQueueDeclareOptionsDurable(durable bool) QueueDeclareOption + func WithQueueDeclareOptionsInternal(exclusive bool) QueueDeclareOption + func WithQueueDeclareOptionsNoWait(noWait bool) QueueDeclareOption + type QueueDeleteOption func(*queueDeleteParams) + func WithQueueDeleteOptionsIfUnused(ifUnused bool) QueueDeleteOption + func WithQueueDeleteOptionsNoWait(noWait bool) QueueDeleteOption + type RabbitmqClient struct + func NewAMQPClient(endpoint string, opts ...ClientOption) (*RabbitmqClient, error) + func NewFogAMQPClient(host, port, accessKey, accessSecret, clientID string, tls bool, ...) (*RabbitmqClient, error) + func (rc *RabbitmqClient) BindQueue(queueName, key, exchangeName string, opts ...QueueBindOption) error + func (rc *RabbitmqClient) Close() error + func (rc *RabbitmqClient) ConsumeWithHandler(prefetchCnt int, queue string, handler AMQPMsgHandler, opts ...ConsumerOption) error + func (rc *RabbitmqClient) DeclareExchange(exchangeName, kind string, opts ...ExchangeDeclareOption) error + func (rc *RabbitmqClient) DeclareQueue(queueName string, opts ...QueueDeclareOption) error + func (rc *RabbitmqClient) DeleteExchange(exchangeName string, opts ...ExchangeDeleteOption) error + func (rc *RabbitmqClient) DeleteQueue(queueName string, opts ...QueueDeleteOption) error + func (rc *RabbitmqClient) PublishUnsafeWithContext(ctx context.Context, exchangeName, key string, body []byte, ...) error + type Table = amqp.Table