kvrwset

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

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.4.0 

func (m *HashedRWSet) XXX_DiscardUnknown()

func (*HashedRWSet) XXX_Marshal added in v1.4.0 

func (m *HashedRWSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HashedRWSet) XXX_Merge added in v1.4.0 

func (dst *HashedRWSet) XXX_Merge(src proto.Message)

func (*HashedRWSet) XXX_Size added in v1.4.0 

func (m *HashedRWSet) XXX_Size() int

func (*HashedRWSet) XXX_Unmarshal added in v1.4.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.4.0 

func (m *KVMetadataEntry) XXX_DiscardUnknown()

func (*KVMetadataEntry) XXX_Marshal added in v1.4.0 

func (m *KVMetadataEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVMetadataEntry) XXX_Merge added in v1.4.0 

func (dst *KVMetadataEntry) XXX_Merge(src proto.Message)

func (*KVMetadataEntry) XXX_Size added in v1.4.0 

func (m *KVMetadataEntry) XXX_Size() int

func (*KVMetadataEntry) XXX_Unmarshal added in v1.4.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.4.0 

func (m *KVMetadataWrite) XXX_DiscardUnknown()

func (*KVMetadataWrite) XXX_Marshal added in v1.4.0 

func (m *KVMetadataWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVMetadataWrite) XXX_Merge added in v1.4.0 

func (dst *KVMetadataWrite) XXX_Merge(src proto.Message)

func (*KVMetadataWrite) XXX_Size added in v1.4.0 

func (m *KVMetadataWrite) XXX_Size() int

func (*KVMetadataWrite) XXX_Unmarshal added in v1.4.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.4.0 

func (m *KVMetadataWriteHash) XXX_DiscardUnknown()

func (*KVMetadataWriteHash) XXX_Marshal added in v1.4.0 

func (m *KVMetadataWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVMetadataWriteHash) XXX_Merge added in v1.4.0 

func (dst *KVMetadataWriteHash) XXX_Merge(src proto.Message)

func (*KVMetadataWriteHash) XXX_Size added in v1.4.0 

func (m *KVMetadataWriteHash) XXX_Size() int

func (*KVMetadataWriteHash) XXX_Unmarshal added in v1.4.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) Descriptor() ([]byte, []int)

func (*KVRWSet) GetMetadataWrites added in v1.2.0 

func (m *KVRWSet) GetMetadataWrites() []*KVMetadataWrite

func (*KVRWSet) GetRangeQueriesInfo 

func (m *KVRWSet) GetRangeQueriesInfo() []*RangeQueryInfo

func (*KVRWSet) GetReads 

func (m *KVRWSet) GetReads() []*KVRead

func (*KVRWSet) GetWrites 

func (m *KVRWSet) GetWrites() []*KVWrite

func (*KVRWSet) ProtoMessage 

func (*KVRWSet) ProtoMessage()

func (*KVRWSet) Reset 

func (m *KVRWSet) Reset()

func (*KVRWSet) String 

func (m *KVRWSet) String() string

func (*KVRWSet) XXX_DiscardUnknown added in v1.4.0 

func (m *KVRWSet) XXX_DiscardUnknown()

func (*KVRWSet) XXX_Marshal added in v1.4.0 

func (m *KVRWSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVRWSet) XXX_Merge added in v1.4.0 

func (dst *KVRWSet) XXX_Merge(src proto.Message)

func (*KVRWSet) XXX_Size added in v1.4.0 

func (m *KVRWSet) XXX_Size() int

func (*KVRWSet) XXX_Unmarshal added in v1.4.0 

func (m *KVRWSet) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*KVRead) GetKey 

func (m *KVRead) GetKey() string

func (*KVRead) GetVersion 

func (m *KVRead) GetVersion() *Version

func (*KVRead) ProtoMessage 

func (*KVRead) ProtoMessage()

func (*KVRead) Reset 

func (m *KVRead) Reset()

func (*KVRead) String 

func (m *KVRead) String() string

func (*KVRead) XXX_DiscardUnknown added in v1.4.0 

func (m *KVRead) XXX_DiscardUnknown()

func (*KVRead) XXX_Marshal added in v1.4.0 

func (m *KVRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVRead) XXX_Merge added in v1.4.0 

func (dst *KVRead) XXX_Merge(src proto.Message)

