Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NopSinkSub ¶
type NopSinkSub struct {
// contains filtered or unexported fields
}
NopSinkSub subscription of sink which does nothing
func NewNopSinkSub ¶
NewNopSinkSub creates a new subscription of sink which does nothing
func (*NopSinkSub) TargetQOS ¶
func (s *NopSinkSub) TargetQOS() uint32
TargetQOS returns the publish qos
func (*NopSinkSub) TargetTopic ¶
func (s *NopSinkSub) TargetTopic() string
TargetTopic returns the publish topic
func (*NopSinkSub) Topic ¶
func (s *NopSinkSub) Topic() string
Topic returns the topic of subscribed topic
type SinkSub ¶
type SinkSub interface { ID() string // client id for session QOS() uint32 Topic() string TargetQOS() uint32 TargetTopic() string Flow(common.Message) }
SinkSub subscription of sink
Click to show internal directories.
Click to hide internal directories.