packets

package

Go to main page

Versions in this module

v0

v0.22.0

Oct 13, 2024

v0.21.0

Feb 26, 2024

v0.20.0

Feb 3, 2024

v0.12.0

Oct 15, 2023

Changes in this version

type ControlPacket

+ func (c *ControlPacket) String() string

type Publish

+ func (p *Publish) SetIdentifier(packetID uint16)

+ func (p *Publish) ToControlPacket() *ControlPacket

+ func (s *Publish) Type() byte

type Pubrec

+ func (p *Pubrec) ToControlPacket() *ControlPacket

type SubOptions

+ Topic string

type Subscribe

+ func (s *Subscribe) SetIdentifier(packetID uint16)

+ func (s *Subscribe) Type() byte

type Unsubscribe

+ func (s *Unsubscribe) Type() byte

+ func (u *Unsubscribe) SetIdentifier(packetID uint16)

v0.11.0

Mar 12, 2023

Changes in this version

+ const ConnackBadAuthenticationMethod

+ const ConnackBadUsernameOrPassword

+ const ConnackBanned

+ const ConnackConnectionRateExceeded

+ const ConnackImplementationSpecificError

+ const ConnackInvalidClientID

+ const ConnackMalformedPacket

+ const ConnackNotAuthorized

+ const ConnackPacketTooLarge

+ const ConnackPayloadFormatInvalid

+ const ConnackProtocolError

+ const ConnackQoSNotSupported

+ const ConnackQuotaExceeded

+ const ConnackRetainNotSupported

+ const ConnackServerBusy

+ const ConnackServerMoved

+ const ConnackServerUnavailable

+ const ConnackSuccess

+ const ConnackTopicNameInvalid

+ const ConnackUnspecifiedError

+ const ConnackUnsupportedProtocolVersion

+ const ConnackUseAnotherServer

+ func NewThreadSafeConn(c net.Conn) net.Conn

type Auth

+ func (a *Auth) String() string

type Connack

+ func (c *Connack) String() string

type Connect

+ func (c *Connect) String() string

type Disconnect

+ func (d *Disconnect) String() string

type Pingreq

+ func (p *Pingreq) String() string

type Pingresp

+ func (p *Pingresp) String() string

type Properties

+ func (p *Properties) String() string

type Puback

+ func (p *Puback) String() string

type Pubcomp

+ func (p *Pubcomp) String() string

type Publish

+ func (p *Publish) String() string

type Pubrec

+ func (p *Pubrec) String() string

type Pubrel

+ func (p *Pubrel) String() string

type Suback

+ func (s *Suback) String() string

type Subscribe

+ func (s *Subscribe) String() string

type Unsuback

+ func (u *Unsuback) String() string

type Unsubscribe

+ func (u *Unsubscribe) String() string

v0.10.0

Jul 20, 2021

Changes in this version

+ const AuthContinueAuthentication

+ const AuthReauthenticate

+ const AuthSuccess

type ControlPacket

+ func (c *ControlPacket) PacketType() string

type Properties

+ func (i *Properties) PackBuf(p byte) *bytes.Buffer

+ type User struct

+ Key string

+ Value string

v0.9.5

Jul 20, 2021

v0.9.0

Mar 21, 2019

Changes in this version

+ const DisconnectAdministrativeAction

+ const DisconnectConnectionRateExceeded

+ const DisconnectDisconnectWithWillMessage

+ const DisconnectImplementationSpecificError

+ const DisconnectKeepAliveTimeout

+ const DisconnectMalformedPacket

+ const DisconnectMaximumConnectTime

+ const DisconnectMessageRateTooHigh

+ const DisconnectNormalDisconnection

+ const DisconnectNotAuthorized

+ const DisconnectPacketTooLarge

+ const DisconnectPayloadFormatInvalid

+ const DisconnectProtocolError

+ const DisconnectQoSNotSupported

+ const DisconnectQuotaExceeded

+ const DisconnectReceiveMaximumExceeded

+ const DisconnectRetainNotSupported

+ const DisconnectServerBusy

+ const DisconnectServerMoved

+ const DisconnectServerShuttingDown

+ const DisconnectSessionTakenOver

+ const DisconnectSharedSubscriptionNotSupported

+ const DisconnectSubscriptionIdentifiersNotSupported

+ const DisconnectTopicAliasInvalid

+ const DisconnectTopicFilterInvalid

+ const DisconnectTopicNameInvalid

