kvrwset

package
v0.0.0-...-523a819 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2019 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 

type HashedRWSet struct {
	HashedReads          []*KVReadHash          `protobuf:"bytes,1,rep,name=hashed_reads,json=hashedReads,proto3" json:"hashed_reads,omitempty"`
	HashedWrites         []*KVWriteHash         `protobuf:"bytes,2,rep,name=hashed_writes,json=hashedWrites,proto3" json:"hashed_writes,omitempty"`
	MetadataWrites       []*KVMetadataWriteHash `protobuf:"bytes,3,rep,name=metadata_writes,json=metadataWrites,proto3" json:"metadata_writes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

hashedrwset封装了kv或文档数据模型专用读写集的哈希表示形式

func (*HashedRWSet) Descriptor 

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

func (*HashedRWSet) GetHashedReads 

func (m *HashedRWSet) GetHashedReads() []*KVReadHash

func (*HashedRWSet) GetHashedWrites 

func (m *HashedRWSet) GetHashedWrites() []*KVWriteHash

func (*HashedRWSet) GetMetadataWrites 

func (m *HashedRWSet) GetMetadataWrites() []*KVMetadataWriteHash

func (*HashedRWSet) ProtoMessage 

func (*HashedRWSet) ProtoMessage()

func (*HashedRWSet) Reset 

func (m *HashedRWSet) Reset()

func (*HashedRWSet) String 

func (m *HashedRWSet) String() string

func (*HashedRWSet) XXX_DiscardUnknown 

func (m *HashedRWSet) XXX_DiscardUnknown()

func (*HashedRWSet) XXX_Marshal 

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

func (*HashedRWSet) XXX_Merge 

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

func (*HashedRWSet) XXX_Size 

func (m *HashedRWSet) XXX_Size() int

func (*HashedRWSet) XXX_Unmarshal 

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

type KVMetadataEntry 

type KVMetadataEntry struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" 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在键/键哈希的元数据中捕获一个“名称”条目。

func (*KVMetadataEntry) Descriptor 

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

func (*KVMetadataEntry) GetName 

func (m *KVMetadataEntry) GetName() string

func (*KVMetadataEntry) GetValue 

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

func (*KVMetadataEntry) ProtoMessage 

func (*KVMetadataEntry) ProtoMessage()

func (*KVMetadataEntry) Reset 

func (m *KVMetadataEntry) Reset()

func (*KVMetadataEntry) String 

func (m *KVMetadataEntry) String() string

func (*KVMetadataEntry) XXX_DiscardUnknown 

func (m *KVMetadataEntry) XXX_DiscardUnknown()

func (*KVMetadataEntry) XXX_Marshal 

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

func (*KVMetadataEntry) XXX_Merge 

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

func (*KVMetadataEntry) XXX_Size 

func (m *KVMetadataEntry) XXX_Size() int

func (*KVMetadataEntry) XXX_Unmarshal 

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

type KVMetadataWrite 

type KVMetadataWrite struct {
	Key                  string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Entries              []*KVMetadataEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

kvMetadataWrite捕获与键关联的元数据中的所有条目

func (*KVMetadataWrite) Descriptor 

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

func (*KVMetadataWrite) GetEntries 

func (m *KVMetadataWrite) GetEntries() []*KVMetadataEntry

func (*KVMetadataWrite) GetKey 

func (m *KVMetadataWrite) GetKey() string

func (*KVMetadataWrite) ProtoMessage 

func (*KVMetadataWrite) ProtoMessage()

func (*KVMetadataWrite) Reset 

func (m *KVMetadataWrite) Reset()

func (*KVMetadataWrite) String 

func (m *KVMetadataWrite) String() string

func (*KVMetadataWrite) XXX_DiscardUnknown 

func (m *KVMetadataWrite) XXX_DiscardUnknown()

func (*KVMetadataWrite) XXX_Marshal 

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

func (*KVMetadataWrite) XXX_Merge 

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

func (*KVMetadataWrite) XXX_Size 

func (m *KVMetadataWrite) XXX_Size() int

func (*KVMetadataWrite) XXX_Unmarshal 

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

type KVMetadataWriteHash 

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,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

kvMetadataWriteHash捕获与键哈希关联的元数据的所有upsert

func (*KVMetadataWriteHash) Descriptor 

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

func (*KVMetadataWriteHash) GetEntries 

func (m *KVMetadataWriteHash) GetEntries() []*KVMetadataEntry

func (*KVMetadataWriteHash) GetKeyHash 

func (m *KVMetadataWriteHash) GetKeyHash() []byte

func (*KVMetadataWriteHash) ProtoMessage 

func (*KVMetadataWriteHash) ProtoMessage()

func (*KVMetadataWriteHash) Reset 

func (m *KVMetadataWriteHash) Reset()

func (*KVMetadataWriteHash) String 

func (m *KVMetadataWriteHash) String() string

func (*KVMetadataWriteHash) XXX_DiscardUnknown 

func (m *KVMetadataWriteHash) XXX_DiscardUnknown()

func (*KVMetadataWriteHash) XXX_Marshal 

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

func (*KVMetadataWriteHash) XXX_Merge 

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

func (*KVMetadataWriteHash) XXX_Size 

func (m *KVMetadataWriteHash) XXX_Size() int

func (*KVMetadataWriteHash) XXX_Unmarshal 

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

type KVRWSet 

type KVRWSet struct {
	Reads                []*KVRead          `protobuf:"bytes,1,rep,name=reads,proto3" json:"reads,omitempty"`
	RangeQueriesInfo     []*RangeQueryInfo  `protobuf:"bytes,2,rep,name=range_queries_info,json=rangeQueriesInfo,proto3" json:"range_queries_info,omitempty"`
	Writes               []*KVWrite         `protobuf:"bytes,3,rep,name=writes,proto3" json:"writes,omitempty"`
	MetadataWrites       []*KVMetadataWrite `protobuf:"bytes,4,rep,name=metadata_writes,json=metadataWrites,proto3" json:"metadata_writes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

kvrwset封装了对kv或文档数据模型进行操作的链代码的读写集。 此结构用于公共数据和私有数据

func (*KVRWSet) Descriptor 

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

func (*KVRWSet) GetMetadataWrites 

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 

func (m *KVRWSet) XXX_DiscardUnknown()

func (*KVRWSet) XXX_Marshal 

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

func (*KVRWSet) XXX_Merge 

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

func (*KVRWSet) XXX_Size 

func (m *KVRWSet) XXX_Size() int

func (*KVRWSet) XXX_Unmarshal 

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

type KVRead 

type KVRead struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Version              *Version `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

kvread捕获在事务模拟期间执行的读取操作 “nil”版本表示事务读取的密钥不存在

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 

func (m *KVRead) XXX_DiscardUnknown()

func (*KVRead) XXX_Marshal 

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

func (*KVRead) XXX_Merge 

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

func (*KVRead) XXX_Size 

func (m *KVRead) XXX_Size() int

func (*KVRead) XXX_Unmarshal 

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

type KVReadHash 

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,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

kvreadhash与kvread在精神上类似。但是，它捕获键的散列而不是键本身 版本暂时保持不变。但是，如果版本还需要隐私保护，则需要 版本的哈希，因此是“bytes”类型

func (*KVReadHash) Descriptor 

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

func (*KVReadHash) GetKeyHash 

func (m *KVReadHash) GetKeyHash() []byte

func (*KVReadHash) GetVersion 

func (m *KVReadHash) GetVersion() *Version

func (*KVReadHash) ProtoMessage 

func (*KVReadHash) ProtoMessage()

func (*KVReadHash) Reset 

func (m *KVReadHash) Reset()

func (*KVReadHash) String 

func (m *KVReadHash) String() string

func (*KVReadHash) XXX_DiscardUnknown 

func (m *KVReadHash) XXX_DiscardUnknown()

func (*KVReadHash) XXX_Marshal 

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

func (*KVReadHash) XXX_Merge 

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

func (*KVReadHash) XXX_Size 

func (m *KVReadHash) XXX_Size() int

func (*KVReadHash) XXX_Unmarshal 

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

type KVWrite 

type KVWrite struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IsDelete             bool     `protobuf:"varint,2,opt,name=is_delete,json=isDelete,proto3" 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捕获事务模拟期间执行的写入（更新/删除）操作

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 

func (m *KVWrite) XXX_DiscardUnknown()

func (*KVWrite) XXX_Marshal 

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

func (*KVWrite) XXX_Merge 

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

func (*KVWrite) XXX_Size 

func (m *KVWrite) XXX_Size() int

func (*KVWrite) XXX_Unmarshal 

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

type KVWriteHash 

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,proto3" 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与kvWrite类似。它捕获在事务模拟期间执行的写入（更新/删除）操作

func (*KVWriteHash) Descriptor 

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

func (*KVWriteHash) GetIsDelete 

func (m *KVWriteHash) GetIsDelete() bool

func (*KVWriteHash) GetKeyHash 

func (m *KVWriteHash) GetKeyHash() []byte

func (*KVWriteHash) GetValueHash 

func (m *KVWriteHash) GetValueHash() []byte

func (*KVWriteHash) ProtoMessage 

func (*KVWriteHash) ProtoMessage()

func (*KVWriteHash) Reset 

func (m *KVWriteHash) Reset()

func (*KVWriteHash) String 

func (m *KVWriteHash) String() string

func (*KVWriteHash) XXX_DiscardUnknown 

func (m *KVWriteHash) XXX_DiscardUnknown()

func (*KVWriteHash) XXX_Marshal 

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

func (*KVWriteHash) XXX_Merge 

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

func (*KVWriteHash) XXX_Size 

func (m *KVWriteHash) XXX_Size() int

func (*KVWriteHash) XXX_Unmarshal 

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

type QueryReads 

type QueryReads struct {
	KvReads              []*KVRead `protobuf:"bytes,1,rep,name=kv_reads,json=kvReads,proto3" json:"kv_reads,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

queryreads为查询执行结果中事务读取的项封装kvreads

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 

func (m *QueryReads) XXX_DiscardUnknown()

func (*QueryReads) XXX_Marshal 

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

func (*QueryReads) XXX_Merge 

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

func (*QueryReads) XXX_Size 

func (m *QueryReads) XXX_Size() int

func (*QueryReads) XXX_Unmarshal 

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

type QueryReadsMerkleSummary 

type QueryReadsMerkleSummary struct {
	MaxDegree            uint32   `protobuf:"varint,1,opt,name=max_degree,json=maxDegree,proto3" json:"max_degree,omitempty"`
	MaxLevel             uint32   `protobuf:"varint,2,opt,name=max_level,json=maxLevel,proto3" 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封装了用于queryreads的merkle树哈希 这允许在查询结果出现时减小rwset的大小。 通过存储某些哈希而不是实际结果。 maxdegree字段是指树中任何级别的子级的最大数目。 maxlevel字段包含节点数小于maxdegree的最低级别（从叶级开始）

func (*QueryReadsMerkleSummary) Descriptor 

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

func (*QueryReadsMerkleSummary) Equal 

func (ms *QueryReadsMerkleSummary) Equal(anotherMS *QueryReadsMerkleSummary) bool

equal验证give merklesummary是否等于此

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 

func (m *QueryReadsMerkleSummary) XXX_DiscardUnknown()

func (*QueryReadsMerkleSummary) XXX_Marshal 

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

func (*QueryReadsMerkleSummary) XXX_Merge 

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

func (*QueryReadsMerkleSummary) XXX_Size 

func (m *QueryReadsMerkleSummary) XXX_Size() int

func (*QueryReadsMerkleSummary) XXX_Unmarshal 

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

type RangeQueryInfo 

type RangeQueryInfo struct {
	StartKey     string `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey       string `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	ItrExhausted bool   `protobuf:"varint,3,opt,name=itr_exhausted,json=itrExhausted,proto3" json:"itr_exhausted,omitempty"`
	//有效分配给readsInfo的类型：
	//*范围查询信息
	//*范围查询信息
	ReadsInfo            isRangeQueryInfo_ReadsInfo `protobuf_oneof:"reads_info"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

rangequeryinfo封装模拟期间事务执行的范围查询的详细信息。 这有助于通过在验证是否有任何新项目时进行变量化来保护事务不受幻象读取的影响。 在事务模拟和验证之间的给定范围内提交 （除了定期检查现有项目的更新/删除之外）。 readinfo字段包含kvards（对于范围查询读取的项目）或merkle树哈希 如果kvreads超过预先配置的数字

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将“readsinfo”字段设置为查询结果的原始kvards的merkle摘要

func (*RangeQueryInfo) SetRawReads 

func (rqi *RangeQueryInfo) SetRawReads(kvReads []*KVRead)

setrawreads将“readsinfo”字段设置为查询执行的原始kvreads

func (*RangeQueryInfo) String 

func (m *RangeQueryInfo) String() string

func (*RangeQueryInfo) XXX_DiscardUnknown 

func (m *RangeQueryInfo) XXX_DiscardUnknown()

func (*RangeQueryInfo) XXX_Marshal 

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

func (*RangeQueryInfo) XXX_Merge 

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{})

xxxoneoffuncs用于Proto包的内部使用。

func (*RangeQueryInfo) XXX_Size 

func (m *RangeQueryInfo) XXX_Size() int

func (*RangeQueryInfo) XXX_Unmarshal 

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,proto3,oneof"`
}

type RangeQueryInfo_ReadsMerkleHashes 

type RangeQueryInfo_ReadsMerkleHashes struct {
	ReadsMerkleHashes *QueryReadsMerkleSummary `protobuf:"bytes,5,opt,name=reads_merkle_hashes,json=readsMerkleHashes,proto3,oneof"`
}

type Version 

type Version struct {
	BlockNum             uint64   `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	TxNum                uint64   `protobuf:"varint,2,opt,name=tx_num,json=txNum,proto3" json:"tx_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

版本封装密钥的版本 已提交密钥的版本被维护为提交该密钥的事务的高度。 高度被表示为一个元组<blocknum，txnum>，其中txnum是事务的位置。 （从0开始）在块内

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 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal 

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

func (*Version) XXX_Merge 

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

func (*Version) XXX_Size 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal 

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.