cache

Documentation

Index

• Constants
• type QueryCache
  • func NewQueryCache(queryCacheSizeMB uint64, expireTime int32) *QueryCache
  • func (q *QueryCache) GetQueryItem(k string) *QueryItem
• type QueryItem
  • func (q *QueryItem) FetchOrLock(ctx context.Context) (interface{}, bool)
  • func (q *QueryItem) GetStatus() uint64
  • func (q *QueryItem) StoreAbort()
  • func (q *QueryItem) StoreAndUnlock(data interface{}, size uint64)

Constants

const (
	Empty uint64 = iota
	QueryIsPending
	DataIsAvailable
)

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 (q *QueryItem) FetchOrLock(ctx context.Context) (interface{}, bool)

func (*QueryItem) GetStatus

func (q *QueryItem) GetStatus() uint64

func (*QueryItem) StoreAbort

func (q *QueryItem) StoreAbort()

func (*QueryItem) StoreAndUnlock

func (q *QueryItem) StoreAndUnlock(data interface{}, size uint64)