multi

func (*Service) Address ¶

func (s *Service) Address() string

Address returns the address of the client.

func (*Service) AggregateAttestation ¶

func (s *Service) AggregateAttestation(ctx context.Context,
	opts *api.AggregateAttestationOpts,
) (
	*api.Response[*spec.VersionedAttestation],
	error,
)

AggregateAttestation fetches the aggregate attestation for the given options.

func (*Service) AgnosticBeaconState ¶ added in v0.1.2

func (s *Service) AgnosticBeaconState(ctx context.Context, opts *api.BeaconStateOpts) (*api.Response[*all.BeaconState], error)

AgnosticBeaconState fetches a beacon state as a fork-agnostic *all.BeaconState.

func (*Service) AgnosticSignedBeaconBlock ¶ added in v0.1.2

func (s *Service) AgnosticSignedBeaconBlock(ctx context.Context,
	opts *api.SignedBeaconBlockOpts,
) (
	*api.Response[*all.SignedBeaconBlock],
	error,
)

AgnosticSignedBeaconBlock fetches a signed beacon block as a fork-agnostic *all.SignedBeaconBlock.

func (*Service) AgnosticSignedExecutionPayloadEnvelope ¶ added in v0.1.2

func (s *Service) AgnosticSignedExecutionPayloadEnvelope(ctx context.Context,
	opts *api.SignedExecutionPayloadEnvelopeOpts,
) (
	*api.Response[*all.SignedExecutionPayloadEnvelope],
	error,
)

AgnosticSignedExecutionPayloadEnvelope fetches a signed execution payload envelope as a fork-agnostic *all.SignedExecutionPayloadEnvelope.

func (*Service) AttestationData ¶

func (s *Service) AttestationData(ctx context.Context,
	opts *api.AttestationDataOpts,
) (
	*api.Response[*phase0.AttestationData],
	error,
)

AttestationData fetches the attestation data for the given slot and committee index.

func (*Service) AttestationPool ¶

func (s *Service) AttestationPool(ctx context.Context,
	opts *api.AttestationPoolOpts,
) (
	*api.Response[[]*spec.VersionedAttestation],
	error,
)

AttestationPool obtains the attestation pool for a given slot.

func (*Service) AttestationRewards ¶

func (s *Service) AttestationRewards(ctx context.Context,
	opts *api.AttestationRewardsOpts,
) (
	*api.Response[*apiv1.AttestationRewards],
	error,
)

AttestationRewards provides rewards to the given validators for attesting.

func (*Service) AttesterDuties ¶

func (s *Service) AttesterDuties(ctx context.Context,
	opts *api.AttesterDutiesOpts,
) (
	*api.Response[[]*apiv1.AttesterDuty],
	error,
)

AttesterDuties obtains attester duties. If validatorIndices is nil it will return all duties for the given epoch.

func (*Service) BeaconBlockHeader ¶

func (s *Service) BeaconBlockHeader(ctx context.Context,
	opts *api.BeaconBlockHeaderOpts,
) (
	*api.Response[*apiv1.BeaconBlockHeader],
	error,
)

BeaconBlockHeader provides the block header of a given block ID.

func (*Service) BeaconBlockRoot ¶

func (s *Service) BeaconBlockRoot(ctx context.Context,
	opts *api.BeaconBlockRootOpts,
) (
	*api.Response[*phase0.Root],
	error,
)

BeaconBlockRoot fetches a block's root given a block ID.

func (*Service) BeaconCommitteeSelections ¶ added in v0.1.0

func (s *Service) BeaconCommitteeSelections(ctx context.Context,
	opts *api.BeaconCommitteeSelectionsOpts,
) (
	*api.Response[[]*apiv1.BeaconCommitteeSelection], error,
)

BeaconCommitteeSelections obtains beacon committee selections.

func (*Service) BeaconCommittees ¶

