mq

package module

Go to main page

Versions in this module

v0

v0.27.0

Jan 15, 2023

v0.26.0

Dec 13, 2022

Changes in this version

+ type HasWellFormed interface

+ WellFormed func() *Malformed

type Subscribe

+ func (p *Subscribe) AddFilters(v ...TopicFilter)

+ func (p *Subscribe) WellFormed() *Malformed

type TopicFilter

+ func (c *TopicFilter) Filter() string

+ func (c *TopicFilter) Options() Opt

+ func (c *TopicFilter) SetFilter(v string)

+ func (c *TopicFilter) SetOptions(v Opt)

+ func (c *TopicFilter) WellFormed() *Malformed

v0.25.0

Nov 26, 2022

Changes in this version

+ type HasReason interface

+ ReasonCode func() ReasonCode

type Malformed

+ func (e *Malformed) SetReasonString(v string)

type PubAck

+ func (p *PubAck) ReasonString() string

+ func (p *PubAck) SetReasonString(v string)

type PubComp

+ func (p *PubComp) ReasonString() string

+ func (p *PubComp) SetReasonString(v string)

type PubRec

+ func (p *PubRec) ReasonString() string

+ func (p *PubRec) SetReasonString(v string)

type PubRel

+ func (p *PubRel) ReasonString() string

+ func (p *PubRel) SetReasonString(v string)

v0.24.0

Nov 25, 2022

Changes in this version

+ func Dump(w io.Writer, p Packet)

type Auth

+ func (p *Auth) AuthData() []byte

+ func (p *Auth) AuthMethod() string

+ func (p *Auth) ReasonString() string

+ func (p *Auth) SetAuthData(v []byte)

+ func (p *Auth) SetAuthMethod(v string)

+ func (p *Auth) SetReasonString(v string)

type Connect

+ func (p *Connect) CleanStart() bool

type Malformed

+ func (e *Malformed) SetPacket(p Packet)

type Subscribe

+ func (p *Subscribe) Filters() []TopicFilter

type Undefined

+ func (p *Undefined) Data() []byte

v0.23.0

Nov 19, 2022

Changes in this version

type Malformed

+ func (e *Malformed) SetReason(v string)

+ type PubComp struct

+ func (p *PubComp) PacketID() uint16

+ func (p *PubComp) Reason() string

+ func (p *PubComp) ReasonCode() ReasonCode

+ func (p *PubComp) SetPacketID(v uint16)

+ func (p *PubComp) SetReason(v string)

+ func (p *PubComp) SetReasonCode(v ReasonCode)

+ func (p *PubComp) String() string

+ func (p *PubComp) UnmarshalBinary(data []byte) error

+ func (p *PubComp) WriteTo(w io.Writer) (int64, error)

+ type PubRec struct

+ func (p *PubRec) PacketID() uint16

+ func (p *PubRec) Reason() string

+ func (p *PubRec) ReasonCode() ReasonCode

+ func (p *PubRec) SetPacketID(v uint16)

+ func (p *PubRec) SetReason(v string)

+ func (p *PubRec) SetReasonCode(v ReasonCode)

+ func (p *PubRec) String() string

+ func (p *PubRec) UnmarshalBinary(data []byte) error

+ func (p *PubRec) WriteTo(w io.Writer) (int64, error)

type PubRel

+ func (p *PubRel) PacketID() uint16

+ func (p *PubRel) Reason() string

+ func (p *PubRel) ReasonCode() ReasonCode

+ func (p *PubRel) SetPacketID(v uint16)

+ func (p *PubRel) SetReason(v string)

+ func (p *PubRel) SetReasonCode(v ReasonCode)

+ func (p *PubRel) String() string

+ func (p *PubRel) UnmarshalBinary(data []byte) error

+ func (p *PubRel) WriteTo(w io.Writer) (int64, error)

type ReasonCode

+ const KeepAliveTimeout

