types

package
v0.0.0-...-dcdc338 Latest Latest
Warning

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

Go to latest
Published: Jul 13, 2022 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	EventTypeCreateClawbackVestingAccount = "create_clawback_vesting_account"
	EventTypeClawback                     = "clawback"

	AttributeKeyCoins       = "coins"
	AttributeKeyStartTime   = "start_time"
	AttributeKeyMerge       = "merge"
	AttributeKeyAccount     = "account"
	AttributeKeyFunder      = "funder"
	AttributeKeyDestination = "destination"
)

vesting events

View Source
const (
	// ModuleName defines the module's name.
	ModuleName = "vesting"

	// StoreKey to be used when creating the KVStore
	StoreKey = ModuleName

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName
)
View Source
const (
	TypeMsgCreateClawbackVestingAccount = "create_clawback_vesting_account"
	TypeMsgClawback                     = "clawback"
)

Variables

View Source
var (
	ErrInsufficientVestedCoins = sdkerrors.Register(ModuleName, 2, "insufficient vested coins error")
	ErrVestingLockup           = sdkerrors.Register(ModuleName, 3, "vesting lockup error")
)

errors

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 (
	ErrInvalidLengthVesting        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowVesting          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupVesting = fmt.Errorf("proto: unexpected end of group")
)

ModuleCdc references the global erc20 module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.

The actual codec used for serialization should be provided to modules/erc20 and defined at the application level.

Functions

func AlignSchedules

func AlignSchedules(
	startTimePeriodA,
	startTimePeriodB int64,
	periodsA, periodsB sdkvesting.Periods,
) (startTime, endTime int64)

AlignSchedules extends the first period's length to align the two given periods to the same start time. The earliest start time is chosen. It returns the aligned new start and end times of the periods.

func ConjunctPeriods

func ConjunctPeriods(
	startTimePeriodA, startTimePeriodB int64,
	periodsA, periodsB sdkvesting.Periods,
) (startTime, endTime int64, conjunctionPeriods sdkvesting.Periods)

ConjunctPeriods returns the combination of two period schedules where the result is the minimum of the two schedules. It returns the resulting periods start and end times as well as the resulting conjunction periods. TODO: rename and add comprehensive comments, this is currently not maintainable

func DisjunctPeriods

func DisjunctPeriods(
	startTimePeriodsA, startTimePeriodsB int64,
	periodsA, periodsB sdkvesting.Periods,
) (startTime, endTime int64, periods sdkvesting.Periods)

DisjunctPeriods returns the union of two vesting period schedules. The returned schedule is the union of the vesting events, with simultaneous events combined into a single event. Input schedules P and Q are defined by their start times and periods. Returns new start time, new end time, and merged vesting events, relative to the new start time.

func Max64

func Max64(i, j int64) int64

max64 returns the maximum of its inputs.

func Min64

func Min64(i, j int64) int64

Min64 returns the minimum of its inputs.

func ReadPastPeriodCount

func ReadPastPeriodCount(
	startTime, endTime int64,
	periods sdkvesting.Periods,
	readTime int64,
) int

ReadPastPeriodCount returns the amount of passed periods before read time

func ReadSchedule

func ReadSchedule(
	startTime, endTime int64,
	periods sdkvesting.Periods,
	totalCoins sdk.Coins,
	readTime int64,
) sdk.Coins

A "schedule" is an increasing step function of Coins over time. It's specified as an absolute start time and a sequence of relative periods, with each step at the end of a period. A schedule may also give the time and total value at the last step, which can speed evaluation of the step function after the last step.

ReadSchedule returns the value of a schedule at readTime.

func RegisterInterfaces

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterface associates protoName with AccountI and VestingAccount Interfaces and creates a registry of it's concrete implementations

func RegisterMsgHandler

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

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

func RegisterMsgHandlerClient

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint

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

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

func RegisterMsgHandlerServer

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer 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 RegisterMsgHandlerFromEndpoint instead.

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

