packets

package

Go to main page

Versions in this module

v2

v2.2.16

Jul 20, 2023

Changes in this version

+ const TPubackUnexpectedError

+ const TPublishQos1Mqtt5

+ var CodeSuccessIgnore = Code

type Packet

+ Ignore bool

type Subscription

+ FwdRetainedFlag bool

v2.2.15

Jul 8, 2023

v2.2.14

Jun 19, 2023

v2.2.13

Jun 14, 2023

v2.2.12

Jun 4, 2023

v2.2.11

May 18, 2023

v2.2.10

May 8, 2023

v2.2.9

May 6, 2023

Changes in this version

+ const TConnackServerKeepalive

v2.2.8

May 4, 2023

Changes in this version

+ const WillProperties

v2.2.7

Apr 21, 2023

v2.2.6

Mar 11, 2023

v2.2.5

Feb 28, 2023

v2.2.4

Feb 25, 2023

Changes in this version

+ const TConnectZeroByteUsername

v2.2.3

Feb 22, 2023

v2.2.2

Feb 20, 2023

v2.2.1

Feb 10, 2023

v2.2.0

Feb 9, 2023

Changes in this version

+ var ErrPendingClientWritesExceeded = Code

v2.1.8

Feb 5, 2023

v2.1.7

Feb 4, 2023

v2.1.6

Jan 16, 2023

v2.1.5

Jan 13, 2023

v2.1.4

Jan 10, 2023

Changes in this version

+ const TConnackMqtt5BadUsernamePasswordNoSession

+ var Err3ClientIdentifierNotValid = Code

+ var Err3NotAuthorized = Code

+ var Err3ServerUnavailable = Code

+ var Err3UnsupportedProtocolVersion = Code

+ var ErrMalformedUsernameOrPassword = Code

+ var V5CodesToV3 = map[Code]Code

v2.1.3

Jan 9, 2023

v2.1.2

Jan 7, 2023

v2.1.1

Jan 7, 2023

v2.1.0

Dec 21, 2022

v2.0.7

Dec 16, 2022

v2.0.6

Dec 16, 2022

v2.0.5

Dec 15, 2022

v2.0.4

Dec 12, 2022

v2.0.3

Dec 11, 2022

v2.0.2

Dec 11, 2022

v2.0.1

Dec 11, 2022

Changes in this version

+ const Auth

+ const Connack

+ const Connect

+ const Disconnect

+ const Pingreq

+ const Pingresp

+ const PropAssignedClientID

+ const PropAuthenticationData

+ const PropAuthenticationMethod

+ const PropContentType

+ const PropCorrelationData

+ const PropMaximumPacketSize

+ const PropMaximumQos

+ const PropMessageExpiryInterval

+ const PropPayloadFormat

+ const PropReasonString

+ const PropReceiveMaximum

+ const PropRequestProblemInfo

+ const PropRequestResponseInfo

+ const PropResponseInfo

+ const PropResponseTopic

+ const PropRetainAvailable

+ const PropServerKeepAlive

+ const PropServerReference

+ const PropSessionExpiryInterval

+ const PropSharedSubAvailable

+ const PropSubIDAvailable

+ const PropSubscriptionIdentifier

+ const PropTopicAlias

+ const PropTopicAliasMaximum

+ const PropUser

+ const PropWildcardSubAvailable

+ const PropWillDelayInterval

+ const Puback

+ const Pubcomp

+ const Publish

+ const Pubrec

+ const Pubrel

+ const Reserved

+ const Suback

+ const Subscribe

+ const TAuth

+ const TAuthInvalidReason

+ const TAuthInvalidReason2

+ const TAuthMalProperties

+ const TAuthMalReasonCode

+ const TConnackAcceptedAdjustedExpiryInterval

+ const TConnackAcceptedMqtt5

+ const TConnackAcceptedNoSession

+ const TConnackAcceptedSessionExists

+ const TConnackBadClientID

+ const TConnackBadProtocolVersion

+ const TConnackBadUsernamePassword

+ const TConnackBadUsernamePasswordNoSession

+ const TConnackDropProperties

+ const TConnackDropPropertiesPartial

+ const TConnackInvalidMinMqtt5

+ const TConnackMalProperties

+ const TConnackMalReturnCode

+ const TConnackMalSessionPresent

+ const TConnackMinCleanMqtt5

+ const TConnackMinMqtt5

+ const TConnackNotAuthorised

+ const TConnackProtocolViolationNoSession

+ const TConnackServerUnavailable

