Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Variables
- type BlockMetadata
- func (*BlockMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *BlockMetadata) GetRequestFinalizeBlock() *abci.RequestFinalizeBlock
- func (x *BlockMetadata) GetResponseCommit() *abci.ResponseCommit
- func (x *BlockMetadata) GetResponseFinalizeBlock() *abci.ResponseFinalizeBlock
- func (*BlockMetadata) ProtoMessage()
- func (x *BlockMetadata) ProtoReflect() protoreflect.Message
- func (x *BlockMetadata) Reset()
- func (x *BlockMetadata) String() string
- type CommitID
- type CommitInfo
- func (*CommitInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CommitInfo) GetStoreInfos() []*StoreInfo
- func (x *CommitInfo) GetTimestamp() *timestamppb.Timestamp
- func (x *CommitInfo) GetVersion() int64
- func (*CommitInfo) ProtoMessage()
- func (x *CommitInfo) ProtoReflect() protoreflect.Message
- func (x *CommitInfo) Reset()
- func (x *CommitInfo) String() string
- type StoreInfo
- type StoreKVPair
- func (*StoreKVPair) Descriptor() ([]byte, []int)deprecated
- func (x *StoreKVPair) GetDelete() bool
- func (x *StoreKVPair) GetKey() []byte
- func (x *StoreKVPair) GetStoreKey() string
- func (x *StoreKVPair) GetValue() []byte
- func (*StoreKVPair) ProtoMessage()
- func (x *StoreKVPair) ProtoReflect() protoreflect.Message
- func (x *StoreKVPair) Reset()
- func (x *StoreKVPair) String() string
Constants ¶
This section is empty.
Variables ¶
var File_cosmos_store_v1beta1_commit_info_proto protoreflect.FileDescriptor
var File_cosmos_store_v1beta1_listening_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BlockMetadata ¶
type BlockMetadata struct { ResponseCommit *abci.ResponseCommit `protobuf:"bytes,6,opt,name=response_commit,json=responseCommit,proto3" json:"response_commit,omitempty"` RequestFinalizeBlock *abci.RequestFinalizeBlock `protobuf:"bytes,7,opt,name=request_finalize_block,json=requestFinalizeBlock,proto3" json:"request_finalize_block,omitempty"` ResponseFinalizeBlock *abci.ResponseFinalizeBlock `` // TODO: should we renumber this? /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
BlockMetadata contains all the abci event data of a block the file streamer dump them into files together with the state changes.
func (*BlockMetadata) Descriptor
deprecated
func (*BlockMetadata) Descriptor() ([]byte, []int)
Deprecated: Use BlockMetadata.ProtoReflect.Descriptor instead.
func (*BlockMetadata) GetRequestFinalizeBlock ¶ added in v0.4.2
func (x *BlockMetadata) GetRequestFinalizeBlock() *abci.RequestFinalizeBlock
func (*BlockMetadata) GetResponseCommit ¶
func (x *BlockMetadata) GetResponseCommit() *abci.ResponseCommit
func (*BlockMetadata) GetResponseFinalizeBlock ¶ added in v0.4.2
func (x *BlockMetadata) GetResponseFinalizeBlock() *abci.ResponseFinalizeBlock
func (*BlockMetadata) ProtoMessage ¶
func (*BlockMetadata) ProtoMessage()
func (*BlockMetadata) ProtoReflect ¶
func (x *BlockMetadata) ProtoReflect() protoreflect.Message
func (*BlockMetadata) Reset ¶
func (x *BlockMetadata) Reset()
func (*BlockMetadata) String ¶
func (x *BlockMetadata) String() string
type CommitID ¶
type CommitID struct { Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
CommitID defines the commitment information when a specific store is committed.
func (*CommitID) ProtoReflect ¶
func (x *CommitID) ProtoReflect() protoreflect.Message
type CommitInfo ¶
type CommitInfo struct { Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` StoreInfos []*StoreInfo `protobuf:"bytes,2,rep,name=store_infos,json=storeInfos,proto3" json:"store_infos,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
CommitInfo defines commit information used by the multi-store when committing a version/height.
func (*CommitInfo) Descriptor
deprecated
func (*CommitInfo) Descriptor() ([]byte, []int)
Deprecated: Use CommitInfo.ProtoReflect.Descriptor instead.
func (*CommitInfo) GetStoreInfos ¶
func (x *CommitInfo) GetStoreInfos() []*StoreInfo
func (*CommitInfo) GetTimestamp ¶ added in v0.4.0
func (x *CommitInfo) GetTimestamp() *timestamppb.Timestamp
func (*CommitInfo) GetVersion ¶
func (x *CommitInfo) GetVersion() int64
func (*CommitInfo) ProtoMessage ¶
func (*CommitInfo) ProtoMessage()
func (*CommitInfo) ProtoReflect ¶
func (x *CommitInfo) ProtoReflect() protoreflect.Message
func (*CommitInfo) Reset ¶
func (x *CommitInfo) Reset()
func (*CommitInfo) String ¶
func (x *CommitInfo) String() string
type StoreInfo ¶
type StoreInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CommitId *CommitID `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"` // contains filtered or unexported fields }
StoreInfo defines store-specific commit information. It contains a reference between a store name and the commit ID.
func (*StoreInfo) ProtoReflect ¶
func (x *StoreInfo) ProtoReflect() protoreflect.Message
type StoreKVPair ¶
type StoreKVPair struct { StoreKey string `protobuf:"bytes,1,opt,name=store_key,json=storeKey,proto3" json:"store_key,omitempty"` // the store key for the KVStore this pair originates from Delete bool `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"` // true indicates a delete operation, false indicates a set operation Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
StoreKVPair is a KVStore KVPair used for listening to state changes (Sets and Deletes) It optionally includes the StoreKey for the originating KVStore and a Boolean flag to distinguish between Sets and Deletes
Since: cosmos-sdk 0.43
func (*StoreKVPair) Descriptor
deprecated
func (*StoreKVPair) Descriptor() ([]byte, []int)
Deprecated: Use StoreKVPair.ProtoReflect.Descriptor instead.
func (*StoreKVPair) GetDelete ¶
func (x *StoreKVPair) GetDelete() bool
func (*StoreKVPair) GetKey ¶
func (x *StoreKVPair) GetKey() []byte
func (*StoreKVPair) GetStoreKey ¶
func (x *StoreKVPair) GetStoreKey() string
func (*StoreKVPair) GetValue ¶
func (x *StoreKVPair) GetValue() []byte
func (*StoreKVPair) ProtoMessage ¶
func (*StoreKVPair) ProtoMessage()
func (*StoreKVPair) ProtoReflect ¶
func (x *StoreKVPair) ProtoReflect() protoreflect.Message
func (*StoreKVPair) Reset ¶
func (x *StoreKVPair) Reset()
func (*StoreKVPair) String ¶
func (x *StoreKVPair) String() string