Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

amqp

package

Go to main page

Versions in this module

v1

v1.2.1

Mar 7, 2023

v1.2.0

Feb 7, 2023

v1.1.4

Jan 4, 2023

v1.1.3

Nov 17, 2022

v1.1.2

Nov 8, 2022

retracted

v1.1.1

Oct 4, 2022

v1.1.0

Aug 9, 2022

Changes in this version

+ type Address = string

+ type Binary = []byte

+ type ConnOptions struct

+ ContainerID string

+ HostName string

+ IdleTimeout time.Duration

+ MaxFrameSize uint32

+ MaxSessions uint16

+ Properties map[string]interface{}

+ SASLType SASLType

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ type ConnectionError struct

+ func (c *ConnectionError) Error() string

+ type LinkFilter func(encoding.Filter)

+ func LinkFilterSelector(filter string) LinkFilter

+ func LinkFilterSource(name string, code uint64, value interface{}) LinkFilter

+ type MessageID = interface

+ type ModifyMessageOptions struct

+ Annotations Annotations

+ DeliveryFailed bool

+ UndeliverableHere bool

+ type ReceiverOptions struct

+ BatchMaxAge time.Duration

+ Batching bool

+ Capabilities []string

+ Credit uint32

+ Durability Durability

+ DynamicAddress bool

+ ExpiryPolicy ExpiryPolicy

+ ExpiryTimeout uint32

+ Filters []LinkFilter

+ ManualCredits bool

+ MaxMessageSize uint64

+ Name string

+ Properties map[string]interface{}

+ RequestedSenderSettleMode *SenderSettleMode

+ SettlementMode *ReceiverSettleMode

+ TargetAddress string

+ type SASLType func(c *conn) error

+ func SASLTypeAnonymous() SASLType

+ func SASLTypeExternal(resp string) SASLType

+ func SASLTypePlain(username, password string) SASLType

+ func SASLTypeXOAUTH2(username, bearer string, saslMaxFrameSizeOverride uint32) SASLType

+ type SenderOptions struct

+ Capabilities []string

+ Durability Durability

+ DynamicAddress bool

+ ExpiryPolicy ExpiryPolicy

+ ExpiryTimeout uint32

+ IgnoreDispositionErrors bool

+ Name string

+ Properties map[string]interface{}

+ RequestedReceiverSettleMode *ReceiverSettleMode

+ SettlementMode *SenderSettleMode

+ SourceAddress string

+ type SequenceNumber = uint32

+ type SessionOptions struct

+ IncomingWindow uint32

+ MaxLinks uint32

+ OutgoingWindow uint32

+ type Symbol = string

v1.0.2

Jul 5, 2022

v1.0.2-beta.0

Jul 7, 2022

v1.0.1

Jun 7, 2022

v1.0.0

May 16, 2022

Changes in this version

+ const DefaultIdleTimeout

+ const DefaultLinkBatchMaxAge

+ const DefaultLinkBatching

+ const DefaultLinkCredit

+ const DefaultMaxFrameSize

+ const DefaultMaxLinks

+ const DefaultMaxSessions

+ const DefaultWindow

+ const DurabilityConfiguration

+ const DurabilityNone

+ const DurabilityUnsettledState

+ const ExpiryConnectionClose

+ const ExpiryLinkDetach

+ const ExpiryNever

+ const ExpirySessionEnd

+ const ModeFirst

+ const ModeMixed

+ const ModeSecond

+ const ModeSettled

+ const ModeUnsettled

+ var ErrConnClosed = errors.New("amqp: connection closed")

+ var ErrLinkClosed = errors.New("amqp: link closed")

+ var ErrSessionClosed = errors.New("amqp: session closed")

+ var ErrTimeout = errors.New("amqp: timeout waiting for response")

+ type AMQPAddress = string

+ type AMQPBinary = []byte

+ type AMQPMessageID = interface

+ type AMQPSequenceNumber = uint32

+ type AMQPSymbol = string

+ type Annotations = encoding.Annotations

+ type Client struct

+ func Dial(addr string, opts ...ConnOption) (*Client, error)

+ func New(conn net.Conn, opts ...ConnOption) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) NewSession(opts ...SessionOption) (*Session, error)

+ type ConnOption func(*conn) error

+ func ConnConnectTimeout(d time.Duration) ConnOption

+ func ConnContainerID(id string) ConnOption

+ func ConnIdleTimeout(d time.Duration) ConnOption

+ func ConnMaxFrameSize(n uint32) ConnOption

+ func ConnMaxSessions(n int) ConnOption

+ func ConnProperty(key, value string) ConnOption

+ func ConnSASLAnonymous() ConnOption

+ func ConnSASLExternal(resp string) ConnOption

+ func ConnSASLPlain(username, password string) ConnOption

+ func ConnSASLXOAUTH2(username, bearer string, saslMaxFrameSizeOverride uint32) ConnOption

+ func ConnServerHostname(hostname string) ConnOption

+ func ConnTLS(enable bool) ConnOption

+ func ConnTLSConfig(tc *tls.Config) ConnOption

+ type DetachError struct

+ RemoteError *Error

+ func (e *DetachError) Error() string

+ type Durability = encoding.Durability

+ type Error = encoding.Error

+ type ErrorCondition = encoding.ErrorCondition

+ const ErrorConnectionForced

+ const ErrorConnectionRedirect

+ const ErrorDecodeError

+ const ErrorDetachForced

+ const ErrorErrantLink

+ const ErrorFrameSizeTooSmall

+ const ErrorFramingError

+ const ErrorHandleInUse

+ const ErrorIllegalState

+ const ErrorInternalError

+ const ErrorInvalidField

+ const ErrorLinkRedirect

+ const ErrorMessageSizeExceeded

+ const ErrorNotAllowed

+ const ErrorNotFound

+ const ErrorNotImplemented

+ const ErrorPreconditionFailed

+ const ErrorResourceDeleted

+ const ErrorResourceLimitExceeded

+ const ErrorResourceLocked

+ const ErrorStolen

+ const ErrorTransferLimitExceeded

+ const ErrorUnattachedHandle

+ const ErrorUnauthorizedAccess

+ const ErrorWindowViolation

+ type ExpiryPolicy = encoding.ExpiryPolicy

+ type LinkOption func(*link) error

+ func LinkAddressDynamic() LinkOption

+ func LinkBatchMaxAge(d time.Duration) LinkOption

+ func LinkBatching(enable bool) LinkOption

+ func LinkCredit(credit uint32) LinkOption

+ func LinkDetachOnDispositionError(detachOnDispositionError bool) LinkOption

+ func LinkMaxMessageSize(size uint64) LinkOption

+ func LinkName(name string) LinkOption

+ func LinkProperty(key, value string) LinkOption

+ func LinkPropertyInt32(key string, value int32) LinkOption

+ func LinkPropertyInt64(key string, value int64) LinkOption

+ func LinkReceiverSettle(mode ReceiverSettleMode) LinkOption

+ func LinkSelectorFilter(filter string) LinkOption

+ func LinkSenderSettle(mode SenderSettleMode) LinkOption

+ func LinkSourceAddress(addr string) LinkOption

+ func LinkSourceCapabilities(capabilities ...string) LinkOption

+ func LinkSourceDurability(d Durability) LinkOption

+ func LinkSourceExpiryPolicy(p ExpiryPolicy) LinkOption

+ func LinkSourceFilter(name string, code uint64, value interface{}) LinkOption

+ func LinkSourceTimeout(timeout uint32) LinkOption

+ func LinkTargetAddress(addr string) LinkOption

+ func LinkTargetDurability(d Durability) LinkOption

+ func LinkTargetExpiryPolicy(p ExpiryPolicy) LinkOption

+ func LinkTargetTimeout(timeout uint32) LinkOption

+ func LinkWithManualCredits() LinkOption

+ type Message struct

+ Annotations encoding.Annotations

+ ApplicationProperties map[string]interface{}

+ Data [][]byte

+ DeliveryAnnotations encoding.Annotations

+ DeliveryTag []byte

+ Footer encoding.Annotations

+ Format uint32

+ Header *MessageHeader

+ Properties *MessageProperties

+ SendSettled bool

+ Sequence [][]interface{}

+ Value interface{}

+ func NewMessage(data []byte) *Message

+ func (m *Message) GetData() []byte

+ func (m *Message) LinkName() string

+ func (m *Message) Marshal(wr *buffer.Buffer) error

+ func (m *Message) MarshalBinary() ([]byte, error)

+ func (m *Message) Unmarshal(r *buffer.Buffer) error

+ func (m *Message) UnmarshalBinary(data []byte) error

+ type MessageHeader struct

+ DeliveryCount uint32

+ Durable bool

+ FirstAcquirer bool

+ Priority uint8

+ TTL time.Duration

+ func (h *MessageHeader) Marshal(wr *buffer.Buffer) error

+ func (h *MessageHeader) Unmarshal(r *buffer.Buffer) error

+ type MessageProperties struct

+ AbsoluteExpiryTime *time.Time

+ ContentEncoding *AMQPSymbol

+ ContentType *AMQPSymbol

+ CorrelationID AMQPMessageID

+ CreationTime *time.Time

+ GroupID *string

+ GroupSequence *AMQPSequenceNumber

+ MessageID AMQPMessageID

+ ReplyTo *AMQPAddress

+ ReplyToGroupID *string

+ Subject *string

+ To *AMQPAddress

+ UserID AMQPBinary

+ func (p *MessageProperties) Marshal(wr *buffer.Buffer) error

+ func (p *MessageProperties) Unmarshal(r *buffer.Buffer) error

+ type Receiver struct

+ func (r *Receiver) AcceptMessage(ctx context.Context, msg *Message) error

+ func (r *Receiver) Address() string

+ func (r *Receiver) Close(ctx context.Context) error

+ func (r *Receiver) DrainCredit(ctx context.Context) error

+ func (r *Receiver) IssueCredit(credit uint32) error

+ func (r *Receiver) LinkName() string

+ func (r *Receiver) LinkSourceFilterValue(name string) interface{}

+ func (r *Receiver) ModifyMessage(ctx context.Context, msg *Message, deliveryFailed, undeliverableHere bool, ...) error

+ func (r *Receiver) Prefetched(ctx context.Context) (*Message, error)

+ func (r *Receiver) Receive(ctx context.Context) (*Message, error)

+ func (r *Receiver) RejectMessage(ctx context.Context, msg *Message, e *Error) error

+ func (r *Receiver) ReleaseMessage(ctx context.Context, msg *Message) error

+ type ReceiverSettleMode = encoding.ReceiverSettleMode

+ type Sender struct

+ func (s *Sender) Address() string

+ func (s *Sender) Close(ctx context.Context) error

+ func (s *Sender) LinkName() string

+ func (s *Sender) MaxMessageSize() uint64

+ func (s *Sender) Send(ctx context.Context, msg *Message) error

+ type SenderSettleMode = encoding.SenderSettleMode

+ type Session struct

+ func (s *Session) Close(ctx context.Context) error

+ func (s *Session) NewReceiver(opts ...LinkOption) (*Receiver, error)

+ func (s *Session) NewSender(opts ...LinkOption) (*Sender, error)

+ type SessionOption func(*Session) error

+ func SessionIncomingWindow(window uint32) SessionOption

+ func SessionMaxLinks(n int) SessionOption

+ func SessionOutgoingWindow(window uint32) SessionOption

+ type UUID = encoding.UUID