beeq

README

beeq

Embed MQTT server, MQTT服务器，主要作为库使用

Documentation

Index

• func MatchSubscribe(topic []byte, sub []byte) bool
• func ValidSubscribe(topic []byte) error
• func ValidTopic(topic []byte) error
• type Bee
  • func NewBee(conn net.Conn) *Bee
  • func (b *Bee) ClientId() string
  • func (b *Bee) Close() error
  • func (b *Bee) Disconnect() error
• type Hive
  • func NewHive() *Hive
  • func (h *Hive) ListenAndServe(addr string) error
  • func (h *Hive) OnConnect(fn func(*packet.Connect, *Bee) bool)
  • func (h *Hive) OnDisconnect(fn func(*packet.DisConnect, *Bee))
  • func (h *Hive) OnPublish(fn func(*packet.Publish, *Bee) bool)
  • func (h *Hive) OnSubscribe(fn func(*packet.Subscribe, *Bee) bool)
  • func (h *Hive) OnUnSubscribe(fn func(*packet.UnSubscribe, *Bee))
  • func (h *Hive) Publish(pub *packet.Publish)
  • func (h *Hive) Receive(conn net.Conn)
  • func (h *Hive) Receive2(conn net.Conn)
  • func (h *Hive) Serve(ln net.Listener)
  • func (h *Hive) Subscribe(topic string, callback SubscribeCallback)
• type RetainNode
  • func (rn *RetainNode) Fetch(topics []string, cb func(clientId string, pub *packet.Publish))
  • func (rn *RetainNode) Retain(topics []string, clientId string, pub *packet.Publish) *RetainNode
• type RetainTree
  • func (rt *RetainTree) Fetch(topic []byte, cb func(clientId string, pub *packet.Publish))
  • func (rt *RetainTree) Retain(topic []byte, clientId string, pub *packet.Publish)
  • func (rt *RetainTree) UnRetain(clientId string)
• type SubNode
  • func (sn *SubNode) Callback(topics []string, pub *packet.Publish)
  • func (sn *SubNode) ClearClient(clientId string)
  • func (sn *SubNode) Publish(topics []string, subs map[string]packet.MsgQos)
  • func (sn *SubNode) Subscribe(topics []string, clientId string, qos packet.MsgQos)
  • func (sn *SubNode) SubscribeCallback(topics []string, callback SubscribeCallback)
  • func (sn *SubNode) UnSubscribe(topics []string, clientId string)
• type SubTree
  • func (st *SubTree) Callback(pub *packet.Publish)
  • func (st *SubTree) ClearClient(clientId string)
  • func (st *SubTree) Publish(topic []byte, subs map[string]packet.MsgQos)
  • func (st *SubTree) Subscribe(topic []byte, clientId string, qos packet.MsgQos)
  • func (st *SubTree) SubscribeCallback(topic []byte, callback SubscribeCallback)
  • func (st *SubTree) UnSubscribe(topic []byte, clientId string)
• type SubscribeCallback

Functions

func MatchSubscribe

func MatchSubscribe(topic []byte, sub []byte) bool

func ValidSubscribe

func ValidSubscribe(topic []byte) error

func ValidTopic

func ValidTopic(topic []byte) error

Types

type Bee

type Bee struct {
	// contains filtered or unexported fields
}

func NewBee

func NewBee(conn net.Conn) *Bee

func (*Bee) ClientId

func (b *Bee) ClientId() string

func (*Bee) Close

func (b *Bee) Close() error

func (*Bee) Disconnect

func (b *Bee) Disconnect() error

type Hive

type Hive struct {
	// contains filtered or unexported fields
}

func NewHive

func NewHive() *Hive

TODO 添加参数

func (*Hive) ListenAndServe

func (h *Hive) ListenAndServe(addr string) error

func (*Hive) OnConnect

func (h *Hive) OnConnect(fn func(*packet.Connect, *Bee) bool)

func (*Hive) OnDisconnect

func (h *Hive) OnDisconnect(fn func(*packet.DisConnect, *Bee))

func (*Hive) OnPublish

func (h *Hive) OnPublish(fn func(*packet.Publish, *Bee) bool)

func (*Hive) OnSubscribe

func (h *Hive) OnSubscribe(fn func(*packet.Subscribe, *Bee) bool)

func (*Hive) OnUnSubscribe

func (h *Hive) OnUnSubscribe(fn func(*packet.UnSubscribe, *Bee))

func (*Hive) Publish

func (h *Hive) Publish(pub *packet.Publish)

func (*Hive) Receive

func (h *Hive) Receive(conn net.Conn)

func (*Hive) Receive2

func (h *Hive) Receive2(conn net.Conn)

func (*Hive) Serve

func (h *Hive) Serve(ln net.Listener)

func (*Hive) Subscribe

func (h *Hive) Subscribe(topic string, callback SubscribeCallback)

type RetainNode

type RetainNode struct {
	// contains filtered or unexported fields
}

func (*RetainNode) Fetch

func (rn *RetainNode) Fetch(topics []string, cb func(clientId string, pub *packet.Publish))

func (*RetainNode) Retain

func (rn *RetainNode) Retain(topics []string, clientId string, pub *packet.Publish) *RetainNode

type RetainTree

type RetainTree struct {
	// contains filtered or unexported fields
}

func (*RetainTree) Fetch

func (rt *RetainTree) Fetch(topic []byte, cb func(clientId string, pub *packet.Publish))

func (*RetainTree) Retain

func (rt *RetainTree) Retain(topic []byte, clientId string, pub *packet.Publish)

func (*RetainTree) UnRetain

func (rt *RetainTree) UnRetain(clientId string)

type SubNode

type SubNode struct {
	// contains filtered or unexported fields
}

func (*SubNode) Callback

func (sn *SubNode) Callback(topics []string, pub *packet.Publish)

func (*SubNode) ClearClient

func (sn *SubNode) ClearClient(clientId string)

func (*SubNode) Publish

func (sn *SubNode) Publish(topics []string, subs map[string]packet.MsgQos)

func (*SubNode) Subscribe

func (sn *SubNode) Subscribe(topics []string, clientId string, qos packet.MsgQos)

func (*SubNode) SubscribeCallback

func (sn *SubNode) SubscribeCallback(topics []string, callback SubscribeCallback)

func (*SubNode) UnSubscribe

func (sn *SubNode) UnSubscribe(topics []string, clientId string)

type SubTree

type SubTree struct {
	// contains filtered or unexported fields
}

func (*SubTree) Callback

func (st *SubTree) Callback(pub *packet.Publish)

func (*SubTree) ClearClient

func (st *SubTree) ClearClient(clientId string)

func (*SubTree) Publish

func (st *SubTree) Publish(topic []byte, subs map[string]packet.MsgQos)

func (*SubTree) Subscribe

func (st *SubTree) Subscribe(topic []byte, clientId string, qos packet.MsgQos)

func (*SubTree) SubscribeCallback

func (st *SubTree) SubscribeCallback(topic []byte, callback SubscribeCallback)

func (*SubTree) UnSubscribe

func (st *SubTree) UnSubscribe(topic []byte, clientId string)

type SubscribeCallback

type SubscribeCallback func(pub *packet.Publish)