gmqtt

package module

Go to main page

Versions in this module

v0

v0.5.0

Dec 11, 2022

v0.4.1

Jul 21, 2021

v0.4.0

Jul 2, 2021

v0.3.2

May 16, 2021

v0.3.1

Apr 18, 2021

v0.3.0

Feb 16, 2021

v0.2.3

Jan 16, 2021

v0.2.2

Dec 19, 2020

v0.2.1

Dec 15, 2020

v0.2.0

Dec 14, 2020

Changes in this version

+ func MessageToPublish(msg *Message, version packets.Version) *packets.Publish

+ type Message struct

+ ContentType string

+ CorrelationData []byte

+ Dup bool

+ MessageExpiry uint32

+ PacketID packets.PacketID

+ Payload []byte

+ PayloadFormat packets.PayloadFormat

+ QoS uint8

+ ResponseTopic string

+ Retained bool

+ SubscriptionIdentifier []uint32

+ Topic string

+ UserProperties []packets.UserProperty

+ func MessageFromPublish(p *packets.Publish) *Message

+ func (m *Message) Copy() *Message

+ func (m *Message) TotalBytes(version packets.Version) uint32

+ type Session struct

+ ClientID string

+ ConnectedAt time.Time

+ ExpiryInterval uint32

+ Will *Message

+ WillDelayInterval uint32

+ func (s *Session) IsExpired(now time.Time) bool

+ type Subscription struct

+ ID uint32

+ NoLocal bool

+ QoS packets.QoS

+ RetainAsPublished bool

+ RetainHandling byte

+ ShareName string

+ TopicFilter string

+ func (s *Subscription) Copy() *Subscription

+ func (s *Subscription) GetFullTopicName() string

+ func (s *Subscription) Validate() error

v0.1.4

Dec 4, 2020

v0.1.3

Sep 29, 2020

Changes in this version

type HookWrapper

+ OnUnsubscribeWrapper OnUnsubscribeWrapper

+ type OnUnsubscribe func(ctx context.Context, client Client, topicName string)

+ type OnUnsubscribeWrapper func(OnUnsubscribe) OnUnsubscribe

v0.1.2

Feb 24, 2020

v0.1.1

Feb 20, 2020

Changes in this version

type Client

+ Connection func() net.Conn

v0.1.0

Jan 28, 2020

Changes in this version

+ const Connected

+ const Connecting

+ const DefaultMsgRouterLen

+ const DefaultRegisterLen

+ const DefaultUnRegisterLen

+ const Disconnected

+ const Switiching

+ var DefaultConfig = Config

+ var ErrConnectTimeOut = errors.New("connect time out")

+ var ErrInvalStatus = errors.New("invalid connection status")

+ var ErrInvalWsMsgType = errors.New("invalid websocket message type")

+ func LoggerWithField(fields ...zap.Field) *zap.Logger

+ func NewMessage(topic string, payload []byte, qos uint8, opts ...msgOptions) packets.Message

+ func NewServer(opts ...Options) *server

+ func Retained(retained bool) msgOptions

+ type Client interface

+ Close func() <-chan struct{}

+ ConnectedAt func() time.Time

+ DisconnectedAt func() time.Time

+ GetSessionStatsManager func() SessionStatsManager

+ IsConnected func() bool

+ OptionsReader func() ClientOptionsReader

+ type ClientOptionsReader interface

+ CleanSession func() bool

+ ClientID func() string

+ KeepAlive func() uint16

+ LocalAddr func() net.Addr

+ Password func() string

+ RemoteAddr func() net.Addr

+ Username func() string

+ WillFlag func() bool

+ WillPayload func() []byte

+ WillQos func() uint8

+ WillRetain func() bool

+ WillTopic func() string

+ type ClientStats struct

+ ActiveCurrent uint64

+ ConnectedTotal uint64

+ DisconnectedTotal uint64

+ ExpiredTotal uint64

+ InactiveCurrent uint64

+ type Config struct

+ DeliveryMode DeliveryMode

+ MaxAwaitRel int

+ MaxInflight int

+ MaxMsgQueue int

+ MsgRouterLen int

+ QueueQos0Messages bool

+ RegisterLen int

+ RetryCheckInterval time.Duration

+ RetryInterval time.Duration

+ SessionExpiryCheckInterval time.Duration

+ SessionExpiryInterval time.Duration

+ UnregisterLen int

+ type DeliveryMode int

+ const OnlyOnce

+ const Overlap

+ type HookWrapper struct

+ OnAcceptWrapper OnAcceptWrapper

+ OnAckedWrapper OnAckedWrapper

+ OnCloseWrapper OnCloseWrapper

+ OnConnectWrapper OnConnectWrapper

+ OnConnectedWrapper OnConnectedWrapper

+ OnDeliverWrapper OnDeliverWrapper

+ OnMsgArrivedWrapper OnMsgArrivedWrapper

+ OnMsgDroppedWrapper OnMsgDroppedWrapper

+ OnSessionCreatedWrapper OnSessionCreatedWrapper

+ OnSessionResumedWrapper OnSessionResumedWrapper

+ OnSessionTerminatedWrapper OnSessionTerminatedWrapper

+ OnStopWrapper OnStopWrapper

+ OnSubscribeWrapper OnSubscribeWrapper

+ OnSubscribedWrapper OnSubscribedWrapper

+ OnUnsubscribedWrapper OnUnsubscribedWrapper

+ type Hooks struct

+ type MessageStats struct

+ Qos0 struct{ ... }

+ Qos1 struct{ ... }

+ Qos2 struct{ ... }

+ QueuedCurrent uint64

+ type OnAccept func(ctx context.Context, conn net.Conn) bool

+ type OnAcceptWrapper func(OnAccept) OnAccept

+ type OnAcked func(ctx context.Context, client Client, msg packets.Message)

+ type OnAckedWrapper func(OnAcked) OnAcked

+ type OnClose func(ctx context.Context, client Client, err error)

+ type OnCloseWrapper func(OnClose) OnClose

+ type OnConnect func(ctx context.Context, client Client) (code uint8)

+ type OnConnectWrapper func(OnConnect) OnConnect

+ type OnConnected func(ctx context.Context, client Client)

+ type OnConnectedWrapper func(OnConnected) OnConnected

+ type OnDeliver func(ctx context.Context, client Client, msg packets.Message)

+ type OnDeliverWrapper func(OnDeliver) OnDeliver

+ type OnMsgArrived func(ctx context.Context, client Client, msg packets.Message) (valid bool)

+ type OnMsgArrivedWrapper func(OnMsgArrived) OnMsgArrived

+ type OnMsgDropped func(ctx context.Context, client Client, msg packets.Message)

+ type OnMsgDroppedWrapper func(OnMsgDropped) OnMsgDropped

+ type OnSessionCreated func(ctx context.Context, client Client)

+ type OnSessionCreatedWrapper func(OnSessionCreated) OnSessionCreated

+ type OnSessionResumed func(ctx context.Context, client Client)

+ type OnSessionResumedWrapper func(OnSessionResumed) OnSessionResumed

+ type OnSessionTerminated func(ctx context.Context, client Client, reason SessionTerminatedReason)

+ type OnSessionTerminatedWrapper func(OnSessionTerminated) OnSessionTerminated

+ type OnStop func(ctx context.Context)

+ type OnStopWrapper func(OnStop) OnStop

+ type OnSubscribe func(ctx context.Context, client Client, topic packets.Topic) (qos uint8)

+ type OnSubscribeWrapper func(OnSubscribe) OnSubscribe

+ type OnSubscribed func(ctx context.Context, client Client, topic packets.Topic)

+ type OnSubscribedWrapper func(OnSubscribed) OnSubscribed

+ type OnUnsubscribed func(ctx context.Context, client Client, topicName string)

+ type OnUnsubscribedWrapper func(OnUnsubscribed) OnUnsubscribed

+ type Options func(srv *server)

+ func WithConfig(config Config) Options

+ func WithHook(hooks Hooks) Options

+ func WithLogger(logger *zap.Logger) Options

+ func WithPlugin(plugin ...Plugable) Options

+ func WithTCPListener(lns ...net.Listener) Options

+ func WithWebsocketServer(ws ...*WsServer) Options

+ type PacketBytes struct

+ Connack uint64

+ Connect uint64

+ Disconnect uint64

+ Pingreq uint64

+ Pingresp uint64

+ Puback uint64

+ Pubcomp uint64

+ Publish uint64

+ Pubrec uint64

+ Pubrel uint64

+ Suback uint64

+ Subscribe uint64

+ Unsuback uint64

+ Unsubscribe uint64

+ type PacketCount struct

+ Connack uint64

+ Connect uint64

+ Disconnect uint64

+ Pingreq uint64

+ Pingresp uint64

+ Puback uint64

+ Pubcomp uint64

+ Publish uint64

+ Pubrec uint64

+ Pubrel uint64

+ Suback uint64

+ Subscribe uint64

+ Unsuback uint64

+ Unsubscribe uint64

+ type PacketStats struct

+ BytesReceived *PacketBytes

+ BytesSent *PacketBytes

+ ReceivedTotal *PacketCount

+ SentTotal *PacketCount

+ type Plugable interface

+ HookWrapper func() HookWrapper

+ Load func(service Server) error

+ Name func() string

+ Unload func() error

+ type PublishService interface

+ Publish func(message packets.Message)

+ PublishToClient func(clientID string, message packets.Message, match bool)

+ type Server interface

+ Client func(clientID string) Client

+ GetConfig func() Config

+ GetStatsManager func() StatsManager

+ PublishService func() PublishService

+ RetainedStore func() retained.Store

+ SubscriptionStore func() subscription.Store

+ type ServerStats struct

+ ClientStats *ClientStats

+ MessageStats *MessageStats

+ PacketStats *PacketStats

+ SubscriptionStats *subscription.Stats

+ type SessionStats struct

+ AwaitRelCurrent uint64

+ InflightCurrent uint64

+ type SessionStatsManager interface

+ GetStats func() *SessionStats

+ type SessionTerminatedReason byte

+ const ConflictTermination

+ const ExpiredTermination

+ const NormalTermination

+ type StatsManager interface

+ GetStats func() *ServerStats

+ type WsServer struct

+ CertFile string

+ KeyFile string

+ Path string

+ Server *http.Server

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