types

package
v0.4.0-rc3 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2024 License: Apache-2.0 Imports: 31 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 = math.LegacyNewDecWithPrec(1, 1)
	DefaultAirdropFactor         = math.LegacyNewDecWithPrec(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 context.Context, account sdk.AccountI) sdk.AccountI
	SetAccount(ctx context.Context, account sdk.AccountI)
	GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.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 context.Context,
		senderModule string,
		recipientAddr sdk.AccAddress,
		amt sdk.Coins,
	) error
	SendCoinsFromModuleToModule(ctx context.Context, senderModule, recipientModule string, amt sdk.Coins) error
	MintCoins(ctx context.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 {
	FundCommunityPool(ctx context.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

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) 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 *math.LegacyDec,
	airdropFactor *math.LegacyDec,
	govAddress string,
) *MsgSetParams

func (*MsgSetParams) Descriptor

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

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 *cosmossdk_io_math.LegacyDec `` /* 163-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 *cosmossdk_io_math.LegacyDec `` /* 139-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 context.Context,
		delegator sdk.AccAddress,
		maxRetrieve uint16,
	) ([]stakingtypes.Delegation, error)
}

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

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AirdropAccount

func (*UnimplementedQueryServer) Params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL