types

package
v0.53.6 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2026 License: Apache-2.0 Imports: 33 Imported by: 20

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName is the module name constant used in many places
	//
	// The module account associated with this name is the x/protocolpool community pool module account.
	// Funded by:
	// - direct funding from users using MsgFundProtocolPool
	// - all leftover funds that are not allocated to continuous funds in the BeginBlocker from ProtocolPoolEscrowAccount
	// Distributes to:
	// - users on MsgCommunityPoolSpend
	ModuleName = "protocolpool"

	// ProtocolPoolEscrowAccount is an intermediary account that holds the funds to be distributed to other accounts.
	//
	// It can receive funds from `x/distribution` and distribute them to continuous funds and/or the community pool.
	// Funded by:
	// - `x/distribution` during its BeginBlocker from the FeePool.CommunityPool
	// Distributes to:
	// - Continuous Funds in the store in the BeginBlocker
	// - CommunityPool (all remaining funds not allocated for Continuous Funds) in the BeginBlocker
	ProtocolPoolEscrowAccount = "protocolpool_escrow"

	// StoreKey is the store key string for protocolpool
	StoreKey = ModuleName
)

Variables

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ContinuousFundsKey = collections.NewPrefix(3)
	ParamsKey          = collections.NewPrefix(8)
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrInvalidSigner = errors.Register(ModuleName, 2, "expected authority account as only signer for community pool spend message")
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func RegisterInterfaces 

func RegisterInterfaces(ir codectypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/protocolpool interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

NOTE amino msg name paths are shorted due to the 40-character limit for amino.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	AddressCodec() address.Codec
	GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx context.Context, name string) sdk.ModuleAccountI
	SetModuleAccount(ctx context.Context, macc sdk.ModuleAccountI)
}

type BankKeeper 

type BankKeeper interface {
	BlockedAddr(addr sdk.AccAddress) bool
	GetBalance(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx context.Context, senderModule, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type ContinuousFund 

type ContinuousFund struct {
	// Recipient is the address string of the account receiving funds.
	Recipient string `protobuf:"bytes,1,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// Percentage is the percentage of funds to be allocated from Community pool.
	Percentage cosmossdk_io_math.LegacyDec `protobuf:"bytes,2,opt,name=percentage,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"percentage"`
	// Optional, if expiry is set, removes the state object when expired.
	Expiry *time.Time `protobuf:"bytes,3,opt,name=expiry,proto3,stdtime" json:"expiry,omitempty"`
}

ContinuousFund defines the fields of continuous fund proposal.

func (*ContinuousFund) Descriptor 

func (*ContinuousFund) Descriptor() ([]byte, []int)

func (*ContinuousFund) GetExpiry 

func (m *ContinuousFund) GetExpiry() *time.Time

func (*ContinuousFund) GetRecipient 

func (m *ContinuousFund) GetRecipient() string

func (*ContinuousFund) Marshal 

func (m *ContinuousFund) Marshal() (dAtA []byte, err error)

func (*ContinuousFund) MarshalTo 

func (m *ContinuousFund) MarshalTo(dAtA []byte) (int, error)

func (*ContinuousFund) MarshalToSizedBuffer 

func (m *ContinuousFund) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContinuousFund) ProtoMessage 

func (*ContinuousFund) ProtoMessage()

func (*ContinuousFund) Reset 

func (m *ContinuousFund) Reset()

func (*ContinuousFund) Size 

func (m *ContinuousFund) Size() (n int)

func (*ContinuousFund) String 

func (m *ContinuousFund) String() string

func (*ContinuousFund) Unmarshal 

func (m *ContinuousFund) Unmarshal(dAtA []byte) error

func (*ContinuousFund) Validate 

func (cf *ContinuousFund) Validate() error

func (*ContinuousFund) XXX_DiscardUnknown 

func (m *ContinuousFund) XXX_DiscardUnknown()

func (*ContinuousFund) XXX_Marshal 

func (m *ContinuousFund) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContinuousFund) XXX_Merge 

func (m *ContinuousFund) XXX_Merge(src proto.Message)

func (*ContinuousFund) XXX_Size 

func (m *ContinuousFund) XXX_Size() int

func (*ContinuousFund) XXX_Unmarshal 

func (m *ContinuousFund) XXX_Unmarshal(b []byte) error

type ExternalCommunityPoolKeeper 

type ExternalCommunityPoolKeeper interface {
	// GetCommunityPoolModule gets the module name that funds should be sent to for the community pool.
	// This is the address that x/distribution will send funds to for external management.
	GetCommunityPoolModule() string
	// FundCommunityPool allows an account to directly fund the community fund pool.
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, senderAddr sdk.AccAddress) error
	// DistributeFromCommunityPool distributes funds from the community pool module account to
	// a receiver address.
	DistributeFromCommunityPool(ctx sdk.Context, amount sdk.Coins, receiveAddr sdk.AccAddress) error
}

ExternalCommunityPoolKeeper is the interface that an external community pool module keeper must fulfill for x/distribution to properly accept it as a community pool fund destination.

type GenesisState 

type GenesisState struct {
	// ContinuousFunds defines the continuous funds at genesis.
	ContinuousFunds []ContinuousFund `protobuf:"bytes,1,rep,name=continuous_funds,json=continuousFunds,proto3" json:"continuous_funds"`
	// Params defines the parameters of this module, currently only contains the
	// denoms that will be used for continuous fund distributions.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

GenesisState defines the protocolpool module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(cf []ContinuousFund) *GenesisState

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetContinuousFunds 

func (m *GenesisState) GetContinuousFunds() []ContinuousFund

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) Validate 

func (gs *GenesisState) Validate() error

Validate validates the genesis state of protocolpool genesis input

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type MsgCancelContinuousFund 

type MsgCancelContinuousFund struct {
	// Authority is the account address of authority.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// Recipient is the account address string of the recipient whose funds are to be cancelled.
	Recipient string `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"`
}

