rp

Documentation

Index

• Constants
• func CheckCollateral(rp *rocketpool.RocketPool, nodeAddress common.Address, opts *bind.CallOpts) (ethMatched *big.Int, ethMatchedLimit *big.Int, pendingMatchAmount *big.Int, ...)
• func GetMinipoolValidators(rp *rocketpool.RocketPool, bc beacon.Client, addresses []common.Address, ...) (map[common.Address]beacon.ValidatorStatus, error)
• func GetNodeValidatorIndices(rp *rocketpool.RocketPool, ec rocketpool.ExecutionClient, bc beacon.Client, ...) ([]string, error)
• func IsFirstRun(configDir string) bool
• func LoadConfigFromFile(path string) (*config.RocketPoolConfig, error)
• func RemoveUpgradeFlagFile(configDir string) error
• func SaveConfig(cfg *config.RocketPoolConfig, path string) error
• type FeeRecipientInfo
  • func GetFeeRecipientInfo(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, ...) (*FeeRecipientInfo, error)
  • func GetFeeRecipientInfoWithoutState(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, ...) (*FeeRecipientInfo, error)

Constants

const MinipoolPubkeyBatchSize = 50

Settings

Functions

func CheckCollateral

func CheckCollateral(rp *rocketpool.RocketPool, nodeAddress common.Address, opts *bind.CallOpts) (ethMatched *big.Int, ethMatchedLimit *big.Int, pendingMatchAmount *big.Int, err error)

Checks the given node's current matched ETH, its limit on matched ETH, and how much ETH is preparing to be matched by pending bond reductions

func GetMinipoolValidators

func GetMinipoolValidators(rp *rocketpool.RocketPool, bc beacon.Client, addresses []common.Address, callOpts *bind.CallOpts, validatorStatusOpts *beacon.ValidatorStatusOptions) (map[common.Address]beacon.ValidatorStatus, error)

Get minipool validator statuses

func GetNodeValidatorIndices

func GetNodeValidatorIndices(rp *rocketpool.RocketPool, ec rocketpool.ExecutionClient, bc beacon.Client, nodeAddress common.Address) ([]string, error)

func IsFirstRun

func IsFirstRun(configDir string) bool

Checks if this is the first run of the configurator after an install

func LoadConfigFromFile

func LoadConfigFromFile(path string) (*config.RocketPoolConfig, error)

Loads a config without updating it if it exists

func RemoveUpgradeFlagFile

func RemoveUpgradeFlagFile(configDir string) error

Remove the upgrade flag file

func SaveConfig

func SaveConfig(cfg *config.RocketPoolConfig, path string) error

Saves a config and removes the upgrade flag file

Types

type FeeRecipientInfo

type FeeRecipientInfo struct {
	SmoothingPoolAddress  common.Address `json:"smoothingPoolAddress"`
	FeeDistributorAddress common.Address `json:"feeDistributorAddress"`
	IsInSmoothingPool     bool           `json:"isInSmoothingPool"`
	IsInOptOutCooldown    bool           `json:"isInOptOutCooldown"`
	OptOutEpoch           uint64         `json:"optOutEpoch"`
}

func GetFeeRecipientInfo

func GetFeeRecipientInfo(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, state *state.NetworkState) (*FeeRecipientInfo, error)

func GetFeeRecipientInfoWithoutState

func GetFeeRecipientInfoWithoutState(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, opts *bind.CallOpts) (*FeeRecipientInfo, error)