amqp

May 6, 2021

Changes in this version

type ConnOption

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

type LinkOption

+ func LinkPropertyInt32(key string, value int32) LinkOption

+ func LinkSourceTimeout(timeout uint32) LinkOption

+ func LinkTargetTimeout(timeout uint32) LinkOption

type Message

+ func (m *Message) Ignore()

type Receiver

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

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)