types

package
v0.3.0-rc7 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName is the name of the airdrop module
	ModuleName = "airdrop"

	// StoreKey is the string store representation
	StoreKey = ModuleName

	// RouterKey is the message route
	RouterKey = ModuleName

	// QuerierRoute is the query router key for the airdrop module
	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgClaimAirdrop = "claim_airdrop"
)

Variables

View Source 
var (
	ErrInvalidLengthAirdrop        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAirdrop          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAirdrop = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrNoAccountFound         = errors.Register(ModuleName, 2, "no airdrop account found")
	ErrAirdropAlreadyClaimed  = errors.Register(ModuleName, 3, "airdrop account already claimed")
	ErrInsufficientDelegation = errors.Register(ModuleName, 4, "delegation requirement not met")
	ErrAirdropExpired         = errors.Register(ModuleName, 5, "airdrop expired; chain is past the expire block")
	ErrOriginAccountExists    = errors.Register(ModuleName, 6, "origin account already exists")
)
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 (
	ParamsKey               = []byte{0x01}
	AirdropAccountKeyPrefix = []byte{0x02}
)

KVStore key prefixes

View Source 
var (
	DefaultOriginAccountsCreated = false
	DefaultExpiryBlock           = uint64(5000)
	DefaultDelegationRequirement = sdk.NewDecWithPrec(1, 1)
	DefaultAirdropFactor         = sdk.NewDecWithPrec(1, 1)
)
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 AirdropAccount_State_name = map[int32]string{
	0: "STATE_UNSPECIFIED",
	1: "STATE_CREATED",
	2: "STATE_UNCLAIMED",
	3: "STATE_CLAIMED",
}
View Source 
var AirdropAccount_State_value = map[string]int32{
	"STATE_UNSPECIFIED": 0,
	"STATE_CREATED":     1,
	"STATE_UNCLAIMED":   2,
	"STATE_CLAIMED":     3,
}
View Source 
var (

	// ModuleCdc references the global x/airdrop module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/staking and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func AirdropAccountKey 

func AirdropAccountKey(originAddress string, state AirdropAccount_State) (key []byte)

AirdropAccountKey returns the store key for an airdrop account

func AirdropIteratorKey added in v0.2.0 

func AirdropIteratorKey(state AirdropAccount_State) (key []byte)

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces registers the x/airdrop interfaces types with the interface registry

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

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 {
	NewAccount(ctx sdk.Context, account authtypes.AccountI) authtypes.AccountI
	SetAccount(ctx sdk.Context, account authtypes.AccountI)
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(moduleName string) sdk.AccAddress
}

AccountKeeper defines the expected interface contract defined by the x/auth module.

type AirdropAccount 

type AirdropAccount struct {
	VestingEndTime int64 `protobuf:"varint,1,opt,name=vesting_end_time,json=vestingEndTime,proto3" json:"vesting_end_time,omitempty"`
	// The address of the account that was created at genesis with the initial airdrop.
	OriginAddress string `protobuf:"bytes,2,opt,name=origin_address,json=originAddress,proto3" json:"origin_address,omitempty"`
	// The amount of tokens that were airdropped to the genesis account.
	OriginAmount uint64               `protobuf:"varint,3,opt,name=origin_amount,json=originAmount,proto3" json:"origin_amount,omitempty"`
	State        AirdropAccount_State `protobuf:"varint,4,opt,name=state,proto3,enum=ojo.airdrop.v1.AirdropAccount_State" json:"state,omitempty"`
	// The address of the account that the user has claimed the 2nd half of their airdrop to.
	ClaimAddress string `protobuf:"bytes,5,opt,name=claim_address,json=claimAddress,proto3" json:"claim_address,omitempty"`
	// The amount of tokens claimed in the 2nd half of the airdrop.
	ClaimAmount uint64 `protobuf:"varint,6,opt,name=claim_amount,json=claimAmount,proto3" json:"claim_amount,omitempty"`
}

AirDropAccount defines an account that was created at genesis with an initial airdrop.

func NewAirdropAccount added in v0.2.0 

func NewAirdropAccount(
	originAddress string,
	originAmount uint64,
	vestingEndTime int64,
) *AirdropAccount

func (*AirdropAccount) ClaimAccAddress added in v0.1.4 

func (aa *AirdropAccount) ClaimAccAddress() (sdk.AccAddress, error)

func (AirdropAccount) ClaimCoin added in v0.1.4 

func (aa AirdropAccount) ClaimCoin() sdk.Coin

func (*AirdropAccount) ClaimCoins added in v0.1.4 

func (aa *AirdropAccount) ClaimCoins() sdk.Coins

func (*AirdropAccount) ClaimDecCoin added in v0.1.4 

func (aa *AirdropAccount) ClaimDecCoin() sdk.DecCoin

func (*AirdropAccount) Descriptor 

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

func (*AirdropAccount) Marshal 

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

func (*AirdropAccount) MarshalTo 

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

func (*AirdropAccount) MarshalToSizedBuffer 

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

func (*AirdropAccount) OriginAccAddress added in v0.1.4 

func (aa *AirdropAccount) OriginAccAddress() (sdk.AccAddress, error)

func (AirdropAccount) OriginCoins added in v0.1.4 

func (aa AirdropAccount) OriginCoins() sdk.Coins

func (*AirdropAccount) ProtoMessage 

func (*AirdropAccount) ProtoMessage()

func (*AirdropAccount) Reset 

func (m *AirdropAccount) Reset()

func (*AirdropAccount) Size 

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

func (*AirdropAccount) String 

func (m *AirdropAccount) String() string

func (*AirdropAccount) Unmarshal 

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

func (*AirdropAccount) VerifyNotClaimed added in v0.1.4 

func (aa *AirdropAccount) VerifyNotClaimed() error

func (*AirdropAccount) XXX_DiscardUnknown 

func (m *AirdropAccount) XXX_DiscardUnknown()

func (*AirdropAccount) XXX_Marshal 

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

func (*AirdropAccount) XXX_Merge 

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

func (*AirdropAccount) XXX_Size 

func (m *AirdropAccount) XXX_Size() int

func (*AirdropAccount) XXX_Unmarshal 

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

type AirdropAccountRequest 

type AirdropAccountRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

AirdropAccountRequest is the request type for the QueryAirdropAccount RPC method.

func (*AirdropAccountRequest) Descriptor 

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

func (*AirdropAccountRequest) GetAddress 

func (m *AirdropAccountRequest) GetAddress() string

func (*AirdropAccountRequest) Marshal 

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

func (*AirdropAccountRequest) MarshalTo 

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

func (*AirdropAccountRequest) MarshalToSizedBuffer 

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

func (*AirdropAccountRequest) ProtoMessage 

func (*AirdropAccountRequest) ProtoMessage()

func (*AirdropAccountRequest) Reset 

func (m *AirdropAccountRequest) Reset()

func (*AirdropAccountRequest) Size 

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

func (*AirdropAccountRequest) String 

func (m *AirdropAccountRequest) String() string

func (*AirdropAccountRequest) Unmarshal 

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

func (*AirdropAccountRequest) XXX_DiscardUnknown 

func (m *AirdropAccountRequest) XXX_DiscardUnknown()

func (*AirdropAccountRequest) XXX_Marshal 

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

func (*AirdropAccountRequest) XXX_Merge 

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

func (*AirdropAccountRequest) XXX_Size 

func (m *AirdropAccountRequest) XXX_Size() int

func (*AirdropAccountRequest) XXX_Unmarshal 

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

type AirdropAccountResponse 

type AirdropAccountResponse struct {
	AirdropAccount *AirdropAccount `protobuf:"bytes,1,opt,name=airdrop_account,json=airdropAccount,proto3" json:"airdrop_account,omitempty"`
}

AirdropAccountResponse is the response type for the QueryAirdropAccount RPC method.

func (*AirdropAccountResponse) Descriptor 

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

func (*AirdropAccountResponse) GetAirdropAccount 

func (m *AirdropAccountResponse) GetAirdropAccount() *AirdropAccount

func (*AirdropAccountResponse) Marshal 

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

func (*AirdropAccountResponse) MarshalTo 

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

func (*AirdropAccountResponse) MarshalToSizedBuffer 

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

func (*AirdropAccountResponse) ProtoMessage 

func (*AirdropAccountResponse) ProtoMessage()

func (*AirdropAccountResponse) Reset 

func (m *AirdropAccountResponse) Reset()

func (*AirdropAccountResponse) Size 

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

func (*AirdropAccountResponse) String 

func (m *AirdropAccountResponse) String() string

func (*AirdropAccountResponse) Unmarshal 

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

func (*AirdropAccountResponse) XXX_DiscardUnknown 

func (m *AirdropAccountResponse) XXX_DiscardUnknown()

func (*AirdropAccountResponse) XXX_Marshal 

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

func (*AirdropAccountResponse) XXX_Merge 

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

func (*AirdropAccountResponse) XXX_Size 

func (m *AirdropAccountResponse) XXX_Size() int

func (*AirdropAccountResponse) XXX_Unmarshal 

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

type AirdropAccount_State added in v0.2.0 

type AirdropAccount_State int32

The current state of the airdrop account 

const (
	// Unspecified state
	AirdropAccount_STATE_UNSPECIFIED AirdropAccount_State = 0
	// The KV store entry has been created but initial tokens have not been allocated
	AirdropAccount_STATE_CREATED AirdropAccount_State = 1
	// The initial airdrop has been distributed but the 2nd half is unclaimed
	AirdropAccount_STATE_UNCLAIMED AirdropAccount_State = 2
	// The 2nd half of the airdrop has been distributed
	AirdropAccount_STATE_CLAIMED AirdropAccount_State = 3
)

func (AirdropAccount_State) EnumDescriptor added in v0.2.0 

func (AirdropAccount_State) EnumDescriptor() ([]byte, []int)

func (AirdropAccount_State) String added in v0.2.0 

func (x AirdropAccount_State) String() string

type BankKeeper added in v0.1.4 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
}

