Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

vault

package

Go to main page

Versions in this module

v0

v0.3.0

Oct 5, 2023

Changes in this version

type Inspector

+ Rws readWriteSet

+ func NewInspector() *Inspector

type Interceptor

+ Closed bool

+ QE QueryExecutor

+ Rws readWriteSet

+ TxID string

+ TxIDStore TXIDStoreReader

+ func NewInterceptor(qe QueryExecutor, txidStore TXIDStoreReader, txid string) *Interceptor

+ func (i *Interceptor) Reopen(qe QueryExecutor) error

type Vault

+ Counter atomic.Int32

+ Interceptors map[string]*Interceptor

+ InterceptorsLock sync.RWMutex

+ Store driver.VersionedPersistence

+ StoreLock sync.RWMutex

+ TXIDStore TXIDStore

+ func (db *Vault) GetExistingRWSet(txID string) (*Interceptor, error)

+ func (db *Vault) UnmapInterceptor(txID string) (*Interceptor, error)

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

Changes in this version

+ type Inspector struct

+ func (i *Inspector) AppendRWSet(raw []byte, nss ...string) error

+ func (i *Inspector) Bytes() ([]byte, error)

+ func (i *Inspector) Clear(ns string) error

+ func (i *Inspector) DeleteState(namespace string, key string) error

+ func (i *Inspector) Done()

+ func (i *Inspector) Equals(other interface{}, nss ...string) error

+ func (i *Inspector) GetReadAt(ns string, pos int) (string, []byte, error)

+ func (i *Inspector) GetReadKeyAt(ns string, pos int) (string, error)

+ func (i *Inspector) GetState(namespace string, key string, opts ...driver.GetStateOpt) ([]byte, error)

+ func (i *Inspector) GetStateMetadata(namespace, key string, opts ...driver.GetStateOpt) (map[string][]byte, error)

+ func (i *Inspector) GetWriteAt(ns string, pos int) (string, []byte, error)

+ func (i *Inspector) IsValid() error

+ func (i *Inspector) Namespaces() []string

+ func (i *Inspector) NumReads(ns string) int

+ func (i *Inspector) NumWrites(ns string) int

+ func (i *Inspector) SetState(namespace string, key string, value []byte) error

+ func (i *Inspector) SetStateMetadata(namespace, key string, metadata map[string][]byte) error

+ type Interceptor struct

+ func (i *Interceptor) AppendRWSet(raw []byte, nss ...string) error

+ func (i *Interceptor) Bytes() ([]byte, error)

+ func (i *Interceptor) Clear(ns string) error

+ func (i *Interceptor) DeleteState(namespace string, key string) error

+ func (i *Interceptor) Done()

+ func (i *Interceptor) Equals(other interface{}, nss ...string) error

+ func (i *Interceptor) GetReadAt(ns string, pos int) (string, []byte, error)

+ func (i *Interceptor) GetReadKeyAt(ns string, pos int) (string, error)

+ func (i *Interceptor) GetState(namespace string, key string, opts ...driver.GetStateOpt) ([]byte, error)

+ func (i *Interceptor) GetStateMetadata(namespace, key string, opts ...driver.GetStateOpt) (map[string][]byte, error)

+ func (i *Interceptor) GetWriteAt(ns string, pos int) (string, []byte, error)

+ func (i *Interceptor) IsValid() error

+ func (i *Interceptor) Namespaces() []string

+ func (i *Interceptor) NumReads(ns string) int

+ func (i *Interceptor) NumWrites(ns string) int

+ func (i *Interceptor) SetState(namespace string, key string, value []byte) error

+ func (i *Interceptor) SetStateMetadata(namespace string, key string, value map[string][]byte) error

+ type QueryExecutor interface

+ Done func()

+ GetState func(namespace, key string) ([]byte, uint64, uint64, error)

+ GetStateMetadata func(namespace, key string) (map[string][]byte, uint64, uint64, error)

+ type TXIDStore interface

+ Set func(txid string, code fdriver.ValidationCode) error

+ type TXIDStoreReader interface

+ Get func(txid string) (fdriver.ValidationCode, error)

+ type Vault struct

+ func New(store driver.VersionedPersistence, txIDStore TXIDStore) *Vault

+ func (db *Vault) Close() error

+ func (db *Vault) CommitTX(txid string, block uint64, indexInBloc int) error

+ func (db *Vault) DiscardTx(txid string) error

+ func (db *Vault) GetRWSet(txid string, rwsetBytes []byte) (*Interceptor, error)

+ func (db *Vault) InspectRWSet(rwsetBytes []byte, namespaces ...string) (*Inspector, error)

+ func (db *Vault) Match(txid string, rwsRaw []byte) error

+ func (db *Vault) NewQueryExecutor() (fdriver.QueryExecutor, error)

+ func (db *Vault) NewRWSet(txid string) (*Interceptor, error)

+ func (db *Vault) RWSExists(txid string) bool

+ func (db *Vault) SetBusy(txid string) error

+ func (db *Vault) Status(txid string) (fdriver.ValidationCode, error)