MsgCancelContinuousFund defines a message to cancel continuous funds for a specific recipient.

func (*MsgCancelContinuousFund) Descriptor 

func (*MsgCancelContinuousFund) Descriptor() ([]byte, []int)

func (*MsgCancelContinuousFund) GetAuthority 

func (m *MsgCancelContinuousFund) GetAuthority() string

func (*MsgCancelContinuousFund) GetRecipient 

func (m *MsgCancelContinuousFund) GetRecipient() string

func (*MsgCancelContinuousFund) Marshal 

func (m *MsgCancelContinuousFund) Marshal() (dAtA []byte, err error)

func (*MsgCancelContinuousFund) MarshalTo 

func (m *MsgCancelContinuousFund) MarshalTo(dAtA []byte) (int, error)

func (*MsgCancelContinuousFund) MarshalToSizedBuffer 

func (m *MsgCancelContinuousFund) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCancelContinuousFund) ProtoMessage 

func (*MsgCancelContinuousFund) ProtoMessage()

func (*MsgCancelContinuousFund) Reset 

func (m *MsgCancelContinuousFund) Reset()

func (*MsgCancelContinuousFund) Size 

func (m *MsgCancelContinuousFund) Size() (n int)

func (*MsgCancelContinuousFund) String 

func (m *MsgCancelContinuousFund) String() string

func (*MsgCancelContinuousFund) Unmarshal 

func (m *MsgCancelContinuousFund) Unmarshal(dAtA []byte) error

func (*MsgCancelContinuousFund) XXX_DiscardUnknown 

func (m *MsgCancelContinuousFund) XXX_DiscardUnknown()

func (*MsgCancelContinuousFund) XXX_Marshal 

func (m *MsgCancelContinuousFund) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCancelContinuousFund) XXX_Merge 

func (m *MsgCancelContinuousFund) XXX_Merge(src proto.Message)

func (*MsgCancelContinuousFund) XXX_Size 

func (m *MsgCancelContinuousFund) XXX_Size() int

func (*MsgCancelContinuousFund) XXX_Unmarshal 

func (m *MsgCancelContinuousFund) XXX_Unmarshal(b []byte) error

type MsgCancelContinuousFundResponse 

type MsgCancelContinuousFundResponse struct {
	// CanceledTime is the canceled time.
	CanceledTime time.Time `protobuf:"bytes,1,opt,name=canceled_time,json=canceledTime,proto3,stdtime" json:"canceled_time"`
	// CanceledHeight defines the canceled block height.
	CanceledHeight uint64 `protobuf:"varint,2,opt,name=canceled_height,json=canceledHeight,proto3" json:"canceled_height,omitempty"`
	// Recipient is the account address string of the recipient whose funds are cancelled.
	Recipient string `protobuf:"bytes,3,opt,name=recipient,proto3" json:"recipient,omitempty"`
}

MsgCancelContinuousFundResponse defines the response to executing a MsgCancelContinuousFund message.

func (*MsgCancelContinuousFundResponse) Descriptor 

func (*MsgCancelContinuousFundResponse) Descriptor() ([]byte, []int)

func (*MsgCancelContinuousFundResponse) GetCanceledHeight 

func (m *MsgCancelContinuousFundResponse) GetCanceledHeight() uint64

func (*MsgCancelContinuousFundResponse) GetCanceledTime 

func (m *MsgCancelContinuousFundResponse) GetCanceledTime() time.Time

func (*MsgCancelContinuousFundResponse) GetRecipient 

func (m *MsgCancelContinuousFundResponse) GetRecipient() string

func (*MsgCancelContinuousFundResponse) Marshal 

func (m *MsgCancelContinuousFundResponse) Marshal() (dAtA []byte, err error)

func (*MsgCancelContinuousFundResponse) MarshalTo 

func (m *MsgCancelContinuousFundResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCancelContinuousFundResponse) MarshalToSizedBuffer 

func (m *MsgCancelContinuousFundResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCancelContinuousFundResponse) ProtoMessage 

func (*MsgCancelContinuousFundResponse) ProtoMessage()

func (*MsgCancelContinuousFundResponse) Reset 

func (m *MsgCancelContinuousFundResponse) Reset()

func (*MsgCancelContinuousFundResponse) Size 

func (m *MsgCancelContinuousFundResponse) Size() (n int)

func (*MsgCancelContinuousFundResponse) String 

func (m *MsgCancelContinuousFundResponse) String() string

func (*MsgCancelContinuousFundResponse) Unmarshal 

func (m *MsgCancelContinuousFundResponse) Unmarshal(dAtA []byte) error

func (*MsgCancelContinuousFundResponse) XXX_DiscardUnknown 

func (m *MsgCancelContinuousFundResponse) XXX_DiscardUnknown()

func (*MsgCancelContinuousFundResponse) XXX_Marshal 

func (m *MsgCancelContinuousFundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCancelContinuousFundResponse) XXX_Merge 

func (m *MsgCancelContinuousFundResponse) XXX_Merge(src proto.Message)

func (*MsgCancelContinuousFundResponse) XXX_Size 

func (m *MsgCancelContinuousFundResponse) XXX_Size() int

func (*MsgCancelContinuousFundResponse) XXX_Unmarshal 

func (m *MsgCancelContinuousFundResponse) XXX_Unmarshal(b []byte) error

type MsgClient 

