vault

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_txid_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ByNum 

type ByNum struct {
	Txid string `protobuf:"bytes,1,opt,name=txid,proto3" json:"txid,omitempty"`
	Code int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*ByNum) Descriptor deprecated 

func (*ByNum) Descriptor() ([]byte, []int)

Deprecated: Use ByNum.ProtoReflect.Descriptor instead.

func (*ByNum) GetCode 

func (x *ByNum) GetCode() int32

func (*ByNum) GetTxid 

func (x *ByNum) GetTxid() string

func (*ByNum) ProtoMessage 

func (*ByNum) ProtoMessage()

func (*ByNum) ProtoReflect 

func (x *ByNum) ProtoReflect() protoreflect.Message

func (*ByNum) Reset 

func (x *ByNum) Reset()

func (*ByNum) String 

func (x *ByNum) String() string

type ByTxid 

type ByTxid struct {
	Pos  uint64 `protobuf:"varint,1,opt,name=pos,proto3" json:"pos,omitempty"`
	Code int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*ByTxid) Descriptor deprecated 

func (*ByTxid) Descriptor() ([]byte, []int)

Deprecated: Use ByTxid.ProtoReflect.Descriptor instead.

func (*ByTxid) GetCode 

func (x *ByTxid) GetCode() int32

func (*ByTxid) GetPos 

func (x *ByTxid) GetPos() uint64

func (*ByTxid) ProtoMessage 

func (*ByTxid) ProtoMessage()

func (*ByTxid) ProtoReflect 

func (x *ByTxid) ProtoReflect() protoreflect.Message

func (*ByTxid) Reset 

func (x *ByTxid) Reset()

func (*ByTxid) String 

func (x *ByTxid) String() string

type Inspector 

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

func (*Inspector) AppendRWSet 

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

func (*Inspector) Bytes 

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

func (*Inspector) Clear 

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

func (*Inspector) DeleteState 

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

func (*Inspector) Done 

func (i *Inspector) Done()

func (*Inspector) Equals 

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

func (*Inspector) GetReadAt 

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

func (*Inspector) GetReadKeyAt 

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

func (*Inspector) GetState 

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

func (*Inspector) GetStateMetadata 

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

func (*Inspector) GetWriteAt 

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

func (*Inspector) IsValid 

func (i *Inspector) IsValid() error

func (*Inspector) Namespaces 

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

func (*Inspector) NumReads 

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

func (*Inspector) NumWrites 

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

func (*Inspector) SetState 

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

func (*Inspector) SetStateMetadata 

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

type Interceptor 

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

func (*Interceptor) AppendRWSet 

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

func (*Interceptor) Bytes 

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

func (*Interceptor) Clear 

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

func (*Interceptor) DeleteState 

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

func (*Interceptor) Done 

func (i *Interceptor) Done()

func (*Interceptor) Equals 

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

func (*Interceptor) GetReadAt 

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

func (*Interceptor) GetReadKeyAt 

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

func (*Interceptor) GetState 

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

func (*Interceptor) GetStateMetadata 

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

func (*Interceptor) GetWriteAt 

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

func (*Interceptor) IsValid 

func (i *Interceptor) IsValid() error

func (*Interceptor) Namespaces 

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

func (*Interceptor) NumReads 

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

func (*Interceptor) NumWrites 

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

func (*Interceptor) SetState 

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

func (*Interceptor) SetStateMetadata 

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

type QueryExecutor 

type QueryExecutor interface {
	GetStateMetadata(namespace, key string) (map[string][]byte, uint64, uint64, error)
	GetState(namespace, key string) ([]byte, uint64, uint64, error)
	Done()
}

type SimpleTXIDStore 

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

func NewSimpleTXIDStore 

func NewSimpleTXIDStore(persistence driver.Persistence) (*SimpleTXIDStore, error)

func (*SimpleTXIDStore) Get 

func (s *SimpleTXIDStore) Get(txid string) (odriver.ValidationCode, error)

func (*SimpleTXIDStore) GetLastTxID 

func (s *SimpleTXIDStore) GetLastTxID() (string, error)

func (*SimpleTXIDStore) Iterator 

func (s *SimpleTXIDStore) Iterator(pos interface{}) (odriver.TxidIterator, error)

func (*SimpleTXIDStore) Set 

func (s *SimpleTXIDStore) Set(txid string, code odriver.ValidationCode) error

type SimpleTxidIterator 

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

func (*SimpleTxidIterator) Close 

func (i *SimpleTxidIterator) Close()

func (*SimpleTxidIterator) Next 

func (i *SimpleTxidIterator) Next() (*odriver.ByNum, error)

type TXIDStore 

type TXIDStore interface {
	TXIDStoreReader
	Set(txid string, code odriver.ValidationCode) error
}

type TXIDStoreReader 

type TXIDStoreReader interface {
	Get(txid string) (odriver.ValidationCode, error)
}

type Vault 

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

Vault models a key-value store that can be modified by committing rwsets

func New 

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

New returns a new instance of Vault

func (*Vault) Close 

func (db *Vault) Close() error

func (*Vault) CommitTX 

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

func (*Vault) DiscardTx 

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

func (*Vault) GetRWSet 

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

func (*Vault) InspectRWSet 

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

func (*Vault) Match 

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

func (*Vault) NewQueryExecutor 

func (db *Vault) NewQueryExecutor() (odriver.QueryExecutor, error)

func (*Vault) NewRWSet 

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

func (*Vault) RWSExists 

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

func (*Vault) SetBusy 

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

func (*Vault) Status 

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

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.