+ const TConnectClean

+ const TConnectCleanLWT

+ const TConnectInvalidClientIDTooLong

+ const TConnectInvalidFlagNoPassword

+ const TConnectInvalidFlagNoUsername

+ const TConnectInvalidPasswordNoFlag

+ const TConnectInvalidPasswordNoUsername

+ const TConnectInvalidPasswordTooLong

+ const TConnectInvalidProtocolName

+ const TConnectInvalidProtocolVersion

+ const TConnectInvalidProtocolVersion2

+ const TConnectInvalidReservedBit

+ const TConnectInvalidUsernameNoFlag

+ const TConnectInvalidUsernameTooLong

+ const TConnectInvalidWillFlagNoPayload

+ const TConnectInvalidWillFlagQosOutOfRange

+ const TConnectInvalidWillSurplusRetain

+ const TConnectMalClientID

+ const TConnectMalFixedHeader

+ const TConnectMalFlags

+ const TConnectMalKeepalive

+ const TConnectMalPassword

+ const TConnectMalProperties

+ const TConnectMalProtocolName

+ const TConnectMalProtocolVersion

+ const TConnectMalReservedBit

+ const TConnectMalUsername

+ const TConnectMalWillFlag

+ const TConnectMalWillProperties

+ const TConnectMalWillTopic

+ const TConnectMqtt31

+ const TConnectMqtt311

+ const TConnectMqtt5

+ const TConnectMqtt5LWT

+ const TConnectNotCleanNoClientID

+ const TConnectSpecInvalidUTF80000

+ const TConnectSpecInvalidUTF8D800

+ const TConnectSpecInvalidUTF8DFFF

+ const TConnectSpecInvalidUTF8NoSkip

+ const TConnectUserPass

+ const TConnectUserPassLWT

+ const TDisconnect

+ const TDisconnectDropProperties

+ const TDisconnectMalProperties

+ const TDisconnectMalReasonCode

+ const TDisconnectMqtt5

+ const TDisconnectNormalMqtt5

+ const TDisconnectReceiveMaximum

+ const TDisconnectSecondConnect

+ const TDisconnectShuttingDown

+ const TDisconnectTakeover

+ const TDisconnectZeroNonZeroExpiry

+ const TPingreq

+ const TPingresp

+ const TPuback

+ const TPubackMalPacketID

+ const TPubackMalProperties

+ const TPubackMqtt5

+ const TPubcomp

+ const TPubcompInvalidReason

+ const TPubcompMalPacketID

+ const TPubcompMalProperties

+ const TPubcompMqtt5

+ const TPubcompMqtt5AckNoPacket

+ const TPublishBasic

+ const TPublishBasicMqtt5

+ const TPublishBasicTopicAliasOnly

+ const TPublishCopyBasic

+ const TPublishDropOversize

+ const TPublishDup

+ const TPublishInvalidExcessTopicAlias

+ const TPublishInvalidNoTopic

+ const TPublishInvalidQos0NoPacketID

+ const TPublishInvalidQosMustPacketID

+ const TPublishInvalidSurplusSubID

+ const TPublishInvalidSurplusWildcard

+ const TPublishInvalidSurplusWildcard2

+ const TPublishInvalidTopicAlias

+ const TPublishMalPacketID

+ const TPublishMalProperties

+ const TPublishMalTopicName

+ const TPublishMqtt5

+ const TPublishNoPayload

+ const TPublishQos1

+ const TPublishQos1Dup

+ const TPublishQos1NoPayload

+ const TPublishQos2

+ const TPublishQos2Mqtt5

+ const TPublishQos2Upgraded

+ const TPublishRetain

+ const TPublishRetainMqtt5

+ const TPublishSpecDenySysTopic

+ const TPublishSpecQos0NoPacketID

+ const TPublishSpecQosMustPacketID

+ const TPublishSubscriberIdentifier

+ const TPubrec

+ const TPubrecInvalidReason

+ const TPubrecMalPacketID

+ const TPubrecMalProperties

+ const TPubrecMalReasonCode

+ const TPubrecMqtt5

+ const TPubrecMqtt5IDInUse

+ const TPubrel

+ const TPubrelInvalidReason

+ const TPubrelMalPacketID

+ const TPubrelMalProperties

+ const TPubrelMqtt5

+ const TPubrelMqtt5AckNoPacket

+ const TSuback

+ const TSubackDeny

+ const TSubackInvalidFilter

+ const TSubackInvalidSharedNoLocal

