task

Documentation

Index

• Constants
• Variables
• type Coin
• type Handler
• type ICAData
• type PoolAddr
• type PoolBond
• type QueryPoolInfoReq
• type QueryPoolInfoRes
• type RedeemTokenForShareMsg
• type RegisterQueryInfoRes
• type StackInfoReq
• type StackInfoRes
• type Task
  • func NewTask(cfg *config.Config) (*Task, error)
  • func (t *Task) Start() error
  • func (t *Task) Stop()
• type UpdateIcqUpdatePeriodMsg

Constants

const (
	EraUpdateStarted = "era_update_started"
	EraUpdateEnded   = "era_update_ended"
	BondStarted      = "bond_started"
	BondEnded        = "bond_ended"
	WithdrawStarted  = "withdraw_started"
	WithdrawEnded    = "withdraw_ended"
	RebondStarted    = "rebond_started"
	RebondEnded      = "rebond_ended"
	ActiveEnded      = "active_ended"
)

Status

const (
	BalancesQueryKind    = "balances"
	DelegationsQueryKind = "delegations"
	ValidatorsQueryKind  = "validators"
)

QueryKind

const (
	WaitQueryUpdate = "wait_query_update"
)

ValidatorUpdateStatus

Variables

var StatusForExecute = map[string]string{
	ActiveEnded:    "era_update",
	EraUpdateEnded: "era_bond",
	BondEnded:      "era_withdraw_collect",
	WithdrawEnded:  "era_rebond",
	RebondEnded:    "era_active",
}

Types

type Coin

type Coin struct {
	Denom  string `json:"denom"`
	Amount string `json:"amount"`
}

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

type ICAData

type ICAData struct {
	Admin              string `json:"admin"`
	PoolAddressIcaInfo struct {
		CtrlChannelID    string `json:"ctrl_channel_id"`
		CtrlConnectionID string `json:"ctrl_connection_id"`
		CtrlPortID       string `json:"ctrl_port_id"`
		HostChannelID    string `json:"host_channel_id"`
		HostConnectionID string `json:"host_connection_id"`
		IcaAddr          string `json:"ica_addr"`
	} `json:"pool_address_ica_info"`
	WithdrawAddressIcaInfo struct {
		CtrlChannelID    string `json:"ctrl_channel_id"`
		CtrlConnectionID string `json:"ctrl_connection_id"`
		CtrlPortID       string `json:"ctrl_port_id"`
		HostChannelID    string `json:"host_channel_id"`
		HostConnectionID string `json:"host_connection_id"`
		IcaAddr          string `json:"ica_addr"`
	} `json:"withdraw_address_ica_info"`
}

type PoolAddr

type PoolAddr struct {
	Addr string `json:"pool_addr"`
}

type PoolBond

type PoolBond struct {
	Addr       string   `json:"pool_addr"`
	SelectVals []string `json:"select_vals"`
}

type QueryPoolInfoReq

type QueryPoolInfoReq struct {
	PoolInfo PoolAddr `json:"pool_info"`
}

type QueryPoolInfoRes

type QueryPoolInfoRes struct {
	IcaId                     string      `json:"ica_id"`
	Era                       uint64      `json:"era"`
	EraSeconds                uint64      `json:"era_seconds"`
	Offset                    int64       `json:"offset"`
	Bond                      string      `json:"bond"`
	Unbond                    string      `json:"unbond"`
	Active                    string      `json:"active"`
	Rate                      string      `json:"rate"`
	RateChangeLimit           string      `json:"rate_change_limit"`
	Status                    string      `json:"status"`
	ValidatorUpdateStatus     string      `json:"validator_update_status"`
	ShareTokens               []Coin      `json:"share_tokens"`
	RedeemmingShareTokenDenom []string    `json:"redeemming_share_token_denom"`
	EraSnapshot               eraSnapshot `json:"era_snapshot"`
	Paused                    bool        `json:"paused"`
	LsmSupport                bool        `json:"lsm_support"`
	ValidatorAddrs            []string    `json:"validator_addrs"`
}

type RedeemTokenForShareMsg

type RedeemTokenForShareMsg struct {
	PoolAddr string `json:"pool_addr"`
	Tokens   []Coin `json:"tokens"`
}

type RegisterQueryInfoRes

type RegisterQueryInfoRes struct {
	RegisteredQuery struct {
		Id    int    `json:"id"`
		Owner string `json:"owner"`
		Keys  []struct {
			Path string `json:"path"`
			Key  string `json:"key"`
		} `json:"keys"`
		QueryType                       string `json:"query_type"`
		TransactionsFilter              string `json:"transactions_filter"`
		ConnectionId                    string `json:"connection_id"`
		UpdatePeriod                    uint64 `json:"update_period"`
		LastSubmittedResultLocalHeight  uint64 `json:"last_submitted_result_local_height"`
		LastSubmittedResultRemoteHeight struct {
			RevisionNumber int `json:"revision_number"`
			RevisionHeight int `json:"revision_height"`
		} `json:"last_submitted_result_remote_height"`
		Deposit []struct {
			Denom  string `json:"denom"`
			Amount string `json:"amount"`
		} `json:"deposit"`
		SubmitTimeout      int `json:"submit_timeout"`
		RegisteredAtHeight int `json:"registered_at_height"`
	} `json:"registered_query"`
}

type StackInfoReq

type StackInfoReq struct{}

type StackInfoRes

type StackInfoRes struct {
	Pools []string `json:"pools"`
}

type Task

type Task struct {
	// contains filtered or unexported fields
}

func NewTask

func NewTask(cfg *config.Config) (*Task, error)

func (*Task) Start

func (t *Task) Start() error

func (*Task) Stop

func (t *Task) Stop()

type UpdateIcqUpdatePeriodMsg

type UpdateIcqUpdatePeriodMsg struct {
	Addr            string `json:"pool_addr"`
	NewUpdatePeriod uint64 `json:"new_update_period"`
}