abci

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source
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

View Source
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)

View Source
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 (*ListenBeginBlockRequest) GetRes

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 (*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 (*ListenDeliverTxRequest) GetRes

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 (*ListenEndBlockRequest) GetRes

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) ListenCommit

func (UnimplementedABCIListenerServiceServer) ListenDeliverTx

func (UnimplementedABCIListenerServiceServer) ListenEndBlock

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL