amqp

Sep 17, 2023

Changes in this version

type Config

+ func (c Config) GetQueueBind(name string) (QueueBindConfig, error)

+ type ExchangeKind string

+ const ExchangeDirect

+ const ExchangeFanout

+ const ExchangeHeaders

+ const ExchangeTopic

+ func (e ExchangeKind) String() string

+ type QueueBindConfig struct

+ Args map[string]interface{}

+ Exchange string

+ Key string

+ NoWait bool

Sep 17, 2023

Changes in this version

type ProducerConfig

+ Key string

Sep 17, 2023

Changes in this version

+ type AwaitForBodyHandler struct

+ Handler BodyHandler

+ func (h *AwaitForBodyHandler) Done()

+ func (h *AwaitForBodyHandler) Wait()

+ type BodyHandler func(Body) Handled

Sep 16, 2023

Changes in this version

type MessageHandlerFunc

+ func WaitForReply(i T) (MessageHandlerFunc, *sync.WaitGroup, T)

Sep 16, 2023

Changes in this version

+ type Producer struct

+ func (p Producer) Publish(msg PublishMessage) (PublishedMessage, error)

Sep 16, 2023

Changes in this version

+ var ConfigNotFound = errors.New("config not found")

+ type Acknowledge string

+ const Ack

+ const Nack

+ const Reject

+ type Body map[string]interface

+ func (b Body) To(i interface{})

+ type Config struct

+ func NewConfig(consumers map[string]ConsumerConfig, exchanges map[string]ExchangeConfig, ...) Config

+ func (c Config) GetConsumer(name string) (ConsumerConfig, error)

+ func (c Config) GetExchange(name string) (ExchangeConfig, error)

+ func (c Config) GetProducer(name string) (ProducerConfig, error)

+ func (c Config) GetQueue(name string) (QueueConfig, error)

+ func (c Config) GetRoute(i interface{}) (RouteConfig, error)

+ type Consumer interface

+ Handle func(Body) Handled

+ Name func() string

+ type ConsumerConfig struct

+ Args map[string]interface{}

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ Queue string

+ type Controller struct

+ func Init(url string, config Config, consumers []Consumer) (*Controller, error)

+ func (c Controller) Consume()

+ func (p Controller) Publish(msg PublishMessage) (PublishedMessage, error)

+ type ExchangeConfig struct

+ Args map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Kind string

+ NoWait bool

+ type Handled struct

+ func HandledAndRejected() Handled

+ func HandledNotSuccessfully(requeue bool) Handled

+ func HandledSuccessfully() Handled

+ func (h Handled) WithReply(r interface{}) Handled

+ type MessageHandlerFunc func(Body) Handled

+ type MessageType string

+ const MessageRegular

+ const MessageWithReply

+ type NoReply struct

+ type ProducerConfig struct

+ Exchange string

+ Immediate bool

+ Mandatory bool

+ Queues []string

+ ReplyTo string

+ type PublishMessage struct

+ func MessageToPublish(msg interface{}) PublishMessage

+ func MessageToPublishWithReply(msg interface{}, handler MessageHandlerFunc) PublishMessage

+ type PublishedMessage struct

+ CorrelationID uuid.UUID

+ ID uuid.UUID

+ Message interface{}

+ SentAt time.Time

+ type QueueConfig struct

+ Args map[string]interface{}

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ NoWait bool

+ type RouteConfig struct

+ Producer string

+ Type interface{}