+ const ServerShuttingDown

+ const SessionTakenOver

+ const TopicFilterInvalid

v0.22.0

Nov 6, 2022

v0.21.0

Nov 5, 2022

Changes in this version

type Connect

+ func (c *Connect) SetWill(p *Publish, delayInterval uint32)

+ func (c *Connect) Will() *Publish

+ type PubRel struct

type Publish

+ func (p *Publish) WellFormed() error

+ type UserProp [2]string

+ func (v *UserProp) UnmarshalBinary(data []byte) error

+ func (v UserProp) String() string

+ type UserProperties []UserProp

+ func (p *UserProperties) AddUserProp(kvPair ...string)

v0.20.0

Nov 1, 2022

v0.19.0

Oct 21, 2022

Changes in this version

type Publish

+ func Pub(qos uint8, topic, payload string) *Publish

v0.18.0

Oct 19, 2022

Changes in this version

+ func NoopHandler(_ context.Context, _ Packet) error

v0.17.0

Oct 17, 2022

Changes in this version

+ type HasPacketID interface

+ PacketID func() uint16

+ type PubHandler func(context.Context, *Publish) error

v0.16.0

Oct 14, 2022

Changes in this version

type Client

+ Send func(context.Context, Packet) error

type Connect

+ func (c *Connect) ClientIDShort() string

+ type FilterOption byte

+ type Handler func(context.Context, Packet) error

+ type Middleware func(next Handler) Handler

+ type Opt = FilterOption

+ const OptNL

+ const OptQoS1

+ const OptQoS2

+ const OptQoS3

+ const OptRAP

+ const OptRetain1

+ const OptRetain2

+ const OptRetain3

type PubAck

+ func (p *PubAck) AckType() byte

v0.15.0

Oct 1, 2022

Changes in this version

+ const AUTH

+ const CONNACK

+ const CONNECT

+ const CleanStart

+ const DISCONNECT

+ const DUP

+ const PINGREQ

+ const PINGRESP

+ const PUBACK

+ const PUBCOMP

+ const PUBLISH

+ const PUBREC

+ const PUBREL

+ const PasswordFlag

+ const QoS1

+ const QoS2

+ const QoS3

+ const RETAIN

+ const Reserved

+ const SUBACK

+ const SUBSCRIBE

+ const SessionPresent

+ const UNDEFINED

+ const UNSUBACK

+ const UNSUBSCRIBE

+ const UsernameFlag

+ const WillFlag

+ const WillQoS1

+ const WillQoS2

+ const WillRetain

+ var ErrMissingData = fmt.Errorf("missing data")

+ type Auth struct

+ func NewAuth() Auth

+ func (p *Auth) AddUserProp(key, val string)

+ func (p *Auth) AddUserProperty(prop property)

+ func (p *Auth) ReasonCode() ReasonCode

+ func (p *Auth) SetReasonCode(v ReasonCode)

+ func (p *Auth) String() string

+ func (p *Auth) UnmarshalBinary(data []byte) error

+ func (p *Auth) WriteTo(w io.Writer) (int64, error)

+ type Bits byte

+ func (v *Bits) ReadFrom(r io.Reader) (int64, error)

+ func (v *Bits) UnmarshalBinary(data []byte) error

+ func (v Bits) Has(b byte) bool

+ type Client interface

+ Connect func(context.Context, *Connect) error

+ Disconnect func(context.Context, *Disconnect) error

+ Pub func(context.Context, *Publish) error

+ Sub func(context.Context, *Subscribe) error

+ type ConnAck struct

+ func NewConnAck() ConnAck

+ func (c *ConnAck) AddUserProp(key, val string)

+ func (c *ConnAck) AddUserProperty(p property)

+ func (c *ConnAck) AssignedClientID() string

+ func (c *ConnAck) AuthData() []byte

+ func (c *ConnAck) AuthMethod() string

+ func (c *ConnAck) Flags() Bits