func (*KVRead) XXX_Size added in v1.4.0 

func (m *KVRead) XXX_Size() int

func (*KVRead) XXX_Unmarshal added in v1.4.0 

func (m *KVRead) XXX_Unmarshal(b []byte) error

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.4.0 

func (m *KVReadHash) XXX_DiscardUnknown()

func (*KVReadHash) XXX_Marshal added in v1.4.0 

func (m *KVReadHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVReadHash) XXX_Merge added in v1.4.0 

func (dst *KVReadHash) XXX_Merge(src proto.Message)

func (*KVReadHash) XXX_Size added in v1.4.0 

func (m *KVReadHash) XXX_Size() int

func (*KVReadHash) XXX_Unmarshal added in v1.4.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) Descriptor() ([]byte, []int)

func (*KVWrite) GetIsDelete 

func (m *KVWrite) GetIsDelete() bool

func (*KVWrite) GetKey 

func (m *KVWrite) GetKey() string

func (*KVWrite) GetValue 

func (m *KVWrite) GetValue() []byte

func (*KVWrite) ProtoMessage 

func (*KVWrite) ProtoMessage()

func (*KVWrite) Reset 

func (m *KVWrite) Reset()

func (*KVWrite) String 

func (m *KVWrite) String() string

func (*KVWrite) XXX_DiscardUnknown added in v1.4.0 

func (m *KVWrite) XXX_DiscardUnknown()

func (*KVWrite) XXX_Marshal added in v1.4.0 

func (m *KVWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVWrite) XXX_Merge added in v1.4.0 

func (dst *KVWrite) XXX_Merge(src proto.Message)

func (*KVWrite) XXX_Size added in v1.4.0 

func (m *KVWrite) XXX_Size() int

func (*KVWrite) XXX_Unmarshal added in v1.4.0 

func (m *KVWrite) XXX_Unmarshal(b []byte) error

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.4.0 

func (m *KVWriteHash) XXX_DiscardUnknown()

func (*KVWriteHash) XXX_Marshal added in v1.4.0 

func (m *KVWriteHash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVWriteHash) XXX_Merge added in v1.4.0 

func (dst *KVWriteHash) XXX_Merge(src proto.Message)

func (*KVWriteHash) XXX_Size added in v1.4.0 

func (m *KVWriteHash) XXX_Size() int

func (*KVWriteHash) XXX_Unmarshal added in v1.4.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.4.0 

func (m *QueryReads) XXX_DiscardUnknown()

func (*QueryReads) XXX_Marshal added in v1.4.0 

func (m *QueryReads) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryReads) XXX_Merge added in v1.4.0 

func (dst *QueryReads) XXX_Merge(src proto.Message)

func (*QueryReads) XXX_Size added in v1.4.0 

func (m *QueryReads) XXX_Size() int

func (*QueryReads) XXX_Unmarshal added in v1.4.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.4.0 

func (m *QueryReadsMerkleSummary) XXX_DiscardUnknown()

func (*QueryReadsMerkleSummary) XXX_Marshal added in v1.4.0 

func (m *QueryReadsMerkleSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryReadsMerkleSummary) XXX_Merge added in v1.4.0 

func (dst *QueryReadsMerkleSummary) XXX_Merge(src proto.Message)

func (*QueryReadsMerkleSummary) XXX_Size added in v1.4.0 

func (m *QueryReadsMerkleSummary) XXX_Size() int

func (*QueryReadsMerkleSummary) XXX_Unmarshal added in v1.4.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.4.0 

func (m *RangeQueryInfo) XXX_DiscardUnknown()

func (*RangeQueryInfo) XXX_Marshal added in v1.4.0 

func (m *RangeQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeQueryInfo) XXX_Merge added in v1.4.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.4.0 

func (m *RangeQueryInfo) XXX_Size() int

func (*RangeQueryInfo) XXX_Unmarshal added in v1.4.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) Descriptor() ([]byte, []int)

func (*Version) GetBlockNum 

func (m *Version) GetBlockNum() uint64

func (*Version) GetTxNum 

func (m *Version) GetTxNum() uint64

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) Reset 

func (m *Version) Reset()

func (*Version) String 

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown added in v1.4.0 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal added in v1.4.0 

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge added in v1.4.0 

func (dst *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size added in v1.4.0 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal added in v1.4.0 

func (m *Version) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.