func (s *Service) BeaconCommittees(ctx context.Context,
	opts *api.BeaconCommitteesOpts,
) (
	*api.Response[[]*apiv1.BeaconCommittee],
	error,
)

BeaconCommittees fetches all beacon committees for the epoch at the given state.

func (*Service) BeaconState ¶

func (s *Service) BeaconState(ctx context.Context, opts *api.BeaconStateOpts) (*api.Response[*spec.VersionedBeaconState], error)

BeaconState fetches a beacon state.

func (*Service) BeaconStateRoot ¶

func (s *Service) BeaconStateRoot(ctx context.Context,
	opts *api.BeaconStateRootOpts,
) (
	*api.Response[*phase0.Root],
	error,
)

BeaconStateRoot fetches a beacon state root given a state ID.

func (*Service) BlobSidecars ¶

func (s *Service) BlobSidecars(ctx context.Context,
	opts *api.BlobSidecarsOpts,
) (*api.Response[[]*deneb.BlobSidecar],
	error,
)

BlobSidecars fetches the blob sidecars given options.

func (*Service) Blobs ¶

func (s *Service) Blobs(ctx context.Context,
	opts *api.BlobsOpts,
) (*api.Response[apiv1.Blobs],
	error,
)

Blobs fetches the blobs given options.

func (*Service) BlockRewards ¶

func (s *Service) BlockRewards(ctx context.Context,
	opts *api.BlockRewardsOpts,
) (
	*api.Response[*apiv1.BlockRewards],
	error,
)

BlockRewards provides rewards for proposing a block.

func (*Service) DepositContract ¶

func (s *Service) DepositContract(ctx context.Context,
	opts *api.DepositContractOpts,
) (
	*api.Response[*apiv1.DepositContract],
	error,
)

DepositContract provides details of the Ethereum 1 deposit contract for the chain.

func (*Service) Domain ¶

func (s *Service) Domain(ctx context.Context,
	domainType phase0.DomainType,
	epoch phase0.Epoch,
) (
	phase0.Domain,
	error,
)

Domain provides a domain for a given domain type at a given epoch.

func (*Service) Events ¶

func (s *Service) Events(ctx context.Context,
	opts *api.EventsOpts,
) error

Events feeds requested events with the given topics to the supplied handler.

func (*Service) FarFutureEpoch ¶

func (s *Service) FarFutureEpoch(ctx context.Context) (phase0.Epoch, error)

FarFutureEpoch provides the far future epoch of the chain.

func (*Service) Finality ¶

func (s *Service) Finality(ctx context.Context, opts *api.FinalityOpts) (*api.Response[*apiv1.Finality], error)

Finality provides the finality given a state ID.

func (*Service) Fork ¶

func (s *Service) Fork(ctx context.Context,
	opts *api.ForkOpts,
) (
	*api.Response[*phase0.Fork],
	error,
)

Fork fetches fork information for the given state.

func (*Service) ForkChoice ¶

func (s *Service) ForkChoice(ctx context.Context,
	opts *api.ForkChoiceOpts,
) (
	*api.Response[*apiv1.ForkChoice],
	error,
)

ForkChoice fetches all current fork choice context.

func (*Service) ForkChoiceV2 ¶ added in v0.1.10

func (s *Service) ForkChoiceV2(ctx context.Context,
	opts *api.ForkChoiceOpts,
) (
	*api.Response[*apiv1.ForkChoiceV2],
	error,
)

ForkChoiceV2 fetches all current fork choice context, with one node per (block root, payload status) pair.

