proxy

Documentation

Index

• type MQTTProxy
  • func CreateMQTTProxy(conf *conf.Configuration) *MQTTProxy
  • func (p *MQTTProxy) MqttMsgRewriter(user *store.User) *rewrite.MsgRewriter
  • func (p *MQTTProxy) RegisterSession(conn net.Conn)
  • func (p *MQTTProxy) UnRegisterSession(conn net.Conn)
• type ProxyConn

Types

type MQTTProxy

type MQTTProxy struct {
	Conf *conf.Configuration

	Metrics metrics.ProxyMetrics
	// contains filtered or unexported fields
}

func CreateMQTTProxy

func CreateMQTTProxy(conf *conf.Configuration) *MQTTProxy

func (*MQTTProxy) MqttMsgRewriter

func (p *MQTTProxy) MqttMsgRewriter(user *store.User) *rewrite.MsgRewriter

func (*MQTTProxy) RegisterSession

func (p *MQTTProxy) RegisterSession(conn net.Conn)

func (*MQTTProxy) UnRegisterSession

func (p *MQTTProxy) UnRegisterSession(conn net.Conn)

type ProxyConn

type ProxyConn interface {
	Id() string
	Close()
}