duties

Documentation

Index

• func CreateDutyExecuteMsg(duty *spectypes.Duty, pubKey *bls.PublicKey) (*spectypes.SSVMessage, error)
• type ControllerOptions
• type DutyController
  • func NewDutyController(logger *zap.Logger, opts *ControllerOptions) DutyController
• type DutyExecutor
  • func NewReadOnlyExecutor() DutyExecutor
• type DutyFetcher

Functions

func CreateDutyExecuteMsg

func CreateDutyExecuteMsg(duty *spectypes.Duty, pubKey *bls.PublicKey) (*spectypes.SSVMessage, error)

CreateDutyExecuteMsg returns ssvMsg with event type of duty execute

Types

type ControllerOptions

type ControllerOptions struct {
	Ctx                 context.Context
	BeaconClient        beaconprotocol.Beacon
	EthNetwork          beaconprotocol.Network
	ValidatorController validator.Controller
	Executor            DutyExecutor
	DutyLimit           uint64
	ForkVersion         forksprotocol.ForkVersion
	Ticker              slot_ticker.Ticker
}

ControllerOptions holds the needed dependencies

type DutyController

type DutyController interface {
	Start(logger *zap.Logger)
}

DutyController interface for dispatching duties execution according to slot ticker

func NewDutyController

func NewDutyController(logger *zap.Logger, opts *ControllerOptions) DutyController

NewDutyController creates a new instance of DutyController

type DutyExecutor

type DutyExecutor interface {
	ExecuteDuty(logger *zap.Logger, duty *spectypes.Duty) error
}

DutyExecutor represents the component that executes duties

func NewReadOnlyExecutor

func NewReadOnlyExecutor() DutyExecutor

NewReadOnlyExecutor creates a dummy executor that is used to run in read mode

type DutyFetcher

type DutyFetcher interface {
	GetDuties(logger *zap.Logger, slot phase0.Slot) ([]spectypes.Duty, error)
	SyncCommitteeDuties(logger *zap.Logger, epoch phase0.Epoch, indices []phase0.ValidatorIndex) ([]*eth2apiv1.SyncCommitteeDuty, error)
	eth2client.EventsProvider
}

DutyFetcher represents the component that manages duties