+ func (c *ConnAck) HasFlag(v byte) bool

+ func (c *ConnAck) MaxPacketSize() uint32

+ func (c *ConnAck) MaxQoS() uint8

+ func (c *ConnAck) ReasonCode() ReasonCode

+ func (c *ConnAck) ReasonString() string

+ func (c *ConnAck) ReceiveMax() uint16

+ func (c *ConnAck) ResponseInformation() string

+ func (c *ConnAck) RetainAvailable() bool

+ func (c *ConnAck) ServerKeepAlive() uint16

+ func (c *ConnAck) ServerReference() string

+ func (c *ConnAck) SessionExpiryInterval() uint32

+ func (c *ConnAck) SessionPresent() bool

+ func (c *ConnAck) SetAssignedClientID(v string)

+ func (c *ConnAck) SetAuthData(v []byte)

+ func (c *ConnAck) SetAuthMethod(v string)

+ func (c *ConnAck) SetMaxPacketSize(v uint32)

+ func (c *ConnAck) SetMaxQoS(v uint8)

+ func (c *ConnAck) SetReasonCode(v ReasonCode)

+ func (c *ConnAck) SetReasonString(v string)

+ func (c *ConnAck) SetReceiveMax(v uint16)

+ func (c *ConnAck) SetResponseInformation(v string)

+ func (c *ConnAck) SetRetainAvailable(v bool)

+ func (c *ConnAck) SetServerKeepAlive(v uint16)

+ func (c *ConnAck) SetServerReference(v string)

+ func (c *ConnAck) SetSessionExpiryInterval(v uint32)

+ func (c *ConnAck) SetSessionPresent(v bool)

+ func (c *ConnAck) SetSharedSubAvailable(v bool)

+ func (c *ConnAck) SetSubIdentifiersAvailable(v bool)

+ func (c *ConnAck) SetTopicAliasMax(v uint16)

+ func (c *ConnAck) SetWildcardSubAvailable(v bool)

+ func (c *ConnAck) SharedSubAvailable() bool

+ func (c *ConnAck) String() string

+ func (c *ConnAck) SubIdentifiersAvailable() bool

+ func (c *ConnAck) TopicAliasMax() uint16

+ func (c *ConnAck) UnmarshalBinary(data []byte) error

+ func (c *ConnAck) WildcardSubAvailable() bool

+ func (c *ConnAck) WriteTo(w io.Writer) (int64, error)

+ type Connect struct

+ func NewConnect() Connect

+ func (c *Connect) AddUserProp(key, val string)

+ func (c *Connect) AddUserProperty(p property)

+ func (c *Connect) AddWillProp(key, val string)

+ func (c *Connect) AddWillProperty(p property)

+ func (c *Connect) AuthData() []byte

+ func (c *Connect) AuthMethod() string

+ func (c *Connect) ClientID() string

+ func (c *Connect) CorrelationData() []byte

+ func (c *Connect) Flags() Bits

+ func (c *Connect) HasFlag(v byte) bool

+ func (c *Connect) KeepAlive() uint16

+ func (c *Connect) MaxPacketSize() uint32

+ func (c *Connect) Password() []byte

+ func (c *Connect) ProtocolName() string

+ func (c *Connect) ProtocolVersion() uint8

+ func (c *Connect) ReceiveMax() uint16

+ func (c *Connect) RequestProblemInfo() bool

+ func (c *Connect) RequestResponseInfo() bool

+ func (c *Connect) ResponseTopic() string

+ func (c *Connect) SessionExpiryInterval() uint32

+ func (c *Connect) SetAuthData(v []byte)

+ func (c *Connect) SetAuthMethod(v string)

+ func (c *Connect) SetCleanStart(v bool)

+ func (c *Connect) SetClientID(v string)

+ func (c *Connect) SetCorrelationData(v []byte)

+ func (c *Connect) SetKeepAlive(v uint16)

+ func (c *Connect) SetMaxPacketSize(v uint32)

+ func (c *Connect) SetPassword(v []byte)

+ func (c *Connect) SetProtocolName(v string)

+ func (c *Connect) SetProtocolVersion(v uint8)

+ func (c *Connect) SetReceiveMax(v uint16)

+ func (c *Connect) SetRequestProblemInfo(v bool)

+ func (c *Connect) SetRequestResponseInfo(v bool)

+ func (c *Connect) SetResponseTopic(v string)

+ func (c *Connect) SetSessionExpiryInterval(v uint32)

+ func (c *Connect) SetTopicAliasMax(v uint16)

+ func (c *Connect) SetUsername(v string)

+ func (c *Connect) SetWillContentType(v string)

+ func (c *Connect) SetWillDelayInterval(v uint32)

+ func (c *Connect) SetWillMessageExpiryInterval(v uint32)

+ func (c *Connect) SetWillPayload(v []byte)

+ func (c *Connect) SetWillPayloadFormat(v bool)

+ func (c *Connect) SetWillQoS(v uint8)

+ func (c *Connect) SetWillRetain(v bool)

+ func (c *Connect) SetWillTopic(v string)

+ func (c *Connect) String() string

+ func (c *Connect) TopicAliasMax() uint16

+ func (c *Connect) UnmarshalBinary(p []byte) error

+ func (c *Connect) Username() string

+ func (c *Connect) WillContentType() string

+ func (c *Connect) WillDelayInterval() uint32

+ func (c *Connect) WillMessageExpiryInterval() uint32

+ func (c *Connect) WillPayload() []byte

+ func (c *Connect) WillPayloadFormat() bool

+ func (c *Connect) WillQoS() uint8

+ func (c *Connect) WillRetain() bool

+ func (c *Connect) WillTopic() string

+ func (c *Connect) WriteTo(w io.Writer) (int64, error)

+ type ControlPacket interface

+ func ReadPacket(r io.Reader) (ControlPacket, error)

+ type Disconnect struct

+ func NewDisconnect() Disconnect

+ func (p *Disconnect) AddUserProp(key, val string)

+ func (p *Disconnect) AddUserProperty(prop property)

+ func (p *Disconnect) ReasonCode() ReasonCode

+ func (p *Disconnect) SetReasonCode(v ReasonCode)

+ func (p *Disconnect) String() string

+ func (p *Disconnect) UnmarshalBinary(data []byte) error

+ func (p *Disconnect) WriteTo(w io.Writer) (int64, error)

+ type FixedHeader struct

+ func (f *FixedHeader) ReadFrom(r io.Reader) (int64, error)

+ func (f *FixedHeader) ReadRemaining(r io.Reader) (ControlPacket, error)

+ type Fop byte

+ const FopNL

+ const FopQoS1

+ const FopQoS2

+ const FopQoS3

+ const FopRAP

+ const FopRetain1

+ const FopRetain2

+ const FopRetain3

+ type Ident uint8

+ const AssignedClientID

+ const AuthData

+ const AuthMethod

+ const ContentType

+ const CorrelationData

+ const MaxPacketSize

+ const MaxQoS

+ const MessageExpiryInterval

+ const PayloadFormatIndicator

+ const ReasonString

+ const ReceiveMax

+ const RequestProblemInfo

+ const RequestResponseInfo

+ const ResponseInformation

+ const ResponseTopic

+ const RetainAvailable

+ const ServerKeepAlive

+ const ServerReference

+ const SessionExpiryInterval

+ const SharedSubAvailable

+ const SubIDsAvailable

+ const SubscriptionID

+ const TopicAlias

+ const TopicAliasMax

+ const UserProperty

+ const WildcardSubAvailable

+ const WillDelayInterval

+ func (v *Ident) UnmarshalBinary(data []byte) error

+ type Malformed struct

+ func (e *Malformed) Error() string

+ type Packet = ControlPacket