+ const DisconnectUnspecifiedError

+ const DisconnectUseAnotherServer

+ const DisconnectWildcardSubscriptionsNotSupported

+ const PropAssignedClientID

+ const PropAuthData

+ const PropAuthMethod

+ const PropContentType

+ const PropCorrelationData

+ const PropMaximumPacketSize

+ const PropMaximumQOS

+ const PropMessageExpiry

+ 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 PubackImplementationSpecificError

+ const PubackNoMatchingSubscribers

+ const PubackNotAuthorized

+ const PubackPacketIdentifierInUse

+ const PubackPayloadFormatInvalid

+ const PubackQuotaExceeded

+ const PubackSuccess

+ const PubackTopicNameInvalid

+ const PubackUnspecifiedError

+ const PubcompPacketIdentifierNotFound

+ const PubcompSuccess

+ const PubrecImplementationSpecificError

+ const PubrecNoMatchingSubscribers

+ const PubrecNotAuthorized

+ const PubrecPacketIdentifierInUse

+ const PubrecPayloadFormatInvalid

+ const PubrecQuotaExceeded

+ const PubrecSuccess

+ const PubrecTopicNameInvalid

+ const PubrecUnspecifiedError

+ const SubackGrantedQoS0

+ const SubackGrantedQoS1

+ const SubackGrantedQoS2

+ const SubackImplementationspecificerror

+ const SubackNotauthorized

+ const SubackPacketIdentifierinuse

+ const SubackQuotaexceeded

+ const SubackSharedSubscriptionnotsupported

+ const SubackSubscriptionIdentifiersnotsupported

+ const SubackTopicFilterinvalid

+ const SubackUnspecifiederror

+ const SubackWildcardsubscriptionsnotsupported

+ const UnsubackImplementationSpecificError

+ const UnsubackNoSubscriptionFound

+ const UnsubackNotAuthorized

+ const UnsubackPacketIdentifierInUse

+ const UnsubackSuccess

+ const UnsubackTopicFilterInvalid

+ const UnsubackUnspecifiedError

+ var ValidProperties = map[byte]map[PacketType]struct

+ func ValidateID(p PacketType, i byte) bool

+ type Auth struct

+ Properties *Properties

+ ReasonCode byte

+ func (a *Auth) Buffers() net.Buffers

+ func (a *Auth) Unpack(r *bytes.Buffer) error

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

+ type Connack struct

+ Properties *Properties

+ ReasonCode byte

+ SessionPresent bool

+ func (c *Connack) Buffers() net.Buffers

+ func (c *Connack) Reason() string

+ func (c *Connack) Unpack(r *bytes.Buffer) error

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

+ type Connect struct

+ CleanStart bool

+ ClientID string

+ KeepAlive uint16

+ Password []byte

+ PasswordFlag bool

+ Properties *Properties

+ ProtocolName string

+ ProtocolVersion byte

+ Username string

+ UsernameFlag bool

+ WillFlag bool

+ WillMessage []byte

+ WillProperties *Properties

+ WillQOS byte

+ WillRetain bool

+ WillTopic string

+ func (c *Connect) Buffers() net.Buffers

+ func (c *Connect) PackFlags() (f byte)

+ func (c *Connect) Unpack(r *bytes.Buffer) error

+ func (c *Connect) UnpackFlags(b byte)

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

+ type ControlPacket struct

+ Content Packet

+ func NewControlPacket(t PacketType) *ControlPacket

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

+ func (c *ControlPacket) PacketID() uint16

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

+ type Disconnect struct

+ Properties *Properties

+ ReasonCode byte

+ func (d *Disconnect) Buffers() net.Buffers

+ func (d *Disconnect) Reason() string

+ func (d *Disconnect) Unpack(r *bytes.Buffer) error

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

+ type FixedHeader struct

+ Flags byte

+ Type PacketType

+ func (f *FixedHeader) WriteTo(w io.Writer) (int64, error)

+ type Packet interface

+ Buffers func() net.Buffers

+ Unpack func(*bytes.Buffer) error

+ WriteTo func(io.Writer) (int64, error)

+ type PacketType byte

+ const AUTH

+ const CONNACK

+ const CONNECT

+ const DISCONNECT

+ const PINGREQ

+ const PINGRESP

+ const PUBACK

+ const PUBCOMP

+ const PUBLISH

+ const PUBREC

+ const PUBREL

+ const SUBACK

+ const SUBSCRIBE

+ const UNSUBACK

+ const UNSUBSCRIBE

+ type Pingreq struct

+ func (p *Pingreq) Buffers() net.Buffers

+ func (p *Pingreq) Unpack(r *bytes.Buffer) error

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

+ type Pingresp struct

+ func (p *Pingresp) Buffers() net.Buffers

+ func (p *Pingresp) Unpack(r *bytes.Buffer) error

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

+ type Properties struct

+ AssignedClientID string

+ AuthData []byte

+ AuthMethod string

+ ContentType string

+ CorrelationData []byte

+ MaximumPacketSize *uint32

+ MaximumQOS *byte

+ MessageExpiry *uint32

+ PayloadFormat *byte

+ ReasonString string

+ ReceiveMaximum *uint16

+ RequestProblemInfo *byte

+ RequestResponseInfo *byte

+ ResponseInfo string

+ ResponseTopic string

+ RetainAvailable *byte

+ ServerKeepAlive *uint16

+ ServerReference string

+ SessionExpiryInterval *uint32

+ SharedSubAvailable *byte

+ SubIDAvailable *byte

+ SubscriptionIdentifier *uint32

+ TopicAlias *uint16

+ TopicAliasMaximum *uint16

+ User map[string]string

+ WildcardSubAvailable *byte

+ WillDelayInterval *uint32

+ func (i *Properties) Pack(p PacketType) []byte

+ func (i *Properties) Unpack(r *bytes.Buffer, p PacketType) error

+ type Puback struct

+ PacketID uint16

+ Properties *Properties

+ ReasonCode byte

+ func (p *Puback) Buffers() net.Buffers

+ func (p *Puback) Reason() string

+ func (p *Puback) Unpack(r *bytes.Buffer) error

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

+ type Pubcomp struct

+ PacketID uint16

+ Properties *Properties

+ ReasonCode byte

+ func (p *Pubcomp) Buffers() net.Buffers

+ func (p *Pubcomp) Reason() string

+ func (p *Pubcomp) Unpack(r *bytes.Buffer) error

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

+ type Publish struct

+ Duplicate bool

+ PacketID uint16

+ Payload []byte

+ Properties *Properties

+ QoS byte

+ Retain bool

+ Topic string

+ func (p *Publish) Buffers() net.Buffers

+ func (p *Publish) Unpack(r *bytes.Buffer) error

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

+ type Pubrec struct

+ PacketID uint16

+ Properties *Properties

+ ReasonCode byte

+ func (p *Pubrec) Buffers() net.Buffers

+ func (p *Pubrec) Reason() string

+ func (p *Pubrec) Unpack(r *bytes.Buffer) error

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

+ type Pubrel struct

+ PacketID uint16

+ Properties *Properties

+ ReasonCode byte

+ func (p *Pubrel) Buffers() net.Buffers

+ func (p *Pubrel) Unpack(r *bytes.Buffer) error

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

+ type SubOptions struct

+ NoLocal bool

+ QoS byte

+ RetainAsPublished bool

+ RetainHandling byte

+ func (s *SubOptions) Pack() byte

+ func (s *SubOptions) Unpack(r *bytes.Buffer) error

+ type Suback struct

+ PacketID uint16

+ Properties *Properties

+ Reasons []byte

+ func (s *Suback) Buffers() net.Buffers

+ func (s *Suback) Reason(index int) string

+ func (s *Suback) Unpack(r *bytes.Buffer) error

+ func (s *Suback) WriteTo(w io.Writer) (int64, error)

+ type Subscribe struct

+ PacketID uint16

+ Properties *Properties

+ Subscriptions map[string]SubOptions

+ func (s *Subscribe) Buffers() net.Buffers

+ func (s *Subscribe) Unpack(r *bytes.Buffer) error

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

+ type Unsuback struct

+ PacketID uint16

+ Properties *Properties

+ Reasons []byte

+ func (u *Unsuback) Buffers() net.Buffers

+ func (u *Unsuback) Reason(index int) string

+ func (u *Unsuback) Unpack(r *bytes.Buffer) error

+ func (u *Unsuback) WriteTo(w io.Writer) (int64, error)

+ type Unsubscribe struct

+ PacketID uint16

+ Properties *Properties

+ Topics []string

+ func (u *Unsubscribe) Buffers() net.Buffers

+ func (u *Unsubscribe) Unpack(r *bytes.Buffer) error

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

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