type MsgClient interface {
	// FundCommunityPool defines a method to allow an account to directly
	// fund the community pool.
	FundCommunityPool(ctx context.Context, in *MsgFundCommunityPool, opts ...grpc.CallOption) (*MsgFundCommunityPoolResponse, error)
	// CommunityPoolSpend defines a governance operation for sending tokens from
	// the community pool in the x/protocolpool module to another account, which
	// could be the governance module itself. The authority is defined in the
	// keeper.
	CommunityPoolSpend(ctx context.Context, in *MsgCommunityPoolSpend, opts ...grpc.CallOption) (*MsgCommunityPoolSpendResponse, error)
	// CreateContinuousFund defines a method to distribute a percentage of funds to an address continuously.
	// This ContinuousFund can be indefinite or run until a given expiry time.
	// Funds come from validator block rewards from x/distribution, but may also come from
	// any user who funds the ProtocolPoolEscrow module account directly through x/bank.
	CreateContinuousFund(ctx context.Context, in *MsgCreateContinuousFund, opts ...grpc.CallOption) (*MsgCreateContinuousFundResponse, error)
	// CancelContinuousFund defines a method for cancelling continuous fund.
	CancelContinuousFund(ctx context.Context, in *MsgCancelContinuousFund, opts ...grpc.CallOption) (*MsgCancelContinuousFundResponse, error)
	// UpdateParams defines a governance operation for updating the x/protocolpool module parameters.
	// The authority is defined in the keeper.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCommunityPoolSpend 

type MsgCommunityPoolSpend struct {
	// Authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string                                   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Recipient string                                   `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"`
	Amount    github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

MsgCommunityPoolSpend defines a message for sending tokens from the community pool to another account. This message is typically executed via a governance proposal with the governance module being the executing authority.

func NewMsgCommunityPoolSpend 

func NewMsgCommunityPoolSpend(amount sdk.Coins, authority, recipient string) *MsgCommunityPoolSpend

NewMsgCommunityPoolSpend returns a new CommunityPoolSpend with authority, recipient and a spending amount.

func (*MsgCommunityPoolSpend) Descriptor 

func (*MsgCommunityPoolSpend) Descriptor() ([]byte, []int)

func (*MsgCommunityPoolSpend) GetAmount 

func (m *MsgCommunityPoolSpend) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*MsgCommunityPoolSpend) GetAuthority 

func (m *MsgCommunityPoolSpend) GetAuthority() string

func (*MsgCommunityPoolSpend) GetRecipient 

func (m *MsgCommunityPoolSpend) GetRecipient() string

func (*MsgCommunityPoolSpend) Marshal 

func (m *MsgCommunityPoolSpend) Marshal() (dAtA []byte, err error)

func (*MsgCommunityPoolSpend) MarshalTo 

func (m *MsgCommunityPoolSpend) MarshalTo(dAtA []byte) (int, error)

func (*MsgCommunityPoolSpend) MarshalToSizedBuffer 

func (m *MsgCommunityPoolSpend) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCommunityPoolSpend) ProtoMessage 

func (*MsgCommunityPoolSpend) ProtoMessage()

func (*MsgCommunityPoolSpend) Reset 

func (m *MsgCommunityPoolSpend) Reset()

func (*MsgCommunityPoolSpend) Size 

func (m *MsgCommunityPoolSpend) Size() (n int)

func (*MsgCommunityPoolSpend) String 

func (m *MsgCommunityPoolSpend) String() string

func (*MsgCommunityPoolSpend) Unmarshal 

func (m *MsgCommunityPoolSpend) Unmarshal(dAtA []byte) error

func (*MsgCommunityPoolSpend) XXX_DiscardUnknown 

func (m *MsgCommunityPoolSpend) XXX_DiscardUnknown()

func (*MsgCommunityPoolSpend) XXX_Marshal 

func (m *MsgCommunityPoolSpend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCommunityPoolSpend) XXX_Merge 

func (m *MsgCommunityPoolSpend) XXX_Merge(src proto.Message)

func (*MsgCommunityPoolSpend) XXX_Size 

func (m *MsgCommunityPoolSpend) XXX_Size() int

func (*MsgCommunityPoolSpend) XXX_Unmarshal 

func (m *MsgCommunityPoolSpend) XXX_Unmarshal(b []byte) error

type MsgCommunityPoolSpendResponse 

type MsgCommunityPoolSpendResponse struct {
}

MsgCommunityPoolSpendResponse defines the response to executing a MsgCommunityPoolSpend message.

func (*MsgCommunityPoolSpendResponse) Descriptor 

func (*MsgCommunityPoolSpendResponse) Descriptor() ([]byte, []int)

func (*MsgCommunityPoolSpendResponse) Marshal 

func (m *MsgCommunityPoolSpendResponse) Marshal() (dAtA []byte, err error)

func (*MsgCommunityPoolSpendResponse) MarshalTo 

func (m *MsgCommunityPoolSpendResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCommunityPoolSpendResponse) MarshalToSizedBuffer 

func (m *MsgCommunityPoolSpendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCommunityPoolSpendResponse) ProtoMessage 

func (*MsgCommunityPoolSpendResponse) ProtoMessage()

func (*MsgCommunityPoolSpendResponse) Reset 

func (m *MsgCommunityPoolSpendResponse) Reset()

func (*MsgCommunityPoolSpendResponse) Size 

func (m *MsgCommunityPoolSpendResponse) Size() (n int)

func (*MsgCommunityPoolSpendResponse) String 

func (m *MsgCommunityPoolSpendResponse) String() string

func (*MsgCommunityPoolSpendResponse) Unmarshal 

func (m *MsgCommunityPoolSpendResponse) Unmarshal(dAtA []byte) error

func (*MsgCommunityPoolSpendResponse) XXX_DiscardUnknown 

func (m *MsgCommunityPoolSpendResponse) XXX_DiscardUnknown()

func (*MsgCommunityPoolSpendResponse) XXX_Marshal 

func (m *MsgCommunityPoolSpendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCommunityPoolSpendResponse) XXX_Merge 

func (m *MsgCommunityPoolSpendResponse) XXX_Merge(src proto.Message)

func (*MsgCommunityPoolSpendResponse) XXX_Size 

func (m *MsgCommunityPoolSpendResponse) XXX_Size() int

func (*MsgCommunityPoolSpendResponse) XXX_Unmarshal 

