LaconicNetwork/cosmos-sdk
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

feat(cli/api): add validator distribution info grpc gateway get endpoint (#13144)

Browse Source
This commit is contained in:
Sai Kumar
2022-09-05 15:01:01 +00:00
committed by GitHub
parent 2efee04e4f
commit 65fff07a34
10 changed files with 2648 additions and 516 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/cosmos/distribution/v1beta1/query.pulsar.go
+1710 -428
View File
File diff suppressed because it is too large Load Diff
api/cosmos/distribution/v1beta1/query_grpc.pb.go
+38
View File
@@ -24,6 +24,8 @@ const _ = grpc.SupportPackageIsVersion7
type QueryClient interface {
// Params queries params of the distribution module.
Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
// ValidatorDistributionInfo queries validator commision and self-delegation rewards for validator
ValidatorDistributionInfo(ctx context.Context, in *QueryValidatorDistributionInfoRequest, opts ...grpc.CallOption) (*QueryValidatorDistributionInfoResponse, error)
// ValidatorOutstandingRewards queries rewards of a validator address.
ValidatorOutstandingRewards(ctx context.Context, in *QueryValidatorOutstandingRewardsRequest, opts ...grpc.CallOption) (*QueryValidatorOutstandingRewardsResponse, error)
// ValidatorCommission queries accumulated commission for a validator.
@@ -60,6 +62,15 @@ func (c *queryClient) Params(ctx context.Context, in *QueryParamsRequest, opts .
return out, nil
}
func (c *queryClient) ValidatorDistributionInfo(ctx context.Context, in *QueryValidatorDistributionInfoRequest, opts ...grpc.CallOption) (*QueryValidatorDistributionInfoResponse, error) {
out := new(QueryValidatorDistributionInfoResponse)
err := c.cc.Invoke(ctx, "/cosmos.distribution.v1beta1.Query/ValidatorDistributionInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) ValidatorOutstandingRewards(ctx context.Context, in *QueryValidatorOutstandingRewardsRequest, opts ...grpc.CallOption) (*QueryValidatorOutstandingRewardsResponse, error) {
out := new(QueryValidatorOutstandingRewardsResponse)
err := c.cc.Invoke(ctx, "/cosmos.distribution.v1beta1.Query/ValidatorOutstandingRewards", in, out, opts...)
@@ -138,6 +149,8 @@ func (c *queryClient) CommunityPool(ctx context.Context, in *QueryCommunityPoolR
type QueryServer interface {
// Params queries params of the distribution module.
Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
// ValidatorDistributionInfo queries validator commision and self-delegation rewards for validator
ValidatorDistributionInfo(context.Context, *QueryValidatorDistributionInfoRequest) (*QueryValidatorDistributionInfoResponse, error)
// ValidatorOutstandingRewards queries rewards of a validator address.
ValidatorOutstandingRewards(context.Context, *QueryValidatorOutstandingRewardsRequest) (*QueryValidatorOutstandingRewardsResponse, error)
// ValidatorCommission queries accumulated commission for a validator.
@@ -165,6 +178,9 @@ type UnimplementedQueryServer struct {
func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Params not implemented")
}
func (UnimplementedQueryServer) ValidatorDistributionInfo(context.Context, *QueryValidatorDistributionInfoRequest) (*QueryValidatorDistributionInfoResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ValidatorDistributionInfo not implemented")
}
func (UnimplementedQueryServer) ValidatorOutstandingRewards(context.Context, *QueryValidatorOutstandingRewardsRequest) (*QueryValidatorOutstandingRewardsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ValidatorOutstandingRewards not implemented")
}
@@ -220,6 +236,24 @@ func _Query_Params_Handler(srv interface{}, ctx context.Context, dec func(interf
return interceptor(ctx, in, info, handler)
}
func _Query_ValidatorDistributionInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryValidatorDistributionInfoRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).ValidatorDistributionInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/cosmos.distribution.v1beta1.Query/ValidatorDistributionInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).ValidatorDistributionInfo(ctx, req.(*QueryValidatorDistributionInfoRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_ValidatorOutstandingRewards_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryValidatorOutstandingRewardsRequest)
if err := dec(in); err != nil {
@@ -375,6 +409,10 @@ var Query_ServiceDesc = grpc.ServiceDesc{
MethodName: "Params",
Handler: _Query_Params_Handler,
},
{
MethodName: "ValidatorDistributionInfo",
Handler: _Query_ValidatorDistributionInfo_Handler,
},
{
MethodName: "ValidatorOutstandingRewards",
Handler: _Query_ValidatorOutstandingRewards_Handler,