unversioned

Documentation

Index

• type Transactional
  • func (t *Transactional) BeginUpdate() error
  • func (t *Transactional) Close() error
  • func (t *Transactional) Commit() error
  • func (t *Transactional) DeleteState(namespace driver2.Namespace, key driver2.PKey) error
  • func (t *Transactional) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error
  • func (t *Transactional) Discard() error
  • func (t *Transactional) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)
  • func (t *Transactional) GetStateRangeScanIterator(namespace driver2.Namespace, startKey driver2.PKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (t *Transactional) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (t *Transactional) NewWriteTransaction() (driver.UnversionedWriteTransaction, error)
  • func (t *Transactional) SetState(namespace driver2.Namespace, key driver2.PKey, value driver2.RawValue) error
  • func (t *Transactional) SetStates(namespace driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error
  • func (t *Transactional) Stats() any
• type Unversioned
  • func (db *Unversioned) BeginUpdate() error
  • func (db *Unversioned) Close() error
  • func (db *Unversioned) Commit() error
  • func (db *Unversioned) DeleteState(namespace driver2.Namespace, key driver2.PKey) error
  • func (db *Unversioned) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error
  • func (db *Unversioned) Discard() error
  • func (db *Unversioned) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)
  • func (db *Unversioned) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (db *Unversioned) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)
  • func (db *Unversioned) SetState(namespace driver2.Namespace, key driver2.PKey, value driver2.RawValue) error
  • func (db *Unversioned) SetStates(namespace driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error
  • func (db *Unversioned) Stats() any
• type WriteTransaction
  • func (w *WriteTransaction) Commit() error
  • func (w *WriteTransaction) DeleteState(namespace driver2.Namespace, key string) error
  • func (w *WriteTransaction) Discard() error
  • func (w *WriteTransaction) SetState(namespace driver2.Namespace, key string, value []byte) error

Types

type Transactional

type Transactional struct {
	TransactionalVersioned driver.TransactionalVersionedPersistence
}

func (*Transactional) BeginUpdate

func (t *Transactional) BeginUpdate() error

func (*Transactional) Close

func (t *Transactional) Close() error

func (*Transactional) Commit

func (t *Transactional) Commit() error

func (*Transactional) DeleteState

func (t *Transactional) DeleteState(namespace driver2.Namespace, key driver2.PKey) error

func (*Transactional) DeleteStates

func (t *Transactional) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error

func (*Transactional) Discard

func (t *Transactional) Discard() error

func (*Transactional) GetState

func (t *Transactional) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)

func (*Transactional) GetStateRangeScanIterator

func (t *Transactional) GetStateRangeScanIterator(namespace driver2.Namespace, startKey driver2.PKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*Transactional) GetStateSetIterator

func (t *Transactional) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*Transactional) NewWriteTransaction

func (t *Transactional) NewWriteTransaction() (driver.UnversionedWriteTransaction, error)

func (*Transactional) SetState

func (t *Transactional) SetState(namespace driver2.Namespace, key driver2.PKey, value driver2.RawValue) error

func (*Transactional) SetStates

func (t *Transactional) SetStates(namespace driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error

func (*Transactional) Stats

func (t *Transactional) Stats() any

type Unversioned

type Unversioned struct {
	Versioned driver.VersionedPersistence
}

func (*Unversioned) BeginUpdate

func (db *Unversioned) BeginUpdate() error

func (*Unversioned) Close

func (db *Unversioned) Close() error

func (*Unversioned) Commit

func (db *Unversioned) Commit() error

func (*Unversioned) DeleteState

func (db *Unversioned) DeleteState(namespace driver2.Namespace, key driver2.PKey) error

func (*Unversioned) DeleteStates

func (db *Unversioned) DeleteStates(namespace driver2.Namespace, keys ...driver2.PKey) map[driver2.PKey]error

func (*Unversioned) Discard

func (db *Unversioned) Discard() error

func (*Unversioned) GetState

func (db *Unversioned) GetState(namespace driver2.Namespace, key driver2.PKey) (driver2.RawValue, error)

func (*Unversioned) GetStateRangeScanIterator

func (db *Unversioned) GetStateRangeScanIterator(namespace driver2.Namespace, startKey, endKey driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*Unversioned) GetStateSetIterator

func (db *Unversioned) GetStateSetIterator(ns driver2.Namespace, keys ...driver2.PKey) (driver.UnversionedResultsIterator, error)

func (*Unversioned) SetState

func (db *Unversioned) SetState(namespace driver2.Namespace, key driver2.PKey, value driver2.RawValue) error

func (*Unversioned) SetStates

func (db *Unversioned) SetStates(namespace driver2.Namespace, kvs map[driver2.PKey]driver2.RawValue) map[driver2.PKey]error

func (*Unversioned) Stats

func (db *Unversioned) Stats() any

type WriteTransaction

type WriteTransaction struct {
	WriteTransaction driver.WriteTransaction
}

func (*WriteTransaction) Commit

func (w *WriteTransaction) Commit() error

func (*WriteTransaction) DeleteState

func (w *WriteTransaction) DeleteState(namespace driver2.Namespace, key string) error

func (*WriteTransaction) Discard

func (w *WriteTransaction) Discard() error

func (*WriteTransaction) SetState

func (w *WriteTransaction) SetState(namespace driver2.Namespace, key string, value []byte) error