func (m *MsgCommunityPoolSpendResponse) XXX_Unmarshal(b []byte) error

type MsgCreateContinuousFund 

type MsgCreateContinuousFund struct {
	// Authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// Recipient address of the account receiving funds.
	Recipient string `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"`
	// Percentage is the percentage of funds to be allocated from Community pool.
	Percentage cosmossdk_io_math.LegacyDec `protobuf:"bytes,3,opt,name=percentage,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"percentage"`
	// Optional, if expiry is set, removes the state object when expired.
	Expiry *time.Time `protobuf:"bytes,4,opt,name=expiry,proto3,stdtime" json:"expiry,omitempty"`
}

MsgCreateContinuousFund defines a message for adding continuous funds.

func (*MsgCreateContinuousFund) Descriptor 

func (*MsgCreateContinuousFund) Descriptor() ([]byte, []int)

func (*MsgCreateContinuousFund) GetAuthority 

func (m *MsgCreateContinuousFund) GetAuthority() string

func (*MsgCreateContinuousFund) GetExpiry 

func (m *MsgCreateContinuousFund) GetExpiry() *time.Time

func (*MsgCreateContinuousFund) GetRecipient 

func (m *MsgCreateContinuousFund) GetRecipient() string

func (*MsgCreateContinuousFund) Marshal 

func (m *MsgCreateContinuousFund) Marshal() (dAtA []byte, err error)

func (*MsgCreateContinuousFund) MarshalTo 

func (m *MsgCreateContinuousFund) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateContinuousFund) MarshalToSizedBuffer 

func (m *MsgCreateContinuousFund) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateContinuousFund) ProtoMessage 

func (*MsgCreateContinuousFund) ProtoMessage()

func (*MsgCreateContinuousFund) Reset 

func (m *MsgCreateContinuousFund) Reset()

func (*MsgCreateContinuousFund) Size 

func (m *MsgCreateContinuousFund) Size() (n int)

func (*MsgCreateContinuousFund) String 

func (m *MsgCreateContinuousFund) String() string

func (*MsgCreateContinuousFund) Unmarshal 

func (m *MsgCreateContinuousFund) Unmarshal(dAtA []byte) error

func (*MsgCreateContinuousFund) XXX_DiscardUnknown 

func (m *MsgCreateContinuousFund) XXX_DiscardUnknown()

func (*MsgCreateContinuousFund) XXX_Marshal 

func (m *MsgCreateContinuousFund) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateContinuousFund) XXX_Merge 

func (m *MsgCreateContinuousFund) XXX_Merge(src proto.Message)

func (*MsgCreateContinuousFund) XXX_Size 

func (m *MsgCreateContinuousFund) XXX_Size() int

func (*MsgCreateContinuousFund) XXX_Unmarshal 

func (m *MsgCreateContinuousFund) XXX_Unmarshal(b []byte) error

type MsgCreateContinuousFundResponse 

type MsgCreateContinuousFundResponse struct {
}

MsgCreateContinuousFundResponse defines the response to executing a MsgCreateContinuousFund message.

func (*MsgCreateContinuousFundResponse) Descriptor 

func (*MsgCreateContinuousFundResponse) Descriptor() ([]byte, []int)

func (*MsgCreateContinuousFundResponse) Marshal 

func (m *MsgCreateContinuousFundResponse) Marshal() (dAtA []byte, err error)

func (*MsgCreateContinuousFundResponse) MarshalTo 

func (m *MsgCreateContinuousFundResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateContinuousFundResponse) MarshalToSizedBuffer 

func (m *MsgCreateContinuousFundResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateContinuousFundResponse) ProtoMessage 

func (*MsgCreateContinuousFundResponse) ProtoMessage()

func (*MsgCreateContinuousFundResponse) Reset 

func (m *MsgCreateContinuousFundResponse) Reset()

func (*MsgCreateContinuousFundResponse) Size 

func (m *MsgCreateContinuousFundResponse) Size() (n int)

func (*MsgCreateContinuousFundResponse) String 

func (m *MsgCreateContinuousFundResponse) String() string

func (*MsgCreateContinuousFundResponse) Unmarshal 

func (m *MsgCreateContinuousFundResponse) Unmarshal(dAtA []byte) error

func (*MsgCreateContinuousFundResponse) XXX_DiscardUnknown 

func (m *MsgCreateContinuousFundResponse) XXX_DiscardUnknown()

func (*MsgCreateContinuousFundResponse) XXX_Marshal 

func (m *MsgCreateContinuousFundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateContinuousFundResponse) XXX_Merge 

func (m *MsgCreateContinuousFundResponse) XXX_Merge(src proto.Message)

func (*MsgCreateContinuousFundResponse) XXX_Size 

func (m *MsgCreateContinuousFundResponse) XXX_Size() int

func (*MsgCreateContinuousFundResponse) XXX_Unmarshal 

func (m *MsgCreateContinuousFundResponse) XXX_Unmarshal(b []byte) error

type MsgFundCommunityPool 

type MsgFundCommunityPool struct {
	Depositor string                                   `protobuf:"bytes,1,opt,name=depositor,proto3" json:"depositor,omitempty"`
	Amount    github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

MsgFundCommunityPool allows an account to directly fund the community pool.

func NewMsgFundCommunityPool 

func NewMsgFundCommunityPool(amount sdk.Coins, depositor string) *MsgFundCommunityPool

NewMsgFundCommunityPool returns a new MsgFundCommunityPool with a sender and a funding amount.

func (*MsgFundCommunityPool) Descriptor 

func (*MsgFundCommunityPool) Descriptor() ([]byte, []int)

func (*MsgFundCommunityPool) Marshal 

func (m *MsgFundCommunityPool) Marshal() (dAtA []byte, err error)

func (*MsgFundCommunityPool) MarshalTo 

func (m *MsgFundCommunityPool) MarshalTo(dAtA []byte) (int, error)

func (*MsgFundCommunityPool) MarshalToSizedBuffer 

func (m *MsgFundCommunityPool) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgFundCommunityPool) ProtoMessage 

