session

type Config struct {
	ZQueueLen      int
	OTQueueLen     int
	Inflight       int
	PeerZQueueLen  int
	PeerOTQueueLen int
	PeerInflight   int
}

type IStore interface {
	Count() int

	GetOrCreate(id string, connID string, peer bool) (*Session, bool, error)

	RemoveAndCreate(id string, connID string, peer bool) (*Session, error)

	Remove(id string, connID string) error
}

type Session struct {

	// for qos 0
	ZQueue    *list.List
	ZQueueLen int
	// for qos 1, 2
	OTQueue    *list.List
	OTQueueLen int
	// contains filtered or unexported fields
}