cache

Documentation

Index

• Constants
• Variables
• func GetGlobalIterNum(queryID string) (int32, bool)
• func GetNodeIterNum(queryID string) (int32, bool)
• func PutGlobalIterNum(queryID string, iterCount int32)
• func PutNodeIterNum(queryID string, iterCount int32)
• func UpdateIterNumFunc(old, new Entry) bool
• func UpdateMetaData(_, _ Entry) bool
• type Cache
  • func NewCache(maxBytes int64, expireTime time.Duration) *Cache
  • func (c *Cache) Get(key string) (Entry, bool)
  • func (c *Cache) Len() int
  • func (c *Cache) Put(key string, value Entry, needUpdate func(old Entry, new Entry) bool)
  • func (c *Cache) Remove(key string)
• type Entry
• type IncIterNumEntry
  • func NewIncIterNumEntry(queryID string) *IncIterNumEntry
  • func (e *IncIterNumEntry) GetKey() string
  • func (e *IncIterNumEntry) GetTime() time.Time
  • func (e *IncIterNumEntry) GetValue() interface{}
  • func (e *IncIterNumEntry) SetTime(time time.Time)
  • func (e *IncIterNumEntry) SetValue(value interface{})
  • func (e *IncIterNumEntry) Size() int64

Constants

const (
	IncIterNumCacheSize int64 = 1 * 1024 * 1024
	IncIterNumCacheTTL        = 10 * time.Minute
)

const TimeSizeBytes = int(unsafe.Sizeof(time.Time{}))

Variables

var GlobalIncIterNumCache = NewCache(IncIterNumCacheSize, IncIterNumCacheTTL)

var NodeIncIterNumCache = NewCache(IncIterNumCacheSize, IncIterNumCacheTTL)

Functions

func GetGlobalIterNum

func GetGlobalIterNum(queryID string) (int32, bool)

func GetNodeIterNum

func GetNodeIterNum(queryID string) (int32, bool)

func PutGlobalIterNum

func PutGlobalIterNum(queryID string, iterCount int32)

func PutNodeIterNum

func PutNodeIterNum(queryID string, iterCount int32)

func UpdateIterNumFunc

func UpdateIterNumFunc(old, new Entry) bool

func UpdateMetaData

func UpdateMetaData(_, _ Entry) bool

Types

type Cache

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

func NewCache

func NewCache(maxBytes int64, expireTime time.Duration) *Cache

NewCache used to create a cache instance.

func (*Cache) Get

func (c *Cache) Get(key string) (Entry, bool)

Get used to obtain the value of the key and returns whether the key is obtained successfully.

func (*Cache) Len

func (c *Cache) Len() int

Len used to obtain the number of elements in the cache.

func (*Cache) Put

func (c *Cache) Put(key string, value Entry, needUpdate func(old Entry, new Entry) bool)

Put used to add or update a Key-Value Pair

func (*Cache) Remove

func (c *Cache) Remove(key string)

Remove to delete an element with a specified key.

type Entry

type Entry interface {
	SetTime(time time.Time)
	GetTime() time.Time
	SetValue(value interface{})
	GetValue() interface{}
	GetKey() string
	Size() int64
}

type IncIterNumEntry

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

func NewIncIterNumEntry

func NewIncIterNumEntry(queryID string) *IncIterNumEntry

func (*IncIterNumEntry) GetKey

func (e *IncIterNumEntry) GetKey() string

func (*IncIterNumEntry) GetTime

func (e *IncIterNumEntry) GetTime() time.Time

func (*IncIterNumEntry) GetValue

func (e *IncIterNumEntry) GetValue() interface{}

func (*IncIterNumEntry) SetTime

func (e *IncIterNumEntry) SetTime(time time.Time)

func (*IncIterNumEntry) SetValue

func (e *IncIterNumEntry) SetValue(value interface{})

func (*IncIterNumEntry) Size

func (e *IncIterNumEntry) Size() int64