Versions in this module Expand all Collapse all v0 v0.0.3 Jun 30, 2022 Changes in this version + func MatchTopic(topic string) []string + type AUTHRouter struct + func (s *AUTHRouter) Handle(request *Request) + type BaseRouter struct + func (s *BaseRouter) Handle(request *Request) + func (s *BaseRouter) PostHandle(request *Request) + func (s *BaseRouter) PreHandle(request *Request) + type CONNECTRouter struct + func (s *CONNECTRouter) Handle(request *Request) + type Conn struct + type ConnManager struct + type ConnectVerifyFUNC func(*proto.CONNECTProtocol) uint8 + type DISCONNECTRouter struct + func (s *DISCONNECTRouter) Handle(request *Request) + type GHapi struct + func NewGHapi() *GHapi + func (s *GHapi) AddRouter(i uint8, router ImplBaseRouter) + func (s *GHapi) GetConnList() *types.Response + func (s *GHapi) GetTopList() *types.Response + func (s *GHapi) Run() + func (s *GHapi) SendAuth() *types.Response + func (s *GHapi) SendPublish(msg *types.PublishMsg) *types.Response + func (s *GHapi) ServerInfo() *types.Response + func (s *GHapi) SetConnectVerify(cvf ConnectVerifyFUNC) + func (s *GHapi) SetRetainMsg(msg *types.PublishMsg) *types.Response + func (s *GHapi) Stop() + type ImplBaseRouter interface + Handle func(request *Request) + PostHandle func(request *Request) + PreHandle func(request *Request) + type MqttDataPack struct + type PINGREQRouter struct + func (s *PINGREQRouter) Handle(request *Request) + type PUBACKRouter struct + func (s *PUBACKRouter) Handle(request *Request) + type PUBCOMPRouter struct + func (s *PUBCOMPRouter) Handle(request *Request) + type PUBLISHRouter struct + func (s *PUBLISHRouter) Handle(request *Request) + type PUBRECRouter struct + func (s *PUBRECRouter) Handle(request *Request) + type PUBRELRouter struct + func (s *PUBRELRouter) Handle(request *Request) + type Request struct + func (s *Request) ConnStop() + func (s *Request) GetConnClientID() string + func (s *Request) GetProto() proto.ImplMqttProto + func (s *Request) GetQos2ID(id uint16) bool + func (s *Request) MsgInPool(sp *proto.PUBLISHProtocol) + func (s *Request) RemoveQos2ID(id uint16) + func (s *Request) SendRES(p proto.ImplMqttProto) error + func (s *Request) SetQos2ID(id uint16) + func (s *Request) SetRetainMsg(name string, payload []byte) + func (s *Request) SubTopic(top string) + func (s *Request) UnSubTopic(top string) + type RouterManager struct + type SUBSCRIBERouter struct + func (s *SUBSCRIBERouter) Handle(request *Request) + type Server struct + type TopicManager struct + type TopicWork struct + type UNSUBSCRIBERouter struct + func (s *UNSUBSCRIBERouter) Handle(request *Request)