Versions in this module Expand all Collapse all v0 v0.14.0 Nov 30, 2021 Changes in this version + const DeleteOnClose + const DeleteOnNoLinks + const DeleteOnNoLinksOrMessages + const DeleteOnNoMessages + func Marshal(wr *buffer.Buffer, i interface{}) error + func MarshalComposite(wr *buffer.Buffer, code AMQPType, fields []MarshalField) error + func PeekMessageType(buf []byte) (uint8, error) + func ReadAny(r *buffer.Buffer) (interface{}, error) + func ReadString(r *buffer.Buffer) (string, error) + func ReadUbyte(r *buffer.Buffer) (uint8, error) + func Unmarshal(r *buffer.Buffer, i interface{}) error + func UnmarshalComposite(r *buffer.Buffer, type_ AMQPType, fields ...UnmarshalField) error + func ValidateExpiryPolicy(e ExpiryPolicy) error + func WriteBinary(wr *buffer.Buffer, bin []byte) error + func WriteDescriptor(wr *buffer.Buffer, code AMQPType) + type AMQPType uint8 + const TypeCodeAMQPSequence + const TypeCodeAMQPValue + const TypeCodeApplicationData + const TypeCodeApplicationProperties + const TypeCodeArray32 + const TypeCodeArray8 + const TypeCodeAttach + const TypeCodeBegin + const TypeCodeBool + const TypeCodeBoolFalse + const TypeCodeBoolTrue + const TypeCodeByte + const TypeCodeChar + const TypeCodeClose + const TypeCodeDecimal128 + const TypeCodeDecimal32 + const TypeCodeDecimal64 + const TypeCodeDeleteOnClose + const TypeCodeDeleteOnNoLinks + const TypeCodeDeleteOnNoLinksOrMessages + const TypeCodeDeleteOnNoMessages + const TypeCodeDeliveryAnnotations + const TypeCodeDetach + const TypeCodeDisposition + const TypeCodeDouble + const TypeCodeEnd + const TypeCodeError + const TypeCodeFloat + const TypeCodeFlow + const TypeCodeFooter + const TypeCodeInt + const TypeCodeList0 + const TypeCodeList32 + const TypeCodeList8 + const TypeCodeLong + const TypeCodeMap32 + const TypeCodeMap8 + const TypeCodeMessageAnnotations + const TypeCodeMessageHeader + const TypeCodeMessageProperties + const TypeCodeNull + const TypeCodeOpen + const TypeCodeSASLChallenge + const TypeCodeSASLInit + const TypeCodeSASLMechanism + const TypeCodeSASLOutcome + const TypeCodeSASLResponse + const TypeCodeShort + const TypeCodeSmallUint + const TypeCodeSmallUlong + const TypeCodeSmallint + const TypeCodeSmalllong + const TypeCodeSource + const TypeCodeStateAccepted + const TypeCodeStateModified + const TypeCodeStateReceived + const TypeCodeStateRejected + const TypeCodeStateReleased + const TypeCodeStr32 + const TypeCodeStr8 + const TypeCodeSym32 + const TypeCodeSym8 + const TypeCodeTarget + const TypeCodeTimestamp + const TypeCodeTransfer + const TypeCodeUUID + const TypeCodeUbyte + const TypeCodeUint + const TypeCodeUint0 + const TypeCodeUlong + const TypeCodeUlong0 + const TypeCodeUshort + const TypeCodeVbin32 + const TypeCodeVbin8 + type Annotations map[interface{}]interface + func (a *Annotations) Unmarshal(r *buffer.Buffer) error + func (a Annotations) Marshal(wr *buffer.Buffer) error + type ArrayUByte []uint8 + func (a *ArrayUByte) Unmarshal(r *buffer.Buffer) error + func (a ArrayUByte) Marshal(wr *buffer.Buffer) error + type DeliveryState interface + type DescribedType struct + Descriptor interface{} + Value interface{} + func (t *DescribedType) Unmarshal(r *buffer.Buffer) error + func (t DescribedType) Marshal(wr *buffer.Buffer) error + func (t DescribedType) String() string + type Durability uint32 + const DurabilityConfiguration + const DurabilityNone + const DurabilityUnsettledState + func (d *Durability) String() string + func (d *Durability) Unmarshal(r *buffer.Buffer) error + func (d Durability) Marshal(wr *buffer.Buffer) error + type Error struct + Condition ErrorCondition + Description string + Info map[string]interface{} + func (e *Error) Error() string + func (e *Error) Marshal(wr *buffer.Buffer) error + func (e *Error) String() string + func (e *Error) Unmarshal(r *buffer.Buffer) error + type ErrorCondition string + func (ec *ErrorCondition) Unmarshal(r *buffer.Buffer) error + func (ec ErrorCondition) Marshal(wr *buffer.Buffer) error + type ExpiryPolicy Symbol + const ExpiryConnectionClose + const ExpiryLinkDetach + const ExpiryNever + const ExpirySessionEnd + func (e *ExpiryPolicy) String() string + func (e *ExpiryPolicy) Unmarshal(r *buffer.Buffer) error + func (e ExpiryPolicy) Marshal(wr *buffer.Buffer) error + type Filter map[Symbol]*DescribedType + func (f *Filter) Unmarshal(r *buffer.Buffer) error + func (f Filter) Marshal(wr *buffer.Buffer) error + type LifetimePolicy uint8 + func (p *LifetimePolicy) Unmarshal(r *buffer.Buffer) error + func (p LifetimePolicy) Marshal(wr *buffer.Buffer) error + type MarshalField struct + Omit bool + Value interface{} + type Milliseconds time.Duration + func (m *Milliseconds) Unmarshal(r *buffer.Buffer) error + func (m Milliseconds) Marshal(wr *buffer.Buffer) error + type MultiSymbol []Symbol + func (ms *MultiSymbol) Unmarshal(r *buffer.Buffer) error + func (ms MultiSymbol) Marshal(wr *buffer.Buffer) error + type NullHandler func() error + type ReceiverSettleMode uint8 + const ModeFirst + const ModeSecond + func (m *ReceiverSettleMode) String() string + func (m *ReceiverSettleMode) Unmarshal(r *buffer.Buffer) error + func (m ReceiverSettleMode) Marshal(wr *buffer.Buffer) error + type Role bool + const RoleReceiver + const RoleSender + func (rl *Role) Unmarshal(r *buffer.Buffer) error + func (rl Role) Marshal(wr *buffer.Buffer) error + func (rl Role) String() string + type SASLCode uint8 + const CodeSASLAuth + const CodeSASLOK + const CodeSASLSysPerm + func (s *SASLCode) Unmarshal(r *buffer.Buffer) error + func (s SASLCode) Marshal(wr *buffer.Buffer) error + type SenderSettleMode uint8 + const ModeMixed + const ModeSettled + const ModeUnsettled + func (m *SenderSettleMode) String() string + func (m *SenderSettleMode) Unmarshal(r *buffer.Buffer) error + func (m SenderSettleMode) Marshal(wr *buffer.Buffer) error + type StateAccepted struct + func (sa *StateAccepted) Marshal(wr *buffer.Buffer) error + func (sa *StateAccepted) String() string + func (sa *StateAccepted) Unmarshal(r *buffer.Buffer) error + type StateModified struct + DeliveryFailed bool + MessageAnnotations Annotations + UndeliverableHere bool + func (sm *StateModified) Marshal(wr *buffer.Buffer) error + func (sm *StateModified) String() string + func (sm *StateModified) Unmarshal(r *buffer.Buffer) error + type StateReceived struct + SectionNumber uint32 + SectionOffset uint64 + func (sr *StateReceived) Marshal(wr *buffer.Buffer) error + func (sr *StateReceived) Unmarshal(r *buffer.Buffer) error + type StateRejected struct + Error *Error + func (sr *StateRejected) Marshal(wr *buffer.Buffer) error + func (sr *StateRejected) String() string + func (sr *StateRejected) Unmarshal(r *buffer.Buffer) error + type StateReleased struct + func (sr *StateReleased) Marshal(wr *buffer.Buffer) error + func (sr *StateReleased) String() string + func (sr *StateReleased) Unmarshal(r *buffer.Buffer) error + type Symbol string + func (s Symbol) Marshal(wr *buffer.Buffer) error + type UUID [16]byte + func (u *UUID) Unmarshal(r *buffer.Buffer) error + func (u UUID) Marshal(wr *buffer.Buffer) error + func (u UUID) String() string + type UnmarshalField struct + Field interface{} + HandleNull NullHandler + type Unsettled map[string]DeliveryState + func (u *Unsettled) Unmarshal(r *buffer.Buffer) error + func (u Unsettled) Marshal(wr *buffer.Buffer) error