Versions in this module Expand all Collapse all v1 deprecated v1.1.0 Jun 19, 2023 v1.0.0 Jan 8, 2020 Changes in this version + const AccessRefused + const ChannelError + const CommandInvalid + const ConnectionForced + const ContentTooLarge + const ExchangeDirect + const ExchangeFanout + const ExchangeHeaders + const ExchangeTopic + const FrameError + const InternalError + const InvalidPath + const NoConsumers + const NoRoute + const NotAllowed + const NotFound + const NotImplemented + const Persistent + const PreconditionFailed + const ResourceError + const ResourceLocked + const SyntaxError + const Transient + const UnexpectedFrame + var ErrChannelMax = &Error + var ErrClosed = &Error + var ErrCommandInvalid = &Error + var ErrCredentials = &Error + var ErrFieldType = &Error + var ErrFrame = &Error + var ErrSASL = &Error + var ErrSyntax = &Error + var ErrUnexpectedFrame = &Error + var ErrVhost = &Error + func DefaultDial(connectionTimeout time.Duration) func(network, addr string) (net.Conn, error) + type AMQPlainAuth struct + Password string + Username string + func (auth *AMQPlainAuth) Mechanism() string + func (auth *AMQPlainAuth) Response() string + type Acknowledger interface + Ack func(tag uint64, multiple bool) error + Nack func(tag uint64, multiple bool, requeue bool) error + Reject func(tag uint64, requeue bool) error + type Authentication interface + Mechanism func() string + Response func() string + type Blocking struct + Active bool + Reason string + type Channel struct + func (ch *Channel) Ack(tag uint64, multiple bool) error + func (ch *Channel) Cancel(consumer string, noWait bool) error + func (ch *Channel) Close() error + func (ch *Channel) Confirm(noWait bool) error + func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args Table) (<-chan Delivery, error) + func (ch *Channel) ExchangeBind(destination, key, source string, noWait bool, args Table) error + func (ch *Channel) ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error + func (ch *Channel) ExchangeDeclarePassive(name, kind string, durable, autoDelete, internal, noWait bool, args Table) error + func (ch *Channel) ExchangeDelete(name string, ifUnused, noWait bool) error + func (ch *Channel) ExchangeUnbind(destination, key, source string, noWait bool, args Table) error + func (ch *Channel) Flow(active bool) error + func (ch *Channel) Get(queue string, autoAck bool) (msg Delivery, ok bool, err error) + func (ch *Channel) Nack(tag uint64, multiple bool, requeue bool) error + func (ch *Channel) NotifyCancel(c chan string) chan string + func (ch *Channel) NotifyClose(c chan *Error) chan *Error + func (ch *Channel) NotifyConfirm(ack, nack chan uint64) (chan uint64, chan uint64) + func (ch *Channel) NotifyFlow(c chan bool) chan bool + func (ch *Channel) NotifyPublish(confirm chan Confirmation) chan Confirmation + func (ch *Channel) NotifyReturn(c chan Return) chan Return + func (ch *Channel) Publish(exchange, key string, mandatory, immediate bool, msg Publishing) error + func (ch *Channel) Qos(prefetchCount, prefetchSize int, global bool) error + func (ch *Channel) QueueBind(name, key, exchange string, noWait bool, args Table) error + func (ch *Channel) QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error) + func (ch *Channel) QueueDeclarePassive(name string, durable, autoDelete, exclusive, noWait bool, args Table) (Queue, error) + func (ch *Channel) QueueDelete(name string, ifUnused, ifEmpty, noWait bool) (int, error) + func (ch *Channel) QueueInspect(name string) (Queue, error) + func (ch *Channel) QueuePurge(name string, noWait bool) (int, error) + func (ch *Channel) QueueUnbind(name, key, exchange string, args Table) error + func (ch *Channel) Recover(requeue bool) error + func (ch *Channel) Reject(tag uint64, requeue bool) error + func (ch *Channel) Tx() error + func (ch *Channel) TxCommit() error + func (ch *Channel) TxRollback() error + type Config struct + ChannelMax int + Dial func(network, addr string) (net.Conn, error) + FrameSize int + Heartbeat time.Duration + Locale string + Properties Table + SASL []Authentication + TLSClientConfig *tls.Config + Vhost string + type Confirmation struct + Ack bool + DeliveryTag uint64 + type Connection struct + Config Config + Locales []string + Major int + Minor int + Properties Table + func Dial(url string) (*Connection, error) + func DialConfig(url string, config Config) (*Connection, error) + func DialTLS(url string, amqps *tls.Config) (*Connection, error) + func Open(conn io.ReadWriteCloser, config Config) (*Connection, error) + func (c *Connection) Channel() (*Channel, error) + func (c *Connection) Close() error + func (c *Connection) ConnectionState() tls.ConnectionState + func (c *Connection) IsClosed() bool + func (c *Connection) LocalAddr() net.Addr + func (c *Connection) NotifyBlocked(receiver chan Blocking) chan Blocking + func (c *Connection) NotifyClose(receiver chan *Error) chan *Error + type Decimal struct + Scale uint8 + Value int32 + type Delivery struct + Acknowledger Acknowledger + AppId string + Body []byte + ConsumerTag string + ContentEncoding string + ContentType string + CorrelationId string + DeliveryMode uint8 + DeliveryTag uint64 + Exchange string + Expiration string + Headers Table + MessageCount uint32 + MessageId string + Priority uint8 + Redelivered bool + ReplyTo string + RoutingKey string + Timestamp time.Time + Type string + UserId string + func (d Delivery) Ack(multiple bool) error + func (d Delivery) Nack(multiple, requeue bool) error + func (d Delivery) Reject(requeue bool) error + type Error struct + Code int + Reason string + Recover bool + Server bool + func (e Error) Error() string + type PlainAuth struct + Password string + Username string + func (auth *PlainAuth) Mechanism() string + func (auth *PlainAuth) Response() string + type Publishing struct + AppId string + Body []byte + ContentEncoding string + ContentType string + CorrelationId string + DeliveryMode uint8 + Expiration string + Headers Table + MessageId string + Priority uint8 + ReplyTo string + Timestamp time.Time + Type string + UserId string + type Queue struct + Consumers int + Messages int + Name string + type Return struct + AppId string + Body []byte + ContentEncoding string + ContentType string + CorrelationId string + DeliveryMode uint8 + Exchange string + Expiration string + Headers Table + MessageId string + Priority uint8 + ReplyCode uint16 + ReplyText string + ReplyTo string + RoutingKey string + Timestamp time.Time + Type string + UserId string + type Table map[string]interface + func (t Table) Validate() error + type URI struct + Host string + Password string + Port int + Scheme string + Username string + Vhost string + func ParseURI(uri string) (URI, error) + func (uri URI) AMQPlainAuth() *AMQPlainAuth + func (uri URI) PlainAuth() *PlainAuth + func (uri URI) String() string
Go to main page