Not every client implements the endpoint yet, and those that do not answer with an error status (Lighthouse 400, Nimbus 404) rather than failing over. Such clients, and clients whose response does not follow the spec (client.ErrInvalidResponse), are skipped without being deactivated in favour of the next client: they still serve other endpoints. If no client returns a fork choice and any of them lacked the endpoint, the error returned is (or, alongside the other clients' error, wraps) the last of those errors, so callers can fall back to GET /eth/v1/debug/fork_choice, which the clients without the v2 endpoint can serve.

func (*Service) ForkSchedule ¶

func (s *Service) ForkSchedule(ctx context.Context,
	opts *api.ForkScheduleOpts,
) (
	*api.Response[[]*phase0.Fork],
	error,
)

ForkSchedule provides details of past and future changes in the chain's fork version.

func (*Service) Genesis ¶

func (s *Service) Genesis(ctx context.Context,
	opts *api.GenesisOpts,
) (
	*api.Response[*apiv1.Genesis],
	error,
)

Genesis provides the genesis for the chain.

func (*Service) GenesisDomain ¶

func (s *Service) GenesisDomain(ctx context.Context,
	domainType phase0.DomainType,
) (
	phase0.Domain,
	error,
)

GenesisDomain provides a domain for a given domain type.

func (*Service) IsActive ¶

func (s *Service) IsActive() bool

IsActive returns true if the client is active. The service is considered active if at least one client is synced.

func (*Service) IsSynced ¶

func (s *Service) IsSynced() bool

IsSynced returns true if the client is synced. The service is considered synced if at least one client is synced.

func (*Service) Name ¶

func (*Service) Name() string

Name returns the name of the client implementation.

func (*Service) NodeIdentity ¶ added in v0.1.6

func (s *Service) NodeIdentity(ctx context.Context,
	opts *api.NodeIdentityOpts,
) (
	*api.Response[*apiv1.NodeIdentity],
	error,
)

NodeIdentity provides the node's network identity.

func (*Service) NodePeers ¶

func (s *Service) NodePeers(ctx context.Context, opts *api.NodePeersOpts) (*api.Response[[]*apiv1.Peer], error)

NodePeers provides the peers of the node.

func (*Service) NodeSyncing ¶

func (s *Service) NodeSyncing(ctx context.Context,
	opts *api.NodeSyncingOpts,
) (
	*api.Response[*apiv1.SyncState],
	error,
)

NodeSyncing provides the syncing information for the node.

func (*Service) NodeVersion ¶

func (s *Service) NodeVersion(ctx context.Context, opts *api.NodeVersionOpts) (*api.Response[string], error)

NodeVersion provides the version information of the node.

func (*Service) PendingConsolidations ¶

func (s *Service) PendingConsolidations(ctx context.Context,
	opts *api.PendingConsolidationsOpts,
) (
	*api.Response[[]*electra.PendingConsolidation],
	error,
)

PendingConsolidations provides the pending consolidations for a given state.

func (*Service) PendingDeposits ¶

func (s *Service) PendingDeposits(ctx context.Context,
	opts *api.PendingDepositsOpts,
) (
	*api.Response[[]*electra.PendingDeposit],
	error,
)

PendingDeposits provides the pending deposits for a given state.

func (*Service) PendingPartialWithdrawals ¶

func (s *Service) PendingPartialWithdrawals(ctx context.Context,
	opts *api.PendingPartialWithdrawalsOpts,
) (
	*api.Response[[]*electra.PendingPartialWithdrawal],
	error,
)

PendingPartialWithdrawals provides the pending partial withdrawals for a given state.

func (*Service) Proposal ¶

func (s *Service) Proposal(ctx context.Context,
	opts *api.ProposalOpts,
) (
	*api.Response[*api.VersionedProposal],
	error,
)

Proposal fetches a proposal for signing.

func (*Service) ProposerDuties ¶

func (s *Service) ProposerDuties(ctx context.Context,
	opts *api.ProposerDutiesOpts,
) (
	*api.Response[[]*apiv1.ProposerDuty],
	error,
)

ProposerDuties obtains proposer duties for the given epoch. If validatorIndices is empty all duties are returned, otherwise only matching duties are returned.

func (*Service) SignedBeaconBlock ¶

func (s *Service) SignedBeaconBlock(ctx context.Context,
	opts *api.SignedBeaconBlockOpts,
) (
	*api.Response[*spec.VersionedSignedBeaconBlock],
	error,
)

SignedBeaconBlock fetches a signed beacon block given a block ID.

func (*Service) SignedExecutionPayloadEnvelope ¶

func (s *Service) SignedExecutionPayloadEnvelope(ctx context.Context,
	opts *api.SignedExecutionPayloadEnvelopeOpts,
) (
	*api.Response[*spec.VersionedSignedExecutionPayloadEnvelope],
	error,
)

SignedExecutionPayloadEnvelope fetches a signed execution payload envelope given a block ID.

func (*Service) Spec ¶

func (s *Service) Spec(ctx context.Context,
	opts *api.SpecOpts,
) (
	*api.Response[map[string]any],
	error,
)

Spec provides the spec information of the chain.

func (*Service) SubmitAggregateAttestations ¶

func (s *Service) SubmitAggregateAttestations(ctx context.Context,
	opts *api.SubmitAggregateAttestationsOpts,
) error

SubmitAggregateAttestations submits aggregate attestations.

func (*Service) SubmitAgnosticExecutionPayloadBid ¶ added in v0.1.6

func (s *Service) SubmitAgnosticExecutionPayloadBid(ctx context.Context,
	opts *api.SubmitAgnosticExecutionPayloadBidOpts,
) error

SubmitAgnosticExecutionPayloadBid submits a fork-agnostic execution payload bid.

func (*Service) SubmitAgnosticExecutionPayloadEnvelope ¶ added in v0.1.6

func (s *Service) SubmitAgnosticExecutionPayloadEnvelope(ctx context.Context,
	opts *api.SubmitAgnosticExecutionPayloadEnvelopeOpts,
) error

SubmitAgnosticExecutionPayloadEnvelope submits a fork-agnostic execution payload envelope.

func (*Service) SubmitAttestations ¶

func (s *Service) SubmitAttestations(ctx context.Context,
	opts *api.SubmitAttestationsOpts,
) error

SubmitAttestations submits attestations.

func (*Service) SubmitAttesterSlashingV2 ¶ added in v0.1.7

func (s *Service) SubmitAttesterSlashingV2(ctx context.Context,
	opts *api.SubmitAttesterSlashingOpts,
) error

SubmitAttesterSlashingV2 submits a versioned attester slashing.

func (*Service) SubmitBeaconCommitteeSubscriptions ¶

func (s *Service) SubmitBeaconCommitteeSubscriptions(ctx context.Context,
	subscriptions []*api.BeaconCommitteeSubscription,
) error

SubmitBeaconCommitteeSubscriptions subscribes to beacon committees.

func (*Service) SubmitBlindedProposal ¶

func (s *Service) SubmitBlindedProposal(ctx context.Context, opts *api.SubmitBlindedProposalOpts) error

SubmitBlindedProposal submits a blinded proposal.

func (*Service) SubmitExecutionPayloadBid ¶ added in v0.1.6

func (s *Service) SubmitExecutionPayloadBid(ctx context.Context,
	opts *api.SubmitExecutionPayloadBidOpts,
) error

SubmitExecutionPayloadBid submits an execution payload bid.

func (*Service) SubmitExecutionPayloadEnvelope ¶ added in v0.1.6

func (s *Service) SubmitExecutionPayloadEnvelope(ctx context.Context,
	opts *api.SubmitExecutionPayloadEnvelopeOpts,
) error

SubmitExecutionPayloadEnvelope submits an execution payload envelope.

func (*Service) SubmitProposal ¶

func (s *Service) SubmitProposal(ctx context.Context,
	opts *api.SubmitProposalOpts,
) error

SubmitProposal submits a beacon block.

func (*Service) SubmitProposalPreparations ¶

func (s *Service) SubmitProposalPreparations(ctx context.Context,
	preparations []*apiv1.ProposalPreparation,
) error

SubmitProposalPreparations provides the beacon node with information required if a proposal for the given validators shows up in the next epoch.

func (*Service) SubmitSyncCommitteeContributions ¶

func (s *Service) SubmitSyncCommitteeContributions(ctx context.Context,
	contributionAndProofs []*altair.SignedContributionAndProof,
) error

SubmitSyncCommitteeContributions submits sync committee contributions.

func (*Service) SubmitSyncCommitteeMessages ¶

func (s *Service) SubmitSyncCommitteeMessages(ctx context.Context,
	messages []*altair.SyncCommitteeMessage,
) error

SubmitSyncCommitteeMessages submits sync committee messages.

func (*Service) SubmitSyncCommitteeSubscriptions ¶

func (s *Service) SubmitSyncCommitteeSubscriptions(ctx context.Context,
	subscriptions []*api.SyncCommitteeSubscription,
) error

SubmitSyncCommitteeSubscriptions subscribes to sync committees.

func (*Service) SubmitValidatorRegistrations ¶

func (s *Service) SubmitValidatorRegistrations(ctx context.Context,
	registrations []*api.VersionedSignedValidatorRegistration,
) error

SubmitValidatorRegistrations submits a validator registration.

func (*Service) SubmitVoluntaryExit ¶

func (s *Service) SubmitVoluntaryExit(ctx context.Context, voluntaryExit *phase0.SignedVoluntaryExit) error

SubmitVoluntaryExit submits a voluntary exit.

func (*Service) SyncCommittee ¶

func (s *Service) SyncCommittee(ctx context.Context, opts *api.SyncCommitteeOpts) (*api.Response[*apiv1.SyncCommittee], error)

SyncCommittee fetches the sync committee for the given state.

func (*Service) SyncCommitteeContribution ¶

func (s *Service) SyncCommitteeContribution(ctx context.Context,
	opts *api.SyncCommitteeContributionOpts,
) (
	*api.Response[*altair.SyncCommitteeContribution],
	error,
)

SyncCommitteeContribution provides a sync committee contribution.

func (*Service) SyncCommitteeDuties ¶

func (s *Service) SyncCommitteeDuties(ctx context.Context,
	opts *api.SyncCommitteeDutiesOpts,
) (
	*api.Response[[]*apiv1.SyncCommitteeDuty],
	error,
)

SyncCommitteeDuties obtains attester duties. If validatorIndices is nil it will return all duties for the given epoch.

func (*Service) SyncCommitteeRewards ¶

func (s *Service) SyncCommitteeRewards(ctx context.Context,
	opts *api.SyncCommitteeRewardsOpts,
) (
	*api.Response[[]*apiv1.SyncCommitteeReward],
	error,
)

SyncCommitteeRewards provides rewards to the given validators for being members of a sync committee.

func (*Service) ValidatorBalances ¶

func (s *Service) ValidatorBalances(ctx context.Context,
	opts *api.ValidatorBalancesOpts,
) (
	*api.Response[map[phase0.ValidatorIndex]phase0.Gwei],
	error,
)

ValidatorBalances provides the validator balances for a given state.

func (*Service) ValidatorLiveness ¶

func (s *Service) ValidatorLiveness(ctx context.Context,
	opts *api.ValidatorLivenessOpts,
) (
	*api.Response[[]*apiv1.ValidatorLiveness],
	error,
)

ValidatorLiveness provides the liveness data to the given validators.

func (*Service) Validators ¶

func (s *Service) Validators(ctx context.Context,
	opts *api.ValidatorsOpts,
) (
	*api.Response[map[phase0.ValidatorIndex]*apiv1.Validator],
	error,
)

Validators provides the validators, with their balance and status, for a given state.

func (*Service) VoluntaryExitPool ¶

func (s *Service) VoluntaryExitPool(ctx context.Context,
	opts *api.VoluntaryExitPoolOpts,
) (
	*api.Response[[]*phase0.SignedVoluntaryExit],
	error,
)

VoluntaryExitPool obtains the voluntary exit pool.