Versions in this module Expand all Collapse all v1 v1.1.1 Sep 29, 2020 v1.1.0 Sep 24, 2020 Changes in this version type Config + AutoDelete bool v1.0.2 Aug 5, 2020 v1.0.1 Jul 1, 2020 v1.0.0 Apr 4, 2018 Changes in this version + var ChannelClosed = fmt.Errorf("Channel closed!") + var TimedOut = fmt.Errorf("Timeout") + func IsDecodeFailure(err error) bool + type Config struct + Addr string + DisablePersistence bool + DisablePublishConfirm bool + EnableMultiAck bool + EnableTLS bool + Exchange string + ExchangeType string + MessageTTL time.Duration + Password string + Port int + PrefetchCount int + QueueTTL time.Duration + Serializer Serializer + Username string + Vhost string + WithoutPrefix bool + func ConfigFromURI(amqpUri string) (*Config, error) + type Consumer struct + func (c *Consumer) Ack() error + func (c *Consumer) Close() error + func (c *Consumer) Consume(out interface{}) error + func (c *Consumer) ConsumeAck(out interface{}) error + func (c *Consumer) ConsumeTimeout(out interface{}, timeout time.Duration) error + func (c *Consumer) Nack() error + type GOBSerializer struct + func (*GOBSerializer) ContentType() string + func (*GOBSerializer) RelayDecode(r io.Reader, o interface{}) error + func (*GOBSerializer) RelayEncode(w io.Writer, e interface{}) error + type JSONSerializer struct + func (*JSONSerializer) ContentType() string + func (*JSONSerializer) RelayDecode(r io.Reader, o interface{}) error + func (*JSONSerializer) RelayEncode(w io.Writer, e interface{}) error + type Publisher struct + func (p *Publisher) Close() error + func (p *Publisher) Publish(in interface{}) error + type Relay struct + func New(c *Config) (*Relay, error) + func (r *Relay) Broker() broker.Broker + func (r *Relay) Close() error + func (r *Relay) Consumer(queue string) (*Consumer, error) + func (r *Relay) ConsumerWithRoutingKey(queue string, routingKey string) (*Consumer, error) + func (r *Relay) Publisher(queue string) (*Publisher, error) + func (r *Relay) PublisherWithRoutingKey(queue string, routingKey string) (*Publisher, error) + func (r *Relay) RetryBroker(attempts int, min, max time.Duration) (*retryBroker, error) + type Serializer interface + ContentType func() string + RelayDecode func(io.Reader, interface{}) error + RelayEncode func(io.Writer, interface{}) error
Go to main page