cache

Documentation

Index

• func GetDB(name string) *bolt.DB
• type BoltCache
  • func NewBoltDBCache(db *bolt.DB, bucket []byte) *BoltCache
  • func (c *BoltCache) Delete(key []byte) error
  • func (c *BoltCache) DeleteBucket(name []byte) (err error)
  • func (c *BoltCache) DeleteData() error
  • func (c *BoltCache) Get(key []byte) (value []byte, err error)
  • func (c *BoltCache) GetAllEntries() (values map[string][]byte, err error)
  • func (c *BoltCache) GetAllKeys() (keys map[string]bool, err error)
  • func (c *BoltCache) GetAllValues() (values [][]byte, err error)
  • func (c *BoltCache) RecordsCount() (count int, err error)
  • func (c *BoltCache) Set(key, value []byte) error
• type Cache
• type FastCache
• type InMemoryCache
  • func NewInMemoryCache() *InMemoryCache
  • func (c *InMemoryCache) Delete(key []byte) error
  • func (c *InMemoryCache) DeleteData() (err error)
  • func (c *InMemoryCache) Get(key []byte) (value []byte, err error)
  • func (c *InMemoryCache) GetAllEntries() (map[string][]byte, error)
  • func (c *InMemoryCache) GetAllKeys() (keys map[string]bool, err error)
  • func (c *InMemoryCache) GetAllValues() (values [][]byte, err error)
  • func (c *InMemoryCache) RecordsCount() (int, error)
  • func (c *InMemoryCache) Set(key, value []byte) (err error)
• type LRUFastCache
  • func NewDefaultLRUCache() *LRUFastCache
  • func NewLRUCache(size int) (*LRUFastCache, error)
  • func (c *LRUFastCache) DeleteData() (err error)
  • func (c *LRUFastCache) Get(key interface{}) (value interface{}, found bool)
  • func (c *LRUFastCache) GetAllEntries() (map[interface{}]interface{}, error)
  • func (c *LRUFastCache) RecordsCount() (count int, err error)
  • func (c *LRUFastCache) Set(key, value interface{}) (err error)

Functions

func GetDB

func GetDB(name string) *bolt.DB

GetDB - returns open BoltDB database with read/write permissions or goes down in flames if something bad happends

Types

type BoltCache

type BoltCache struct {
	DS            *bolt.DB
	CurrentBucket []byte
}

BoltCache - container to implement Cache instance with BoltDB backend for storage

func NewBoltDBCache

func NewBoltDBCache(db *bolt.DB, bucket []byte) *BoltCache

NewBoltDBCache - returns new BoltCache instance

func (*BoltCache) Delete

func (c *BoltCache) Delete(key []byte) error

Delete - deletes specified key

func (*BoltCache) DeleteBucket

func (c *BoltCache) DeleteBucket(name []byte) (err error)

DeleteBucket - deletes bucket with all saved data

func (*BoltCache) DeleteData

func (c *BoltCache) DeleteData() error

DeleteData - deletes bucket with all saved data

func (*BoltCache) Get

func (c *BoltCache) Get(key []byte) (value []byte, err error)

Get - searches for given key in the cache and returns value if found

func (*BoltCache) GetAllEntries

func (c *BoltCache) GetAllEntries() (values map[string][]byte, err error)

GetAllEntries - returns all keys/values

func (*BoltCache) GetAllKeys

func (c *BoltCache) GetAllKeys() (keys map[string]bool, err error)

GetAllKeys - gets all current keys

func (*BoltCache) GetAllValues

func (c *BoltCache) GetAllValues() (values [][]byte, err error)

GetAllValues - returns all values

func (*BoltCache) RecordsCount

func (c *BoltCache) RecordsCount() (count int, err error)

RecordsCount - returns records count

func (*BoltCache) Set

func (c *BoltCache) Set(key, value []byte) error

Set - saves given key and value pair to cache

type Cache

type Cache interface {
	Set(key, value []byte) error
	Get(key []byte) ([]byte, error)
	GetAllValues() ([][]byte, error)
	GetAllEntries() (map[string][]byte, error)
	RecordsCount() (int, error)
	Delete(key []byte) error
	DeleteData() error
	GetAllKeys() (map[string]bool, error)
}

Cache - cache interface used to store and retrieve serialized data

type FastCache

type FastCache interface {
	Set(key, value interface{}) error
	Get(key interface{}) (interface{}, bool)
	GetAllEntries() (map[interface{}]interface{}, error)
	RecordsCount() (int, error)
	DeleteData() error
}

FastCache - cache interface used to store and retrieve any data type which requires no serialization

type InMemoryCache

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

Cache used for storing serialized data in memory

func NewInMemoryCache

func NewInMemoryCache() *InMemoryCache

func (*InMemoryCache) Delete

func (c *InMemoryCache) Delete(key []byte) error

func (*InMemoryCache) DeleteData

func (c *InMemoryCache) DeleteData() (err error)

func (*InMemoryCache) Get

func (c *InMemoryCache) Get(key []byte) (value []byte, err error)

func (*InMemoryCache) GetAllEntries

func (c *InMemoryCache) GetAllEntries() (map[string][]byte, error)

func (*InMemoryCache) GetAllKeys

func (c *InMemoryCache) GetAllKeys() (keys map[string]bool, err error)

func (*InMemoryCache) GetAllValues

func (c *InMemoryCache) GetAllValues() (values [][]byte, err error)

func (*InMemoryCache) RecordsCount

func (c *InMemoryCache) RecordsCount() (int, error)

func (*InMemoryCache) Set

func (c *InMemoryCache) Set(key, value []byte) (err error)

type LRUFastCache

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

Fixed size LRU cache for storing any data type

func NewDefaultLRUCache

func NewDefaultLRUCache() *LRUFastCache

func NewLRUCache

func NewLRUCache(size int) (*LRUFastCache, error)

func (*LRUFastCache) DeleteData

func (c *LRUFastCache) DeleteData() (err error)

func (*LRUFastCache) Get

func (c *LRUFastCache) Get(key interface{}) (value interface{}, found bool)

func (*LRUFastCache) GetAllEntries

func (c *LRUFastCache) GetAllEntries() (map[interface{}]interface{}, error)

func (*LRUFastCache) RecordsCount

func (c *LRUFastCache) RecordsCount() (count int, err error)

func (*LRUFastCache) Set

func (c *LRUFastCache) Set(key, value interface{}) (err error)