sessions

type Ackqueue struct {
	Size  int64
	Mask  int64
	Count int64
	Head  int64
	Tail  int64

	Ping ackmsg
	Ring []ackmsg
	Emap map[string]int64

	Ackdone []ackmsg
	// contains filtered or unexported fields
}

type Constructor func(context fmt.Stringer) SessionsProvider

type Manager struct {
	// contains filtered or unexported fields
}

type Session struct {
	// Ack queue for outgoing PUBLISH QoS 1 messages
	Pub1ack *Ackqueue

	// Ack queue for incoming PUBLISH QoS 2 messages
	Pub2in *Ackqueue

	// Ack queue for outgoing PUBLISH QoS 2 messages
	Pub2out *Ackqueue

	// Ack queue for outgoing SUBSCRIBE messages
	Suback *Ackqueue

	// Ack queue for outgoing UNSUBSCRIBE messages
	Unsuback *Ackqueue

	// Ack queue for outgoing PINGREQ messages
	Pingack *Ackqueue

	// cmsg is the CONNECT message
	Cmsg *message.ConnectMessage `json:"-"`

	// Will message to publish if connect is closed unexpectedly
	Will *message.PublishMessage

	// Retained publish message
	Retained *message.PublishMessage

	Id string

	SessionTopics `json:"-"`
	// contains filtered or unexported fields
}

type SessionTopics interface {
	InitTopics(msg *message.ConnectMessage) error
	AddTopic(topic string, qos byte) error
	RemoveTopic(topic string) error
	Topics() ([]string, []byte, error)
}

type SessionsProvider interface {
	New(id string) (*Session, error)
	Get(id string) (*Session, error)
	Del(id string)
	Save(id string, session *Session) error
	Count() int
	Close() error
}