+ type PingReq struct

+ func NewPingReq() PingReq

+ func (p *PingReq) String() string

+ func (p *PingReq) UnmarshalBinary(data []byte) error

+ func (p *PingReq) WriteTo(w io.Writer) (int64, error)

+ type PingResp struct

+ func NewPingResp() PingResp

+ func (p *PingResp) String() string

+ func (p *PingResp) UnmarshalBinary(data []byte) error

+ func (p *PingResp) WriteTo(w io.Writer) (int64, error)

+ type PubAck struct

+ func NewPubAck() PubAck

+ func NewPubComp() PubAck

+ func NewPubRec() PubAck

+ func NewPubRel() PubAck

+ func (p *PubAck) AddUserProp(key, val string)

+ func (p *PubAck) AddUserProperty(prop property)

+ func (p *PubAck) PacketID() uint16

+ func (p *PubAck) Reason() string

+ func (p *PubAck) ReasonCode() ReasonCode

+ func (p *PubAck) SetPacketID(v uint16)

+ func (p *PubAck) SetReason(v string)

+ func (p *PubAck) SetReasonCode(v ReasonCode)

+ func (p *PubAck) String() string

+ func (p *PubAck) UnmarshalBinary(data []byte) error

+ func (p *PubAck) WriteTo(w io.Writer) (int64, error)

+ type Publish struct

+ func NewPublish() Publish

+ func (p *Publish) AddSubscriptionID(v uint32)

+ func (p *Publish) AddUserProp(key, val string)

+ func (p *Publish) AddUserProperty(prop property)

+ func (p *Publish) ContentType() string

+ func (p *Publish) CorrelationData() []byte

+ func (p *Publish) Duplicate() bool

+ func (p *Publish) MessageExpiryInterval() uint32

+ func (p *Publish) PacketID() uint16

+ func (p *Publish) Payload() []byte

+ func (p *Publish) PayloadFormat() bool

+ func (p *Publish) QoS() uint8

+ func (p *Publish) ResponseTopic() string

+ func (p *Publish) Retain() bool

+ func (p *Publish) SetContentType(v string)

+ func (p *Publish) SetCorrelationData(v []byte)

+ func (p *Publish) SetDuplicate(v bool)

+ func (p *Publish) SetMessageExpiryInterval(v uint32)

+ func (p *Publish) SetPacketID(v uint16)

+ func (p *Publish) SetPayload(v []byte)

+ func (p *Publish) SetPayloadFormat(v bool)

+ func (p *Publish) SetQoS(v uint8)

+ func (p *Publish) SetResponseTopic(v string)

+ func (p *Publish) SetRetain(v bool)

+ func (p *Publish) SetTopicAlias(v uint16)

+ func (p *Publish) SetTopicName(v string)

+ func (p *Publish) String() string

+ func (p *Publish) SubscriptionIDs() []uint32

+ func (p *Publish) TopicAlias() uint16

+ func (p *Publish) TopicName() string

+ func (p *Publish) UnmarshalBinary(data []byte) error

+ func (p *Publish) WriteTo(w io.Writer) (int64, error)

+ type ReasonCode byte

+ const AdministrativeAction

+ const BadAuthenticationMethod

+ const BadUserNameOrPassword

+ const Banned

+ const ClientIdentifierNotValid

+ const ConnectionRateExceeded

+ const ContinueAuth

+ const DisconnectWithWill

+ const GrantedQoS0

+ const GrantedQoS1

+ const GrantedQoS2

+ const ImplementationSpecificError

+ const MalformedPacket

+ const MaximumConnectTime

+ const MessageRateToHigh

+ const NoMatchingSubscribers

+ const NoSubscriptionExisted

+ const NormalDisconnect

+ const NotAuthorized

+ const PacketIdentifierInUse

+ const PacketIdentifierNotFound

+ const PacketTooLarge

+ const PayloadFormatInvalid