+ const TSubackMalPacketID

+ const TSubackMalProperties

+ const TSubackMany

+ const TSubackMqtt5

+ const TSubackPacketIDInUse

+ const TSubackUnspecifiedError

+ const TSubackUnspecifiedErrorMqtt5

+ const TSubscribe

+ const TSubscribeInvalidFilter

+ const TSubscribeInvalidIdentifierOversize

+ const TSubscribeInvalidNoFilters

+ const TSubscribeInvalidQosMustPacketID

+ const TSubscribeInvalidSharedNoLocal

+ const TSubscribeMalPacketID

+ const TSubscribeMalProperties

+ const TSubscribeMalQos

+ const TSubscribeMalQosRange

+ const TSubscribeMalTopic

+ const TSubscribeMany

+ const TSubscribeMqtt5

+ const TSubscribeRetainAsPublished

+ const TSubscribeRetainHandling1

+ const TSubscribeRetainHandling2

+ const TSubscribeSpecQosMustPacketID

+ const TUnsuback

+ const TUnsubackMalPacketID

+ const TUnsubackMalProperties

+ const TUnsubackMany

+ const TUnsubackMqtt5

+ const TUnsubackPacketIDInUse

+ const TUnsubscribe

+ const TUnsubscribeDropProperties

+ const TUnsubscribeInvalidNoFilters

+ const TUnsubscribeInvalidQosMustPacketID

+ const TUnsubscribeMalPacketID

+ const TUnsubscribeMalProperties

+ const TUnsubscribeMalTopicName

+ const TUnsubscribeMany

+ const TUnsubscribeMqtt5

+ const TUnsubscribeSpecQosMustPacketID

+ const Unsuback

+ const Unsubscribe

+ var CodeContinueAuthentication = Code

+ var CodeDisconnect = Code

+ var CodeDisconnectWillMessage = Code

+ var CodeGrantedQos0 = Code

+ var CodeGrantedQos1 = Code

+ var CodeGrantedQos2 = Code

+ var CodeNoMatchingSubscribers = Code

+ var CodeNoSubscriptionExisted = Code

+ var CodeReAuthenticate = Code

+ var CodeSuccess = Code

+ var ErrAdministrativeAction = Code

+ var ErrBadAuthenticationMethod = Code

+ var ErrBadUsernameOrPassword = Code

+ var ErrBanned = Code

+ var ErrClientIdentifierNotValid = Code

+ var ErrClientIdentifierTooLong = Code

+ var ErrConnectionRateExceeded = Code

+ var ErrImplementationSpecificError = Code

+ var ErrKeepAliveTimeout = Code

+ var ErrMalformedBadProperty = Code

+ var ErrMalformedFlags = Code

+ var ErrMalformedInvalidUTF8 = Code

+ var ErrMalformedKeepalive = Code

+ var ErrMalformedOffsetBoolOutOfRange = Code

+ var ErrMalformedOffsetByteOutOfRange = Code

+ var ErrMalformedOffsetBytesOutOfRange = Code

+ var ErrMalformedOffsetUintOutOfRange = Code

+ var ErrMalformedPacket = Code

+ var ErrMalformedPacketID = Code

+ var ErrMalformedPassword = Code

+ var ErrMalformedProperties = Code

+ var ErrMalformedProtocolName = Code

+ var ErrMalformedProtocolVersion = Code

+ var ErrMalformedQos = Code

+ var ErrMalformedReasonCode = Code

+ var ErrMalformedSessionPresent = Code

+ var ErrMalformedTopic = Code

+ var ErrMalformedUsername = Code

+ var ErrMalformedVariableByteInteger = Code

+ var ErrMalformedWillPayload = Code

+ var ErrMalformedWillProperties = Code

+ var ErrMalformedWillTopic = Code

+ var ErrMaxConnectTime = Code

+ var ErrMessageRateTooHigh = Code

+ var ErrNoValidPacketAvailable error = errors.New("no valid packet available")

+ var ErrNotAuthorized = Code

+ var ErrPacketIdentifierInUse = Code

+ var ErrPacketIdentifierNotFound = Code

+ var ErrPacketTooLarge = Code

+ var ErrPayloadFormatInvalid = Code

+ var ErrProtocolViolation = Code

+ var ErrProtocolViolationDupNoQos = Code

+ var ErrProtocolViolationFlagNoPassword = Code

+ var ErrProtocolViolationFlagNoUsername = Code

+ var ErrProtocolViolationInvalidReason = Code

