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 ListenBeginBlockRequest
- func (*ListenBeginBlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenBeginBlockRequest) GetReq() *abci.RequestBeginBlock
- func (x *ListenBeginBlockRequest) GetRes() *abci.ResponseBeginBlock
- func (*ListenBeginBlockRequest) ProtoMessage()
- func (x *ListenBeginBlockRequest) ProtoReflect() protoreflect.Message
- func (x *ListenBeginBlockRequest) Reset()
- func (x *ListenBeginBlockRequest) String() string
- type ListenBeginBlockResponse
- 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 ListenDeliverTxRequest
- func (*ListenDeliverTxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenDeliverTxRequest) GetBlockHeight() int64
- func (x *ListenDeliverTxRequest) GetReq() *abci.RequestDeliverTx
- func (x *ListenDeliverTxRequest) GetRes() *abci.ResponseDeliverTx
- func (*ListenDeliverTxRequest) ProtoMessage()
- func (x *ListenDeliverTxRequest) ProtoReflect() protoreflect.Message
- func (x *ListenDeliverTxRequest) Reset()
- func (x *ListenDeliverTxRequest) String() string
- type ListenDeliverTxResponse
- type ListenEndBlockRequest
- func (*ListenEndBlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenEndBlockRequest) GetReq() *abci.RequestEndBlock
- func (x *ListenEndBlockRequest) GetRes() *abci.ResponseEndBlock
- func (*ListenEndBlockRequest) ProtoMessage()
- func (x *ListenEndBlockRequest) ProtoReflect() protoreflect.Message
- func (x *ListenEndBlockRequest) Reset()
- func (x *ListenEndBlockRequest) String() string
- type ListenEndBlockResponse
- type UnimplementedABCIListenerServiceServer
- func (UnimplementedABCIListenerServiceServer) ListenBeginBlock(context.Context, *ListenBeginBlockRequest) (*ListenBeginBlockResponse, error)
- func (UnimplementedABCIListenerServiceServer) ListenCommit(context.Context, *ListenCommitRequest) (*ListenCommitResponse, error)
- func (UnimplementedABCIListenerServiceServer) ListenDeliverTx(context.Context, *ListenDeliverTxRequest) (*ListenDeliverTxResponse, error)
- func (UnimplementedABCIListenerServiceServer) ListenEndBlock(context.Context, *ListenEndBlockRequest) (*ListenEndBlockResponse, error)
- type UnsafeABCIListenerServiceServer
Constants ¶
const ( ABCIListenerService_ListenBeginBlock_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenBeginBlock" ABCIListenerService_ListenEndBlock_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenEndBlock" ABCIListenerService_ListenDeliverTx_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenDeliverTx" 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: "ListenBeginBlock", Handler: _ABCIListenerService_ListenBeginBlock_Handler, }, { MethodName: "ListenEndBlock", Handler: _ABCIListenerService_ListenEndBlock_Handler, }, { MethodName: "ListenDeliverTx", Handler: _ABCIListenerService_ListenDeliverTx_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 { // ListenBeginBlock is the corresponding endpoint for ABCIListener.ListenBeginBlock ListenBeginBlock(ctx context.Context, in *ListenBeginBlockRequest, opts ...grpc.CallOption) (*ListenBeginBlockResponse, error) // ListenEndBlock is the corresponding endpoint for ABCIListener.ListenEndBlock ListenEndBlock(ctx context.Context, in *ListenEndBlockRequest, opts ...grpc.CallOption) (*ListenEndBlockResponse, error) // ListenDeliverTx is the corresponding endpoint for ABCIListener.ListenDeliverTx ListenDeliverTx(ctx context.Context, in *ListenDeliverTxRequest, opts ...grpc.CallOption) (*ListenDeliverTxResponse, 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 { // ListenBeginBlock is the corresponding endpoint for ABCIListener.ListenBeginBlock ListenBeginBlock(context.Context, *ListenBeginBlockRequest) (*ListenBeginBlockResponse, error) // ListenEndBlock is the corresponding endpoint for ABCIListener.ListenEndBlock ListenEndBlock(context.Context, *ListenEndBlockRequest) (*ListenEndBlockResponse, error) // ListenDeliverTx is the corresponding endpoint for ABCIListener.ListenDeliverTx ListenDeliverTx(context.Context, *ListenDeliverTxRequest) (*ListenDeliverTxResponse, 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 ListenBeginBlockRequest ¶
type ListenBeginBlockRequest struct { Req *abci.RequestBeginBlock `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"` Res *abci.ResponseBeginBlock `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"` // contains filtered or unexported fields }
ListenBeginBlockRequest is the request type for the ListenBeginBlock RPC method
func (*ListenBeginBlockRequest) Descriptor
deprecated
func (*ListenBeginBlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenBeginBlockRequest.ProtoReflect.Descriptor instead.
func (*ListenBeginBlockRequest) GetReq ¶
func (x *ListenBeginBlockRequest) GetReq() *abci.RequestBeginBlock
func (*ListenBeginBlockRequest) GetRes ¶
func (x *ListenBeginBlockRequest) GetRes() *abci.ResponseBeginBlock
func (*ListenBeginBlockRequest) ProtoMessage ¶
func (*ListenBeginBlockRequest) ProtoMessage()
func (*ListenBeginBlockRequest) ProtoReflect ¶
func (x *ListenBeginBlockRequest) ProtoReflect() protoreflect.Message
func (*ListenBeginBlockRequest) Reset ¶
func (x *ListenBeginBlockRequest) Reset()
func (*ListenBeginBlockRequest) String ¶
func (x *ListenBeginBlockRequest) String() string
type ListenBeginBlockResponse ¶
type ListenBeginBlockResponse struct {
// contains filtered or unexported fields
}
ListenBeginBlockResponse is the response type for the ListenBeginBlock RPC method
func (*ListenBeginBlockResponse) Descriptor
deprecated
func (*ListenBeginBlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenBeginBlockResponse.ProtoReflect.Descriptor instead.
func (*ListenBeginBlockResponse) ProtoMessage ¶
func (*ListenBeginBlockResponse) ProtoMessage()
func (*ListenBeginBlockResponse) ProtoReflect ¶
func (x *ListenBeginBlockResponse) ProtoReflect() protoreflect.Message
func (*ListenBeginBlockResponse) Reset ¶
func (x *ListenBeginBlockResponse) Reset()
func (*ListenBeginBlockResponse) String ¶
func (x *ListenBeginBlockResponse) String() string
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 ListenDeliverTxRequest ¶
type ListenDeliverTxRequest struct { // explicitly pass in block height as neither RequestDeliverTx or ResponseDeliverTx contain it BlockHeight int64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` Req *abci.RequestDeliverTx `protobuf:"bytes,2,opt,name=req,proto3" json:"req,omitempty"` Res *abci.ResponseDeliverTx `protobuf:"bytes,3,opt,name=res,proto3" json:"res,omitempty"` // contains filtered or unexported fields }
ListenDeliverTxRequest is the request type for the ListenDeliverTx RPC method
func (*ListenDeliverTxRequest) Descriptor
deprecated
func (*ListenDeliverTxRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenDeliverTxRequest.ProtoReflect.Descriptor instead.
func (*ListenDeliverTxRequest) GetBlockHeight ¶
func (x *ListenDeliverTxRequest) GetBlockHeight() int64
func (*ListenDeliverTxRequest) GetReq ¶
func (x *ListenDeliverTxRequest) GetReq() *abci.RequestDeliverTx
func (*ListenDeliverTxRequest) GetRes ¶
func (x *ListenDeliverTxRequest) GetRes() *abci.ResponseDeliverTx
func (*ListenDeliverTxRequest) ProtoMessage ¶
func (*ListenDeliverTxRequest) ProtoMessage()
func (*ListenDeliverTxRequest) ProtoReflect ¶
func (x *ListenDeliverTxRequest) ProtoReflect() protoreflect.Message
func (*ListenDeliverTxRequest) Reset ¶
func (x *ListenDeliverTxRequest) Reset()
func (*ListenDeliverTxRequest) String ¶
func (x *ListenDeliverTxRequest) String() string
type ListenDeliverTxResponse ¶
type ListenDeliverTxResponse struct {
// contains filtered or unexported fields
}
ListenDeliverTxResponse is the response type for the ListenDeliverTx RPC method
func (*ListenDeliverTxResponse) Descriptor
deprecated
func (*ListenDeliverTxResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenDeliverTxResponse.ProtoReflect.Descriptor instead.
func (*ListenDeliverTxResponse) ProtoMessage ¶
func (*ListenDeliverTxResponse) ProtoMessage()
func (*ListenDeliverTxResponse) ProtoReflect ¶
func (x *ListenDeliverTxResponse) ProtoReflect() protoreflect.Message
func (*ListenDeliverTxResponse) Reset ¶
func (x *ListenDeliverTxResponse) Reset()
func (*ListenDeliverTxResponse) String ¶
func (x *ListenDeliverTxResponse) String() string
type ListenEndBlockRequest ¶
type ListenEndBlockRequest struct { Req *abci.RequestEndBlock `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"` Res *abci.ResponseEndBlock `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 (*ListenEndBlockRequest) Descriptor
deprecated
func (*ListenEndBlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenEndBlockRequest.ProtoReflect.Descriptor instead.
func (*ListenEndBlockRequest) GetReq ¶
func (x *ListenEndBlockRequest) GetReq() *abci.RequestEndBlock
func (*ListenEndBlockRequest) GetRes ¶
func (x *ListenEndBlockRequest) GetRes() *abci.ResponseEndBlock
func (*ListenEndBlockRequest) ProtoMessage ¶
func (*ListenEndBlockRequest) ProtoMessage()
func (*ListenEndBlockRequest) ProtoReflect ¶
func (x *ListenEndBlockRequest) ProtoReflect() protoreflect.Message
func (*ListenEndBlockRequest) Reset ¶
func (x *ListenEndBlockRequest) Reset()
func (*ListenEndBlockRequest) String ¶
func (x *ListenEndBlockRequest) String() string
type ListenEndBlockResponse ¶
type ListenEndBlockResponse struct {
// contains filtered or unexported fields
}
ListenEndBlockResponse is the response type for the ListenEndBlock RPC method
func (*ListenEndBlockResponse) Descriptor
deprecated
func (*ListenEndBlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenEndBlockResponse.ProtoReflect.Descriptor instead.
func (*ListenEndBlockResponse) ProtoMessage ¶
func (*ListenEndBlockResponse) ProtoMessage()
func (*ListenEndBlockResponse) ProtoReflect ¶
func (x *ListenEndBlockResponse) ProtoReflect() protoreflect.Message
func (*ListenEndBlockResponse) Reset ¶
func (x *ListenEndBlockResponse) Reset()
func (*ListenEndBlockResponse) String ¶
func (x *ListenEndBlockResponse) String() string
type UnimplementedABCIListenerServiceServer ¶
type UnimplementedABCIListenerServiceServer struct { }
UnimplementedABCIListenerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedABCIListenerServiceServer) ListenBeginBlock ¶
func (UnimplementedABCIListenerServiceServer) ListenBeginBlock(context.Context, *ListenBeginBlockRequest) (*ListenBeginBlockResponse, error)
func (UnimplementedABCIListenerServiceServer) ListenCommit ¶
func (UnimplementedABCIListenerServiceServer) ListenCommit(context.Context, *ListenCommitRequest) (*ListenCommitResponse, error)
func (UnimplementedABCIListenerServiceServer) ListenDeliverTx ¶
func (UnimplementedABCIListenerServiceServer) ListenDeliverTx(context.Context, *ListenDeliverTxRequest) (*ListenDeliverTxResponse, error)
func (UnimplementedABCIListenerServiceServer) ListenEndBlock ¶
func (UnimplementedABCIListenerServiceServer) ListenEndBlock(context.Context, *ListenEndBlockRequest) (*ListenEndBlockResponse, 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.