+ const ProtocolError

+ const QoSNotSupported

+ const QuotaExceeded

+ const ReAuthenticate

+ const ReceiveMaximumExceeded

+ const RetainNotSupported

+ const ServerBusy

+ const ServerMoved

+ const ServerUnavailable

+ const SharedSubscriptionsNotSupported

+ const SubscriptionIdentifiersNotSupported

+ const Success

+ const TopicAliasInvalid

+ const TopicNameInvalid

+ const UnspecifiedError

+ const UnsupportedProtocolVersion

+ const UseAnotherServer

+ const WildcardSubscriptionsNotSupported

+ func (i ReasonCode) String() string

+ type Receiver func(Packet) error

+ type SubAck struct

+ func NewSubAck() SubAck

+ func (p *SubAck) AddReasonCode(v ReasonCode)

+ func (p *SubAck) AddUserProp(key, val string)

+ func (p *SubAck) AddUserProperty(prop property)

+ func (p *SubAck) PacketID() uint16

+ func (p *SubAck) ReasonCodes() []uint8

+ func (p *SubAck) ReasonString() string

+ func (p *SubAck) SetPacketID(v uint16)

+ func (p *SubAck) SetReasonString(v string)

+ func (p *SubAck) String() string

+ func (p *SubAck) UnmarshalBinary(data []byte) error

+ func (p *SubAck) WriteTo(w io.Writer) (int64, error)

+ type Subscribe struct

+ func NewSubscribe() Subscribe

+ func (p *Subscribe) AddFilter(filter string, options Fop)

+ func (p *Subscribe) AddUserProp(key, val string)

+ func (p *Subscribe) AddUserProperty(prop property)

+ func (p *Subscribe) PacketID() uint16

+ func (p *Subscribe) SetPacketID(v uint16)

+ func (p *Subscribe) SetSubscriptionID(v int)

+ func (p *Subscribe) String() string

+ func (p *Subscribe) SubscriptionID() int

+ func (p *Subscribe) UnmarshalBinary(data []byte) error

+ func (p *Subscribe) WriteTo(w io.Writer) (int64, error)

+ type TopicFilter struct

+ func NewTopicFilter(filter string, options Fop) TopicFilter

+ func (c TopicFilter) String() string

+ type Undefined struct

+ func NewUndefined() Undefined

+ func (p *Undefined) String() string

+ func (p *Undefined) UnmarshalBinary(data []byte) error

+ func (p *Undefined) WriteTo(w io.Writer) (int64, error)

+ type UnsubAck struct

+ func NewUnsubAck() UnsubAck

+ func (p *UnsubAck) AddReasonCode(v ReasonCode)

+ func (p *UnsubAck) AddUserProp(key, val string)

+ func (p *UnsubAck) AddUserProperty(prop property)

+ func (p *UnsubAck) PacketID() uint16

+ func (p *UnsubAck) ReasonCodes() []uint8

+ func (p *UnsubAck) ReasonString() string

+ func (p *UnsubAck) SetPacketID(v uint16)

+ func (p *UnsubAck) SetReasonString(v string)

+ func (p *UnsubAck) String() string

+ func (p *UnsubAck) UnmarshalBinary(data []byte) error

+ func (p *UnsubAck) WriteTo(w io.Writer) (int64, error)

+ type Unsubscribe struct

+ func NewUnsubscribe() Unsubscribe

+ func (p *Unsubscribe) AddFilter(filter string)

+ func (p *Unsubscribe) AddUserProp(key, val string)

+ func (p *Unsubscribe) AddUserProperty(prop property)

+ func (p *Unsubscribe) PacketID() uint16

+ func (p *Unsubscribe) SetPacketID(v uint16)

+ func (p *Unsubscribe) String() string

+ func (p *Unsubscribe) UnmarshalBinary(data []byte) error

+ func (p *Unsubscribe) WriteTo(w io.Writer) (int64, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL