rwsetutil

Documentation

Index

• func NewKVRead(key string, version *version.Height) *kvrwset.KVRead
• func NewVersion(protoVersion *kvrwset.Version) *version.Height
• func SetMerkelSummary(rqi *kvrwset.RangeQueryInfo, merkleSummary *kvrwset.QueryReadsMerkleSummary)
• func SetRawReads(rqi *kvrwset.RangeQueryInfo, kvReads []*kvrwset.KVRead)
• type CollHashedRwSet
• type CollPvtRwSet
• type Hash
• type MerkleTreeLevel
• type NsPvtRwSet
• type NsRwSet
• type RWSetBuilder
  • func NewRWSetBuilder() *RWSetBuilder
  • func (b *RWSetBuilder) AddToHashedMetadataWriteSet(ns, coll, key string, metadata map[string][]byte)
  • func (b *RWSetBuilder) AddToHashedReadSet(ns string, coll string, key string, version *version.Height)
  • func (b *RWSetBuilder) AddToMetadataWriteSet(ns, key string, metadata map[string][]byte)
  • func (b *RWSetBuilder) AddToPvtAndHashedWriteSet(ns string, coll string, key string, value []byte)
  • func (b *RWSetBuilder) AddToRangeQuerySet(ns string, rqi *kvrwset.RangeQueryInfo)
  • func (b *RWSetBuilder) AddToReadSet(ns string, key string, version *version.Height)
  • func (b *RWSetBuilder) AddToWriteSet(ns string, key string, value []byte)
  • func (b *RWSetBuilder) GetTxReadWriteSet() *TxRwSet
  • func (b *RWSetBuilder) GetTxSimulationResults() (*ledger.TxSimulationResults, error)
• type RangeQueryResultsHelper
  • func NewRangeQueryResultsHelper(enableHashing bool, maxDegree uint32) (*RangeQueryResultsHelper, error)
  • func (helper *RangeQueryResultsHelper) AddResult(kvRead *kvrwset.KVRead) error
  • func (helper *RangeQueryResultsHelper) Done() ([]*kvrwset.KVRead, *kvrwset.QueryReadsMerkleSummary, error)
  • func (helper *RangeQueryResultsHelper) GetMerkleSummary() *kvrwset.QueryReadsMerkleSummary
• type TxPvtRwSet
  • func TxPvtRwSetFromProtoMsg(protoMsg *rwset.TxPvtReadWriteSet) (*TxPvtRwSet, error)
  • func (txPvtRwSet *TxPvtRwSet) FromProtoBytes(protoBytes []byte) error
  • func (txPvtRwSet *TxPvtRwSet) ToProtoBytes() ([]byte, error)
• type TxRwSet
  • func TxRwSetFromProtoMsg(protoMsg *rwset.TxReadWriteSet) (*TxRwSet, error)
  • func (txRwSet *TxRwSet) FromProtoBytes(protoBytes []byte) error
  • func (txRwSet *TxRwSet) GetPvtDataHash(ns, coll string) []byte
  • func (txRwSet *TxRwSet) NumCollections() int
  • func (txRwSet *TxRwSet) ToProtoBytes() ([]byte, error)

Functions

func NewKVRead

func NewKVRead(key string, version *version.Height) *kvrwset.KVRead

func NewVersion

func NewVersion(protoVersion *kvrwset.Version) *version.Height

func SetMerkelSummary

func SetMerkelSummary(rqi *kvrwset.RangeQueryInfo, merkleSummary *kvrwset.QueryReadsMerkleSummary)

func SetRawReads

func SetRawReads(rqi *kvrwset.RangeQueryInfo, kvReads []*kvrwset.KVRead)

Types

type CollHashedRwSet

type CollHashedRwSet struct {
	CollectionName string
	HashedRwSet    *kvrwset.HashedRWSet
	PvtRwSetHash   []byte
}

type CollPvtRwSet

type CollPvtRwSet struct {
	CollectionName string
	KvRwSet        *kvrwset.KVRWSet
}

type Hash

type Hash []byte

type MerkleTreeLevel

type MerkleTreeLevel uint32

