amqp

package

Go to main page

Versions in this module

v0

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