tasks

Documentation

Index

• type UpdateNodesTask
  • func NewUpdateNodesTask(proxy, rocketscan string, nodes *models.NodeRegistry, secureGRPC bool, ...) *UpdateNodesTask
  • func (t *UpdateNodesTask) Run()
  • func (t *UpdateNodesTask) Stop() error
• type UpdateWithdrawalAddressesTask
  • func NewUpdateWithdrawalAddressesTask(proxy string, withdrawalAddresses *models.NodeRegistry, secureGRPC bool, ...) *UpdateWithdrawalAddressesTask
  • func (t *UpdateWithdrawalAddressesTask) Run()
  • func (t *UpdateWithdrawalAddressesTask) Stop() error

Types

type UpdateNodesTask

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

UpdateNodesTask periodically updates the registry of known Rocket Pool nodes. It uses the Rescue Proxy (primary) and Rocketscan (fallback) APIs to retrieve the list of nodes.

func NewUpdateNodesTask

func NewUpdateNodesTask(
	proxy, rocketscan string,
	nodes *models.NodeRegistry,
	secureGRPC bool,
	logger *zap.Logger,
) *UpdateNodesTask

func (*UpdateNodesTask) Run

func (t *UpdateNodesTask) Run()

func (*UpdateNodesTask) Stop

func (t *UpdateNodesTask) Stop() error

type UpdateWithdrawalAddressesTask

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

UpdateWithdrawalAddressesTask periodically updates the registry of known validators' withdrawal addreses It uses the Rescue Proxy APIsto retrieve the list of addresses.

func NewUpdateWithdrawalAddressesTask

func NewUpdateWithdrawalAddressesTask(
	proxy string,
	withdrawalAddresses *models.NodeRegistry,
	secureGRPC bool,
	logger *zap.Logger,
) *UpdateWithdrawalAddressesTask

func (*UpdateWithdrawalAddressesTask) Run

func (t *UpdateWithdrawalAddressesTask) Run()

func (*UpdateWithdrawalAddressesTask) Stop

func (t *UpdateWithdrawalAddressesTask) Stop() error