abci

package
v0.7.4 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 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 (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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.