AccountKeeper defines the expected interface contract the vesting module requires for storing accounts.

type BankKeeper

type BankKeeper interface {
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	BlockedAddr(addr sdk.AccAddress) bool
}

BankKeeper defines the expected interface contract the vesting module requires for creating vesting accounts with funds.

type ClawbackVestingAccount

type ClawbackVestingAccount struct {
	// base_vesting_account implements the VestingAccount interface. It contains
	// all the necessary fields needed for any vesting account implementation
	*types.BaseVestingAccount `` /* 147-byte string literal not displayed */
	// funder_address specifies the account which can perform clawback
	FunderAddress string `protobuf:"bytes,2,opt,name=funder_address,json=funderAddress,proto3" json:"funder_address,omitempty"`
	// start_time defines the time at which the vesting period begins
	StartTime time.Time `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	// lockup_periods defines the unlocking schedule relative to the start_time
	LockupPeriods github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods `` /* 161-byte string literal not displayed */
	// vesting_periods defines the vesting schedule relative to the start_time
	VestingPeriods github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods `` /* 164-byte string literal not displayed */
}

ClawbackVestingAccount implements the VestingAccount interface. It provides an account that can hold contributions subject to "lockup" (like a PeriodicVestingAccount), or vesting which is subject to clawback of unvested tokens, or a combination (tokens vest, but are still locked).

func NewClawbackVestingAccount

func NewClawbackVestingAccount(
	baseAcc *authtypes.BaseAccount,
	funder sdk.AccAddress,
	originalVesting sdk.Coins,
	startTime time.Time,
	lockupPeriods,
	vestingPeriods sdkvesting.Periods,
) *ClawbackVestingAccount

NewClawbackVestingAccount returns a new ClawbackVestingAccount

func (ClawbackVestingAccount) ComputeClawback

func (va ClawbackVestingAccount) ComputeClawback(
	clawbackTime int64,
) (ClawbackVestingAccount, sdk.Coins)

ComputeClawback returns an account with all future vesting events removed and the clawback amount (total sum of these events). Future unlocking events are preserved and update in case unlocked vested coins remain after clawback.

func (*ClawbackVestingAccount) Descriptor

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

func (ClawbackVestingAccount) GetLockedOnly

func (va ClawbackVestingAccount) GetLockedOnly(blockTime time.Time) sdk.Coins

GetLockedOnly returns the locking schedule at blockTIme.

func (ClawbackVestingAccount) GetPassedPeriodCount

func (va ClawbackVestingAccount) GetPassedPeriodCount(blockTime time.Time) int

GetPassedPeriodCount returns the amount of passed periods at blockTime.

func (ClawbackVestingAccount) GetStartTime

func (va ClawbackVestingAccount) GetStartTime() int64

GetStartTime returns the time when vesting starts for a periodic vesting account.

func (ClawbackVestingAccount) GetUnlockedOnly

func (va ClawbackVestingAccount) GetUnlockedOnly(blockTime time.Time) sdk.Coins

GetUnlockedOnly returns the unlocking schedule at blockTIme.

func (ClawbackVestingAccount) GetUnvestedOnly

func (va ClawbackVestingAccount) GetUnvestedOnly(blockTime time.Time) sdk.Coins

GetUnvestedOnly returns the unvesting schedule at blockTime.

func (ClawbackVestingAccount) GetVestedCoins

func (va ClawbackVestingAccount) GetVestedCoins(blockTime time.Time) sdk.Coins

GetVestedCoins returns the total number of vested coins that are still in lockup. If no coins are vested, nil is returned.

func (ClawbackVestingAccount) GetVestedOnly

func (va ClawbackVestingAccount) GetVestedOnly(blockTime time.Time) sdk.Coins

GetVestedOnly returns the vesting schedule at blockTime.

func (ClawbackVestingAccount) GetVestingCoins

func (va ClawbackVestingAccount) GetVestingCoins(blockTime time.Time) sdk.Coins

GetVestingCoins returns the total number of vesting coins. If no coins are vesting, nil is returned.

func (ClawbackVestingAccount) GetVestingPeriods

func (va ClawbackVestingAccount) GetVestingPeriods() sdkvesting.Periods

GetVestingPeriods returns vesting periods associated with periodic vesting account.

func (ClawbackVestingAccount) HasLockedCoins

func (va ClawbackVestingAccount) HasLockedCoins(blockTime time.Time) bool

HasLockedCoins returns true if the blocktime has not passed all clawback account's lockup periods

func (ClawbackVestingAccount) LockedCoins

func (va ClawbackVestingAccount) LockedCoins(blockTime time.Time) sdk.Coins

LockedCoins returns the set of coins that are not spendable (i.e. locked), defined as the vesting coins that are not delegated.

func (*ClawbackVestingAccount) Marshal

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

func (*ClawbackVestingAccount) MarshalTo

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

func (*ClawbackVestingAccount) MarshalToSizedBuffer

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

func (*ClawbackVestingAccount) ProtoMessage

func (*ClawbackVestingAccount) ProtoMessage()

func (*ClawbackVestingAccount) Reset

func (m *ClawbackVestingAccount) Reset()

func (*ClawbackVestingAccount) Size

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

func (*ClawbackVestingAccount) TrackDelegation

func (va *ClawbackVestingAccount) TrackDelegation(blockTime time.Time, balance, amount sdk.Coins)

TrackDelegation tracks a desired delegation amount by setting the appropriate values for the amount of delegated vesting, delegated free, and reducing the overall amount of base coins.

func (*ClawbackVestingAccount) Unmarshal

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

func (ClawbackVestingAccount) Validate

func (va ClawbackVestingAccount) Validate() error

Validate checks for errors on the account fields

func (*ClawbackVestingAccount) XXX_DiscardUnknown

func (m *ClawbackVestingAccount) XXX_DiscardUnknown()

func (*ClawbackVestingAccount) XXX_Marshal

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

func (*ClawbackVestingAccount) XXX_Merge

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

func (*ClawbackVestingAccount) XXX_Size

func (m *ClawbackVestingAccount) XXX_Size() int

func (*ClawbackVestingAccount) XXX_Unmarshal

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

type MsgClawback

type MsgClawback struct {
	// funder_address is the address which funded the account
	FunderAddress string `protobuf:"bytes,1,opt,name=funder_address,json=funderAddress,proto3" json:"funder_address,omitempty"`
	// account_address is the address of the ClawbackVestingAccount to claw back
	// from.
	AccountAddress string `protobuf:"bytes,2,opt,name=account_address,json=accountAddress,proto3" json:"account_address,omitempty"`
	// dest_address specifies where the clawed-back tokens should be transferred
	// to. If empty, the tokens will be transferred back to the original funder of
	// the account.
	DestAddress string `protobuf:"bytes,3,opt,name=dest_address,json=destAddress,proto3" json:"dest_address,omitempty"`
}

MsgClawback defines a message that removes unvested tokens from a ClawbackVestingAccount.

func NewMsgClawback

func NewMsgClawback(funder, addr, dest sdk.AccAddress) *MsgClawback

NewMsgClawbackcreates new instance of MsgClawback. The dest_address may be nil - defaulting to the funder.

func (*MsgClawback) Descriptor

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

func (*MsgClawback) GetAccountAddress

func (m *MsgClawback) GetAccountAddress() string

func (*MsgClawback) GetDestAddress

func (m *MsgClawback) GetDestAddress() string

func (*MsgClawback) GetFunderAddress

func (m *MsgClawback) GetFunderAddress() string

func (*MsgClawback) GetSignBytes

func (msg *MsgClawback) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgClawback) GetSigners

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

GetSigners defines whose signature is required

func (*MsgClawback) Marshal

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

func (*MsgClawback) MarshalTo

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

func (*MsgClawback) MarshalToSizedBuffer

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

func (*MsgClawback) ProtoMessage

func (*MsgClawback) ProtoMessage()

func (*MsgClawback) Reset

func (m *MsgClawback) Reset()

func (MsgClawback) Route

func (msg MsgClawback) Route() string

Route returns the message route for a MsgClawback.

func (*MsgClawback) Size

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

func (*MsgClawback) String

func (m *MsgClawback) String() string

func (MsgClawback) Type

func (msg MsgClawback) Type() string

Type returns the message type for a MsgClawback.

func (*MsgClawback) Unmarshal

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

func (MsgClawback) ValidateBasic

func (msg MsgClawback) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgClawback) XXX_DiscardUnknown

func (m *MsgClawback) XXX_DiscardUnknown()

func (*MsgClawback) XXX_Marshal

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

func (*MsgClawback) XXX_Merge

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

func (*MsgClawback) XXX_Size

func (m *MsgClawback) XXX_Size() int

func (*MsgClawback) XXX_Unmarshal

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

type MsgClawbackResponse

type MsgClawbackResponse struct {
}

MsgClawbackResponse defines the MsgClawback response type.

func (*MsgClawbackResponse) Descriptor

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

func (*MsgClawbackResponse) Marshal

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

func (*MsgClawbackResponse) MarshalTo

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

func (*MsgClawbackResponse) MarshalToSizedBuffer

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

func (*MsgClawbackResponse) ProtoMessage

func (*MsgClawbackResponse) ProtoMessage()

func (*MsgClawbackResponse) Reset

func (m *MsgClawbackResponse) Reset()

func (*MsgClawbackResponse) Size

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

func (*MsgClawbackResponse) String

func (m *MsgClawbackResponse) String() string

func (*MsgClawbackResponse) Unmarshal

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

func (*MsgClawbackResponse) XXX_DiscardUnknown

func (m *MsgClawbackResponse) XXX_DiscardUnknown()

func (*MsgClawbackResponse) XXX_Marshal

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

func (*MsgClawbackResponse) XXX_Merge

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

func (*MsgClawbackResponse) XXX_Size

func (m *MsgClawbackResponse) XXX_Size() int

func (*MsgClawbackResponse) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// CreateClawbackVestingAccount creats a vesting account that is subject to
	// clawback and the configuration of vesting and lockup schedules.
	CreateClawbackVestingAccount(ctx context.Context, in *MsgCreateClawbackVestingAccount, opts ...grpc.CallOption) (*MsgCreateClawbackVestingAccountResponse, error)
	// Clawback removes the unvested tokens from a ClawbackVestingAccount.
	Clawback(ctx context.Context, in *MsgClawback, opts ...grpc.CallOption) (*MsgClawbackResponse, 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 MsgCreateClawbackVestingAccount

type MsgCreateClawbackVestingAccount struct {
	// from_address specifies the account to provide the funds and sign the
	// clawback request
	FromAddress string `protobuf:"bytes,1,opt,name=from_address,json=fromAddress,proto3" json:"from_address,omitempty"`
	// to_address specifies the account to receive the funds
	ToAddress string `protobuf:"bytes,2,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"`
	// start_time defines the time at which the vesting period begins
	StartTime time.Time `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	// lockup_periods defines the unlocking schedule relative to the start_time
	LockupPeriods github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods `` /* 161-byte string literal not displayed */
	// vesting_periods defines thevesting schedule relative to the start_time
	VestingPeriods github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods `` /* 164-byte string literal not displayed */
	// merge specifies a the creation mechanism for existing
	// ClawbackVestingAccounts. If true, merge this new grant into an existing
	// ClawbackVestingAccount, or create it if it does not exist. If false,
	// creates a new account. New grants to an existing account must be from the
	// same from_address.
	Merge bool `protobuf:"varint,6,opt,name=merge,proto3" json:"merge,omitempty"`
}

