cstasks

Documentation

Index

• Constants
• type ConstellationNodeSnapshot
• type NetworkSnapshot
• type NetworkSnapshotTask
  • func NewNetworkSnapshotTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, ...) *NetworkSnapshotTask
  • func (t *NetworkSnapshotTask) Run(walletStatus *wallet.WalletStatus) (*NetworkSnapshot, error)
• type RocketPoolNetworkSettings
• type StakeMinipoolsTask
  • func NewStakeMinipoolsTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, ...) *StakeMinipoolsTask
  • func (t *StakeMinipoolsTask) Run(snapshot *NetworkSnapshot) error
• type SubmitSignedExitsTask
  • func NewSubmitSignedExitsTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, ...) *SubmitSignedExitsTask
  • func (t *SubmitSignedExitsTask) Run(snapshot *NetworkSnapshot) error
• type TaskLoop
  • func NewTaskLoop(sp cscommon.IConstellationServiceProvider, wg *sync.WaitGroup) *TaskLoop
  • func (t *TaskLoop) Run() error

Constants

const (
	ErrorColor             = color.FgRed
	WarningColor           = color.FgYellow
	UpdateDepositDataColor = color.FgHiWhite
	SendExitDataColor      = color.FgGreen
)

Config

Types

type ConstellationNodeSnapshot

type ConstellationNodeSnapshot struct {
	NodeAddress common.Address
	Minipools   []minipool.IMinipool
}

type NetworkSnapshot

type NetworkSnapshot struct {
	ExecutionBlockHeader      *types.Header
	RocketPoolNetworkSettings *RocketPoolNetworkSettings
	ConstellationNode         *ConstellationNodeSnapshot
}

type NetworkSnapshotTask

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

func NewNetworkSnapshotTask

func NewNetworkSnapshotTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, logger *log.Logger) *NetworkSnapshotTask

Creates a new network snapshot task

func (*NetworkSnapshotTask) Run

func (t *NetworkSnapshotTask) Run(walletStatus *wallet.WalletStatus) (*NetworkSnapshot, error)

Run the task

type RocketPoolNetworkSettings

type RocketPoolNetworkSettings struct {
	ScrubPeriod        time.Duration
	LaunchTimeout      time.Duration
	MinipoolStakeValue *big.Int
}

type StakeMinipoolsTask

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

Stake minipools task

func NewStakeMinipoolsTask

func NewStakeMinipoolsTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, logger *log.Logger) *StakeMinipoolsTask

Create a stake minipools task

func (*StakeMinipoolsTask) Run

func (t *StakeMinipoolsTask) Run(snapshot *NetworkSnapshot) error

Stake prelaunch minipools

type SubmitSignedExitsTask

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

Submit signed exits task

func NewSubmitSignedExitsTask

func NewSubmitSignedExitsTask(ctx context.Context, sp cscommon.IConstellationServiceProvider, logger *log.Logger) *SubmitSignedExitsTask

Create a submit signed exits task

func (*SubmitSignedExitsTask) Run

func (t *SubmitSignedExitsTask) Run(snapshot *NetworkSnapshot) error

Submit signed exits

type TaskLoop

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

func NewTaskLoop

func NewTaskLoop(sp cscommon.IConstellationServiceProvider, wg *sync.WaitGroup) *TaskLoop

func (*TaskLoop) Run

func (t *TaskLoop) Run() error

Run daemon