type NsPvtRwSet

type NsPvtRwSet struct {
	NameSpace     string
	CollPvtRwSets []*CollPvtRwSet
}

type NsRwSet

type NsRwSet struct {
	NameSpace        string
	KvRwSet          *kvrwset.KVRWSet
	CollHashedRwSets []*CollHashedRwSet
}

type RWSetBuilder

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

func NewRWSetBuilder

func NewRWSetBuilder() *RWSetBuilder

func (*RWSetBuilder) AddToHashedMetadataWriteSet

func (b *RWSetBuilder) AddToHashedMetadataWriteSet(ns, coll, key string, metadata map[string][]byte)

func (*RWSetBuilder) AddToHashedReadSet

func (b *RWSetBuilder) AddToHashedReadSet(ns string, coll string, key string, version *version.Height)

func (*RWSetBuilder) AddToMetadataWriteSet

func (b *RWSetBuilder) AddToMetadataWriteSet(ns, key string, metadata map[string][]byte)

func (*RWSetBuilder) AddToPvtAndHashedWriteSet

func (b *RWSetBuilder) AddToPvtAndHashedWriteSet(ns string, coll string, key string, value []byte)

func (*RWSetBuilder) AddToRangeQuerySet

func (b *RWSetBuilder) AddToRangeQuerySet(ns string, rqi *kvrwset.RangeQueryInfo)

func (*RWSetBuilder) AddToReadSet

func (b *RWSetBuilder) AddToReadSet(ns string, key string, version *version.Height)

func (*RWSetBuilder) AddToWriteSet

func (b *RWSetBuilder) AddToWriteSet(ns string, key string, value []byte)

func (*RWSetBuilder) GetTxReadWriteSet

func (b *RWSetBuilder) GetTxReadWriteSet() *TxRwSet

func (*RWSetBuilder) GetTxSimulationResults

func (b *RWSetBuilder) GetTxSimulationResults() (*ledger.TxSimulationResults, error)

type RangeQueryResultsHelper

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

func NewRangeQueryResultsHelper

func NewRangeQueryResultsHelper(enableHashing bool, maxDegree uint32) (*RangeQueryResultsHelper, error)

func (*RangeQueryResultsHelper) AddResult

func (helper *RangeQueryResultsHelper) AddResult(kvRead *kvrwset.KVRead) error

func (*RangeQueryResultsHelper) Done

func (helper *RangeQueryResultsHelper) Done() ([]*kvrwset.KVRead, *kvrwset.QueryReadsMerkleSummary, error)

func (*RangeQueryResultsHelper) GetMerkleSummary

func (helper *RangeQueryResultsHelper) GetMerkleSummary() *kvrwset.QueryReadsMerkleSummary

type TxPvtRwSet

type TxPvtRwSet struct {
	NsPvtRwSet []*NsPvtRwSet
}

func TxPvtRwSetFromProtoMsg

func TxPvtRwSetFromProtoMsg(protoMsg *rwset.TxPvtReadWriteSet) (*TxPvtRwSet, error)

func (*TxPvtRwSet) FromProtoBytes

func (txPvtRwSet *TxPvtRwSet) FromProtoBytes(protoBytes []byte) error

func (*TxPvtRwSet) ToProtoBytes

func (txPvtRwSet *TxPvtRwSet) ToProtoBytes() ([]byte, error)

type TxRwSet

type TxRwSet struct {
	NsRwSets []*NsRwSet
}

func TxRwSetFromProtoMsg

func TxRwSetFromProtoMsg(protoMsg *rwset.TxReadWriteSet) (*TxRwSet, error)

func (*TxRwSet) FromProtoBytes

func (txRwSet *TxRwSet) FromProtoBytes(protoBytes []byte) error

func (*TxRwSet) GetPvtDataHash

func (txRwSet *TxRwSet) GetPvtDataHash(ns, coll string) []byte

func (*TxRwSet) NumCollections

func (txRwSet *TxRwSet) NumCollections() int

func (*TxRwSet) ToProtoBytes

func (txRwSet *TxRwSet) ToProtoBytes() ([]byte, error)