+ var ErrProtocolViolationInvalidSharedNoLocal = Code

+ var ErrProtocolViolationInvalidTopic = Code

+ var ErrProtocolViolationNoFilters = Code

+ var ErrProtocolViolationNoPacketID = Code

+ var ErrProtocolViolationNoTopic = Code

+ var ErrProtocolViolationOversizeSubID = Code

+ var ErrProtocolViolationPasswordNoFlag = Code

+ var ErrProtocolViolationPasswordTooLong = Code

+ var ErrProtocolViolationProtocolName = Code

+ var ErrProtocolViolationProtocolVersion = Code

+ var ErrProtocolViolationQosOutOfRange = Code

+ var ErrProtocolViolationRequireFirstConnect = Code

+ var ErrProtocolViolationReservedBit = Code

+ var ErrProtocolViolationSecondConnect = Code

+ var ErrProtocolViolationSurplusPacketID = Code

+ var ErrProtocolViolationSurplusSubID = Code

+ var ErrProtocolViolationSurplusWildcard = Code

+ var ErrProtocolViolationUnsupportedProperty = Code

+ var ErrProtocolViolationUsernameNoFlag = Code

+ var ErrProtocolViolationUsernameTooLong = Code

+ var ErrProtocolViolationWillFlagNoPayload = Code

+ var ErrProtocolViolationWillFlagSurplusRetain = Code

+ var ErrProtocolViolationZeroNonZeroExpiry = Code

+ var ErrQosNotSupported = Code

+ var ErrQuotaExceeded = Code

+ var ErrReceiveMaximum = Code

+ var ErrRejectPacket = Code

+ var ErrRetainNotSupported = Code

+ var ErrServerBusy = Code

+ var ErrServerMoved = Code

+ var ErrServerShuttingDown = Code

+ var ErrServerUnavailable = Code

+ var ErrSessionTakenOver = Code

+ var ErrSharedSubscriptionsNotSupported = Code

+ var ErrSubscriptionIdentifiersNotSupported = Code

+ var ErrTopicAliasInvalid = Code

+ var ErrTopicFilterInvalid = Code

+ var ErrTopicNameInvalid = Code

+ var ErrUnspecifiedError = Code

+ var ErrUnsupportedProtocolVersion = Code

+ var ErrUseAnotherServer = Code

+ var ErrWildcardSubscriptionsNotSupported = Code

+ var PacketNames = map[byte]string

+ var QosCodes = map[byte]Code

+ var TPacketData = map[byte]TPacketCases

+ func DecodeLength(b io.ByteReader) (n, bu int, err error)

+ type Code struct

+ Code byte

+ Reason string

+ func (c Code) Error() string

+ func (c Code) String() string

+ type ConnectParams struct

+ Clean bool

+ ClientIdentifier string

+ Keepalive uint16

+ Password []byte

+ PasswordFlag bool

+ ProtocolName []byte

+ Username []byte

+ UsernameFlag bool

+ WillFlag bool

+ WillPayload []byte

+ WillProperties Properties

+ WillQos byte

+ WillRetain bool

+ WillTopic string

+ type FixedHeader struct

+ Dup bool

+ Qos byte

+ Remaining int

+ Retain bool

+ Type byte

+ func (fh *FixedHeader) Decode(hb byte) error

+ func (fh *FixedHeader) Encode(buf *bytes.Buffer)

+ type Mods struct

+ AllowResponseInfo bool

+ DisallowProblemInfo bool

+ MaxSize uint32

+ type Packet struct

+ Connect ConnectParams

+ Created int64

+ Expiry int64

+ Filters Subscriptions

+ FixedHeader FixedHeader

+ Mods Mods

+ Origin string

+ PacketID uint16

+ Payload []byte

+ Properties Properties

+ ProtocolVersion byte

+ ReasonCode byte

+ ReasonCodes []byte

+ ReservedBit byte

+ SessionPresent bool

+ TopicName string

+ func (pk *Packet) AuthDecode(buf []byte) error

+ func (pk *Packet) AuthEncode(buf *bytes.Buffer) error

+ func (pk *Packet) AuthValidate() Code

+ func (pk *Packet) ConnackDecode(buf []byte) error

+ func (pk *Packet) ConnackEncode(buf *bytes.Buffer) error

+ func (pk *Packet) ConnectDecode(buf []byte) error

+ func (pk *Packet) ConnectEncode(buf *bytes.Buffer) error

+ func (pk *Packet) ConnectValidate() Code

+ func (pk *Packet) Copy(allowTransfer bool) Packet

