broker

Documentation

Index

• type Client
  • func NewClient(conn interface{}, eng *Engine) *Client
  • func (c *Client) Clear()
  • func (c *Client) ClearWill()
  • func (c *Client) Close()
  • func (c *Client) Receive(pkt packet.Generic) (err error)
  • func (c *Client) TickFunc()
  • func (c *Client) Wills()
• type Engine
  • func NewEngine() *Engine
  • func (e *Engine) AddClient(conn interface{}, tlsConn *tls.Conn) *Client
  • func (e *Engine) Close()
  • func (e *Engine) DelClient(conn interface{})
  • func (e *Engine) GetClient(conn interface{}) (*Client, bool)
  • func (e *Engine) InitIpBlocker()

Types

type Client

type Client struct {
	ClientID string

	Subscribed *topic.Tree

	Cache bytes.Buffer
	// contains filtered or unexported fields
}

func NewClient

func NewClient(conn interface{}, eng *Engine) *Client

func (*Client) Clear

func (c *Client) Clear()

func (*Client) ClearWill

func (c *Client) ClearWill()

func (*Client) Close

func (c *Client) Close()

func (*Client) Receive

func (c *Client) Receive(pkt packet.Generic) (err error)

func (*Client) TickFunc

func (c *Client) TickFunc()

func (*Client) Wills

func (c *Client) Wills()

type Engine

type Engine struct {
	Subscribed   *topic.Tree
	Retained     *sync.Map
	Clients      *sync.Map
	Qos1Store    *multimap.MultiMap
	Qos2PubStore *multimap.MultiMap
	Qos2RelStore *multimap.MultiMap

	JwtSecretKey [][]byte
	SelfDdosDeny int
	LazyMsgSend  int
	NilConnDeny  int
	BlockTime    int
	MaxAttempts  int
	IpBlocker    *ipblocker.Blocker // 增加Blocker字段
	// contains filtered or unexported fields
}

func NewEngine

func NewEngine() *Engine

func (*Engine) AddClient

func (e *Engine) AddClient(conn interface{}, tlsConn *tls.Conn) *Client

func (*Engine) Close

func (e *Engine) Close()

func (*Engine) DelClient

func (e *Engine) DelClient(conn interface{})

func (*Engine) GetClient

func (e *Engine) GetClient(conn interface{}) (*Client, bool)

func (*Engine) InitIpBlocker

func (e *Engine) InitIpBlocker()