types

type BeaconNodeSet interface {
	ComponentRunner
	// SetENR provides the relevant bootnode's enr to the beacon nodes.
	SetENR(enr string)
}

type ComponentRunner interface {
	// Start starts a component.
	Start(ctx context.Context) error
	// Started checks whether an underlying component is started and ready to be queried.
	Started() <-chan struct{}
	// Pause pauses a component.
	Pause() error
	// Resume resumes a component.
	Resume() error
	// Stop stops a component.
	Stop() error
	// UnderlyingProcess is the underlying process, once started.
	UnderlyingProcess() *os.Process
}

type DepositBalancer interface {
	Balances(DepositBatch) map[[field_params.DilithiumPubkeyLength]byte]uint64
}

type DepositBatch int

type E2EConfig struct {
	// TestCheckpointSync  bool
	TestSync            bool
	TestFeature         bool
	UseQrysmShValidator bool
	UsePprof            bool
	// UseWeb3RemoteSigner bool
	TestDeposits        bool
	UseFixedPeerIDs     bool
	UseBeaconRestApi    bool
	UseBuilder          bool
	EpochsToRun         uint64
	Seed                int64
	TracingSinkEndpoint string
	Evaluators          []Evaluator
	EvalInterceptor     func(*EvaluationContext, uint64, []*grpc.ClientConn) bool
	BeaconFlags         []string
	ValidatorFlags      []string
	PeerIDs             []string
	ExtraEpochs         uint64
}

type E2EConfigOpt func(*E2EConfig)

type EmptyComponent struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type EngineProxy interface {
	ComponentRunner
	// AddRequestInterceptor adds in a json-rpc request interceptor.
	AddRequestInterceptor(rpcMethodName string, responseGen func() interface{}, trigger func() bool)
	// RemoveRequestInterceptor removes the request interceptor for the provided method.
	RemoveRequestInterceptor(rpcMethodName string)
	// ReleaseBackedUpRequests releases backed up http requests.
	ReleaseBackedUpRequests(rpcMethodName string)
}

type EvaluationContext struct {
	DepositBalancer
	ExitedVals           map[[field_params.DilithiumPubkeyLength]byte]bool
	SeenVotes            map[primitives.Slot][]byte
	ExpectedEth1DataVote []byte
}

type Evaluator struct {
	Name   string
	Policy func(currentEpoch primitives.Epoch) bool
	// Evaluation accepts one or many/all conns, depending on what is needed by the set of evaluators.
	Evaluation func(ec *EvaluationContext, conn ...*grpc.ClientConn) error
}

type MultipleComponentRunners interface {
	ComponentRunner
	// ComponentAtIndex returns the component at index
	ComponentAtIndex(i int) (ComponentRunner, error)
	// PauseAtIndex pauses the grouped component element at the desired index.
	PauseAtIndex(i int) error
	// ResumeAtIndex resumes the grouped component element at the desired index.
	ResumeAtIndex(i int) error
	// StopAtIndex stops the grouped component element at the desired index.
	StopAtIndex(i int) error
}