Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterABCIListenerServiceServer(s grpc.ServiceRegistrar, srv ABCIListenerServiceServer)
- type ABCIListenerServiceClient
- type ABCIListenerServiceServer
- type ListenCommitRequest
- func (*ListenCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenCommitRequest) GetBlockHeight() int64
- func (x *ListenCommitRequest) GetChangeSet() []*v1beta1.StoreKVPair
- func (x *ListenCommitRequest) GetRes() *abci.ResponseCommit
- func (*ListenCommitRequest) ProtoMessage()
- func (x *ListenCommitRequest) ProtoReflect() protoreflect.Message
- func (x *ListenCommitRequest) Reset()
- func (x *ListenCommitRequest) String() string
- type ListenCommitResponse
- type ListenFinalizeBlockRequest
- func (*ListenFinalizeBlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenFinalizeBlockRequest) GetReq() *abci.RequestFinalizeBlock
- func (x *ListenFinalizeBlockRequest) GetRes() *abci.ResponseFinalizeBlock
- func (*ListenFinalizeBlockRequest) ProtoMessage()
- func (x *ListenFinalizeBlockRequest) ProtoReflect() protoreflect.Message
- func (x *ListenFinalizeBlockRequest) Reset()
- func (x *ListenFinalizeBlockRequest) String() string
- type ListenFinalizeBlockResponse
- type UnimplementedABCIListenerServiceServer
- type UnsafeABCIListenerServiceServer
Constants ¶
const ( ABCIListenerService_ListenFinalizeBlock_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenFinalizeBlock" ABCIListenerService_ListenCommit_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenCommit" )
Variables ¶
var ABCIListenerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cosmos.store.streaming.abci.ABCIListenerService", HandlerType: (*ABCIListenerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListenFinalizeBlock", Handler: _ABCIListenerService_ListenFinalizeBlock_Handler, }, { MethodName: "ListenCommit", Handler: _ABCIListenerService_ListenCommit_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cosmos/store/streaming/abci/grpc.proto", }
ABCIListenerService_ServiceDesc is the grpc.ServiceDesc for ABCIListenerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_cosmos_store_streaming_abci_grpc_proto protoreflect.FileDescriptor
Functions ¶
func RegisterABCIListenerServiceServer ¶
func RegisterABCIListenerServiceServer(s grpc.ServiceRegistrar, srv ABCIListenerServiceServer)
Types ¶
type ABCIListenerServiceClient ¶
type ABCIListenerServiceClient interface { // ListenFinalizeBlock is the corresponding endpoint for ABCIListener.ListenEndBlock ListenFinalizeBlock(ctx context.Context, in *ListenFinalizeBlockRequest, opts ...grpc.CallOption) (*ListenFinalizeBlockResponse, error) // ListenCommit is the corresponding endpoint for ABCIListener.ListenCommit ListenCommit(ctx context.Context, in *ListenCommitRequest, opts ...grpc.CallOption) (*ListenCommitResponse, error) }
ABCIListenerServiceClient is the client API for ABCIListenerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewABCIListenerServiceClient ¶
func NewABCIListenerServiceClient(cc grpc.ClientConnInterface) ABCIListenerServiceClient
type ABCIListenerServiceServer ¶
type ABCIListenerServiceServer interface { // ListenFinalizeBlock is the corresponding endpoint for ABCIListener.ListenEndBlock ListenFinalizeBlock(context.Context, *ListenFinalizeBlockRequest) (*ListenFinalizeBlockResponse, error) // ListenCommit is the corresponding endpoint for ABCIListener.ListenCommit ListenCommit(context.Context, *ListenCommitRequest) (*ListenCommitResponse, error) // contains filtered or unexported methods }
ABCIListenerServiceServer is the server API for ABCIListenerService service. All implementations must embed UnimplementedABCIListenerServiceServer for forward compatibility
type ListenCommitRequest ¶
type ListenCommitRequest struct { // explicitly pass in block height as ResponseCommit does not contain this info BlockHeight int64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` Res *abci.ResponseCommit `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"` ChangeSet []*v1beta1.StoreKVPair `protobuf:"bytes,3,rep,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"` // contains filtered or unexported fields }
ListenCommitRequest is the request type for the ListenCommit RPC method
func (*ListenCommitRequest) Descriptor
deprecated
func (*ListenCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenCommitRequest.ProtoReflect.Descriptor instead.
func (*ListenCommitRequest) GetBlockHeight ¶
func (x *ListenCommitRequest) GetBlockHeight() int64
func (*ListenCommitRequest) GetChangeSet ¶
func (x *ListenCommitRequest) GetChangeSet() []*v1beta1.StoreKVPair
func (*ListenCommitRequest) GetRes ¶
func (x *ListenCommitRequest) GetRes() *abci.ResponseCommit
func (*ListenCommitRequest) ProtoMessage ¶
func (*ListenCommitRequest) ProtoMessage()
func (*ListenCommitRequest) ProtoReflect ¶
func (x *ListenCommitRequest) ProtoReflect() protoreflect.Message
func (*ListenCommitRequest) Reset ¶
func (x *ListenCommitRequest) Reset()
func (*ListenCommitRequest) String ¶
func (x *ListenCommitRequest) String() string
type ListenCommitResponse ¶
type ListenCommitResponse struct {
// contains filtered or unexported fields
}
ListenCommitResponse is the response type for the ListenCommit RPC method
func (*ListenCommitResponse) Descriptor
deprecated
func (*ListenCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenCommitResponse.ProtoReflect.Descriptor instead.
func (*ListenCommitResponse) ProtoMessage ¶
func (*ListenCommitResponse) ProtoMessage()
func (*ListenCommitResponse) ProtoReflect ¶
func (x *ListenCommitResponse) ProtoReflect() protoreflect.Message
func (*ListenCommitResponse) Reset ¶
func (x *ListenCommitResponse) Reset()
func (*ListenCommitResponse) String ¶
func (x *ListenCommitResponse) String() string
type ListenFinalizeBlockRequest ¶ added in v0.4.2
type ListenFinalizeBlockRequest struct { Req *abci.RequestFinalizeBlock `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"` Res *abci.ResponseFinalizeBlock `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"` // contains filtered or unexported fields }
ListenEndBlockRequest is the request type for the ListenEndBlock RPC method
func (*ListenFinalizeBlockRequest) Descriptor
deprecated
added in
v0.4.2
func (*ListenFinalizeBlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenFinalizeBlockRequest.ProtoReflect.Descriptor instead.
func (*ListenFinalizeBlockRequest) GetReq ¶ added in v0.4.2
func (x *ListenFinalizeBlockRequest) GetReq() *abci.RequestFinalizeBlock
func (*ListenFinalizeBlockRequest) GetRes ¶ added in v0.4.2
func (x *ListenFinalizeBlockRequest) GetRes() *abci.ResponseFinalizeBlock
func (*ListenFinalizeBlockRequest) ProtoMessage ¶ added in v0.4.2
func (*ListenFinalizeBlockRequest) ProtoMessage()
func (*ListenFinalizeBlockRequest) ProtoReflect ¶ added in v0.4.2
func (x *ListenFinalizeBlockRequest) ProtoReflect() protoreflect.Message
func (*ListenFinalizeBlockRequest) Reset ¶ added in v0.4.2
func (x *ListenFinalizeBlockRequest) Reset()
func (*ListenFinalizeBlockRequest) String ¶ added in v0.4.2
func (x *ListenFinalizeBlockRequest) String() string
type ListenFinalizeBlockResponse ¶ added in v0.4.2
type ListenFinalizeBlockResponse struct {
// contains filtered or unexported fields
}
ListenEndBlockResponse is the response type for the ListenEndBlock RPC method
func (*ListenFinalizeBlockResponse) Descriptor
deprecated
added in
v0.4.2
func (*ListenFinalizeBlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenFinalizeBlockResponse.ProtoReflect.Descriptor instead.
func (*ListenFinalizeBlockResponse) ProtoMessage ¶ added in v0.4.2
func (*ListenFinalizeBlockResponse) ProtoMessage()
func (*ListenFinalizeBlockResponse) ProtoReflect ¶ added in v0.4.2
func (x *ListenFinalizeBlockResponse) ProtoReflect() protoreflect.Message
func (*ListenFinalizeBlockResponse) Reset ¶ added in v0.4.2
func (x *ListenFinalizeBlockResponse) Reset()
func (*ListenFinalizeBlockResponse) String ¶ added in v0.4.2
func (x *ListenFinalizeBlockResponse) String() string
type UnimplementedABCIListenerServiceServer ¶
type UnimplementedABCIListenerServiceServer struct { }
UnimplementedABCIListenerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedABCIListenerServiceServer) ListenCommit ¶
func (UnimplementedABCIListenerServiceServer) ListenCommit(context.Context, *ListenCommitRequest) (*ListenCommitResponse, error)
func (UnimplementedABCIListenerServiceServer) ListenFinalizeBlock ¶ added in v0.4.2
func (UnimplementedABCIListenerServiceServer) ListenFinalizeBlock(context.Context, *ListenFinalizeBlockRequest) (*ListenFinalizeBlockResponse, error)
type UnsafeABCIListenerServiceServer ¶
type UnsafeABCIListenerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeABCIListenerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ABCIListenerServiceServer will result in compilation errors.