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")
)
View Source 
var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

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 (m *MsgCreateClawbackVestingAccount) GetLockupPeriods() github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods

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 (m *MsgCreateClawbackVestingAccount) GetVestingPeriods() github_com_cosmos_cosmos_sdk_x_auth_vesting_types.Periods

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 (m *MsgCreateClawbackVestingAccount) Reset()

func (MsgCreateClawbackVestingAccount) Route 

func (msg MsgCreateClawbackVestingAccount) Route() string

Route returns the name of the module

func (*MsgCreateClawbackVestingAccount) Size 

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

func (*MsgCreateClawbackVestingAccount) String 

func (m *MsgCreateClawbackVestingAccount) String() string

func (MsgCreateClawbackVestingAccount) Type 

func (msg MsgCreateClawbackVestingAccount) Type() string

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) ProtoMessage()

func (*MsgCreateClawbackVestingAccountResponse) Reset 

func (m *MsgCreateClawbackVestingAccountResponse) Reset()

func (*MsgCreateClawbackVestingAccountResponse) Size 

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

func (*MsgCreateClawbackVestingAccountResponse) String 

func (m *MsgCreateClawbackVestingAccountResponse) String() 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 (m *MsgCreateClawbackVestingAccountResponse) XXX_Merge(src proto.Message)

func (*MsgCreateClawbackVestingAccountResponse) XXX_Size 

func (m *MsgCreateClawbackVestingAccountResponse) XXX_Size() int

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 (m *QueryBalancesResponse) GetLocked() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryBalancesResponse) GetUnvested 

func (m *QueryBalancesResponse) GetUnvested() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryBalancesResponse) GetVested 

func (m *QueryBalancesResponse) GetVested() github_com_cosmos_cosmos_sdk_types.Coins

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 

func (*UnimplementedMsgServer) Clawback(ctx context.Context, req *MsgClawback) (*MsgClawbackResponse, error)

func (*UnimplementedMsgServer) CreateClawbackVestingAccount 

func (*UnimplementedMsgServer) CreateClawbackVestingAccount(ctx context.Context, req *MsgCreateClawbackVestingAccount) (*MsgCreateClawbackVestingAccountResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Balances 

func (*UnimplementedQueryServer) Balances(ctx context.Context, req *QueryBalancesRequest) (*QueryBalancesResponse, 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.