MsgCreateClawbackVestingAccount defines a message that enables creating a ClawbackVestingAccount.

func NewMsgCreateClawbackVestingAccount

func NewMsgCreateClawbackVestingAccount(
	fromAddr, toAddr sdk.AccAddress,
	startTime time.Time,
	lockupPeriods,
	vestingPeriods sdkvesting.Periods,
	merge bool,
) *MsgCreateClawbackVestingAccount

NewMsgCreateClawbackVestingAccount creates new instance of MsgCreateClawbackVestingAccount

func (*MsgCreateClawbackVestingAccount) Descriptor

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

func (*MsgCreateClawbackVestingAccount) GetFromAddress

func (m *MsgCreateClawbackVestingAccount) GetFromAddress() string

func (*MsgCreateClawbackVestingAccount) GetLockupPeriods

func (*MsgCreateClawbackVestingAccount) GetMerge

func (m *MsgCreateClawbackVestingAccount) GetMerge() bool

func (*MsgCreateClawbackVestingAccount) GetSignBytes

func (msg *MsgCreateClawbackVestingAccount) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (MsgCreateClawbackVestingAccount) GetSigners

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

GetSigners defines whose signature is required

func (*MsgCreateClawbackVestingAccount) GetStartTime

func (m *MsgCreateClawbackVestingAccount) GetStartTime() time.Time