func (*MsgFundCommunityPool) ProtoMessage()

func (*MsgFundCommunityPool) Reset 

func (m *MsgFundCommunityPool) Reset()

func (*MsgFundCommunityPool) Size 

func (m *MsgFundCommunityPool) Size() (n int)

func (*MsgFundCommunityPool) String 

func (m *MsgFundCommunityPool) String() string

func (*MsgFundCommunityPool) Unmarshal 

func (m *MsgFundCommunityPool) Unmarshal(dAtA []byte) error

func (*MsgFundCommunityPool) XXX_DiscardUnknown 

func (m *MsgFundCommunityPool) XXX_DiscardUnknown()

func (*MsgFundCommunityPool) XXX_Marshal 

func (m *MsgFundCommunityPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgFundCommunityPool) XXX_Merge 

func (m *MsgFundCommunityPool) XXX_Merge(src proto.Message)

func (*MsgFundCommunityPool) XXX_Size 

func (m *MsgFundCommunityPool) XXX_Size() int

func (*MsgFundCommunityPool) XXX_Unmarshal 

func (m *MsgFundCommunityPool) XXX_Unmarshal(b []byte) error

type MsgFundCommunityPoolResponse 

type MsgFundCommunityPoolResponse struct {
}

MsgFundCommunityPoolResponse defines the Msg/FundCommunityPool response type.

func (*MsgFundCommunityPoolResponse) Descriptor 

func (*MsgFundCommunityPoolResponse) Descriptor() ([]byte, []int)

func (*MsgFundCommunityPoolResponse) Marshal 

func (m *MsgFundCommunityPoolResponse) Marshal() (dAtA []byte, err error)

func (*MsgFundCommunityPoolResponse) MarshalTo 

func (m *MsgFundCommunityPoolResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgFundCommunityPoolResponse) MarshalToSizedBuffer 

func (m *MsgFundCommunityPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgFundCommunityPoolResponse) ProtoMessage 

func (*MsgFundCommunityPoolResponse) ProtoMessage()

func (*MsgFundCommunityPoolResponse) Reset 

func (m *MsgFundCommunityPoolResponse) Reset()

func (*MsgFundCommunityPoolResponse) Size 

func (m *MsgFundCommunityPoolResponse) Size() (n int)

func (*MsgFundCommunityPoolResponse) String 

func (m *MsgFundCommunityPoolResponse) String() string

func (*MsgFundCommunityPoolResponse) Unmarshal 

func (m *MsgFundCommunityPoolResponse) Unmarshal(dAtA []byte) error

func (*MsgFundCommunityPoolResponse) XXX_DiscardUnknown 

func (m *MsgFundCommunityPoolResponse) XXX_DiscardUnknown()

func (*MsgFundCommunityPoolResponse) XXX_Marshal 

func (m *MsgFundCommunityPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgFundCommunityPoolResponse) XXX_Merge 

func (m *MsgFundCommunityPoolResponse) XXX_Merge(src proto.Message)

func (*MsgFundCommunityPoolResponse) XXX_Size 

func (m *MsgFundCommunityPoolResponse) XXX_Size() int

func (*MsgFundCommunityPoolResponse) XXX_Unmarshal 

func (m *MsgFundCommunityPoolResponse) XXX_Unmarshal(b []byte) error

type MsgServer 

type MsgServer interface {
	// FundCommunityPool defines a method to allow an account to directly
	// fund the community pool.
	FundCommunityPool(context.Context, *MsgFundCommunityPool) (*MsgFundCommunityPoolResponse, error)
	// CommunityPoolSpend defines a governance operation for sending tokens from
	// the community pool in the x/protocolpool module to another account, which
	// could be the governance module itself. The authority is defined in the
	// keeper.
	CommunityPoolSpend(context.Context, *MsgCommunityPoolSpend) (*MsgCommunityPoolSpendResponse, error)
	// CreateContinuousFund defines a method to distribute a percentage of funds to an address continuously.
	// This ContinuousFund can be indefinite or run until a given expiry time.
	// Funds come from validator block rewards from x/distribution, but may also come from
	// any user who funds the ProtocolPoolEscrow module account directly through x/bank.
	CreateContinuousFund(context.Context, *MsgCreateContinuousFund) (*MsgCreateContinuousFundResponse, error)
	// CancelContinuousFund defines a method for cancelling continuous fund.
	CancelContinuousFund(context.Context, *MsgCancelContinuousFund) (*MsgCancelContinuousFundResponse, error)
	// UpdateParams defines a governance operation for updating the x/protocolpool module parameters.
	// The authority is defined in the keeper.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/protocolpool parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

func (*MsgUpdateParams) Descriptor 

func (*MsgUpdateParams) Descriptor() ([]byte, []int)

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) Marshal 

func (m *MsgUpdateParams) Marshal() (dAtA []byte, err error)

func (*MsgUpdateParams) MarshalTo 

func (m *MsgUpdateParams) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateParams) MarshalToSizedBuffer 

func (m *MsgUpdateParams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

func (m *MsgUpdateParams) Size() (n int)

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

func (m *MsgUpdateParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateParams) XXX_Merge 

func (m *MsgUpdateParams) XXX_Merge(src proto.Message)

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor 

func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateParamsResponse) Marshal 

func (m *MsgUpdateParamsResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateParamsResponse) MarshalTo 

