subscriber

Apr 22, 2018

Changes in this version

type Config

+ OfflinePublish Publisher

+ type Publisher interface

+ Publish func(string, *packet.Publish)

+ type SessionProvider interface

+ HasSubscriptions func() bool

+ Hash func() uintptr

+ Offline func(bool)

+ Online func(c Publisher)

+ Subscribe func(string, *topicsTypes.SubscriptionParams) (packet.QosType, []*packet.Publish, error)

+ Subscriptions func() Subscriptions

+ UnSubscribe func(string) error

type Type

+ func (s *Type) GetID() string

+ func (s *Type) GetVersion() packet.ProtocolVersion

Sep 21, 2017

Changes in this version

+ type Config struct

+ ID string

+ OfflineQoS0 bool

+ OnOfflinePublish OfflinePublish

+ Topics topicsTypes.SubscriberInterface

+ Version packet.ProtocolVersion

+ type ConnectionProvider interface

+ HasSubscriptions func() bool

+ Hash func() uintptr

+ ID func() string

+ Offline func(bool)

+ Online func(c OnlinePublish)

+ OnlineRedirect func(c OnlinePublish)

+ Subscribe func(string, *topicsTypes.SubscriptionParams) (packet.QosType, []*packet.Publish, error)

+ Subscriptions func() Subscriptions

+ UnSubscribe func(string) error

+ Version func() packet.ProtocolVersion

+ type OfflinePublish func(string, *packet.Publish)

+ type OnlinePublish func(*packet.Publish)

+ type Subscriptions map[string]*topicsTypes.SubscriptionParams

+ type Type struct

+ func New(c *Config) *Type

+ func (s *Type) Acquire()

+ func (s *Type) HasSubscriptions() bool

+ func (s *Type) Hash() uintptr

+ func (s *Type) ID() string

+ func (s *Type) Offline(shutdown bool)

+ func (s *Type) Online(c OnlinePublish)

+ func (s *Type) OnlineRedirect(c OnlinePublish)

+ func (s *Type) Publish(p *packet.Publish, grantedQoS packet.QosType, ops packet.SubscriptionOptions, ...) error

+ func (s *Type) Release()

+ func (s *Type) Subscribe(topic string, params *topicsTypes.SubscriptionParams) (packet.QosType, []*packet.Publish, error)

+ func (s *Type) Subscriptions() Subscriptions

+ func (s *Type) UnSubscribe(topic string) error

+ func (s *Type) Version() packet.ProtocolVersion