+ func (pk *Packet) DisconnectDecode(buf []byte) error

+ func (pk *Packet) DisconnectEncode(buf *bytes.Buffer) error

+ func (pk *Packet) FormatID() string

+ func (pk *Packet) PingreqDecode(buf []byte) error

+ func (pk *Packet) PingreqEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PingrespDecode(buf []byte) error

+ func (pk *Packet) PingrespEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PubackDecode(buf []byte) error

+ func (pk *Packet) PubackEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PubcompDecode(buf []byte) error

+ func (pk *Packet) PubcompEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PublishDecode(buf []byte) error

+ func (pk *Packet) PublishEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PublishValidate(topicAliasMaximum uint16) Code

+ func (pk *Packet) PubrecDecode(buf []byte) error

+ func (pk *Packet) PubrecEncode(buf *bytes.Buffer) error

+ func (pk *Packet) PubrelDecode(buf []byte) error

+ func (pk *Packet) PubrelEncode(buf *bytes.Buffer) error

+ func (pk *Packet) ReasonCodeValid() bool

+ func (pk *Packet) SubackDecode(buf []byte) error

+ func (pk *Packet) SubackEncode(buf *bytes.Buffer) error

+ func (pk *Packet) SubscribeDecode(buf []byte) error

+ func (pk *Packet) SubscribeEncode(buf *bytes.Buffer) error

+ func (pk *Packet) SubscribeValidate() Code

+ func (pk *Packet) UnsubackDecode(buf []byte) error

+ func (pk *Packet) UnsubackEncode(buf *bytes.Buffer) error

+ func (pk *Packet) UnsubscribeDecode(buf []byte) error

+ func (pk *Packet) UnsubscribeEncode(buf *bytes.Buffer) error

+ func (pk *Packet) UnsubscribeValidate() Code

+ type Packets struct

+ func NewPackets() *Packets

+ func (p *Packets) Add(id string, val Packet)

+ func (p *Packets) Delete(id string)

+ func (p *Packets) Get(id string) (val Packet, ok bool)

+ func (p *Packets) GetAll() map[string]Packet

+ func (p *Packets) Len() int

+ type Properties struct

+ AssignedClientID string

+ AuthenticationData []byte

+ AuthenticationMethod string

+ ContentType string

+ CorrelationData []byte

+ MaximumPacketSize uint32

+ MaximumQos byte

+ MaximumQosFlag bool

+ MessageExpiryInterval uint32

+ PayloadFormat byte

+ PayloadFormatFlag bool

+ ReasonString string

+ ReceiveMaximum uint16

+ RequestProblemInfo byte

+ RequestProblemInfoFlag bool

+ RequestResponseInfo byte

+ ResponseInfo string

+ ResponseTopic string

+ RetainAvailable byte

+ RetainAvailableFlag bool

+ ServerKeepAlive uint16

+ ServerKeepAliveFlag bool

+ ServerReference string

+ SessionExpiryInterval uint32

+ SessionExpiryIntervalFlag bool

+ SharedSubAvailable byte

+ SharedSubAvailableFlag bool

+ SubIDAvailable byte

+ SubIDAvailableFlag bool

+ SubscriptionIdentifier []int

+ TopicAlias uint16

+ TopicAliasFlag bool

+ TopicAliasMaximum uint16

+ User []UserProperty

+ WildcardSubAvailable byte

+ WildcardSubAvailableFlag bool

+ WillDelayInterval uint32

+ func (p *Properties) Copy(allowTransfer bool) Properties

+ func (p *Properties) Decode(pk byte, b *bytes.Buffer) (n int, err error)

+ func (p *Properties) Encode(pk *Packet, b *bytes.Buffer, n int)

+ type Subscription struct

+ Filter string

+ Identifier int

+ Identifiers map[string]int

+ NoLocal bool

+ Qos byte

+ RetainAsPublished bool

+ RetainHandling byte

+ ShareName []string

+ func (s Subscription) Merge(n Subscription) Subscription

+ type Subscriptions []Subscription

+ type TPacketCase struct

+ ActualBytes []byte

+ ActualPacket *Packet

+ Case byte

+ Desc string

+ Expect error

+ FailFirst error

+ Group string

+ Isolate bool

+ Packet *Packet

+ Primary bool

+ RawBytes []byte

+ type TPacketCases []TPacketCase

+ func (f TPacketCases) Get(b byte) TPacketCase

+ type UserProperty struct

+ Key string

+ Val string

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