Documentation
¶
Index ¶
Constants ¶
View Source
const ( Empty uint64 = iota QueryIsPending DataIsAvailable )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueryCache ¶
type QueryCache struct {
// contains filtered or unexported fields
}
func NewQueryCache ¶
func NewQueryCache(queryCacheSizeMB uint64, expireTime int32) *QueryCache
func (*QueryCache) GetQueryItem ¶
func (q *QueryCache) GetQueryItem(k string) *QueryItem
TODO: Make size and expire configurable
type QueryItem ¶
type QueryItem struct {
sync.RWMutex
Key string
Data atomic.Value
Flags uint64 // DataIsAvailable or QueryIsPending
QueryFinished chan struct{}
// contains filtered or unexported fields
}
func (*QueryItem) FetchOrLock ¶
func (*QueryItem) StoreAbort ¶
func (q *QueryItem) StoreAbort()
func (*QueryItem) StoreAndUnlock ¶
Source Files
Click to show internal directories.
Click to hide internal directories.