# Generated by the protocol buffer compiler. DO NOT EDIT!
# sources: cosmos/distribution/v1beta1/distribution.proto, cosmos/distribution/v1beta1/genesis.proto, cosmos/distribution/v1beta1/query.proto, cosmos/distribution/v1beta1/tx.proto
# plugin: python-betterproto
# This file has been @generated
import warnings
from dataclasses import dataclass
from typing import (
TYPE_CHECKING,
Dict,
List,
Optional,
)
import betterproto
import grpclib
from betterproto.grpc.grpclib_server import ServiceBase
from ...base import v1beta1 as __base_v1_beta1__
from ...base.query import v1beta1 as __base_query_v1_beta1__
if TYPE_CHECKING:
import grpclib.server
from betterproto.grpc.grpclib_client import MetadataLike
from grpclib.metadata import Deadline
[docs]
@dataclass(eq=False, repr=False)
class Params(betterproto.Message):
"""Params defines the set of params for the distribution module."""
community_tax: str = betterproto.string_field(1)
base_proposer_reward: str = betterproto.string_field(2)
"""
Deprecated: The base_proposer_reward field is deprecated and is no longer used
in the x/distribution module's reward mechanism.
"""
bonus_proposer_reward: str = betterproto.string_field(3)
"""
Deprecated: The bonus_proposer_reward field is deprecated and is no longer used
in the x/distribution module's reward mechanism.
"""
withdraw_addr_enabled: bool = betterproto.bool_field(4)
def __post_init__(self) -> None:
super().__post_init__()
if self.is_set("base_proposer_reward"):
warnings.warn(
"Params.base_proposer_reward is deprecated", DeprecationWarning
)
if self.is_set("bonus_proposer_reward"):
warnings.warn(
"Params.bonus_proposer_reward is deprecated", DeprecationWarning
)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorHistoricalRewards(betterproto.Message):
"""
ValidatorHistoricalRewards represents historical rewards for a validator.
Height is implicit within the store key.
Cumulative reward ratio is the sum from the zeroeth period
until this period of rewards / tokens, per the spec.
The reference count indicates the number of objects
which might need to reference this historical entry at any point.
ReferenceCount =
number of outstanding delegations which ended the associated period (and
might need to read that record)
+ number of slashes which ended the associated period (and might need to
read that record)
+ one per validator for the zeroeth period, set on initialization
"""
cumulative_reward_ratio: List["__base_v1_beta1__.DecCoin"] = (
betterproto.message_field(1)
)
reference_count: int = betterproto.uint32_field(2)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorCurrentRewards(betterproto.Message):
"""
ValidatorCurrentRewards represents current rewards and current
period for a validator kept as a running counter and incremented
each block as long as the validator's tokens remain constant.
"""
rewards: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(1)
period: int = betterproto.uint64_field(2)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorAccumulatedCommission(betterproto.Message):
"""
ValidatorAccumulatedCommission represents accumulated commission
for a validator kept as a running counter, can be withdrawn at any time.
"""
commission: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(1)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorOutstandingRewards(betterproto.Message):
"""
ValidatorOutstandingRewards represents outstanding (un-withdrawn) rewards
for a validator inexpensive to track, allows simple sanity checks.
"""
rewards: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(1)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorSlashEvent(betterproto.Message):
"""
ValidatorSlashEvent represents a validator slash event.
Height is implicit within the store key.
This is needed to calculate appropriate amount of staking tokens
for delegations which are withdrawn after a slash has occurred.
"""
validator_period: int = betterproto.uint64_field(1)
fraction: str = betterproto.string_field(2)
[docs]
@dataclass(eq=False, repr=False)
class ValidatorSlashEvents(betterproto.Message):
"""ValidatorSlashEvents is a collection of ValidatorSlashEvent messages."""
validator_slash_events: List["ValidatorSlashEvent"] = betterproto.message_field(1)
[docs]
@dataclass(eq=False, repr=False)
class FeePool(betterproto.Message):
"""FeePool is the global fee pool for distribution."""
community_pool: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(1)
[docs]
@dataclass(eq=False, repr=False)
class DelegatorStartingInfo(betterproto.Message):
"""
DelegatorStartingInfo represents the starting info for a delegator reward
period. It tracks the previous validator period, the delegation's amount of
staking token, and the creation height (to check later on if any slashes have
occurred). NOTE: Even though validators are slashed to whole staking tokens,
the delegators within the validator may be left with less than a full token,
thus sdk.Dec is used.
"""
previous_period: int = betterproto.uint64_field(1)
stake: str = betterproto.string_field(2)
height: int = betterproto.uint64_field(3)
[docs]
@dataclass(eq=False, repr=False)
class DelegationDelegatorReward(betterproto.Message):
"""
DelegationDelegatorReward represents the properties
of a delegator's delegation reward.
"""
validator_address: str = betterproto.string_field(1)
reward: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(2)
[docs]
@dataclass(eq=False, repr=False)
class DelegatorWithdrawInfo(betterproto.Message):
"""
DelegatorWithdrawInfo is the address for where distributions rewards are
withdrawn to by default this struct is only used at genesis to feed in
default withdraw addresses.
"""
delegator_address: str = betterproto.string_field(1)
"""delegator_address is the address of the delegator."""
withdraw_address: str = betterproto.string_field(2)
"""withdraw_address is the address to withdraw the delegation rewards to."""
[docs]
@dataclass(eq=False, repr=False)
class ValidatorOutstandingRewardsRecord(betterproto.Message):
"""ValidatorOutstandingRewardsRecord is used for import/export via genesis json."""
validator_address: str = betterproto.string_field(1)
"""validator_address is the address of the validator."""
outstanding_rewards: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(
2
)
"""outstanding_rewards represents the outstanding rewards of a validator."""
[docs]
@dataclass(eq=False, repr=False)
class ValidatorAccumulatedCommissionRecord(betterproto.Message):
"""
ValidatorAccumulatedCommissionRecord is used for import / export via genesis
json.
"""
validator_address: str = betterproto.string_field(1)
"""validator_address is the address of the validator."""
accumulated: "ValidatorAccumulatedCommission" = betterproto.message_field(2)
"""accumulated is the accumulated commission of a validator."""
[docs]
@dataclass(eq=False, repr=False)
class ValidatorHistoricalRewardsRecord(betterproto.Message):
"""
ValidatorHistoricalRewardsRecord is used for import / export via genesis
json.
"""
validator_address: str = betterproto.string_field(1)
"""validator_address is the address of the validator."""
period: int = betterproto.uint64_field(2)
"""period defines the period the historical rewards apply to."""
rewards: "ValidatorHistoricalRewards" = betterproto.message_field(3)
"""rewards defines the historical rewards of a validator."""
[docs]
@dataclass(eq=False, repr=False)
class ValidatorCurrentRewardsRecord(betterproto.Message):
"""ValidatorCurrentRewardsRecord is used for import / export via genesis json."""
validator_address: str = betterproto.string_field(1)
"""validator_address is the address of the validator."""
rewards: "ValidatorCurrentRewards" = betterproto.message_field(2)
"""rewards defines the current rewards of a validator."""
[docs]
@dataclass(eq=False, repr=False)
class DelegatorStartingInfoRecord(betterproto.Message):
"""DelegatorStartingInfoRecord used for import / export via genesis json."""
delegator_address: str = betterproto.string_field(1)
"""delegator_address is the address of the delegator."""
validator_address: str = betterproto.string_field(2)
"""validator_address is the address of the validator."""
starting_info: "DelegatorStartingInfo" = betterproto.message_field(3)
"""starting_info defines the starting info of a delegator."""
[docs]
@dataclass(eq=False, repr=False)
class ValidatorSlashEventRecord(betterproto.Message):
"""ValidatorSlashEventRecord is used for import / export via genesis json."""
validator_address: str = betterproto.string_field(1)
"""validator_address is the address of the validator."""
height: int = betterproto.uint64_field(2)
"""height defines the block height at which the slash event occurred."""
period: int = betterproto.uint64_field(3)
"""period is the period of the slash event."""
validator_slash_event: "ValidatorSlashEvent" = betterproto.message_field(4)
"""validator_slash_event describes the slash event."""
[docs]
@dataclass(eq=False, repr=False)
class GenesisState(betterproto.Message):
"""GenesisState defines the distribution module's genesis state."""
params: "Params" = betterproto.message_field(1)
"""params defines all the parameters of the module."""
fee_pool: "FeePool" = betterproto.message_field(2)
"""fee_pool defines the fee pool at genesis."""
delegator_withdraw_infos: List["DelegatorWithdrawInfo"] = betterproto.message_field(
3
)
"""fee_pool defines the delegator withdraw infos at genesis."""
previous_proposer: str = betterproto.string_field(4)
"""fee_pool defines the previous proposer at genesis."""
outstanding_rewards: List["ValidatorOutstandingRewardsRecord"] = (
betterproto.message_field(5)
)
"""fee_pool defines the outstanding rewards of all validators at genesis."""
validator_accumulated_commissions: List["ValidatorAccumulatedCommissionRecord"] = (
betterproto.message_field(6)
)
"""fee_pool defines the accumulated commissions of all validators at genesis."""
validator_historical_rewards: List["ValidatorHistoricalRewardsRecord"] = (
betterproto.message_field(7)
)
"""fee_pool defines the historical rewards of all validators at genesis."""
validator_current_rewards: List["ValidatorCurrentRewardsRecord"] = (
betterproto.message_field(8)
)
"""fee_pool defines the current rewards of all validators at genesis."""
delegator_starting_infos: List["DelegatorStartingInfoRecord"] = (
betterproto.message_field(9)
)
"""fee_pool defines the delegator starting infos at genesis."""
validator_slash_events: List["ValidatorSlashEventRecord"] = (
betterproto.message_field(10)
)
"""fee_pool defines the validator slash events at genesis."""
[docs]
@dataclass(eq=False, repr=False)
class QueryParamsRequest(betterproto.Message):
"""QueryParamsRequest is the request type for the Query/Params RPC method."""
pass
[docs]
@dataclass(eq=False, repr=False)
class QueryParamsResponse(betterproto.Message):
"""QueryParamsResponse is the response type for the Query/Params RPC method."""
params: "Params" = betterproto.message_field(1)
"""params defines the parameters of the module."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorDistributionInfoRequest(betterproto.Message):
"""
QueryValidatorDistributionInfoRequest is the request type for the
Query/ValidatorDistributionInfo RPC method.
"""
validator_address: str = betterproto.string_field(1)
"""validator_address defines the validator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorDistributionInfoResponse(betterproto.Message):
"""
QueryValidatorDistributionInfoResponse is the response type for the
Query/ValidatorDistributionInfo RPC method.
"""
operator_address: str = betterproto.string_field(1)
"""operator_address defines the validator operator address."""
self_bond_rewards: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(2)
"""self_bond_rewards defines the self delegations rewards."""
commission: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(3)
"""commission defines the commission the validator received."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorOutstandingRewardsRequest(betterproto.Message):
"""
QueryValidatorOutstandingRewardsRequest is the request type for the
Query/ValidatorOutstandingRewards RPC method.
"""
validator_address: str = betterproto.string_field(1)
"""validator_address defines the validator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorOutstandingRewardsResponse(betterproto.Message):
"""
QueryValidatorOutstandingRewardsResponse is the response type for the
Query/ValidatorOutstandingRewards RPC method.
"""
rewards: "ValidatorOutstandingRewards" = betterproto.message_field(1)
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorCommissionRequest(betterproto.Message):
"""
QueryValidatorCommissionRequest is the request type for the
Query/ValidatorCommission RPC method
"""
validator_address: str = betterproto.string_field(1)
"""validator_address defines the validator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorCommissionResponse(betterproto.Message):
"""
QueryValidatorCommissionResponse is the response type for the
Query/ValidatorCommission RPC method
"""
commission: "ValidatorAccumulatedCommission" = betterproto.message_field(1)
"""commission defines the commission the validator received."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorSlashesRequest(betterproto.Message):
"""
QueryValidatorSlashesRequest is the request type for the
Query/ValidatorSlashes RPC method
"""
validator_address: str = betterproto.string_field(1)
"""validator_address defines the validator address to query for."""
starting_height: int = betterproto.uint64_field(2)
"""starting_height defines the optional starting height to query the slashes."""
ending_height: int = betterproto.uint64_field(3)
"""starting_height defines the optional ending height to query the slashes."""
pagination: "__base_query_v1_beta1__.PageRequest" = betterproto.message_field(4)
"""pagination defines an optional pagination for the request."""
[docs]
@dataclass(eq=False, repr=False)
class QueryValidatorSlashesResponse(betterproto.Message):
"""
QueryValidatorSlashesResponse is the response type for the
Query/ValidatorSlashes RPC method.
"""
slashes: List["ValidatorSlashEvent"] = betterproto.message_field(1)
"""slashes defines the slashes the validator received."""
pagination: "__base_query_v1_beta1__.PageResponse" = betterproto.message_field(2)
"""pagination defines the pagination in the response."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegationRewardsRequest(betterproto.Message):
"""
QueryDelegationRewardsRequest is the request type for the
Query/DelegationRewards RPC method.
"""
delegator_address: str = betterproto.string_field(1)
"""delegator_address defines the delegator address to query for."""
validator_address: str = betterproto.string_field(2)
"""validator_address defines the validator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegationRewardsResponse(betterproto.Message):
"""
QueryDelegationRewardsResponse is the response type for the
Query/DelegationRewards RPC method.
"""
rewards: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(1)
"""rewards defines the rewards accrued by a delegation."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegationTotalRewardsRequest(betterproto.Message):
"""
QueryDelegationTotalRewardsRequest is the request type for the
Query/DelegationTotalRewards RPC method.
"""
delegator_address: str = betterproto.string_field(1)
"""delegator_address defines the delegator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegationTotalRewardsResponse(betterproto.Message):
"""
QueryDelegationTotalRewardsResponse is the response type for the
Query/DelegationTotalRewards RPC method.
"""
rewards: List["DelegationDelegatorReward"] = betterproto.message_field(1)
"""rewards defines all the rewards accrued by a delegator."""
total: List["__base_v1_beta1__.DecCoin"] = betterproto.message_field(2)
"""total defines the sum of all the rewards."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegatorValidatorsRequest(betterproto.Message):
"""
QueryDelegatorValidatorsRequest is the request type for the
Query/DelegatorValidators RPC method.
"""
delegator_address: str = betterproto.string_field(1)
"""delegator_address defines the delegator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegatorValidatorsResponse(betterproto.Message):
"""
QueryDelegatorValidatorsResponse is the response type for the
Query/DelegatorValidators RPC method.
"""
validators: List[str] = betterproto.string_field(1)
"""validators defines the validators a delegator is delegating for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegatorWithdrawAddressRequest(betterproto.Message):
"""
QueryDelegatorWithdrawAddressRequest is the request type for the
Query/DelegatorWithdrawAddress RPC method.
"""
delegator_address: str = betterproto.string_field(1)
"""delegator_address defines the delegator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class QueryDelegatorWithdrawAddressResponse(betterproto.Message):
"""
QueryDelegatorWithdrawAddressResponse is the response type for the
Query/DelegatorWithdrawAddress RPC method.
"""
withdraw_address: str = betterproto.string_field(1)
"""withdraw_address defines the delegator address to query for."""
[docs]
@dataclass(eq=False, repr=False)
class MsgSetWithdrawAddress(betterproto.Message):
"""
MsgSetWithdrawAddress sets the withdraw address for
a delegator (or validator self-delegation).
"""
delegator_address: str = betterproto.string_field(1)
withdraw_address: str = betterproto.string_field(2)
[docs]
@dataclass(eq=False, repr=False)
class MsgSetWithdrawAddressResponse(betterproto.Message):
"""
MsgSetWithdrawAddressResponse defines the Msg/SetWithdrawAddress response
type.
"""
pass
[docs]
@dataclass(eq=False, repr=False)
class MsgWithdrawDelegatorReward(betterproto.Message):
"""
MsgWithdrawDelegatorReward represents delegation withdrawal to a delegator
from a single validator.
"""
delegator_address: str = betterproto.string_field(1)
validator_address: str = betterproto.string_field(2)
[docs]
@dataclass(eq=False, repr=False)
class MsgWithdrawDelegatorRewardResponse(betterproto.Message):
"""
MsgWithdrawDelegatorRewardResponse defines the Msg/WithdrawDelegatorReward
response type.
"""
amount: List["__base_v1_beta1__.Coin"] = betterproto.message_field(1)
"""Since: cosmos-sdk 0.46"""
[docs]
@dataclass(eq=False, repr=False)
class MsgWithdrawValidatorCommission(betterproto.Message):
"""
MsgWithdrawValidatorCommission withdraws the full commission to the validator
address.
"""
validator_address: str = betterproto.string_field(1)
[docs]
@dataclass(eq=False, repr=False)
class MsgWithdrawValidatorCommissionResponse(betterproto.Message):
"""
MsgWithdrawValidatorCommissionResponse defines the
Msg/WithdrawValidatorCommission response type.
"""
amount: List["__base_v1_beta1__.Coin"] = betterproto.message_field(1)
"""Since: cosmos-sdk 0.46"""
[docs]
@dataclass(eq=False, repr=False)
class MsgUpdateParams(betterproto.Message):
"""
MsgUpdateParams is the Msg/UpdateParams request type.
Since: cosmos-sdk 0.47
"""
authority: str = betterproto.string_field(1)
"""
authority is the address that controls the module (defaults to x/gov unless
overwritten).
"""
params: "Params" = betterproto.message_field(2)
"""
params defines the x/distribution parameters to update.
NOTE: All parameters must be supplied.
"""
[docs]
@dataclass(eq=False, repr=False)
class MsgUpdateParamsResponse(betterproto.Message):
"""
MsgUpdateParamsResponse defines the response structure for executing a
MsgUpdateParams message.
Since: cosmos-sdk 0.47
"""
pass
[docs]
@dataclass(eq=False, repr=False)
class MsgDepositValidatorRewardsPool(betterproto.Message):
"""
DepositValidatorRewardsPool defines the request structure to provide
additional rewards to delegators from a specific validator.
Since: cosmos-sdk 0.50
"""
depositor: str = betterproto.string_field(1)
validator_address: str = betterproto.string_field(2)
amount: List["__base_v1_beta1__.Coin"] = betterproto.message_field(3)
[docs]
@dataclass(eq=False, repr=False)
class MsgDepositValidatorRewardsPoolResponse(betterproto.Message):
"""
MsgDepositValidatorRewardsPoolResponse defines the response to executing a
MsgDepositValidatorRewardsPool message.
Since: cosmos-sdk 0.50
"""
pass
[docs]
class QueryStub(betterproto.ServiceStub):
[docs]
async def params(
self,
query_params_request: "QueryParamsRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryParamsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/Params",
query_params_request,
QueryParamsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def validator_distribution_info(
self,
query_validator_distribution_info_request: "QueryValidatorDistributionInfoRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryValidatorDistributionInfoResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/ValidatorDistributionInfo",
query_validator_distribution_info_request,
QueryValidatorDistributionInfoResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def validator_outstanding_rewards(
self,
query_validator_outstanding_rewards_request: "QueryValidatorOutstandingRewardsRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryValidatorOutstandingRewardsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/ValidatorOutstandingRewards",
query_validator_outstanding_rewards_request,
QueryValidatorOutstandingRewardsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def validator_commission(
self,
query_validator_commission_request: "QueryValidatorCommissionRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryValidatorCommissionResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/ValidatorCommission",
query_validator_commission_request,
QueryValidatorCommissionResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def validator_slashes(
self,
query_validator_slashes_request: "QueryValidatorSlashesRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryValidatorSlashesResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/ValidatorSlashes",
query_validator_slashes_request,
QueryValidatorSlashesResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def delegation_rewards(
self,
query_delegation_rewards_request: "QueryDelegationRewardsRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryDelegationRewardsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/DelegationRewards",
query_delegation_rewards_request,
QueryDelegationRewardsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def delegation_total_rewards(
self,
query_delegation_total_rewards_request: "QueryDelegationTotalRewardsRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryDelegationTotalRewardsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/DelegationTotalRewards",
query_delegation_total_rewards_request,
QueryDelegationTotalRewardsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def delegator_validators(
self,
query_delegator_validators_request: "QueryDelegatorValidatorsRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryDelegatorValidatorsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/DelegatorValidators",
query_delegator_validators_request,
QueryDelegatorValidatorsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def delegator_withdraw_address(
self,
query_delegator_withdraw_address_request: "QueryDelegatorWithdrawAddressRequest",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "QueryDelegatorWithdrawAddressResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Query/DelegatorWithdrawAddress",
query_delegator_withdraw_address_request,
QueryDelegatorWithdrawAddressResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
class MsgStub(betterproto.ServiceStub):
[docs]
async def set_withdraw_address(
self,
msg_set_withdraw_address: "MsgSetWithdrawAddress",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "MsgSetWithdrawAddressResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Msg/SetWithdrawAddress",
msg_set_withdraw_address,
MsgSetWithdrawAddressResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def withdraw_delegator_reward(
self,
msg_withdraw_delegator_reward: "MsgWithdrawDelegatorReward",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "MsgWithdrawDelegatorRewardResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Msg/WithdrawDelegatorReward",
msg_withdraw_delegator_reward,
MsgWithdrawDelegatorRewardResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def withdraw_validator_commission(
self,
msg_withdraw_validator_commission: "MsgWithdrawValidatorCommission",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "MsgWithdrawValidatorCommissionResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Msg/WithdrawValidatorCommission",
msg_withdraw_validator_commission,
MsgWithdrawValidatorCommissionResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def update_params(
self,
msg_update_params: "MsgUpdateParams",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "MsgUpdateParamsResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Msg/UpdateParams",
msg_update_params,
MsgUpdateParamsResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
async def deposit_validator_rewards_pool(
self,
msg_deposit_validator_rewards_pool: "MsgDepositValidatorRewardsPool",
*,
timeout: Optional[float] = None,
deadline: Optional["Deadline"] = None,
metadata: Optional["MetadataLike"] = None,
) -> "MsgDepositValidatorRewardsPoolResponse":
return await self._unary_unary(
"/cosmos.distribution.v1beta1.Msg/DepositValidatorRewardsPool",
msg_deposit_validator_rewards_pool,
MsgDepositValidatorRewardsPoolResponse,
timeout=timeout,
deadline=deadline,
metadata=metadata,
)
[docs]
class QueryBase(ServiceBase):
[docs]
async def params(
self, query_params_request: "QueryParamsRequest"
) -> "QueryParamsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def validator_distribution_info(
self,
query_validator_distribution_info_request: "QueryValidatorDistributionInfoRequest",
) -> "QueryValidatorDistributionInfoResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def validator_outstanding_rewards(
self,
query_validator_outstanding_rewards_request: "QueryValidatorOutstandingRewardsRequest",
) -> "QueryValidatorOutstandingRewardsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def validator_commission(
self, query_validator_commission_request: "QueryValidatorCommissionRequest"
) -> "QueryValidatorCommissionResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def validator_slashes(
self, query_validator_slashes_request: "QueryValidatorSlashesRequest"
) -> "QueryValidatorSlashesResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def delegation_rewards(
self, query_delegation_rewards_request: "QueryDelegationRewardsRequest"
) -> "QueryDelegationRewardsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def delegation_total_rewards(
self,
query_delegation_total_rewards_request: "QueryDelegationTotalRewardsRequest",
) -> "QueryDelegationTotalRewardsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def delegator_validators(
self, query_delegator_validators_request: "QueryDelegatorValidatorsRequest"
) -> "QueryDelegatorValidatorsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def delegator_withdraw_address(
self,
query_delegator_withdraw_address_request: "QueryDelegatorWithdrawAddressRequest",
) -> "QueryDelegatorWithdrawAddressResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
async def __rpc_params(
self, stream: "grpclib.server.Stream[QueryParamsRequest, QueryParamsResponse]"
) -> None:
request = await stream.recv_message()
response = await self.params(request)
await stream.send_message(response)
async def __rpc_validator_distribution_info(
self,
stream: "grpclib.server.Stream[QueryValidatorDistributionInfoRequest, QueryValidatorDistributionInfoResponse]",
) -> None:
request = await stream.recv_message()
response = await self.validator_distribution_info(request)
await stream.send_message(response)
async def __rpc_validator_outstanding_rewards(
self,
stream: "grpclib.server.Stream[QueryValidatorOutstandingRewardsRequest, QueryValidatorOutstandingRewardsResponse]",
) -> None:
request = await stream.recv_message()
response = await self.validator_outstanding_rewards(request)
await stream.send_message(response)
async def __rpc_validator_commission(
self,
stream: "grpclib.server.Stream[QueryValidatorCommissionRequest, QueryValidatorCommissionResponse]",
) -> None:
request = await stream.recv_message()
response = await self.validator_commission(request)
await stream.send_message(response)
async def __rpc_validator_slashes(
self,
stream: "grpclib.server.Stream[QueryValidatorSlashesRequest, QueryValidatorSlashesResponse]",
) -> None:
request = await stream.recv_message()
response = await self.validator_slashes(request)
await stream.send_message(response)
async def __rpc_delegation_rewards(
self,
stream: "grpclib.server.Stream[QueryDelegationRewardsRequest, QueryDelegationRewardsResponse]",
) -> None:
request = await stream.recv_message()
response = await self.delegation_rewards(request)
await stream.send_message(response)
async def __rpc_delegation_total_rewards(
self,
stream: "grpclib.server.Stream[QueryDelegationTotalRewardsRequest, QueryDelegationTotalRewardsResponse]",
) -> None:
request = await stream.recv_message()
response = await self.delegation_total_rewards(request)
await stream.send_message(response)
async def __rpc_delegator_validators(
self,
stream: "grpclib.server.Stream[QueryDelegatorValidatorsRequest, QueryDelegatorValidatorsResponse]",
) -> None:
request = await stream.recv_message()
response = await self.delegator_validators(request)
await stream.send_message(response)
async def __rpc_delegator_withdraw_address(
self,
stream: "grpclib.server.Stream[QueryDelegatorWithdrawAddressRequest, QueryDelegatorWithdrawAddressResponse]",
) -> None:
request = await stream.recv_message()
response = await self.delegator_withdraw_address(request)
await stream.send_message(response)
async def __rpc_community_pool(
self,
stream: "grpclib.server.Stream[QueryCommunityPoolRequest, QueryCommunityPoolResponse]",
) -> None:
request = await stream.recv_message()
response = await self.community_pool(request)
await stream.send_message(response)
def __mapping__(self) -> Dict[str, grpclib.const.Handler]:
return {
"/cosmos.distribution.v1beta1.Query/Params": grpclib.const.Handler(
self.__rpc_params,
grpclib.const.Cardinality.UNARY_UNARY,
QueryParamsRequest,
QueryParamsResponse,
),
"/cosmos.distribution.v1beta1.Query/ValidatorDistributionInfo": grpclib.const.Handler(
self.__rpc_validator_distribution_info,
grpclib.const.Cardinality.UNARY_UNARY,
QueryValidatorDistributionInfoRequest,
QueryValidatorDistributionInfoResponse,
),
"/cosmos.distribution.v1beta1.Query/ValidatorOutstandingRewards": grpclib.const.Handler(
self.__rpc_validator_outstanding_rewards,
grpclib.const.Cardinality.UNARY_UNARY,
QueryValidatorOutstandingRewardsRequest,
QueryValidatorOutstandingRewardsResponse,
),
"/cosmos.distribution.v1beta1.Query/ValidatorCommission": grpclib.const.Handler(
self.__rpc_validator_commission,
grpclib.const.Cardinality.UNARY_UNARY,
QueryValidatorCommissionRequest,
QueryValidatorCommissionResponse,
),
"/cosmos.distribution.v1beta1.Query/ValidatorSlashes": grpclib.const.Handler(
self.__rpc_validator_slashes,
grpclib.const.Cardinality.UNARY_UNARY,
QueryValidatorSlashesRequest,
QueryValidatorSlashesResponse,
),
"/cosmos.distribution.v1beta1.Query/DelegationRewards": grpclib.const.Handler(
self.__rpc_delegation_rewards,
grpclib.const.Cardinality.UNARY_UNARY,
QueryDelegationRewardsRequest,
QueryDelegationRewardsResponse,
),
"/cosmos.distribution.v1beta1.Query/DelegationTotalRewards": grpclib.const.Handler(
self.__rpc_delegation_total_rewards,
grpclib.const.Cardinality.UNARY_UNARY,
QueryDelegationTotalRewardsRequest,
QueryDelegationTotalRewardsResponse,
),
"/cosmos.distribution.v1beta1.Query/DelegatorValidators": grpclib.const.Handler(
self.__rpc_delegator_validators,
grpclib.const.Cardinality.UNARY_UNARY,
QueryDelegatorValidatorsRequest,
QueryDelegatorValidatorsResponse,
),
"/cosmos.distribution.v1beta1.Query/DelegatorWithdrawAddress": grpclib.const.Handler(
self.__rpc_delegator_withdraw_address,
grpclib.const.Cardinality.UNARY_UNARY,
QueryDelegatorWithdrawAddressRequest,
QueryDelegatorWithdrawAddressResponse,
),
"/cosmos.distribution.v1beta1.Query/CommunityPool": grpclib.const.Handler(
self.__rpc_community_pool,
grpclib.const.Cardinality.UNARY_UNARY,
QueryCommunityPoolRequest,
QueryCommunityPoolResponse,
),
}
[docs]
class MsgBase(ServiceBase):
[docs]
async def set_withdraw_address(
self, msg_set_withdraw_address: "MsgSetWithdrawAddress"
) -> "MsgSetWithdrawAddressResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def withdraw_delegator_reward(
self, msg_withdraw_delegator_reward: "MsgWithdrawDelegatorReward"
) -> "MsgWithdrawDelegatorRewardResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def withdraw_validator_commission(
self, msg_withdraw_validator_commission: "MsgWithdrawValidatorCommission"
) -> "MsgWithdrawValidatorCommissionResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def update_params(
self, msg_update_params: "MsgUpdateParams"
) -> "MsgUpdateParamsResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
[docs]
async def deposit_validator_rewards_pool(
self, msg_deposit_validator_rewards_pool: "MsgDepositValidatorRewardsPool"
) -> "MsgDepositValidatorRewardsPoolResponse":
raise grpclib.GRPCError(grpclib.const.Status.UNIMPLEMENTED)
async def __rpc_set_withdraw_address(
self,
stream: "grpclib.server.Stream[MsgSetWithdrawAddress, MsgSetWithdrawAddressResponse]",
) -> None:
request = await stream.recv_message()
response = await self.set_withdraw_address(request)
await stream.send_message(response)
async def __rpc_withdraw_delegator_reward(
self,
stream: "grpclib.server.Stream[MsgWithdrawDelegatorReward, MsgWithdrawDelegatorRewardResponse]",
) -> None:
request = await stream.recv_message()
response = await self.withdraw_delegator_reward(request)
await stream.send_message(response)
async def __rpc_withdraw_validator_commission(
self,
stream: "grpclib.server.Stream[MsgWithdrawValidatorCommission, MsgWithdrawValidatorCommissionResponse]",
) -> None:
request = await stream.recv_message()
response = await self.withdraw_validator_commission(request)
await stream.send_message(response)
async def __rpc_fund_community_pool(
self,
stream: "grpclib.server.Stream[MsgFundCommunityPool, MsgFundCommunityPoolResponse]",
) -> None:
request = await stream.recv_message()
response = await self.fund_community_pool(request)
await stream.send_message(response)
async def __rpc_update_params(
self, stream: "grpclib.server.Stream[MsgUpdateParams, MsgUpdateParamsResponse]"
) -> None:
request = await stream.recv_message()
response = await self.update_params(request)
await stream.send_message(response)
async def __rpc_community_pool_spend(
self,
stream: "grpclib.server.Stream[MsgCommunityPoolSpend, MsgCommunityPoolSpendResponse]",
) -> None:
request = await stream.recv_message()
response = await self.community_pool_spend(request)
await stream.send_message(response)
async def __rpc_deposit_validator_rewards_pool(
self,
stream: "grpclib.server.Stream[MsgDepositValidatorRewardsPool, MsgDepositValidatorRewardsPoolResponse]",
) -> None:
request = await stream.recv_message()
response = await self.deposit_validator_rewards_pool(request)
await stream.send_message(response)
def __mapping__(self) -> Dict[str, grpclib.const.Handler]:
return {
"/cosmos.distribution.v1beta1.Msg/SetWithdrawAddress": grpclib.const.Handler(
self.__rpc_set_withdraw_address,
grpclib.const.Cardinality.UNARY_UNARY,
MsgSetWithdrawAddress,
MsgSetWithdrawAddressResponse,
),
"/cosmos.distribution.v1beta1.Msg/WithdrawDelegatorReward": grpclib.const.Handler(
self.__rpc_withdraw_delegator_reward,
grpclib.const.Cardinality.UNARY_UNARY,
MsgWithdrawDelegatorReward,
MsgWithdrawDelegatorRewardResponse,
),
"/cosmos.distribution.v1beta1.Msg/WithdrawValidatorCommission": grpclib.const.Handler(
self.__rpc_withdraw_validator_commission,
grpclib.const.Cardinality.UNARY_UNARY,
MsgWithdrawValidatorCommission,
MsgWithdrawValidatorCommissionResponse,
),
"/cosmos.distribution.v1beta1.Msg/FundCommunityPool": grpclib.const.Handler(
self.__rpc_fund_community_pool,
grpclib.const.Cardinality.UNARY_UNARY,
MsgFundCommunityPool,
MsgFundCommunityPoolResponse,
),
"/cosmos.distribution.v1beta1.Msg/UpdateParams": grpclib.const.Handler(
self.__rpc_update_params,
grpclib.const.Cardinality.UNARY_UNARY,
MsgUpdateParams,
MsgUpdateParamsResponse,
),
"/cosmos.distribution.v1beta1.Msg/CommunityPoolSpend": grpclib.const.Handler(
self.__rpc_community_pool_spend,
grpclib.const.Cardinality.UNARY_UNARY,
MsgCommunityPoolSpend,
MsgCommunityPoolSpendResponse,
),
"/cosmos.distribution.v1beta1.Msg/DepositValidatorRewardsPool": grpclib.const.Handler(
self.__rpc_deposit_validator_rewards_pool,
grpclib.const.Cardinality.UNARY_UNARY,
MsgDepositValidatorRewardsPool,
MsgDepositValidatorRewardsPoolResponse,
),
}