session

Oct 16, 2020

Changes in this version

+ type Client struct

+ Cert x509.Certificate

+ ID string

+ Password []byte

+ Username string

+ type Handler interface

+ AuthConnect func(client *Client) error

+ AuthPublish func(client *Client, topic *string, payload *[]byte) error

+ AuthSubscribe func(client *Client, topics *[]string) error

+ Connect func(client *Client)

+ Disconnect func(client *Client)

+ Publish func(client *Client, topic *string, payload *[]byte)

+ Subscribe func(client *Client, topics *[]string)

+ Unsubscribe func(client *Client, topics *[]string)

+ type Session struct

+ Client Client

+ func New(inbound, outbound net.Conn, handler Handler, logger logger.Logger, ...) *Session

+ func (s *Session) Stream() error