clients

type Client struct {
	State State // the operational state of the client.

	sync.RWMutex

	ID            string               // the client id.
	AC            auth.Controller      // an auth controller inherited from the listener.
	Subscriptions topics.Subscriptions // a map of the subscription filters a client maintains.
	Listener      string               // the id of the listener the client is connected to.
	Inflight      Inflight             // a map of in-flight qos messages.
	Username      []byte               // the username the client authenticated with.

	LWT LWT // the last will and testament for the client.
	// contains filtered or unexported fields
}

type Clients struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Inflight struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type InflightMessage struct {
	Packet  packets.Packet // the packet currently in-flight.
	Sent    int64          // the last time the message was sent (for retries) in unixtime.
	Resends int            // the number of times the message was attempted to be sent.
}

type LWT struct {
	Topic   string // the topic the will message shall be sent to.
	Message []byte // the message that shall be sent when the client disconnects.
	Qos     byte   // the quality of service desired.
	Retain  bool   // indicates whether the will message should be retained
}

type State struct {
	Done int64 // atomic counter which indicates that the client has closed.
	// contains filtered or unexported fields
}