amqp

package

Go to main page

Versions in this module

v0

v0.13.0

May 29, 2023

v0.12.0

Sep 18, 2021

v0.11.0

Jul 2, 2021

v0.10.0

Feb 17, 2020

v0.9.0

Jun 24, 2019

Changes in this version

+ func DefaultDeliverer(ctx context.Context, p Publisher, pub *amqp.Publishing) (*amqp.Delivery, error)

+ func DefaultResponsePublisher(ctx context.Context, deliv *amqp.Delivery, ch Channel, pub *amqp.Publishing) error

+ func NopResponsePublisher(ctx context.Context, deliv *amqp.Delivery, ch Channel, pub *amqp.Publishing) error

+ func SendAndForgetDeliverer(ctx context.Context, p Publisher, pub *amqp.Publishing) (*amqp.Delivery, error)

+ type Deliverer func(context.Context, Publisher, *amqp.Publishing) (*amqp.Delivery, error)

type PublisherOption

+ func PublisherDeliverer(deliverer Deliverer) PublisherOption

+ type ResponsePublisher func(context.Context, *amqp.Delivery, Channel, *amqp.Publishing) error

type SubscriberOption

+ func SubscriberErrorHandler(errorHandler transport.ErrorHandler) SubscriberOption

+ func SubscriberResponsePublisher(rp ResponsePublisher) SubscriberOption

v0.8.0

Nov 8, 2018

Changes in this version

+ const ContextKeyAutoAck

+ const ContextKeyConsumeArgs

+ const ContextKeyExchange

+ const ContextKeyNackSleepDuration

+ const ContextKeyPublishKey

+ func DefaultErrorEncoder(ctx context.Context, err error, deliv *amqp.Delivery, ch Channel, ...)

+ func EncodeJSONResponse(ctx context.Context, pub *amqp.Publishing, response interface{}) error

+ func EncodeNopResponse(ctx context.Context, pub *amqp.Publishing, response interface{}) error

+ func ReplyAndAckErrorEncoder(ctx context.Context, err error, deliv *amqp.Delivery, ch Channel, ...)

+ func ReplyErrorEncoder(ctx context.Context, err error, deliv *amqp.Delivery, ch Channel, ...)

+ func SingleNackRequeueErrorEncoder(ctx context.Context, err error, deliv *amqp.Delivery, ch Channel, ...)

+ type Channel interface

+ Consume func(queue, consumer string, autoAck, exclusive, noLocal, noWail bool, ...) (<-chan amqp.Delivery, error)

+ Publish func(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

+ type DecodeRequestFunc func(context.Context, *amqp.Delivery) (request interface{}, err error)

+ type DecodeResponseFunc func(context.Context, *amqp.Delivery) (response interface{}, err error)

+ type DefaultErrorResponse struct

+ Error string

+ type EncodeRequestFunc func(context.Context, *amqp.Publishing, interface{}) error

+ type EncodeResponseFunc func(context.Context, *amqp.Publishing, interface{}) error

+ type ErrorEncoder func(ctx context.Context, err error, deliv *amqp.Delivery, ch Channel, ...)

+ type Publisher struct

+ func NewPublisher(ch Channel, q *amqp.Queue, enc EncodeRequestFunc, dec DecodeResponseFunc, ...) *Publisher

+ func (p Publisher) Endpoint() endpoint.Endpoint

+ type PublisherOption func(*Publisher)

+ func PublisherAfter(after ...PublisherResponseFunc) PublisherOption

+ func PublisherBefore(before ...RequestFunc) PublisherOption

+ func PublisherTimeout(timeout time.Duration) PublisherOption

+ type PublisherResponseFunc func(context.Context, *amqp.Delivery) context.Context

+ type RequestFunc func(context.Context, *amqp.Publishing) context.Context

+ func SetConsumeArgs(args amqp.Table) RequestFunc

+ func SetConsumeAutoAck(autoAck bool) RequestFunc

+ func SetContentEncoding(contentEncoding string) RequestFunc

+ func SetContentType(contentType string) RequestFunc

+ func SetCorrelationID(cid string) RequestFunc

+ func SetNackSleepDuration(duration time.Duration) RequestFunc

+ func SetPublishDeliveryMode(dmode uint8) RequestFunc

+ func SetPublishExchange(publishExchange string) RequestFunc

+ func SetPublishKey(publishKey string) RequestFunc

+ type Subscriber struct

+ func NewSubscriber(e endpoint.Endpoint, dec DecodeRequestFunc, enc EncodeResponseFunc, ...) *Subscriber

+ func (s Subscriber) ServeDelivery(ch Channel) func(deliv *amqp.Delivery)

+ type SubscriberOption func(*Subscriber)

+ func SubscriberAfter(after ...SubscriberResponseFunc) SubscriberOption

+ func SubscriberBefore(before ...RequestFunc) SubscriberOption

+ func SubscriberErrorEncoder(ee ErrorEncoder) SubscriberOption

+ func SubscriberErrorLogger(logger log.Logger) SubscriberOption

+ type SubscriberResponseFunc func(context.Context, *amqp.Delivery, Channel, *amqp.Publishing) context.Context

+ func SetAckAfterEndpoint(multiple bool) SubscriberResponseFunc

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL