amqp

May 5, 2023

Changes in this version

type ConnOptions

+ WriteTimeout time.Duration

Mar 30, 2023

Changes in this version

+ type LinkError struct

+ RemoteErr *Error

+ func (e *LinkError) Error() string

+ type ReceiveOptions struct

type ReceiverOptions

+ SourceCapabilities []string

+ SourceDurability Durability

+ SourceExpiryPolicy ExpiryPolicy

+ SourceExpiryTimeout uint32

+ type SendOptions struct

+ Settled bool

Dec 6, 2022

Changes in this version

+ type Address = string

+ type Binary = []byte

+ type Conn struct

+ func NewConn(conn net.Conn, opts *ConnOptions) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) NewSession(ctx context.Context, opts *SessionOptions) (*Session, error)

+ type ConnError struct

+ RemoteErr *Error

+ func (e *ConnError) Error() string

+ type ConnOptions struct

+ ContainerID string

+ HostName string

+ IdleTimeout time.Duration

+ MaxFrameSize uint32

+ MaxSessions uint16

+ Properties map[string]any

+ SASLType SASLType

+ TLSConfig *tls.Config

+ Timeout time.Duration

type DetachError

+ RemoteErr *Error

+ type ErrCond = encoding.ErrCond

+ const ErrCondConnectionForced

+ const ErrCondConnectionRedirect

+ const ErrCondDecodeError

+ const ErrCondDetachForced

+ const ErrCondErrantLink

+ const ErrCondFrameSizeTooSmall

+ const ErrCondFramingError

+ const ErrCondHandleInUse

+ const ErrCondIllegalState

+ const ErrCondInternalError

+ const ErrCondInvalidField

+ const ErrCondLinkRedirect

+ const ErrCondMessageSizeExceeded

+ const ErrCondNotAllowed

+ const ErrCondNotFound

+ const ErrCondNotImplemented

+ const ErrCondPreconditionFailed

+ const ErrCondResourceDeleted

+ const ErrCondResourceLimitExceeded

+ const ErrCondResourceLocked

+ const ErrCondStolen

+ const ErrCondTransferLimitExceeded

+ const ErrCondUnattachedHandle

+ const ErrCondUnauthorizedAccess

+ const ErrCondWindowViolation

type ExpiryPolicy

+ const ExpiryPolicyConnectionClose

+ const ExpiryPolicyLinkDetach

+ const ExpiryPolicyNever

+ const ExpiryPolicySessionEnd

+ type LinkFilter func(encoding.Filter)

+ func NewLinkFilter(name string, code uint64, value any) LinkFilter

+ func NewSelectorFilter(filter string) LinkFilter

+ type MessageID = any

+ 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]any

+ RequestedSenderSettleMode *SenderSettleMode

+ SenderCapabilities []string

+ SenderDurability Durability

+ SenderExpiryPolicy ExpiryPolicy

+ SenderExpiryTimeout uint32

+ SettlementMode *ReceiverSettleMode

+ TargetAddress string

type ReceiverSettleMode

+ const ReceiverSettleModeFirst

+ const ReceiverSettleModeSecond

+ 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]any

+ RequestedReceiverSettleMode *ReceiverSettleMode

+ SettlementMode *SenderSettleMode

+ SourceAddress string

+ TargetCapabilities []string

+ TargetDurability Durability

+ TargetExpiryPolicy ExpiryPolicy

+ TargetExpiryTimeout uint32

type SenderSettleMode

+ const SenderSettleModeMixed

+ const SenderSettleModeSettled

+ const SenderSettleModeUnsettled

+ type SequenceNumber = uint32

+ type SessionError struct

+ RemoteErr *Error

+ func (e *SessionError) Error() string

+ type SessionOptions struct

+ IncomingWindow uint32

+ MaxLinks uint32

+ OutgoingWindow uint32

+ type Symbol = string

Feb 4, 2022

Changes in this version

type Message

+ Sequence [][]interface{}

Dec 7, 2021

Changes in this version

+ type AMQPAddress = string

+ type AMQPBinary = []byte

+ type AMQPMessageID = interface

+ type AMQPSequenceNumber = uint32

+ type AMQPSymbol = string

Nov 1, 2021

Changes in this version

type Receiver

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

Oct 1, 2021

Changes in this version

type ConnOption

+ func ConnSASLExternal(resp string) ConnOption

type Message

+ func (m *Message) LinkName() string

type Receiver

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

+ func (r *Receiver) LinkName() string

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

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

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

type Sender

+ func (s *Sender) LinkName() string

Sep 13, 2021

Changes in this version

type Sender

+ func (s *Sender) MaxMessageSize() uint64

Sep 9, 2021

Changes in this version

type Durability

+ func (d *Durability) Unmarshal(r *buffer.Buffer) error

+ func (d Durability) Marshal(wr *buffer.Buffer) error

type ExpiryPolicy

+ func (e *ExpiryPolicy) Unmarshal(r *buffer.Buffer) error

+ func (e ExpiryPolicy) Marshal(wr *buffer.Buffer) error

type LinkOption

+ func LinkWithManualCredits() LinkOption

type Message

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

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

type MessageHeader

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

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

type MessageProperties

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

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

type Receiver

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

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

type ReceiverSettleMode

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

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

type SenderSettleMode

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

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

Aug 16, 2021

Changes in this version

type LinkOption

+ func LinkDetachOnDispositionError(detachOnDispositionError bool) LinkOption

Aug 6, 2021

Changes in this version

+ var ErrLinkDetached = errors.New("amqp: link detached")

type Sender

+ func (s *Sender) ID() string

Jun 23, 2021

Changes in this version

type Receiver

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

May 6, 2021

Changes in this version

type Message

+ func (m *Message) GetLinkName() string

Feb 12, 2021

Changes in this version

type Message

+ func (m *Message) Ignore()

type Receiver

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

Aug 6, 2020

Changes in this version

type LinkOption

+ func LinkPropertyInt32(key string, value int32) LinkOption

Jan 7, 2020

Changes in this version

type LinkOption

+ func LinkSourceTimeout(timeout uint32) LinkOption

+ func LinkTargetTimeout(timeout uint32) LinkOption

Dec 12, 2019

Changes in this version

type ConnOption

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

Nov 20, 2019

Changes in this version

type LinkOption

+ func LinkTargetDurability(d Durability) LinkOption

+ func LinkTargetExpiryPolicy(p ExpiryPolicy) LinkOption

Aug 22, 2019

Changes in this version

type Message

+ SendSettled bool

Oct 26, 2018

Changes in this version

type Message

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

Oct 23, 2018

Changes in this version

type LinkOption

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

Oct 23, 2018

Changes in this version

+ type Durability uint32

+ const DurabilityConfiguration

+ const DurabilityNone

+ const DurabilityUnsettledState

+ func (d *Durability) String() string

+ type ExpiryPolicy symbol

+ const ExpiryConnectionClose

+ const ExpiryLinkDetach

+ const ExpiryNever

+ const ExpirySessionEnd

+ func (e *ExpiryPolicy) String() string

type LinkOption

+ func LinkName(name string) LinkOption

+ func LinkSourceCapabilities(capabilities ...string) LinkOption

+ func LinkSourceDurability(d Durability) LinkOption

+ func LinkSourceExpiryPolicy(p ExpiryPolicy) LinkOption

Sep 7, 2018

Changes in this version

type Message

+ DeliveryTag []byte

Aug 1, 2018

Changes in this version

type ConnOption

+ func ConnContainerID(id string) ConnOption

May 14, 2018

Changes in this version

type Message

+ func (m *Message) Modify(deliveryFailed, undeliverableHere bool, messageAnnotations Annotations)

May 13, 2018

Changes in this version

+ const DefaultMaxLinks

+ const DefaultWindow

type LinkOption

+ func LinkMaxMessageSize(size uint64) LinkOption

+ func LinkSessionFilter(sessionID string) LinkOption

+ type SessionOption func(*Session) error

+ func SessionIncomingWindow(window uint32) SessionOption

+ func SessionMaxLinks(n int) SessionOption

+ func SessionOutgoingWindow(window uint32) SessionOption

Apr 3, 2018

Changes in this version

type Error

+ func (e *Error) Error() string

type LinkOption

+ func LinkProperty(key, value string) LinkOption

+ func LinkPropertyInt64(key string, value int64) LinkOption

type Message

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

Feb 18, 2018

Changes in this version

+ const DefaultMaxSessions

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

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

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

+ type Annotations map[interface{}]interface

+ type ArrayUByte []uint8

type ConnOption

+ func ConnMaxSessions(n int) ConnOption

+ func ConnProperty(key, value string) ConnOption

type LinkOption

+ func LinkSourceAddress(addr string) LinkOption

+ func LinkTargetAddress(addr string) LinkOption

type Message

+ Format uint32

+ func NewMessage(data []byte) *Message

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

Jan 16, 2018

Changes in this version

type LinkOption

+ func LinkSelectorFilter(filter string) LinkOption

Jan 12, 2018

Changes in this version

type ConnOption

+ func ConnSASLAnonymous() ConnOption

+ type DetachError struct

+ RemoteError *Error

+ func (e DetachError) Error() string

type Error

+ func (e *Error) String() string

type LinkOption

+ func LinkAddress(source string) LinkOption

+ func LinkAddressDynamic() LinkOption

+ func LinkReceiverSettle(mode ReceiverSettleMode) LinkOption

+ func LinkSenderSettle(mode SenderSettleMode) LinkOption

type Message

+ Value interface{}

type Receiver

+ func (r *Receiver) Address() string

+ type ReceiverSettleMode uint8

+ const ModeFirst

+ const ModeSecond

+ func (m *ReceiverSettleMode) String() string

+ type Sender struct

+ func (s *Sender) Address() string

+ func (s *Sender) Close() error

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

+ type SenderSettleMode uint8

+ const ModeMixed

+ const ModeSettled

+ const ModeUnsettled

+ func (m *SenderSettleMode) String() string

type Session

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

+ type UUID [16]byte

+ func (u UUID) String() string

May 7, 2017

Changes in this version

+ const DefaultIdleTimeout

+ const DefaultLinkBatchMaxAge

+ const DefaultLinkBatching

+ const DefaultLinkCredit

+ const DefaultMaxFrameSize

+ var ErrTimeout = errorNew("timeout waiting for response")

+ 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() (*Session, error)

+ type ConnOption func(*conn) error

+ func ConnConnectTimeout(d time.Duration) ConnOption

+ func ConnIdleTimeout(d time.Duration) ConnOption

+ func ConnMaxFrameSize(n uint32) ConnOption

+ func ConnSASLPlain(username, password string) ConnOption

+ func ConnServerHostname(hostname string) ConnOption

+ func ConnTLS(enable bool) ConnOption

+ func ConnTLSConfig(tc *tls.Config) ConnOption

+ type ErrDetach struct

+ RemoteError *Error

+ func (e ErrDetach) Error() string

+ type Error struct

+ Condition ErrorCondition

+ Description string

+ Info map[string]interface{}

+ type ErrorCondition string

+ 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 LinkOption func(*link) error

+ func LinkBatchMaxAge(d time.Duration) LinkOption

+ func LinkBatching(enable bool) LinkOption

+ func LinkCredit(credit uint32) LinkOption

+ func LinkSource(source string) LinkOption

+ type Message struct

+ Annotations map[interface{}]interface{}

+ ApplicationProperties map[string]interface{}

+ Data []byte

+ DeliveryAnnotations map[interface{}]interface{}

+ Footer map[interface{}]interface{}

+ Header MessageHeader

+ Properties MessageProperties

+ func (m *Message) Accept()

+ func (m *Message) Reject()

+ func (m *Message) Release()

+ type MessageHeader struct

+ DeliveryCount uint32

+ Durable bool

+ FirstAcquirer bool

+ Priority uint8

+ TTL time.Duration

+ type MessageProperties struct

+ AbsoluteExpiryTime time.Time

+ ContentEncoding string

+ ContentType string

+ CorrelationID interface{}

+ CreationTime time.Time

+ GroupID string

+ GroupSequence uint32

+ MessageID interface{}

+ ReplyTo string

+ ReplyToGroupID string

+ Subject string

+ To string

+ UserID []byte

+ type Receiver struct

+ func (r *Receiver) Close() error

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

+ type Session struct

+ func (s *Session) Close() error

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