func (m *MsgUpdateParamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

func (m *MsgUpdateParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

func (m *MsgUpdateParamsResponse) Size() (n int)

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

func (m *MsgUpdateParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateParamsResponse) XXX_Merge 

func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error

type Params 

type Params struct {
	// EnabledDistributionDenoms lists the denoms that are allowed to be distributed.
	// This is to avoid spending time distributing undesired tokens to continuous funds and budgets.
	EnabledDistributionDenoms []string `` /* 138-byte string literal not displayed */
	// DistributionFrequency is the frequency (in terms of blocks) that funds are distributed out from the
	// x/protocolpool module.
	DistributionFrequency uint64 `protobuf:"varint,2,opt,name=distribution_frequency,json=distributionFrequency,proto3" json:"distribution_frequency,omitempty"`
}

Params defines the parameters for the protocolpool module.

func DefaultParams 

func DefaultParams() Params

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) GetDistributionFrequency 

func (m *Params) GetDistributionFrequency() uint64

func (*Params) GetEnabledDistributionDenoms 

func (m *Params) GetEnabledDistributionDenoms() []string

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) Validate 

func (p *Params) Validate() error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

type QueryClient 

type QueryClient interface {
	// CommunityPool queries the community pool coins.
	CommunityPool(ctx context.Context, in *QueryCommunityPoolRequest, opts ...grpc.CallOption) (*QueryCommunityPoolResponse, error)
	// ContinuousFund queries a continuous fund by the recipient is is associated with.
	ContinuousFund(ctx context.Context, in *QueryContinuousFundRequest, opts ...grpc.CallOption) (*QueryContinuousFundResponse, error)
	// ContinuousFunds queries all continuous funds in the store.
	ContinuousFunds(ctx context.Context, in *QueryContinuousFundsRequest, opts ...grpc.CallOption) (*QueryContinuousFundsResponse, error)
	// Params returns the total set of x/protocolpool parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryCommunityPoolRequest 

type QueryCommunityPoolRequest struct {
}

QueryCommunityPoolRequest is the request type for the Query/CommunityPool RPC method.

func (*QueryCommunityPoolRequest) Descriptor 

func (*QueryCommunityPoolRequest) Descriptor() ([]byte, []int)

func (*QueryCommunityPoolRequest) Marshal 

func (m *QueryCommunityPoolRequest) Marshal() (dAtA []byte, err error)

func (*QueryCommunityPoolRequest) MarshalTo 

func (m *QueryCommunityPoolRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryCommunityPoolRequest) MarshalToSizedBuffer 

func (m *QueryCommunityPoolRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCommunityPoolRequest) ProtoMessage 

func (*QueryCommunityPoolRequest) ProtoMessage()

func (*QueryCommunityPoolRequest) Reset 

func (m *QueryCommunityPoolRequest) Reset()

func (*QueryCommunityPoolRequest) Size 

func (m *QueryCommunityPoolRequest) Size() (n int)

func (*QueryCommunityPoolRequest) String 

func (m *QueryCommunityPoolRequest) String() string

func (*QueryCommunityPoolRequest) Unmarshal 

func (m *QueryCommunityPoolRequest) Unmarshal(dAtA []byte) error

func (*QueryCommunityPoolRequest) XXX_DiscardUnknown 

func (m *QueryCommunityPoolRequest) XXX_DiscardUnknown()

func (*QueryCommunityPoolRequest) XXX_Marshal 

func (m *QueryCommunityPoolRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCommunityPoolRequest) XXX_Merge 

func (m *QueryCommunityPoolRequest) XXX_Merge(src proto.Message)

func (*QueryCommunityPoolRequest) XXX_Size 

func (m *QueryCommunityPoolRequest) XXX_Size() int

func (*QueryCommunityPoolRequest) XXX_Unmarshal 

func (m *QueryCommunityPoolRequest) XXX_Unmarshal(b []byte) error

type QueryCommunityPoolResponse 

type QueryCommunityPoolResponse struct {
	// pool defines community pool's coins.
	Pool github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=pool,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"pool"`
}

QueryCommunityPoolResponse is the response type for the Query/CommunityPool RPC method.

func (*QueryCommunityPoolResponse) Descriptor 

func (*QueryCommunityPoolResponse) Descriptor() ([]byte, []int)

func (*QueryCommunityPoolResponse) GetPool 

func (m *QueryCommunityPoolResponse) GetPool() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryCommunityPoolResponse) Marshal 

func (m *QueryCommunityPoolResponse) Marshal() (dAtA []byte, err error)

func (*QueryCommunityPoolResponse) MarshalTo 

func (m *QueryCommunityPoolResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryCommunityPoolResponse) MarshalToSizedBuffer 

func (m *QueryCommunityPoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCommunityPoolResponse) ProtoMessage 

func (*QueryCommunityPoolResponse) ProtoMessage()

func (*QueryCommunityPoolResponse) Reset 

func (m *QueryCommunityPoolResponse) Reset()

func (*QueryCommunityPoolResponse) Size 

func (m *QueryCommunityPoolResponse) Size() (n int)

func (*QueryCommunityPoolResponse) String 

func (m *QueryCommunityPoolResponse) String() string

func (*QueryCommunityPoolResponse) Unmarshal 

func (m *QueryCommunityPoolResponse) Unmarshal(dAtA []byte) error

func (*QueryCommunityPoolResponse) XXX_DiscardUnknown 

func (m *QueryCommunityPoolResponse) XXX_DiscardUnknown()

func (*QueryCommunityPoolResponse) XXX_Marshal 

func (m *QueryCommunityPoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCommunityPoolResponse) XXX_Merge 

func (m *QueryCommunityPoolResponse) XXX_Merge(src proto.Message)

func (*QueryCommunityPoolResponse) XXX_Size 

func (m *QueryCommunityPoolResponse) XXX_Size() int

func (*QueryCommunityPoolResponse) XXX_Unmarshal 

func (m *QueryCommunityPoolResponse) XXX_Unmarshal(b []byte) error

type QueryContinuousFundRequest 

type QueryContinuousFundRequest struct {
	// recipient is the recipient address to query unclaimed budget amount for.
	Recipient string `protobuf:"bytes,1,opt,name=recipient,proto3" json:"recipient,omitempty"`
}

QueryContinuousFundRequest is the request type for the Query/ContinuousFund RPC method.

func (*QueryContinuousFundRequest) Descriptor 

func (*QueryContinuousFundRequest) Descriptor() ([]byte, []int)

func (*QueryContinuousFundRequest) GetRecipient 

func (m *QueryContinuousFundRequest) GetRecipient() string

func (*QueryContinuousFundRequest) Marshal 

func (m *QueryContinuousFundRequest) Marshal() (dAtA []byte, err error)

func (*QueryContinuousFundRequest) MarshalTo 

func (m *QueryContinuousFundRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryContinuousFundRequest) MarshalToSizedBuffer 

func (m *QueryContinuousFundRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryContinuousFundRequest) ProtoMessage 

func (*QueryContinuousFundRequest) ProtoMessage()

func (*QueryContinuousFundRequest) Reset 

func (m *QueryContinuousFundRequest) Reset()

func (*QueryContinuousFundRequest) Size 

func (m *QueryContinuousFundRequest) Size() (n int)

func (*QueryContinuousFundRequest) String 

func (m *QueryContinuousFundRequest) String() string

func (*QueryContinuousFundRequest) Unmarshal 

func (m *QueryContinuousFundRequest) Unmarshal(dAtA []byte) error

func (*QueryContinuousFundRequest) XXX_DiscardUnknown 

func (m *QueryContinuousFundRequest) XXX_DiscardUnknown()

func (*QueryContinuousFundRequest) XXX_Marshal 

func (m *QueryContinuousFundRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryContinuousFundRequest) XXX_Merge 

func (m *QueryContinuousFundRequest) XXX_Merge(src proto.Message)

func (*QueryContinuousFundRequest) XXX_Size 

func (m *QueryContinuousFundRequest) XXX_Size() int

func (*QueryContinuousFundRequest) XXX_Unmarshal 

func (m *QueryContinuousFundRequest) XXX_Unmarshal(b []byte) error

type QueryContinuousFundResponse 

type QueryContinuousFundResponse struct {
	// ContinuousFunds is the given continuous fund returned in the query.
	ContinuousFund ContinuousFund `protobuf:"bytes,1,opt,name=continuous_fund,json=continuousFund,proto3" json:"continuous_fund"`
}

QueryUnclaimedBudgetResponse is the response type for the Query/ContinuousFund RPC method.

func (*QueryContinuousFundResponse) Descriptor 

func (*QueryContinuousFundResponse) Descriptor() ([]byte, []int)

func (*QueryContinuousFundResponse) GetContinuousFund 

func (m *QueryContinuousFundResponse) GetContinuousFund() ContinuousFund

func (*QueryContinuousFundResponse) Marshal 

func (m *QueryContinuousFundResponse) Marshal() (dAtA []byte, err error)

func (*QueryContinuousFundResponse) MarshalTo 

func (m *QueryContinuousFundResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryContinuousFundResponse) MarshalToSizedBuffer 

func (m *QueryContinuousFundResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryContinuousFundResponse) ProtoMessage 

func (*QueryContinuousFundResponse) ProtoMessage()

func (*QueryContinuousFundResponse) Reset 

func (m *QueryContinuousFundResponse) Reset()

func (*QueryContinuousFundResponse) Size 

func (m *QueryContinuousFundResponse) Size() (n int)

func (*QueryContinuousFundResponse) String 

func (m *QueryContinuousFundResponse) String() string

func (*QueryContinuousFundResponse) Unmarshal 

func (m *QueryContinuousFundResponse) Unmarshal(dAtA []byte) error

func (*QueryContinuousFundResponse) XXX_DiscardUnknown 

func (m *QueryContinuousFundResponse) XXX_DiscardUnknown()

func (*QueryContinuousFundResponse) XXX_Marshal 

func (m *QueryContinuousFundResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryContinuousFundResponse) XXX_Merge 

func (m *QueryContinuousFundResponse) XXX_Merge(src proto.Message)

func (*QueryContinuousFundResponse) XXX_Size 

func (m *QueryContinuousFundResponse) XXX_Size() int

func (*QueryContinuousFundResponse) XXX_Unmarshal 

func (m *QueryContinuousFundResponse) XXX_Unmarshal(b []byte) error

type QueryContinuousFundsRequest 

type QueryContinuousFundsRequest struct {
}

QueryContinuousFundRequest is the request type for the Query/ContinuousFunds RPC method.

func (*QueryContinuousFundsRequest) Descriptor 

func (*QueryContinuousFundsRequest) Descriptor() ([]byte, []int)

func (*QueryContinuousFundsRequest) Marshal 

func (m *QueryContinuousFundsRequest) Marshal() (dAtA []byte, err error)

func (*QueryContinuousFundsRequest) MarshalTo 

func (m *QueryContinuousFundsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryContinuousFundsRequest) MarshalToSizedBuffer 

func (m *QueryContinuousFundsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryContinuousFundsRequest) ProtoMessage 

func (*QueryContinuousFundsRequest) ProtoMessage()

func (*QueryContinuousFundsRequest) Reset 

func (m *QueryContinuousFundsRequest) Reset()

func (*QueryContinuousFundsRequest) Size 

func (m *QueryContinuousFundsRequest) Size() (n int)

func (*QueryContinuousFundsRequest) String 

func (m *QueryContinuousFundsRequest) String() string

func (*QueryContinuousFundsRequest) Unmarshal 

func (m *QueryContinuousFundsRequest) Unmarshal(dAtA []byte) error

func (*QueryContinuousFundsRequest) XXX_DiscardUnknown 

func (m *QueryContinuousFundsRequest) XXX_DiscardUnknown()

func (*QueryContinuousFundsRequest) XXX_Marshal 

func (m *QueryContinuousFundsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryContinuousFundsRequest) XXX_Merge 

func (m *QueryContinuousFundsRequest) XXX_Merge(src proto.Message)

func (*QueryContinuousFundsRequest) XXX_Size 

func (m *QueryContinuousFundsRequest) XXX_Size() int

func (*QueryContinuousFundsRequest) XXX_Unmarshal 

func (m *QueryContinuousFundsRequest) XXX_Unmarshal(b []byte) error

type QueryContinuousFundsResponse 

type QueryContinuousFundsResponse struct {
	// ContinuousFunds defines all continuous funds in state.
	ContinuousFunds []ContinuousFund `protobuf:"bytes,1,rep,name=continuous_funds,json=continuousFunds,proto3" json:"continuous_funds"`
}

QueryUnclaimedBudgetResponse is the response type for the Query/ContinuousFunds RPC method.

func (*QueryContinuousFundsResponse) Descriptor 

func (*QueryContinuousFundsResponse) Descriptor() ([]byte, []int)

func (*QueryContinuousFundsResponse) GetContinuousFunds 

func (m *QueryContinuousFundsResponse) GetContinuousFunds() []ContinuousFund

func (*QueryContinuousFundsResponse) Marshal 

func (m *QueryContinuousFundsResponse) Marshal() (dAtA []byte, err error)

func (*QueryContinuousFundsResponse) MarshalTo 

func (m *QueryContinuousFundsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryContinuousFundsResponse) MarshalToSizedBuffer 

func (m *QueryContinuousFundsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryContinuousFundsResponse) ProtoMessage 

func (*QueryContinuousFundsResponse) ProtoMessage()

func (*QueryContinuousFundsResponse) Reset 

func (m *QueryContinuousFundsResponse) Reset()

func (*QueryContinuousFundsResponse) Size 

func (m *QueryContinuousFundsResponse) Size() (n int)

func (*QueryContinuousFundsResponse) String 

func (m *QueryContinuousFundsResponse) String() string

func (*QueryContinuousFundsResponse) Unmarshal 

func (m *QueryContinuousFundsResponse) Unmarshal(dAtA []byte) error

func (*QueryContinuousFundsResponse) XXX_DiscardUnknown 

func (m *QueryContinuousFundsResponse) XXX_DiscardUnknown()

func (*QueryContinuousFundsResponse) XXX_Marshal 

func (m *QueryContinuousFundsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryContinuousFundsResponse) XXX_Merge 

func (m *QueryContinuousFundsResponse) XXX_Merge(src proto.Message)

func (*QueryContinuousFundsResponse) XXX_Size 

func (m *QueryContinuousFundsResponse) XXX_Size() int

func (*QueryContinuousFundsResponse) XXX_Unmarshal 

func (m *QueryContinuousFundsResponse) XXX_Unmarshal(b []byte) error

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the response type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

func (*QueryParamsRequest) Descriptor() ([]byte, []int)

func (*QueryParamsRequest) Marshal 

func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)

func (*QueryParamsRequest) MarshalTo 

func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsRequest) MarshalToSizedBuffer 

func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

func (m *QueryParamsRequest) Size() (n int)

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsRequest) XXX_Merge 

func (m *QueryParamsRequest) XXX_Merge(src proto.Message)

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error

type QueryParamsResponse 

type QueryParamsResponse struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

func (*QueryParamsResponse) Descriptor() ([]byte, []int)

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)

func (*QueryParamsResponse) MarshalTo 

func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryParamsResponse) MarshalToSizedBuffer 

func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

func (m *QueryParamsResponse) Size() (n int)

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryParamsResponse) XXX_Merge 

func (m *QueryParamsResponse) XXX_Merge(src proto.Message)

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error

type QueryServer 

type QueryServer interface {
	// CommunityPool queries the community pool coins.
	CommunityPool(context.Context, *QueryCommunityPoolRequest) (*QueryCommunityPoolResponse, error)
	// ContinuousFund queries a continuous fund by the recipient is is associated with.
	ContinuousFund(context.Context, *QueryContinuousFundRequest) (*QueryContinuousFundResponse, error)
	// ContinuousFunds queries all continuous funds in the store.
	ContinuousFunds(context.Context, *QueryContinuousFundsRequest) (*QueryContinuousFundsResponse, error)
	// Params returns the total set of x/protocolpool parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CancelContinuousFund 

func (*UnimplementedMsgServer) CancelContinuousFund(ctx context.Context, req *MsgCancelContinuousFund) (*MsgCancelContinuousFundResponse, error)

func (*UnimplementedMsgServer) CommunityPoolSpend 

func (*UnimplementedMsgServer) CommunityPoolSpend(ctx context.Context, req *MsgCommunityPoolSpend) (*MsgCommunityPoolSpendResponse, error)

func (*UnimplementedMsgServer) CreateContinuousFund 

func (*UnimplementedMsgServer) CreateContinuousFund(ctx context.Context, req *MsgCreateContinuousFund) (*MsgCreateContinuousFundResponse, error)

func (*UnimplementedMsgServer) FundCommunityPool 

func (*UnimplementedMsgServer) FundCommunityPool(ctx context.Context, req *MsgFundCommunityPool) (*MsgFundCommunityPoolResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CommunityPool 

func (*UnimplementedQueryServer) CommunityPool(ctx context.Context, req *QueryCommunityPoolRequest) (*QueryCommunityPoolResponse, error)

func (*UnimplementedQueryServer) ContinuousFund 

func (*UnimplementedQueryServer) ContinuousFund(ctx context.Context, req *QueryContinuousFundRequest) (*QueryContinuousFundResponse, error)

func (*UnimplementedQueryServer) ContinuousFunds 

func (*UnimplementedQueryServer) ContinuousFunds(ctx context.Context, req *QueryContinuousFundsRequest) (*QueryContinuousFundsResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

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.