ristretto

Documentation

Index

• Constants
• func NewStore() pluginkv.Service
• func NewStoreWith(service pluginkv.Service) pluginkv.Service
• func NewTransaction(txn kv.Transaction, store *Store) kv.Transaction
• type Store
  • func (store *Store) EraseCache(key kv.Key) error
  • func (store *Store) EraseCollectionCache(database string, collection string) error
  • func (store *Store) EraseDatabaseCache(database string) error
  • func (store *Store) GeBufferItems() (int64, error)
  • func (store *Store) GeMetrics() (bool, error)
  • func (store *Store) GetMaxCost() (int64, error)
  • func (store *Store) GetNumCounters() (int64, error)
  • func (store *Store) ServiceName() string
  • func (store *Store) ServiceType() plugins.ServiceType
  • func (store *Store) SetCache(obj *kv.Object) error
  • func (store *Store) Start() error
  • func (store Store) Stop() error
  • func (store *Store) Transact(write bool) (kv.Transaction, error)
• type Transaction
  • func (txn *Transaction) Get(key kv.Key) (*kv.Object, error)
  • func (txn *Transaction) GetRange(key kv.Key, opts ...kv.Option) (kv.ResultSet, error)
  • func (txn *Transaction) Set(obj *kv.Object) error

Constants

const (
	NumCounters = "num_counters"
	MaxCost     = "max_cost"
	BufferItems = "buffer_items"
	Metrics     = "metrics"
)

const (
	DefaultNumCounters = 1000
	DefaultMaxCost     = 1000000
	DefaultBufferItems = 64
	DefalutMetrics     = false
)

Functions

func NewStore

func NewStore() pluginkv.Service

NewStore returns a new FoundationDB store instance.

func NewStoreWith

func NewStoreWith(service pluginkv.Service) pluginkv.Service

NewStoreWith returns a new FoundationDB store instance with the specified key coder.

func NewTransaction

func NewTransaction(txn kv.Transaction, store *Store) kv.Transaction

Types

type Store

type Store struct {
	*kvcache.BaseStore
	pluginkv.Service
	Cache *ristretto.Cache
}

Store represents a cache store service instance.

func (*Store) EraseCache

func (store *Store) EraseCache(key kv.Key) error

EraseCache deletes a cache for the specified key.

func (*Store) EraseCollectionCache

func (store *Store) EraseCollectionCache(database string, collection string) error

EraseCollectionCache deletes a cache for the specified collection.

func (*Store) EraseDatabaseCache

func (store *Store) EraseDatabaseCache(database string) error

EraseDatabaseCache deletes a cache for the specified database.

func (*Store) GeBufferItems

func (store *Store) GeBufferItems() (int64, error)

func (*Store) GeMetrics

func (store *Store) GeMetrics() (bool, error)

func (*Store) GetMaxCost

func (store *Store) GetMaxCost() (int64, error)

func (*Store) GetNumCounters

func (store *Store) GetNumCounters() (int64, error)

func (*Store) ServiceName

func (store *Store) ServiceName() string

ServiceName returns the plug-in service name.

func (*Store) ServiceType

func (store *Store) ServiceType() plugins.ServiceType

ServiceType returns the plug-in service type.

func (*Store) SetCache

func (store *Store) SetCache(obj *kv.Object) error

SetCache sets a cache for the specified key.

func (*Store) Start

func (store *Store) Start() error

Start starts the ristretto store.

func (Store) Stop

func (store Store) Stop() error

Stop stops the ristretto store.

func (*Store) Transact

func (store *Store) Transact(write bool) (kv.Transaction, error)

Transact begin a new transaction.

type Transaction

type Transaction struct {
	kv.Transaction
	*Store
}

func (*Transaction) Get

func (txn *Transaction) Get(key kv.Key) (*kv.Object, error)

Get returns a key-value object of the specified key.

func (*Transaction) GetRange

func (txn *Transaction) GetRange(key kv.Key, opts ...kv.Option) (kv.ResultSet, error)

GetRange returns a result set of the specified key.

func (*Transaction) Set

func (txn *Transaction) Set(obj *kv.Object) error

Set stores a key-value object. If the key already holds some value, it is overwritten.