deriver

type Config struct {
	AttesterSlashingConfig         v2.AttesterSlashingDeriverConfig         `yaml:"attesterSlashing"`
	BLSToExecutionConfig           v2.BLSToExecutionChangeDeriverConfig     `yaml:"blsToExecutionChange"`
	DepositConfig                  v2.DepositDeriverConfig                  `yaml:"deposit"`
	ExecutionTransactionConfig     v2.ExecutionTransactionDeriverConfig     `yaml:"executionTransaction"`
	ProposerSlashingConfig         v2.ProposerSlashingDeriverConfig         `yaml:"proposerSlashing"`
	VoluntaryExitConfig            v2.VoluntaryExitDeriverConfig            `yaml:"voluntaryExit"`
	WithdrawalConfig               v2.WithdrawalDeriverConfig               `yaml:"withdrawal"`
	BeaconBlockConfig              v2.BeaconBlockDeriverConfig              `yaml:"beaconBlock"`
	BeaconBlobSidecarConfig        v1.BeaconBlobDeriverConfig               `yaml:"beaconBlobSidecar"`
	ProposerDutyConfig             v1.ProposerDutyDeriverConfig             `yaml:"proposerDuty"`
	ElaboratedAttestationConfig    v2.ElaboratedAttestationDeriverConfig    `yaml:"elaboratedAttestation"`
	BeaconValidatorsConfig         v1.BeaconValidatorsDeriverConfig         `yaml:"beaconValidators"`
	BeaconCommitteeConfig          v1.BeaconCommitteeDeriverConfig          `yaml:"beaconCommittee"`
	BeaconSyncCommitteeConfig      v1.BeaconSyncCommitteeDeriverConfig      `yaml:"beaconSyncCommittee"`
	BeaconBlockSyncAggregateConfig v2.BeaconBlockSyncAggregateDeriverConfig `yaml:"beaconBlockSyncAggregate"`
}

type EventDeriver interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Name() string
	CannonType() xatu.CannonType
	// Callbacks
	OnEventsDerived(ctx context.Context, fn func(ctx context.Context, events []*xatu.DecoratedEvent) error)
	// ActivationFork is the fork at which the deriver should start deriving events
	ActivationFork() spec.DataVersion
}