func (*MsgCreateClawbackVestingAccount) GetToAddress

func (m *MsgCreateClawbackVestingAccount) GetToAddress() string

func (*MsgCreateClawbackVestingAccount) GetVestingPeriods

func (*MsgCreateClawbackVestingAccount) Marshal

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

func (*MsgCreateClawbackVestingAccount) MarshalTo

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

func (*MsgCreateClawbackVestingAccount) MarshalToSizedBuffer

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

func (*MsgCreateClawbackVestingAccount) ProtoMessage

func (*MsgCreateClawbackVestingAccount) ProtoMessage()

func (*MsgCreateClawbackVestingAccount) Reset

func (MsgCreateClawbackVestingAccount) Route

Route returns the name of the module

func (*MsgCreateClawbackVestingAccount) Size

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

func (*MsgCreateClawbackVestingAccount) String

func (MsgCreateClawbackVestingAccount) Type

Type returns the the action

func (*MsgCreateClawbackVestingAccount) Unmarshal

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

func (MsgCreateClawbackVestingAccount) ValidateBasic

func (msg MsgCreateClawbackVestingAccount) ValidateBasic() error

ValidateBasic runs stateless checks on the message

func (*MsgCreateClawbackVestingAccount) XXX_DiscardUnknown

func (m *MsgCreateClawbackVestingAccount) XXX_DiscardUnknown()

func (*MsgCreateClawbackVestingAccount) XXX_Marshal

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

func (*MsgCreateClawbackVestingAccount) XXX_Merge

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

func (*MsgCreateClawbackVestingAccount) XXX_Size

func (m *MsgCreateClawbackVestingAccount) XXX_Size() int

func (*MsgCreateClawbackVestingAccount) XXX_Unmarshal

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

type MsgCreateClawbackVestingAccountResponse

type MsgCreateClawbackVestingAccountResponse struct {
}

MsgCreateClawbackVestingAccountResponse defines the MsgCreateClawbackVestingAccount response type.

func (*MsgCreateClawbackVestingAccountResponse) Descriptor

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

func (*MsgCreateClawbackVestingAccountResponse) Marshal

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

func (*MsgCreateClawbackVestingAccountResponse) MarshalTo

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

func (*MsgCreateClawbackVestingAccountResponse) MarshalToSizedBuffer

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

func (*MsgCreateClawbackVestingAccountResponse) ProtoMessage

func (*MsgCreateClawbackVestingAccountResponse) Reset

func (*MsgCreateClawbackVestingAccountResponse) Size

func (*MsgCreateClawbackVestingAccountResponse) String

func (*MsgCreateClawbackVestingAccountResponse) Unmarshal

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

