amqp

package module

Go to main page

Versions in this module

v1

v1.1.3

Oct 22, 2018

v1.1.2

Mar 30, 2018

Changes in this version

type PublisherOption

+ func PublisherContentType(t string) PublisherOption

v1.1.1

Mar 28, 2018

Changes in this version

+ type WithLogger struct

v1.1.0

Mar 26, 2018

Changes in this version

+ type Exchanges []Exchange

+ func PersistentExchanges(names ...string) (e Exchanges)

+ type Queues []Queue

+ func PersistentQueues(names ...string) (e Queues)

v1.0.0

Mar 22, 2018

Changes in this version

+ const MaxMessagePriority

+ const MinMessagePriority

+ var CodecNotFound = errors.New("codec not found")

+ var DeliveryChannelWasClosedError = errors.New("delivery channel was closed")

+ var NotAllowedPriority = errors.New("not allowed priority")

+ var QueueDeclareWarning = errors.New("declaring durable or non-auto-delete queue with empty name")

+ func CommonMessageIdBuilder() string

+ func CommonTyper(v interface{}) string

+ func WrapError(errs ...interface{}) error

+ type Binding struct

+ Args amqp.Table

+ Exchange string

+ Key string

+ NoWait bool

+ Queue string

+ type Channel struct

+ type Client struct

+ func NewClient(connector conn.Connector, decls ...Declaration) (cl Client, err error)

+ func (c *Client) Publisher(opts ...PublisherOption) *Publisher

+ func (c *Client) Stop()

+ func (c *Client) Subscriber(opts ...SubscriberOption) *Subscriber

+ type Consumer struct

+ Args amqp.Table

+ AutoAck bool

+ Consumer string

+ Exclusive bool

+ LimitCount int

+ LimitSize int

+ NoLocal bool

+ NoWait bool

+ type ContentTyper interface

+ ContentType func() string

+ type Declaration interface

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

+ type ErrorBefore func(amqp.Delivery, error) error

+ type Event struct

+ Context context.Context

+ Data interface{}

+ func (e Event) Done()

+ type Exchange struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ func LongExchange(name string) Exchange

+ func TemporaryExchange(name string) Exchange

+ type ObserverOption func(opts *observerOpts)

+ func Lifetime(dur time.Duration) ObserverOption

+ func LimitCount(count int) ObserverOption

+ func LimitSize(size int) ObserverOption

+ func Max(max int) ObserverOption

+ func Min(min int) ObserverOption

+ type Publish struct

+ Immediate bool

+ Key string

+ Mandatory bool

+ Priority uint8

+ type Publisher struct

+ func (p Publisher) Publish(ctx context.Context, exchangeName string, obj interface{}, pub Publish) error

+ func (p Publisher) PublishChannel(ctx context.Context, exchangeName string, pub Publish) chan<- interface{}

+ type PublisherOption func(*Publisher)

+ func PublisherBefore(before ...PublishingBefore) PublisherOption

+ func PublisherHandlersAmount(n int) PublisherOption

+ func PublisherLogger(lg logger.Logger) PublisherOption

+ func PublisherWaitConnection(should bool, timeout time.Duration) PublisherOption

+ func PublisherWithObserverOptions(opts ...ObserverOption) PublisherOption

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

+ type Queue struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ func LongQueue(name string) Queue

+ type Subscriber struct

+ func (s Subscriber) Subscribe(ctx context.Context, exchangeName, queueName string, dataType interface{}, ...) <-chan Event

+ func (s Subscriber) SubscribeToExchange(ctx context.Context, exchangeName string, dataType interface{}, cfg Consumer) <-chan Event

+ func (s Subscriber) SubscribeToQueue(ctx context.Context, queueName string, dataType interface{}, cfg Consumer) <-chan Event

+ type SubscriberOption func(*Subscriber)

+ func SubHandlersAmount(n int) SubscriberOption

+ func SubProcessAllDeliveries(v bool) SubscriberOption

+ func SubSetDefaultContentType(t string) SubscriberOption

+ func SubWithObserverOptions(opts ...ObserverOption) SubscriberOption

+ func SubscriberAllowedPriority(from, to uint8) SubscriberOption

+ func SubscriberBufferSize(a int) SubscriberOption

+ func SubscriberDeliverBefore(before ...DeliveryBefore) SubscriberOption

+ func SubscriberLogger(lg logger.Logger) SubscriberOption

+ func SubscriberWaitConnection(should bool, timeout time.Duration) SubscriberOption

+ type SyncedStringSlice struct

+ func (s *SyncedStringSlice) Append(strs ...string)

+ func (s *SyncedStringSlice) Drop()

+ func (s *SyncedStringSlice) Find(str string) int

+ func (s *SyncedStringSlice) Get() []string

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