inmemstore

Documentation

Index

• type Batch
  • func (i *Batch) Commit() error
  • func (i *Batch) Delete(item storage.Item) error
  • func (i *Batch) Put(item storage.Item) error
• type Store
  • func New() *Store
  • func (s *Store) Batch(ctx context.Context) (storage.Batch, error)
  • func (s *Store) Close() error
  • func (s *Store) Count(k storage.Key) (int, error)
  • func (s *Store) Delete(i storage.Item) error
  • func (s *Store) Get(i storage.Item) error
  • func (s *Store) GetSize(k storage.Key) (int, error)
  • func (s *Store) Has(k storage.Key) (bool, error)
  • func (s *Store) Iterate(q storage.Query, fn storage.IterateFn) error
  • func (s *Store) Put(i storage.Item) error
• type TxStore
  • func NewTxStore(store storage.BatchedStore) *TxStore
  • func (s *TxStore) Batch(ctx context.Context) (storage.Batch, error)
  • func (s *TxStore) Commit() error
  • func (s *TxStore) Delete(item storage.Item) error
  • func (s *TxStore) NewTx(state *storage.TxState) storage.TxStore
  • func (s *TxStore) Put(item storage.Item) error
  • func (s *TxStore) Rollback() error

Types

type Batch

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

func (*Batch) Commit

func (i *Batch) Commit() error

Commit implements storage.Batch interface Commit method.

func (*Batch) Delete

func (i *Batch) Delete(item storage.Item) error

Delete implements storage.Batch interface Delete method.

func (*Batch) Put

func (i *Batch) Put(item storage.Item) error

Put implements storage.Batch interface Put method.

type Store

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

Store implements an in-memory Store. We will use the hashicorp/go-radix implementation. This pkg provides a mutable radix which gives O(k) lookup and ordered iteration.

func New

func New() *Store

func (*Store) Batch

func (s *Store) Batch(ctx context.Context) (storage.Batch, error)

Batch implements storage.BatchedStore interface Batch method.

func (*Store) Close

func (s *Store) Close() error

func (*Store) Count

func (s *Store) Count(k storage.Key) (int, error)

func (*Store) Delete

func (s *Store) Delete(i storage.Item) error

func (*Store) Get

func (s *Store) Get(i storage.Item) error

func (*Store) GetSize

func (s *Store) GetSize(k storage.Key) (int, error)

func (*Store) Has

func (s *Store) Has(k storage.Key) (bool, error)

func (*Store) Iterate

func (s *Store) Iterate(q storage.Query, fn storage.IterateFn) error

func (*Store) Put

func (s *Store) Put(i storage.Item) error

type TxStore

type TxStore struct {
	*storage.TxStoreBase
	// contains filtered or unexported fields
}

TxStore is an implementation of in-memory Store where all Store operations are done in a transaction.

func NewTxStore

func NewTxStore(store storage.BatchedStore) *TxStore

NewTxStore returns a new TxStore instance backed by the given store.

func (*TxStore) Batch

func (s *TxStore) Batch(ctx context.Context) (storage.Batch, error)

Batch implements the Batcher interface.

func (*TxStore) Commit

func (s *TxStore) Commit() error

Commit implements the Tx interface.

func (*TxStore) Delete

func (s *TxStore) Delete(item storage.Item) error

Delete implements the Store interface.

func (*TxStore) NewTx

func (s *TxStore) NewTx(state *storage.TxState) storage.TxStore

NewTx implements the TxStore interface.

func (*TxStore) Put

func (s *TxStore) Put(item storage.Item) error

Put implements the Store interface.

func (*TxStore) Rollback

func (s *TxStore) Rollback() error

Rollback implements the Tx interface.