util

type Balancer struct {
	Prior           int64
	Start           int64
	Total           float64
	ElapsedUseconds int64
	SleepUsec       int64
	PerSec          int
}

type MessageContainer struct {
	Message  codec.Message
	Refcount int
	Created  time.Time
	Updated  time.Time
	Opaque   interface{}
}

type MessageTable struct {
	sync.RWMutex
	Id       uint16
	Hash     map[uint16]*MessageContainer
	OnFinish func(uint16, codec.Message, interface{})
	// contains filtered or unexported fields
}

type Qlobber struct {
	Separator    string
	WildcardSome string
	WildcardOne  string
	QlobberTrie  *QlobberTrie
	Mutex        *sync.RWMutex
	Cache        map[string][]interface{}
}

type QlobberTrie struct {
	Collections []interface{}
	Trie        map[string]*QlobberTrie
}