task

Documentation

Index

• type Cluster
• type ReqEjectorUptime
• type RspUptime
• type Task
  • func NewTask(cfg *config.Config, seed []byte, isViewMode bool, ...) (*Task, error)
  • func (task *Task) Start() error
  • func (task *Task) Stop()
• type Validator

Types

type Cluster

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

type ReqEjectorUptime

type ReqEjectorUptime struct {
	ValidatorIndexList []uint64 `json:"validatorIndexList"` //hex string list
}

type RspUptime

type RspUptime struct {
	Status  string      `json:"status"`
	Message string      `json:"message"`
	Data    interface{} `json:"data"`
}

type Task

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

only support stafi super node account now !!! 0. find next key index and cache validator status on start 1. update validator status(on execution/ssv/beacon) periodically 2. check stakepool balance periodically, call stake/deposit if match 3. register validator on ssv, if status is staked on stafi contract 4. remove validator on ssv, if status is exited on beacon

func NewTask

func NewTask(cfg *config.Config, seed []byte, isViewMode bool, superNodeKeyPair, ssvKeyPair *secp256k1.Keypair) (*Task, error)

func (*Task) Start

func (task *Task) Start() error

func (*Task) Stop

func (task *Task) Stop()

type Validator

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