chore: clean-up after go-plugin system pr (#15402)
This commit is contained in:
@@ -1698,7 +1698,7 @@ type PackageReference struct {
|
||||
//
|
||||
// When a new version of a module is released and items are added to existing
|
||||
// .proto files, these definitions should contain comments of the form
|
||||
// "Since Revision N" where N is an integer revision.
|
||||
// "Since: Revision N" where N is an integer revision.
|
||||
//
|
||||
// When the module runtime starts up, it will check the pinned proto
|
||||
// image and panic if there are runtime protobuf definitions that are not
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||
// versions:
|
||||
// - protoc-gen-go-grpc v1.2.0
|
||||
// - protoc-gen-go-grpc v1.3.0
|
||||
// - protoc (unknown)
|
||||
// source: cosmos/store/streaming/abci/grpc.proto
|
||||
|
||||
@@ -18,6 +18,13 @@ import (
|
||||
// Requires gRPC-Go v1.32.0 or later.
|
||||
const _ = grpc.SupportPackageIsVersion7
|
||||
|
||||
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"
|
||||
)
|
||||
|
||||
// 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.
|
||||
@@ -42,7 +49,7 @@ func NewABCIListenerServiceClient(cc grpc.ClientConnInterface) ABCIListenerServi
|
||||
|
||||
func (c *aBCIListenerServiceClient) ListenBeginBlock(ctx context.Context, in *ListenBeginBlockRequest, opts ...grpc.CallOption) (*ListenBeginBlockResponse, error) {
|
||||
out := new(ListenBeginBlockResponse)
|
||||
err := c.cc.Invoke(ctx, "/cosmos.store.streaming.abci.ABCIListenerService/ListenBeginBlock", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, ABCIListenerService_ListenBeginBlock_FullMethodName, in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -51,7 +58,7 @@ func (c *aBCIListenerServiceClient) ListenBeginBlock(ctx context.Context, in *Li
|
||||
|
||||
func (c *aBCIListenerServiceClient) ListenEndBlock(ctx context.Context, in *ListenEndBlockRequest, opts ...grpc.CallOption) (*ListenEndBlockResponse, error) {
|
||||
out := new(ListenEndBlockResponse)
|
||||
err := c.cc.Invoke(ctx, "/cosmos.store.streaming.abci.ABCIListenerService/ListenEndBlock", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, ABCIListenerService_ListenEndBlock_FullMethodName, in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -60,7 +67,7 @@ func (c *aBCIListenerServiceClient) ListenEndBlock(ctx context.Context, in *List
|
||||
|
||||
func (c *aBCIListenerServiceClient) ListenDeliverTx(ctx context.Context, in *ListenDeliverTxRequest, opts ...grpc.CallOption) (*ListenDeliverTxResponse, error) {
|
||||
out := new(ListenDeliverTxResponse)
|
||||
err := c.cc.Invoke(ctx, "/cosmos.store.streaming.abci.ABCIListenerService/ListenDeliverTx", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, ABCIListenerService_ListenDeliverTx_FullMethodName, in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -69,7 +76,7 @@ func (c *aBCIListenerServiceClient) ListenDeliverTx(ctx context.Context, in *Lis
|
||||
|
||||
func (c *aBCIListenerServiceClient) ListenCommit(ctx context.Context, in *ListenCommitRequest, opts ...grpc.CallOption) (*ListenCommitResponse, error) {
|
||||
out := new(ListenCommitResponse)
|
||||
err := c.cc.Invoke(ctx, "/cosmos.store.streaming.abci.ABCIListenerService/ListenCommit", in, out, opts...)
|
||||
err := c.cc.Invoke(ctx, ABCIListenerService_ListenCommit_FullMethodName, in, out, opts...)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -130,7 +137,7 @@ func _ABCIListenerService_ListenBeginBlock_Handler(srv interface{}, ctx context.
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/cosmos.store.streaming.abci.ABCIListenerService/ListenBeginBlock",
|
||||
FullMethod: ABCIListenerService_ListenBeginBlock_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ABCIListenerServiceServer).ListenBeginBlock(ctx, req.(*ListenBeginBlockRequest))
|
||||
@@ -148,7 +155,7 @@ func _ABCIListenerService_ListenEndBlock_Handler(srv interface{}, ctx context.Co
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/cosmos.store.streaming.abci.ABCIListenerService/ListenEndBlock",
|
||||
FullMethod: ABCIListenerService_ListenEndBlock_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ABCIListenerServiceServer).ListenEndBlock(ctx, req.(*ListenEndBlockRequest))
|
||||
@@ -166,7 +173,7 @@ func _ABCIListenerService_ListenDeliverTx_Handler(srv interface{}, ctx context.C
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/cosmos.store.streaming.abci.ABCIListenerService/ListenDeliverTx",
|
||||
FullMethod: ABCIListenerService_ListenDeliverTx_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ABCIListenerServiceServer).ListenDeliverTx(ctx, req.(*ListenDeliverTxRequest))
|
||||
@@ -184,7 +191,7 @@ func _ABCIListenerService_ListenCommit_Handler(srv interface{}, ctx context.Cont
|
||||
}
|
||||
info := &grpc.UnaryServerInfo{
|
||||
Server: srv,
|
||||
FullMethod: "/cosmos.store.streaming.abci.ABCIListenerService/ListenCommit",
|
||||
FullMethod: ABCIListenerService_ListenCommit_FullMethodName,
|
||||
}
|
||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
||||
return srv.(ABCIListenerServiceServer).ListenCommit(ctx, req.(*ListenCommitRequest))
|
||||
|
||||
Reference in New Issue
Block a user