msq

type Config struct {
	TotalByteSizeLimit      uint64 `yaml:"totalByteSizeLimit,omitempty"`
	PerSessionByteSizeLimit uint64 `yaml:"perSessionByteSizeLimit,omitempty"`
	TopicQueueCapacity      int    `yaml:"topicQueueCapacity,omitempty"`

	DeadSessionIDExpireSeconds int64 `yaml:"deadSessionIDExpireSeconds,omitempty"`
	SessionExpireSeconds       int64 `yaml:"sessionExpireSeconds,omitempty"`
	NormalizeActiveSeconds     int64 `yaml:"normalizeActiveSeconds,omitempty"`

	CleanIntervalSeconds int64 `yaml:"cleanIntervalSeconds,omitempty"`
}

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

type MemControl struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Message struct {
	Content []byte
}

type Session struct {
	Queue      *SessionQueue
	ActiveMark *SessionIDItem
}

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

type SessionIDPQ []*SessionIDItem

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

type SessionQueue struct {
	ByteSizeLimit uint64
	ByteSize      uint64
	// contains filtered or unexported fields
}

type Topic struct {
	ByteSize uint64
	// contains filtered or unexported fields
}