func (*MsgCreateClawbackVestingAccountResponse) XXX_DiscardUnknown

func (m *MsgCreateClawbackVestingAccountResponse) XXX_DiscardUnknown()

func (*MsgCreateClawbackVestingAccountResponse) XXX_Marshal

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

func (*MsgCreateClawbackVestingAccountResponse) XXX_Merge

func (*MsgCreateClawbackVestingAccountResponse) XXX_Size

func (*MsgCreateClawbackVestingAccountResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// CreateClawbackVestingAccount creats a vesting account that is subject to
	// clawback and the configuration of vesting and lockup schedules.
	CreateClawbackVestingAccount(context.Context, *MsgCreateClawbackVestingAccount) (*MsgCreateClawbackVestingAccountResponse, error)
	// Clawback removes the unvested tokens from a ClawbackVestingAccount.
	Clawback(context.Context, *MsgClawback) (*MsgClawbackResponse, error)
}

MsgServer is the server API for Msg service.

type QueryBalancesRequest

type QueryBalancesRequest struct {
	// address of the clawback vesting account
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryBalancesRequest is the request type for the Query/Balances RPC method.

func (*QueryBalancesRequest) Descriptor

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

func (*QueryBalancesRequest) GetAddress

func (m *QueryBalancesRequest) GetAddress() string

func (*QueryBalancesRequest) Marshal

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

func (*QueryBalancesRequest) MarshalTo

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

func (*QueryBalancesRequest) MarshalToSizedBuffer

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

func (*QueryBalancesRequest) ProtoMessage

func (*QueryBalancesRequest) ProtoMessage()

func (*QueryBalancesRequest) Reset

func (m *QueryBalancesRequest) Reset()

func (*QueryBalancesRequest) Size

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

func (*QueryBalancesRequest) String

func (m *QueryBalancesRequest) String() string

func (*QueryBalancesRequest) Unmarshal

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

func (*QueryBalancesRequest) XXX_DiscardUnknown

func (m *QueryBalancesRequest) XXX_DiscardUnknown()

func (*QueryBalancesRequest) XXX_Marshal

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

func (*QueryBalancesRequest) XXX_Merge

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

func (*QueryBalancesRequest) XXX_Size

func (m *QueryBalancesRequest) XXX_Size() int

func (*QueryBalancesRequest) XXX_Unmarshal

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

type QueryBalancesResponse

type QueryBalancesResponse struct {
	// current amount of locked tokens
	Locked github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,1,rep,name=locked,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"locked"`
	// current amount of unvested tokens
	Unvested github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=unvested,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"unvested"`
	// current amount of vested tokens
	Vested github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,3,rep,name=vested,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"vested"`
}

QueryBalancesResponse is the response type for the Query/Balances RPC method.

func (*QueryBalancesResponse) Descriptor

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

func (*QueryBalancesResponse) GetLocked

func (*QueryBalancesResponse) GetUnvested

func (*QueryBalancesResponse) GetVested

func (*QueryBalancesResponse) Marshal

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

func (*QueryBalancesResponse) MarshalTo

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

func (*QueryBalancesResponse) MarshalToSizedBuffer

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

func (*QueryBalancesResponse) ProtoMessage

func (*QueryBalancesResponse) ProtoMessage()

func (*QueryBalancesResponse) Reset

func (m *QueryBalancesResponse) Reset()

func (*QueryBalancesResponse) Size

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

func (*QueryBalancesResponse) String

func (m *QueryBalancesResponse) String() string

func (*QueryBalancesResponse) Unmarshal

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

func (*QueryBalancesResponse) XXX_DiscardUnknown

func (m *QueryBalancesResponse) XXX_DiscardUnknown()

func (*QueryBalancesResponse) XXX_Marshal

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

func (*QueryBalancesResponse) XXX_Merge

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

func (*QueryBalancesResponse) XXX_Size

func (m *QueryBalancesResponse) XXX_Size() int

func (*QueryBalancesResponse) XXX_Unmarshal

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

type QueryClient

type QueryClient interface {
	// Retrieves the unvested, vested and locked tokens for a vesting account
	Balances(ctx context.Context, in *QueryBalancesRequest, opts ...grpc.CallOption) (*QueryBalancesResponse, 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 {
	// Retrieves the unvested, vested and locked tokens for a vesting account
	Balances(context.Context, *QueryBalancesRequest) (*QueryBalancesResponse, error)
}

QueryServer is the server API for Query service.

type StakingKeeper

type StakingKeeper interface {
	GetParams(ctx sdk.Context) stakingtypes.Params
	BondDenom(ctx sdk.Context) string
	GetDelegatorDelegations(ctx sdk.Context, delegator sdk.AccAddress, maxRetrieve uint16) []stakingtypes.Delegation
	GetUnbondingDelegations(ctx sdk.Context, delegator sdk.AccAddress, maxRetrieve uint16) []stakingtypes.UnbondingDelegation
	GetValidator(ctx sdk.Context, valAddr sdk.ValAddress) (stakingtypes.Validator, bool)

	// Support functions for Agoric's custom stakingkeeper logic on vestingkeeper
	GetUnbondingDelegation(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) (stakingtypes.UnbondingDelegation, bool)
	HasMaxUnbondingDelegationEntries(ctx sdk.Context, delegatorAddr sdk.AccAddress, validatorAddr sdk.ValAddress) bool
	SetUnbondingDelegationEntry(ctx sdk.Context, delegatorAddr sdk.AccAddress, validatorAddr sdk.ValAddress, creationHeight int64, minTime time.Time, balance sdk.Int) stakingtypes.UnbondingDelegation
	InsertUBDQueue(ctx sdk.Context, ubd stakingtypes.UnbondingDelegation, completionTime time.Time)
	RemoveUnbondingDelegation(ctx sdk.Context, ubd stakingtypes.UnbondingDelegation)
	SetUnbondingDelegation(ctx sdk.Context, ubd stakingtypes.UnbondingDelegation)
	GetDelegation(ctx sdk.Context, delAddr sdk.AccAddress, valAddr sdk.ValAddress) (stakingtypes.Delegation, bool)
	GetRedelegation(ctx sdk.Context, delAddr sdk.AccAddress, valSrcAddr, valDstAddr sdk.ValAddress) (stakingtypes.Redelegation, bool)
	MaxEntries(ctx sdk.Context) uint32
	SetDelegation(ctx sdk.Context, delegation stakingtypes.Delegation)
	RemoveDelegation(ctx sdk.Context, delegation stakingtypes.Delegation)
	GetRedelegations(ctx sdk.Context, delegator sdk.AccAddress, maxRetrieve uint16) []stakingtypes.Redelegation
	SetRedelegationEntry(ctx sdk.Context, delegatorAddr sdk.AccAddress, validatorSrcAddr, validatorDstAddr sdk.ValAddress, creationHeight int64, minTime time.Time, balance sdk.Int, sharesSrc, sharesDst sdk.Dec) stakingtypes.Redelegation
	InsertRedelegationQueue(ctx sdk.Context, red stakingtypes.Redelegation, completionTime time.Time)
	SetRedelegation(ctx sdk.Context, red stakingtypes.Redelegation)
	RemoveRedelegation(ctx sdk.Context, red stakingtypes.Redelegation)
	GetDelegatorUnbonding(ctx sdk.Context, delegator sdk.AccAddress) sdk.Int
	GetDelegatorBonded(ctx sdk.Context, delegator sdk.AccAddress) sdk.Int
	// Hooks
	stakingtypes.StakingHooks
}

StakingKeeper defines the expected interface contract the vesting module requires for finding and changing the delegated tokens, used in clawback.

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Clawback

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Balances

Jump to

Keyboard shortcuts

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