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) GetDeliverTxs() []*BlockMetadata_DeliverTx
- func (x *BlockMetadata) GetRequestBeginBlock() *abci.RequestBeginBlock
- func (x *BlockMetadata) GetRequestEndBlock() *abci.RequestEndBlock
- func (x *BlockMetadata) GetResponseBeginBlock() *abci.ResponseBeginBlock
- func (x *BlockMetadata) GetResponseCommit() *abci.ResponseCommit
- func (x *BlockMetadata) GetResponseEndBlock() *abci.ResponseEndBlock
- func (*BlockMetadata) ProtoMessage()
- func (x *BlockMetadata) ProtoReflect() protoreflect.Message
- func (x *BlockMetadata) Reset()
- func (x *BlockMetadata) String() string
- type BlockMetadata_DeliverTx
- func (*BlockMetadata_DeliverTx) Descriptor() ([]byte, []int)deprecated
- func (x *BlockMetadata_DeliverTx) GetRequest() *abci.RequestDeliverTx
- func (x *BlockMetadata_DeliverTx) GetResponse() *abci.ResponseDeliverTx
- func (*BlockMetadata_DeliverTx) ProtoMessage()
- func (x *BlockMetadata_DeliverTx) ProtoReflect() protoreflect.Message
- func (x *BlockMetadata_DeliverTx) Reset()
- func (x *BlockMetadata_DeliverTx) String() string
- type CommitID
- type CommitInfo
- func (*CommitInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CommitInfo) GetStoreInfos() []*StoreInfo
- 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_base_store_v1beta1_commit_info_proto protoreflect.FileDescriptor
var File_cosmos_base_store_v1beta1_listening_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BlockMetadata ¶ added in v0.2.6
type BlockMetadata struct { RequestBeginBlock *abci.RequestBeginBlock `protobuf:"bytes,1,opt,name=request_begin_block,json=requestBeginBlock,proto3" json:"request_begin_block,omitempty"` ResponseBeginBlock *abci.ResponseBeginBlock `protobuf:"bytes,2,opt,name=response_begin_block,json=responseBeginBlock,proto3" json:"response_begin_block,omitempty"` DeliverTxs []*BlockMetadata_DeliverTx `protobuf:"bytes,3,rep,name=deliver_txs,json=deliverTxs,proto3" json:"deliver_txs,omitempty"` RequestEndBlock *abci.RequestEndBlock `protobuf:"bytes,4,opt,name=request_end_block,json=requestEndBlock,proto3" json:"request_end_block,omitempty"` ResponseEndBlock *abci.ResponseEndBlock `protobuf:"bytes,5,opt,name=response_end_block,json=responseEndBlock,proto3" json:"response_end_block,omitempty"` ResponseCommit *abci.ResponseCommit `protobuf:"bytes,6,opt,name=response_commit,json=responseCommit,proto3" json:"response_commit,omitempty"` // 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
added in
v0.2.6
func (*BlockMetadata) Descriptor() ([]byte, []int)
Deprecated: Use BlockMetadata.ProtoReflect.Descriptor instead.
func (*BlockMetadata) GetDeliverTxs ¶ added in v0.2.6
func (x *BlockMetadata) GetDeliverTxs() []*BlockMetadata_DeliverTx
func (*BlockMetadata) GetRequestBeginBlock ¶ added in v0.2.6
func (x *BlockMetadata) GetRequestBeginBlock() *abci.RequestBeginBlock
func (*BlockMetadata) GetRequestEndBlock ¶ added in v0.2.6
func (x *BlockMetadata) GetRequestEndBlock() *abci.RequestEndBlock
func (*BlockMetadata) GetResponseBeginBlock ¶ added in v0.2.6
func (x *BlockMetadata) GetResponseBeginBlock() *abci.ResponseBeginBlock
func (*BlockMetadata) GetResponseCommit ¶ added in v0.2.6
func (x *BlockMetadata) GetResponseCommit() *abci.ResponseCommit
func (*BlockMetadata) GetResponseEndBlock ¶ added in v0.2.6
func (x *BlockMetadata) GetResponseEndBlock() *abci.ResponseEndBlock
func (*BlockMetadata) ProtoMessage ¶ added in v0.2.6
func (*BlockMetadata) ProtoMessage()
func (*BlockMetadata) ProtoReflect ¶ added in v0.2.6
func (x *BlockMetadata) ProtoReflect() protoreflect.Message
func (*BlockMetadata) Reset ¶ added in v0.2.6
func (x *BlockMetadata) Reset()
func (*BlockMetadata) String ¶ added in v0.2.6
func (x *BlockMetadata) String() string
type BlockMetadata_DeliverTx ¶ added in v0.2.6
type BlockMetadata_DeliverTx struct { Request *abci.RequestDeliverTx `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` Response *abci.ResponseDeliverTx `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` // contains filtered or unexported fields }
DeliverTx encapulate deliver tx request and response.
func (*BlockMetadata_DeliverTx) Descriptor
deprecated
added in
v0.2.6
func (*BlockMetadata_DeliverTx) Descriptor() ([]byte, []int)
Deprecated: Use BlockMetadata_DeliverTx.ProtoReflect.Descriptor instead.
func (*BlockMetadata_DeliverTx) GetRequest ¶ added in v0.2.6
func (x *BlockMetadata_DeliverTx) GetRequest() *abci.RequestDeliverTx
func (*BlockMetadata_DeliverTx) GetResponse ¶ added in v0.2.6
func (x *BlockMetadata_DeliverTx) GetResponse() *abci.ResponseDeliverTx
func (*BlockMetadata_DeliverTx) ProtoMessage ¶ added in v0.2.6
func (*BlockMetadata_DeliverTx) ProtoMessage()
func (*BlockMetadata_DeliverTx) ProtoReflect ¶ added in v0.2.6
func (x *BlockMetadata_DeliverTx) ProtoReflect() protoreflect.Message
func (*BlockMetadata_DeliverTx) Reset ¶ added in v0.2.6
func (x *BlockMetadata_DeliverTx) Reset()
func (*BlockMetadata_DeliverTx) String ¶ added in v0.2.6
func (x *BlockMetadata_DeliverTx) 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"` // 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) 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