BankKeeper defines the expected interface contract defined by the x/bank module.

type DistributionKeeper added in v0.1.4 

type DistributionKeeper interface {
	GetFeePool(ctx sdk.Context) (feePool distributiontypes.FeePool)
	SetFeePool(ctx sdk.Context, feePool distributiontypes.FeePool)
}

type GenesisState 

type GenesisState struct {
	Params          Params            `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	AirdropAccounts []*AirdropAccount `protobuf:"bytes,2,rep,name=airdrop_accounts,json=airdropAccounts,proto3" json:"airdrop_accounts,omitempty"`
}

GenesisState represents the genesis state of the airdrop module.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(
	params Params,
	airdropAccounts []*AirdropAccount,
) *GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAirdropAccounts 

func (m *GenesisState) GetAirdropAccounts() []*AirdropAccount

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) 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 MsgClaimAirdrop 

type MsgClaimAirdrop struct {
	FromAddress string `protobuf:"bytes,1,opt,name=fromAddress,proto3" json:"fromAddress,omitempty"`
	ToAddress   string `protobuf:"bytes,2,opt,name=toAddress,proto3" json:"toAddress,omitempty"`
}

MsgClaimAirdrop defines the MsgClaimAirdrop message type.

func NewMsgClaimAirdrop 

func NewMsgClaimAirdrop(
	fromAddress string,
	toAddress string,
) *MsgClaimAirdrop

func (*MsgClaimAirdrop) Descriptor 

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

func (MsgClaimAirdrop) GetSignBytes 

func (msg MsgClaimAirdrop) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgClaimAirdrop) GetSigners 

func (msg MsgClaimAirdrop) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgClaimAirdrop) Marshal 

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

func (*MsgClaimAirdrop) MarshalTo 

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

func (*MsgClaimAirdrop) MarshalToSizedBuffer 

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

func (*MsgClaimAirdrop) ProtoMessage 

func (*MsgClaimAirdrop) ProtoMessage()

func (*MsgClaimAirdrop) Reset 

func (m *MsgClaimAirdrop) Reset()

func (*MsgClaimAirdrop) Size 

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

func (*MsgClaimAirdrop) String 

func (m *MsgClaimAirdrop) String() string

func (MsgClaimAirdrop) Type 

func (msg MsgClaimAirdrop) Type() string

Type implements LegacyMsg interface

func (*MsgClaimAirdrop) Unmarshal 

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

func (MsgClaimAirdrop) ValidateBasic 

func (msg MsgClaimAirdrop) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgClaimAirdrop) XXX_DiscardUnknown 

func (m *MsgClaimAirdrop) XXX_DiscardUnknown()

func (*MsgClaimAirdrop) XXX_Marshal 

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

func (*MsgClaimAirdrop) XXX_Merge 

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

func (*MsgClaimAirdrop) XXX_Size 

func (m *MsgClaimAirdrop) XXX_Size() int

func (*MsgClaimAirdrop) XXX_Unmarshal 

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

type MsgClaimAirdropResponse 

type MsgClaimAirdropResponse struct {
}

MsgClaimAirdropResponse defines the ClaimAirdrop response type.

func (*MsgClaimAirdropResponse) Descriptor 

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

func (*MsgClaimAirdropResponse) Marshal 

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

func (*MsgClaimAirdropResponse) MarshalTo 

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

func (*MsgClaimAirdropResponse) MarshalToSizedBuffer 

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

func (*MsgClaimAirdropResponse) ProtoMessage 

func (*MsgClaimAirdropResponse) ProtoMessage()

func (*MsgClaimAirdropResponse) Reset 

func (m *MsgClaimAirdropResponse) Reset()

func (*MsgClaimAirdropResponse) Size 

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

func (*MsgClaimAirdropResponse) String 

func (m *MsgClaimAirdropResponse) String() string

func (*MsgClaimAirdropResponse) Unmarshal 

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

func (*MsgClaimAirdropResponse) XXX_DiscardUnknown 

func (m *MsgClaimAirdropResponse) XXX_DiscardUnknown()

func (*MsgClaimAirdropResponse) XXX_Marshal 

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

func (*MsgClaimAirdropResponse) XXX_Merge 

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

func (*MsgClaimAirdropResponse) XXX_Size 

func (m *MsgClaimAirdropResponse) XXX_Size() int

func (*MsgClaimAirdropResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// SetParams sets the parameters for the airdrop module.
	SetParams(ctx context.Context, in *MsgSetParams, opts ...grpc.CallOption) (*MsgSetParamsResponse, error)
	// ClaimAirdrop allows an airdrop recipient to claim the 2nd portion of the airdrop specified in the
	// CreateAirdropAccount message. This transaction will create a new Delayed Vesting Account
	// at toAddress with the amount of tokens determined by tokensToReceive * AirdropFactor.
	// This account will vest as long as vestingLength above. This transaction fails if the amount
	// of tokens staked by the fromAddress account is less than tokensToReceive * DelegationRequirement.
	// Emits an event once the airdrop has been claimed.
	ClaimAirdrop(ctx context.Context, in *MsgClaimAirdrop, opts ...grpc.CallOption) (*MsgClaimAirdropResponse, 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 MsgServer 

type MsgServer interface {
	// SetParams sets the parameters for the airdrop module.
	SetParams(context.Context, *MsgSetParams) (*MsgSetParamsResponse, error)
	// ClaimAirdrop allows an airdrop recipient to claim the 2nd portion of the airdrop specified in the
	// CreateAirdropAccount message. This transaction will create a new Delayed Vesting Account
	// at toAddress with the amount of tokens determined by tokensToReceive * AirdropFactor.
	// This account will vest as long as vestingLength above. This transaction fails if the amount
	// of tokens staked by the fromAddress account is less than tokensToReceive * DelegationRequirement.
	// Emits an event once the airdrop has been claimed.
	ClaimAirdrop(context.Context, *MsgClaimAirdrop) (*MsgClaimAirdropResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetParams 

type MsgSetParams 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 airdrop parameters to update.
	Params *Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
}

MsgSetParams defines the SetParams message type.

func NewMsgSetParams 

func NewMsgSetParams(
	expiryBlock uint64,
	delegationRequirement *sdk.Dec,
	airdropFactor *sdk.Dec,
	govAddress string,
) *MsgSetParams

func (*MsgSetParams) Descriptor 

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

func (MsgSetParams) GetSignBytes 

func (msg MsgSetParams) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (MsgSetParams) GetSigners 

func (msg MsgSetParams) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSetParams) Marshal 

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

func (*MsgSetParams) MarshalTo 

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

func (*MsgSetParams) MarshalToSizedBuffer 

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

func (*MsgSetParams) ProtoMessage 

func (*MsgSetParams) ProtoMessage()

func (*MsgSetParams) Reset 

func (m *MsgSetParams) Reset()

func (*MsgSetParams) Size 

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

func (*MsgSetParams) String 

func (m *MsgSetParams) String() string

func (MsgSetParams) Type 

func (msg MsgSetParams) Type() string

Type implements LegacyMsg interface

func (*MsgSetParams) Unmarshal 

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

func (MsgSetParams) ValidateBasic 

func (msg MsgSetParams) ValidateBasic() error

ValidateBasic Implements sdk.Msg

func (*MsgSetParams) XXX_DiscardUnknown 

func (m *MsgSetParams) XXX_DiscardUnknown()

func (*MsgSetParams) XXX_Marshal 

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

func (*MsgSetParams) XXX_Merge 

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

func (*MsgSetParams) XXX_Size 

func (m *MsgSetParams) XXX_Size() int

func (*MsgSetParams) XXX_Unmarshal 

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

type MsgSetParamsResponse 

type MsgSetParamsResponse struct {
}

MsgSetParamsResponse defines the SetParams response type.

func (*MsgSetParamsResponse) Descriptor 

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

func (*MsgSetParamsResponse) Marshal 

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

func (*MsgSetParamsResponse) MarshalTo 

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

func (*MsgSetParamsResponse) MarshalToSizedBuffer 

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

func (*MsgSetParamsResponse) ProtoMessage 

func (*MsgSetParamsResponse) ProtoMessage()

func (*MsgSetParamsResponse) Reset 

func (m *MsgSetParamsResponse) Reset()

func (*MsgSetParamsResponse) Size 

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

func (*MsgSetParamsResponse) String 

func (m *MsgSetParamsResponse) String() string

func (*MsgSetParamsResponse) Unmarshal 

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

func (*MsgSetParamsResponse) XXX_DiscardUnknown 

func (m *MsgSetParamsResponse) XXX_DiscardUnknown()

func (*MsgSetParamsResponse) XXX_Marshal 

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

func (*MsgSetParamsResponse) XXX_Merge 

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

func (*MsgSetParamsResponse) XXX_Size 

func (m *MsgSetParamsResponse) XXX_Size() int

func (*MsgSetParamsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// Flag to determine if the origin vesting accounts have been created yet
	OriginAccountsCreated bool `` /* 127-byte string literal not displayed */
	// The block at which all unclaimed AirdropAccounts will instead mint tokens
	// into the community pool. After this block, all unclaimed airdrop accounts
	// will no longer be able to be claimed.
	ExpiryBlock uint64 `protobuf:"varint,2,opt,name=expiry_block,json=expiryBlock,proto3" json:"expiry_block,omitempty"`
	// The percentage of the initial airdrop that users must delegate in order to
	// receive their second portion.
	// E.g., if we want to require users to stake their entire initial airdrop, this will be 1.
	// cosmos.base.v1beta1.Dec delegation_requirement = 1;
	DelegationRequirement *github_com_cosmos_cosmos_sdk_types.Dec `` /* 174-byte string literal not displayed */
	// The multiplier for the amount of tokens users will receive once they claim their airdrop.
	// E.g., if we want users to receive an equal second half, this will be 2.
	AirdropFactor *github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

Params defines the parameters for the airdrop module.

func DefaultParams 

func DefaultParams() Params

func (*Params) Descriptor 

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

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 ParamsRequest 

type ParamsRequest struct {
}

ParamsRequest is the request type for the Query/Params RPC method.

func (*ParamsRequest) Descriptor 

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

func (*ParamsRequest) Marshal 

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

func (*ParamsRequest) MarshalTo 

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

func (*ParamsRequest) MarshalToSizedBuffer 

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

func (*ParamsRequest) ProtoMessage 

func (*ParamsRequest) ProtoMessage()

func (*ParamsRequest) Reset 

func (m *ParamsRequest) Reset()

func (*ParamsRequest) Size 

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

func (*ParamsRequest) String 

func (m *ParamsRequest) String() string

func (*ParamsRequest) Unmarshal 

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

func (*ParamsRequest) XXX_DiscardUnknown 

func (m *ParamsRequest) XXX_DiscardUnknown()

func (*ParamsRequest) XXX_Marshal 

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

func (*ParamsRequest) XXX_Merge 

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

func (*ParamsRequest) XXX_Size 

func (m *ParamsRequest) XXX_Size() int

func (*ParamsRequest) XXX_Unmarshal 

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

type ParamsResponse 

type ParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

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

func (*ParamsResponse) Descriptor 

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

func (*ParamsResponse) GetParams 

func (m *ParamsResponse) GetParams() Params

func (*ParamsResponse) Marshal 

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

func (*ParamsResponse) MarshalTo 

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

func (*ParamsResponse) MarshalToSizedBuffer 

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

func (*ParamsResponse) ProtoMessage 

func (*ParamsResponse) ProtoMessage()

func (*ParamsResponse) Reset 

func (m *ParamsResponse) Reset()

func (*ParamsResponse) Size 

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

func (*ParamsResponse) String 

func (m *ParamsResponse) String() string

func (*ParamsResponse) Unmarshal 

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

func (*ParamsResponse) XXX_DiscardUnknown 

func (m *ParamsResponse) XXX_DiscardUnknown()

func (*ParamsResponse) XXX_Marshal 

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

func (*ParamsResponse) XXX_Merge 

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

func (*ParamsResponse) XXX_Size 

func (m *ParamsResponse) XXX_Size() int

func (*ParamsResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries all parameters.
	Params(ctx context.Context, in *ParamsRequest, opts ...grpc.CallOption) (*ParamsResponse, error)
	// AirdropAccount returns an existing airdrop account, along with whether or not
	// the user is eligible to claim, and whether or not the airdrop has been claimed.
	// If the airdrop has been claimed, the account to which the tokens were sent should be
	// returned as well.
	AirdropAccount(ctx context.Context, in *AirdropAccountRequest, opts ...grpc.CallOption) (*AirdropAccountResponse, 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 QueryServer 

type QueryServer interface {
	// Params queries all parameters.
	Params(context.Context, *ParamsRequest) (*ParamsResponse, error)
	// AirdropAccount returns an existing airdrop account, along with whether or not
	// the user is eligible to claim, and whether or not the airdrop has been claimed.
	// If the airdrop has been claimed, the account to which the tokens were sent should be
	// returned as well.
	AirdropAccount(context.Context, *AirdropAccountRequest) (*AirdropAccountResponse, error)
}

QueryServer is the server API for Query service.

type StakingKeeper added in v0.1.4 

type StakingKeeper interface {
	GetDelegatorDelegations(
		ctx sdk.Context,
		delegator sdk.AccAddress,
		maxRetrieve uint16,
	) (delegations []stakingtypes.Delegation)
}

StakingKeeper defines the expected interface contract defined by the x/staking module.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimAirdrop 

func (*UnimplementedMsgServer) ClaimAirdrop(ctx context.Context, req *MsgClaimAirdrop) (*MsgClaimAirdropResponse, error)

func (*UnimplementedMsgServer) SetParams 

func (*UnimplementedMsgServer) SetParams(ctx context.Context, req *MsgSetParams) (*MsgSetParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AirdropAccount 

func (*UnimplementedQueryServer) AirdropAccount(ctx context.Context, req *AirdropAccountRequest) (*AirdropAccountResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *ParamsRequest) (*ParamsResponse, 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.