abci

package
v0.7.5 Latest Latest
Warning

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

Go to latest
Published: May 9, 2024 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_ListenFinalizeBlock_FullMethodName = "/cosmos.store.streaming.abci.ABCIListenerService/ListenFinalizeBlock"
	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: "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)

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 {
	// 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 (*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 (*ListenFinalizeBlockRequest) GetRes added in v0.4.2

func (*ListenFinalizeBlockRequest) ProtoMessage added in v0.4.2

func (*ListenFinalizeBlockRequest) ProtoMessage()

func (*ListenFinalizeBlockRequest) ProtoReflect added in v0.4.2

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 (*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) ListenFinalizeBlock added in v0.4.2

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