Documentation ¶
Index ¶
- type HashedRWSet
- func (*HashedRWSet) Descriptor() ([]byte, []int)
- func (m *HashedRWSet) GetHashedReads() []*KVReadHash
- func (m *HashedRWSet) GetHashedWrites() []*KVWriteHash
- func (m *HashedRWSet) GetMetadataWrites() []*KVMetadataWriteHash
- func (*HashedRWSet) ProtoMessage()
- func (m *HashedRWSet) Reset()
- func (m *HashedRWSet) String() string
- func (m *HashedRWSet) XXX_DiscardUnknown()
- func (m *HashedRWSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HashedRWSet) XXX_Merge(src proto.Message)
- func (m *HashedRWSet) XXX_Size() int
- func (m *HashedRWSet) XXX_Unmarshal(b []byte) error
- type KVMetadataEntry
- func (*KVMetadataEntry) Descriptor() ([]byte, []int)
- func (m *KVMetadataEntry) GetName() string
- func (m *KVMetadataEntry) GetValue() []byte
- func (*KVMetadataEntry) ProtoMessage()
- func (m *KVMetadataEntry) Reset()
- func (m *KVMetadataEntry) String() string
- func (m *KVMetadataEntry) XXX_DiscardUnknown()
- func (m *KVMetadataEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVMetadataEntry) XXX_Merge(src proto.Message)
- func (m *KVMetadataEntry) XXX_Size() int
- func (m *KVMetadataEntry) XXX_Unmarshal(b []byte) error
- type KVMetadataWrite
- func (*KVMetadataWrite) Descriptor() ([]byte, []int)
- func (m *KVMetadataWrite) GetEntries() []*KVMetadataEntry
- func (m *KVMetadataWrite) GetKey() string
- func (*KVMetadataWrite) ProtoMessage()
- func (m *KVMetadataWrite) Reset()
- func (m *KVMetadataWrite) String() string
- func (m *KVMetadataWrite) XXX_DiscardUnknown()
- func (m *KVMetadataWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVMetadataWrite) XXX_Merge(src proto.Message)
- func (m *KVMetadataWrite) XXX_Size() int
- func (m *KVMetadataWrite) XXX_Unmarshal(b []byte) error
- type KVMetadataWriteHash
- func (*KVMetadataWriteHash) Descriptor() ([]byte, []int)
- func (m *KVMetadataWriteHash) GetEntries() []*KVMetadataEntry
- func (m *KVMetadataWriteHash) GetKeyHash() []byte
- func (*KVMetadataWriteHash) ProtoMessage()
- func (m *KVMetadataWriteHash) Reset()
- func (m *KVMetadataWriteHash) String() string
- func (m *KVMetadataWriteHash) XXX_DiscardUnknown()
- func (m *KVMetadataWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVMetadataWriteHash) XXX_Merge(src proto.Message)
- func (m *KVMetadataWriteHash) XXX_Size() int
- func (m *KVMetadataWriteHash) XXX_Unmarshal(b []byte) error
- type KVRWSet
- func (*KVRWSet) Descriptor() ([]byte, []int)
- func (m *KVRWSet) GetMetadataWrites() []*KVMetadataWrite
- func (m *KVRWSet) GetRangeQueriesInfo() []*RangeQueryInfo
- func (m *KVRWSet) GetReads() []*KVRead
- func (m *KVRWSet) GetWrites() []*KVWrite
- func (*KVRWSet) ProtoMessage()
- func (m *KVRWSet) Reset()
- func (m *KVRWSet) String() string
- func (m *KVRWSet) XXX_DiscardUnknown()
- func (m *KVRWSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVRWSet) XXX_Merge(src proto.Message)
- func (m *KVRWSet) XXX_Size() int
- func (m *KVRWSet) XXX_Unmarshal(b []byte) error
- type KVRead
- func (*KVRead) Descriptor() ([]byte, []int)
- func (m *KVRead) GetKey() string
- func (m *KVRead) GetVersion() *Version
- func (*KVRead) ProtoMessage()
- func (m *KVRead) Reset()
- func (m *KVRead) String() string
- func (m *KVRead) XXX_DiscardUnknown()
- func (m *KVRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVRead) XXX_Merge(src proto.Message)
- func (m *KVRead) XXX_Size() int
- func (m *KVRead) XXX_Unmarshal(b []byte) error
- type KVReadHash
- func (*KVReadHash) Descriptor() ([]byte, []int)
- func (m *KVReadHash) GetKeyHash() []byte
- func (m *KVReadHash) GetVersion() *Version
- func (*KVReadHash) ProtoMessage()
- func (m *KVReadHash) Reset()
- func (m *KVReadHash) String() string
- func (m *KVReadHash) XXX_DiscardUnknown()
- func (m *KVReadHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVReadHash) XXX_Merge(src proto.Message)
- func (m *KVReadHash) XXX_Size() int
- func (m *KVReadHash) XXX_Unmarshal(b []byte) error
- type KVWrite
- func (*KVWrite) Descriptor() ([]byte, []int)
- func (m *KVWrite) GetIsDelete() bool
- func (m *KVWrite) GetKey() string
- func (m *KVWrite) GetValue() []byte
- func (*KVWrite) ProtoMessage()
- func (m *KVWrite) Reset()
- func (m *KVWrite) String() string
- func (m *KVWrite) XXX_DiscardUnknown()
- func (m *KVWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVWrite) XXX_Merge(src proto.Message)
- func (m *KVWrite) XXX_Size() int
- func (m *KVWrite) XXX_Unmarshal(b []byte) error
- type KVWriteHash
- func (*KVWriteHash) Descriptor() ([]byte, []int)
- func (m *KVWriteHash) GetIsDelete() bool
- func (m *KVWriteHash) GetKeyHash() []byte
- func (m *KVWriteHash) GetValueHash() []byte
- func (*KVWriteHash) ProtoMessage()
- func (m *KVWriteHash) Reset()
- func (m *KVWriteHash) String() string
- func (m *KVWriteHash) XXX_DiscardUnknown()
- func (m *KVWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *KVWriteHash) XXX_Merge(src proto.Message)
- func (m *KVWriteHash) XXX_Size() int
- func (m *KVWriteHash) XXX_Unmarshal(b []byte) error
- type QueryReads
- func (*QueryReads) Descriptor() ([]byte, []int)
- func (m *QueryReads) GetKvReads() []*KVRead
- func (*QueryReads) ProtoMessage()
- func (m *QueryReads) Reset()
- func (m *QueryReads) String() string
- func (m *QueryReads) XXX_DiscardUnknown()
- func (m *QueryReads) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *QueryReads) XXX_Merge(src proto.Message)
- func (m *QueryReads) XXX_Size() int
- func (m *QueryReads) XXX_Unmarshal(b []byte) error
- type QueryReadsMerkleSummary
- func (*QueryReadsMerkleSummary) Descriptor() ([]byte, []int)
- func (ms *QueryReadsMerkleSummary) Equal(anotherMS *QueryReadsMerkleSummary) bool
- func (m *QueryReadsMerkleSummary) GetMaxDegree() uint32
- func (m *QueryReadsMerkleSummary) GetMaxLevel() uint32
- func (m *QueryReadsMerkleSummary) GetMaxLevelHashes() [][]byte
- func (*QueryReadsMerkleSummary) ProtoMessage()
- func (m *QueryReadsMerkleSummary) Reset()
- func (m *QueryReadsMerkleSummary) String() string
- func (m *QueryReadsMerkleSummary) XXX_DiscardUnknown()
- func (m *QueryReadsMerkleSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *QueryReadsMerkleSummary) XXX_Merge(src proto.Message)
- func (m *QueryReadsMerkleSummary) XXX_Size() int
- func (m *QueryReadsMerkleSummary) XXX_Unmarshal(b []byte) error
- type RangeQueryInfo
- func (*RangeQueryInfo) Descriptor() ([]byte, []int)
- func (m *RangeQueryInfo) GetEndKey() string
- func (m *RangeQueryInfo) GetItrExhausted() bool
- func (m *RangeQueryInfo) GetRawReads() *QueryReads
- func (m *RangeQueryInfo) GetReadsInfo() isRangeQueryInfo_ReadsInfo
- func (m *RangeQueryInfo) GetReadsMerkleHashes() *QueryReadsMerkleSummary
- func (m *RangeQueryInfo) GetStartKey() string
- func (*RangeQueryInfo) ProtoMessage()
- func (m *RangeQueryInfo) Reset()
- func (rqi *RangeQueryInfo) SetMerkelSummary(merkleSummary *QueryReadsMerkleSummary)
- func (rqi *RangeQueryInfo) SetRawReads(kvReads []*KVRead)
- func (m *RangeQueryInfo) String() string
- func (m *RangeQueryInfo) XXX_DiscardUnknown()
- func (m *RangeQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RangeQueryInfo) XXX_Merge(src proto.Message)
- func (*RangeQueryInfo) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *RangeQueryInfo) XXX_Size() int
- func (m *RangeQueryInfo) XXX_Unmarshal(b []byte) error
- type RangeQueryInfo_RawReads
- type RangeQueryInfo_ReadsMerkleHashes
- type Version
- func (*Version) Descriptor() ([]byte, []int)
- func (m *Version) GetBlockNum() uint64
- func (m *Version) GetTxNum() uint64
- func (*Version) ProtoMessage()
- func (m *Version) Reset()
- func (m *Version) String() string
- func (m *Version) XXX_DiscardUnknown()
- func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Version) XXX_Merge(src proto.Message)
- func (m *Version) XXX_Size() int
- func (m *Version) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HashedRWSet ¶ added in v1.1.0
type HashedRWSet struct { HashedReads []*KVReadHash `protobuf:"bytes,1,rep,name=hashed_reads,json=hashedReads" json:"hashed_reads,omitempty"` HashedWrites []*KVWriteHash `protobuf:"bytes,2,rep,name=hashed_writes,json=hashedWrites" json:"hashed_writes,omitempty"` MetadataWrites []*KVMetadataWriteHash `protobuf:"bytes,3,rep,name=metadata_writes,json=metadataWrites" json:"metadata_writes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
HashedRWSet encapsulates hashed representation of a private read-write set for KV or Document data model
func (*HashedRWSet) Descriptor ¶ added in v1.1.0
func (*HashedRWSet) Descriptor() ([]byte, []int)
func (*HashedRWSet) GetHashedReads ¶ added in v1.1.0
func (m *HashedRWSet) GetHashedReads() []*KVReadHash
func (*HashedRWSet) GetHashedWrites ¶ added in v1.1.0
func (m *HashedRWSet) GetHashedWrites() []*KVWriteHash
func (*HashedRWSet) GetMetadataWrites ¶ added in v1.2.0
func (m *HashedRWSet) GetMetadataWrites() []*KVMetadataWriteHash
func (*HashedRWSet) ProtoMessage ¶ added in v1.1.0
func (*HashedRWSet) ProtoMessage()
func (*HashedRWSet) Reset ¶ added in v1.1.0
func (m *HashedRWSet) Reset()
func (*HashedRWSet) String ¶ added in v1.1.0
func (m *HashedRWSet) String() string
func (*HashedRWSet) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *HashedRWSet) XXX_DiscardUnknown()
func (*HashedRWSet) XXX_Marshal ¶ added in v1.3.0
func (m *HashedRWSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HashedRWSet) XXX_Merge ¶ added in v1.3.0
func (dst *HashedRWSet) XXX_Merge(src proto.Message)
func (*HashedRWSet) XXX_Size ¶ added in v1.3.0
func (m *HashedRWSet) XXX_Size() int
func (*HashedRWSet) XXX_Unmarshal ¶ added in v1.3.0
func (m *HashedRWSet) XXX_Unmarshal(b []byte) error
type KVMetadataEntry ¶ added in v1.2.0
type KVMetadataEntry struct { Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVMetadataEntry captures a 'name'ed entry in the metadata of a key/key-hash.
func (*KVMetadataEntry) Descriptor ¶ added in v1.2.0
func (*KVMetadataEntry) Descriptor() ([]byte, []int)
func (*KVMetadataEntry) GetName ¶ added in v1.2.0
func (m *KVMetadataEntry) GetName() string
func (*KVMetadataEntry) GetValue ¶ added in v1.2.0
func (m *KVMetadataEntry) GetValue() []byte
func (*KVMetadataEntry) ProtoMessage ¶ added in v1.2.0
func (*KVMetadataEntry) ProtoMessage()
func (*KVMetadataEntry) Reset ¶ added in v1.2.0
func (m *KVMetadataEntry) Reset()
func (*KVMetadataEntry) String ¶ added in v1.2.0
func (m *KVMetadataEntry) String() string
func (*KVMetadataEntry) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVMetadataEntry) XXX_DiscardUnknown()
func (*KVMetadataEntry) XXX_Marshal ¶ added in v1.3.0
func (m *KVMetadataEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KVMetadataEntry) XXX_Merge ¶ added in v1.3.0
func (dst *KVMetadataEntry) XXX_Merge(src proto.Message)
func (*KVMetadataEntry) XXX_Size ¶ added in v1.3.0
func (m *KVMetadataEntry) XXX_Size() int
func (*KVMetadataEntry) XXX_Unmarshal ¶ added in v1.3.0
func (m *KVMetadataEntry) XXX_Unmarshal(b []byte) error
type KVMetadataWrite ¶ added in v1.2.0
type KVMetadataWrite struct { Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Entries []*KVMetadataEntry `protobuf:"bytes,2,rep,name=entries" json:"entries,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVMetadataWrite captures all the entries in the metadata associated with a key
func (*KVMetadataWrite) Descriptor ¶ added in v1.2.0
func (*KVMetadataWrite) Descriptor() ([]byte, []int)
func (*KVMetadataWrite) GetEntries ¶ added in v1.2.0
func (m *KVMetadataWrite) GetEntries() []*KVMetadataEntry
func (*KVMetadataWrite) GetKey ¶ added in v1.2.0
func (m *KVMetadataWrite) GetKey() string
func (*KVMetadataWrite) ProtoMessage ¶ added in v1.2.0
func (*KVMetadataWrite) ProtoMessage()
func (*KVMetadataWrite) Reset ¶ added in v1.2.0
func (m *KVMetadataWrite) Reset()
func (*KVMetadataWrite) String ¶ added in v1.2.0
func (m *KVMetadataWrite) String() string
func (*KVMetadataWrite) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVMetadataWrite) XXX_DiscardUnknown()
func (*KVMetadataWrite) XXX_Marshal ¶ added in v1.3.0
func (m *KVMetadataWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KVMetadataWrite) XXX_Merge ¶ added in v1.3.0
func (dst *KVMetadataWrite) XXX_Merge(src proto.Message)
func (*KVMetadataWrite) XXX_Size ¶ added in v1.3.0
func (m *KVMetadataWrite) XXX_Size() int
func (*KVMetadataWrite) XXX_Unmarshal ¶ added in v1.3.0
func (m *KVMetadataWrite) XXX_Unmarshal(b []byte) error
type KVMetadataWriteHash ¶ added in v1.2.0
type KVMetadataWriteHash struct { KeyHash []byte `protobuf:"bytes,1,opt,name=key_hash,json=keyHash,proto3" json:"key_hash,omitempty"` Entries []*KVMetadataEntry `protobuf:"bytes,2,rep,name=entries" json:"entries,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVMetadataWriteHash captures all the upserts to the metadata associated with a key hash
func (*KVMetadataWriteHash) Descriptor ¶ added in v1.2.0
func (*KVMetadataWriteHash) Descriptor() ([]byte, []int)
func (*KVMetadataWriteHash) GetEntries ¶ added in v1.2.0
func (m *KVMetadataWriteHash) GetEntries() []*KVMetadataEntry
func (*KVMetadataWriteHash) GetKeyHash ¶ added in v1.2.0
func (m *KVMetadataWriteHash) GetKeyHash() []byte
func (*KVMetadataWriteHash) ProtoMessage ¶ added in v1.2.0
func (*KVMetadataWriteHash) ProtoMessage()
func (*KVMetadataWriteHash) Reset ¶ added in v1.2.0
func (m *KVMetadataWriteHash) Reset()
func (*KVMetadataWriteHash) String ¶ added in v1.2.0
func (m *KVMetadataWriteHash) String() string
func (*KVMetadataWriteHash) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVMetadataWriteHash) XXX_DiscardUnknown()
func (*KVMetadataWriteHash) XXX_Marshal ¶ added in v1.3.0
func (m *KVMetadataWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KVMetadataWriteHash) XXX_Merge ¶ added in v1.3.0
func (dst *KVMetadataWriteHash) XXX_Merge(src proto.Message)
func (*KVMetadataWriteHash) XXX_Size ¶ added in v1.3.0
func (m *KVMetadataWriteHash) XXX_Size() int
func (*KVMetadataWriteHash) XXX_Unmarshal ¶ added in v1.3.0
func (m *KVMetadataWriteHash) XXX_Unmarshal(b []byte) error
type KVRWSet ¶
type KVRWSet struct { Reads []*KVRead `protobuf:"bytes,1,rep,name=reads" json:"reads,omitempty"` RangeQueriesInfo []*RangeQueryInfo `protobuf:"bytes,2,rep,name=range_queries_info,json=rangeQueriesInfo" json:"range_queries_info,omitempty"` Writes []*KVWrite `protobuf:"bytes,3,rep,name=writes" json:"writes,omitempty"` MetadataWrites []*KVMetadataWrite `protobuf:"bytes,4,rep,name=metadata_writes,json=metadataWrites" json:"metadata_writes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVRWSet encapsulates the read-write set for a chaincode that operates upon a KV or Document data model This structure is used for both the public data and the private data
func (*KVRWSet) Descriptor ¶
func (*KVRWSet) GetMetadataWrites ¶ added in v1.2.0
func (m *KVRWSet) GetMetadataWrites() []*KVMetadataWrite
func (*KVRWSet) GetRangeQueriesInfo ¶
func (m *KVRWSet) GetRangeQueriesInfo() []*RangeQueryInfo
func (*KVRWSet) ProtoMessage ¶
func (*KVRWSet) ProtoMessage()
func (*KVRWSet) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVRWSet) XXX_DiscardUnknown()
func (*KVRWSet) XXX_Marshal ¶ added in v1.3.0
func (*KVRWSet) XXX_Unmarshal ¶ added in v1.3.0
type KVRead ¶
type KVRead struct { Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` Version *Version `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVRead captures a read operation performed during transaction simulation A 'nil' version indicates a non-existing key read by the transaction
func (*KVRead) Descriptor ¶
func (*KVRead) GetVersion ¶
func (*KVRead) ProtoMessage ¶
func (*KVRead) ProtoMessage()
func (*KVRead) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVRead) XXX_DiscardUnknown()
func (*KVRead) XXX_Marshal ¶ added in v1.3.0
func (*KVRead) XXX_Unmarshal ¶ added in v1.3.0
type KVReadHash ¶ added in v1.1.0
type KVReadHash struct { KeyHash []byte `protobuf:"bytes,1,opt,name=key_hash,json=keyHash,proto3" json:"key_hash,omitempty"` Version *Version `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVReadHash is similar to the KVRead in spirit. However, it captures the hash of the key instead of the key itself version is kept as is for now. However, if the version also needs to be privacy-protected, it would need to be the hash of the version and hence of 'bytes' type
func (*KVReadHash) Descriptor ¶ added in v1.1.0
func (*KVReadHash) Descriptor() ([]byte, []int)
func (*KVReadHash) GetKeyHash ¶ added in v1.1.0
func (m *KVReadHash) GetKeyHash() []byte
func (*KVReadHash) GetVersion ¶ added in v1.1.0
func (m *KVReadHash) GetVersion() *Version
func (*KVReadHash) ProtoMessage ¶ added in v1.1.0
func (*KVReadHash) ProtoMessage()
func (*KVReadHash) Reset ¶ added in v1.1.0
func (m *KVReadHash) Reset()
func (*KVReadHash) String ¶ added in v1.1.0
func (m *KVReadHash) String() string
func (*KVReadHash) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVReadHash) XXX_DiscardUnknown()
func (*KVReadHash) XXX_Marshal ¶ added in v1.3.0
func (m *KVReadHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KVReadHash) XXX_Merge ¶ added in v1.3.0
func (dst *KVReadHash) XXX_Merge(src proto.Message)
func (*KVReadHash) XXX_Size ¶ added in v1.3.0
func (m *KVReadHash) XXX_Size() int
func (*KVReadHash) XXX_Unmarshal ¶ added in v1.3.0
func (m *KVReadHash) XXX_Unmarshal(b []byte) error
type KVWrite ¶
type KVWrite struct { Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"` IsDelete bool `protobuf:"varint,2,opt,name=is_delete,json=isDelete" json:"is_delete,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVWrite captures a write (update/delete) operation performed during transaction simulation
func (*KVWrite) Descriptor ¶
func (*KVWrite) GetIsDelete ¶
func (*KVWrite) ProtoMessage ¶
func (*KVWrite) ProtoMessage()
func (*KVWrite) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVWrite) XXX_DiscardUnknown()
func (*KVWrite) XXX_Marshal ¶ added in v1.3.0
func (*KVWrite) XXX_Unmarshal ¶ added in v1.3.0
type KVWriteHash ¶ added in v1.1.0
type KVWriteHash struct { KeyHash []byte `protobuf:"bytes,1,opt,name=key_hash,json=keyHash,proto3" json:"key_hash,omitempty"` IsDelete bool `protobuf:"varint,2,opt,name=is_delete,json=isDelete" json:"is_delete,omitempty"` ValueHash []byte `protobuf:"bytes,3,opt,name=value_hash,json=valueHash,proto3" json:"value_hash,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KVWriteHash is similar to the KVWrite. It captures a write (update/delete) operation performed during transaction simulation
func (*KVWriteHash) Descriptor ¶ added in v1.1.0
func (*KVWriteHash) Descriptor() ([]byte, []int)
func (*KVWriteHash) GetIsDelete ¶ added in v1.1.0
func (m *KVWriteHash) GetIsDelete() bool
func (*KVWriteHash) GetKeyHash ¶ added in v1.1.0
func (m *KVWriteHash) GetKeyHash() []byte
func (*KVWriteHash) GetValueHash ¶ added in v1.1.0
func (m *KVWriteHash) GetValueHash() []byte
func (*KVWriteHash) ProtoMessage ¶ added in v1.1.0
func (*KVWriteHash) ProtoMessage()
func (*KVWriteHash) Reset ¶ added in v1.1.0
func (m *KVWriteHash) Reset()
func (*KVWriteHash) String ¶ added in v1.1.0
func (m *KVWriteHash) String() string
func (*KVWriteHash) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *KVWriteHash) XXX_DiscardUnknown()
func (*KVWriteHash) XXX_Marshal ¶ added in v1.3.0
func (m *KVWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KVWriteHash) XXX_Merge ¶ added in v1.3.0
func (dst *KVWriteHash) XXX_Merge(src proto.Message)
func (*KVWriteHash) XXX_Size ¶ added in v1.3.0
func (m *KVWriteHash) XXX_Size() int
func (*KVWriteHash) XXX_Unmarshal ¶ added in v1.3.0
func (m *KVWriteHash) XXX_Unmarshal(b []byte) error
type QueryReads ¶
type QueryReads struct { KvReads []*KVRead `protobuf:"bytes,1,rep,name=kv_reads,json=kvReads" json:"kv_reads,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryReads encapsulates the KVReads for the items read by a transaction as a result of a query execution
func (*QueryReads) Descriptor ¶
func (*QueryReads) Descriptor() ([]byte, []int)
func (*QueryReads) GetKvReads ¶
func (m *QueryReads) GetKvReads() []*KVRead
func (*QueryReads) ProtoMessage ¶
func (*QueryReads) ProtoMessage()
func (*QueryReads) Reset ¶
func (m *QueryReads) Reset()
func (*QueryReads) String ¶
func (m *QueryReads) String() string
func (*QueryReads) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *QueryReads) XXX_DiscardUnknown()
func (*QueryReads) XXX_Marshal ¶ added in v1.3.0
func (m *QueryReads) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryReads) XXX_Merge ¶ added in v1.3.0
func (dst *QueryReads) XXX_Merge(src proto.Message)
func (*QueryReads) XXX_Size ¶ added in v1.3.0
func (m *QueryReads) XXX_Size() int
func (*QueryReads) XXX_Unmarshal ¶ added in v1.3.0
func (m *QueryReads) XXX_Unmarshal(b []byte) error
type QueryReadsMerkleSummary ¶
type QueryReadsMerkleSummary struct { MaxDegree uint32 `protobuf:"varint,1,opt,name=max_degree,json=maxDegree" json:"max_degree,omitempty"` MaxLevel uint32 `protobuf:"varint,2,opt,name=max_level,json=maxLevel" json:"max_level,omitempty"` MaxLevelHashes [][]byte `protobuf:"bytes,3,rep,name=max_level_hashes,json=maxLevelHashes,proto3" json:"max_level_hashes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryReadsMerkleSummary encapsulates the Merkle-tree hashes for the QueryReads This allows to reduce the size of RWSet in the presence of query results by storing certain hashes instead of actual results. maxDegree field refers to the maximum number of children in the tree at any level maxLevel field contains the lowest level which has lesser nodes than maxDegree (starting from leaf level)
func (*QueryReadsMerkleSummary) Descriptor ¶
func (*QueryReadsMerkleSummary) Descriptor() ([]byte, []int)
func (*QueryReadsMerkleSummary) Equal ¶
func (ms *QueryReadsMerkleSummary) Equal(anotherMS *QueryReadsMerkleSummary) bool
Equal verifies whether the give MerkleSummary is equals to this
func (*QueryReadsMerkleSummary) GetMaxDegree ¶
func (m *QueryReadsMerkleSummary) GetMaxDegree() uint32
func (*QueryReadsMerkleSummary) GetMaxLevel ¶
func (m *QueryReadsMerkleSummary) GetMaxLevel() uint32
func (*QueryReadsMerkleSummary) GetMaxLevelHashes ¶
func (m *QueryReadsMerkleSummary) GetMaxLevelHashes() [][]byte
func (*QueryReadsMerkleSummary) ProtoMessage ¶
func (*QueryReadsMerkleSummary) ProtoMessage()
func (*QueryReadsMerkleSummary) Reset ¶
func (m *QueryReadsMerkleSummary) Reset()
func (*QueryReadsMerkleSummary) String ¶
func (m *QueryReadsMerkleSummary) String() string
func (*QueryReadsMerkleSummary) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *QueryReadsMerkleSummary) XXX_DiscardUnknown()
func (*QueryReadsMerkleSummary) XXX_Marshal ¶ added in v1.3.0
func (m *QueryReadsMerkleSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryReadsMerkleSummary) XXX_Merge ¶ added in v1.3.0
func (dst *QueryReadsMerkleSummary) XXX_Merge(src proto.Message)
func (*QueryReadsMerkleSummary) XXX_Size ¶ added in v1.3.0
func (m *QueryReadsMerkleSummary) XXX_Size() int
func (*QueryReadsMerkleSummary) XXX_Unmarshal ¶ added in v1.3.0
func (m *QueryReadsMerkleSummary) XXX_Unmarshal(b []byte) error
type RangeQueryInfo ¶
type RangeQueryInfo struct { StartKey string `protobuf:"bytes,1,opt,name=start_key,json=startKey" json:"start_key,omitempty"` EndKey string `protobuf:"bytes,2,opt,name=end_key,json=endKey" json:"end_key,omitempty"` ItrExhausted bool `protobuf:"varint,3,opt,name=itr_exhausted,json=itrExhausted" json:"itr_exhausted,omitempty"` // Types that are valid to be assigned to ReadsInfo: // *RangeQueryInfo_RawReads // *RangeQueryInfo_ReadsMerkleHashes ReadsInfo isRangeQueryInfo_ReadsInfo `protobuf_oneof:"reads_info"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RangeQueryInfo encapsulates the details of a range query performed by a transaction during simulation. This helps protect transactions from phantom reads by varifying during validation whether any new items got committed within the given range between transaction simuation and validation (in addition to regular checks for updates/deletes of the existing items). readInfo field contains either the KVReads (for the items read by the range query) or a merkle-tree hash if the KVReads exceeds a pre-configured numbers
func (*RangeQueryInfo) Descriptor ¶
func (*RangeQueryInfo) Descriptor() ([]byte, []int)
func (*RangeQueryInfo) GetEndKey ¶
func (m *RangeQueryInfo) GetEndKey() string
func (*RangeQueryInfo) GetItrExhausted ¶
func (m *RangeQueryInfo) GetItrExhausted() bool
func (*RangeQueryInfo) GetRawReads ¶
func (m *RangeQueryInfo) GetRawReads() *QueryReads
func (*RangeQueryInfo) GetReadsInfo ¶
func (m *RangeQueryInfo) GetReadsInfo() isRangeQueryInfo_ReadsInfo
func (*RangeQueryInfo) GetReadsMerkleHashes ¶
func (m *RangeQueryInfo) GetReadsMerkleHashes() *QueryReadsMerkleSummary
func (*RangeQueryInfo) GetStartKey ¶
func (m *RangeQueryInfo) GetStartKey() string
func (*RangeQueryInfo) ProtoMessage ¶
func (*RangeQueryInfo) ProtoMessage()
func (*RangeQueryInfo) Reset ¶
func (m *RangeQueryInfo) Reset()
func (*RangeQueryInfo) SetMerkelSummary ¶
func (rqi *RangeQueryInfo) SetMerkelSummary(merkleSummary *QueryReadsMerkleSummary)
SetMerkelSummary sets the 'readsInfo' field to merkle summary of the raw KVReads of query results
func (*RangeQueryInfo) SetRawReads ¶
func (rqi *RangeQueryInfo) SetRawReads(kvReads []*KVRead)
SetRawReads sets the 'readsInfo' field to raw KVReads performed by the query
func (*RangeQueryInfo) String ¶
func (m *RangeQueryInfo) String() string
func (*RangeQueryInfo) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *RangeQueryInfo) XXX_DiscardUnknown()
func (*RangeQueryInfo) XXX_Marshal ¶ added in v1.3.0
func (m *RangeQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RangeQueryInfo) XXX_Merge ¶ added in v1.3.0
func (dst *RangeQueryInfo) XXX_Merge(src proto.Message)
func (*RangeQueryInfo) XXX_OneofFuncs ¶
func (*RangeQueryInfo) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*RangeQueryInfo) XXX_Size ¶ added in v1.3.0
func (m *RangeQueryInfo) XXX_Size() int
func (*RangeQueryInfo) XXX_Unmarshal ¶ added in v1.3.0
func (m *RangeQueryInfo) XXX_Unmarshal(b []byte) error
type RangeQueryInfo_RawReads ¶
type RangeQueryInfo_RawReads struct {
RawReads *QueryReads `protobuf:"bytes,4,opt,name=raw_reads,json=rawReads,oneof"`
}
type RangeQueryInfo_ReadsMerkleHashes ¶
type RangeQueryInfo_ReadsMerkleHashes struct {
ReadsMerkleHashes *QueryReadsMerkleSummary `protobuf:"bytes,5,opt,name=reads_merkle_hashes,json=readsMerkleHashes,oneof"`
}
type Version ¶
type Version struct { BlockNum uint64 `protobuf:"varint,1,opt,name=block_num,json=blockNum" json:"block_num,omitempty"` TxNum uint64 `protobuf:"varint,2,opt,name=tx_num,json=txNum" json:"tx_num,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Version encapsulates the version of a Key A version of a committed key is maintained as the height of the transaction that committed the key. The height is represenetd as a tuple <blockNum, txNum> where the txNum is the position of the transaction (starting with 0) within block
func (*Version) Descriptor ¶
func (*Version) GetBlockNum ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *Version) XXX_DiscardUnknown()