testclients

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 20, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NetworkName 

func NetworkName(ctx context.Context, service any) string

NetworkName returns the network name (Mainnet, Sepolia, Holesky, or Hoodi) for the given service. It identifies the network by querying the genesis validators root and comparing it against known values. Returns "Unknown" if the network cannot be identified or if genesis information is unavailable.

func NewErroring 

func NewErroring(_ context.Context,
	errorRate float64,
	next consensusclient.Service,
) (consensusclient.Service, error)

NewErroring creates a new Ethereum 2 client that errors at a given rate.

func NewSleepy 

func NewSleepy(_ context.Context,
	minSleep time.Duration,
	maxSleep time.Duration,
	next consensusclient.Service,
) (consensusclient.Service, error)

NewSleepy creates a new Ethereum 2 client that sleeps for random amount of time within a set of bounds between minSleep and maxSleep before continuing.

Types

type Erroring 

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

Erroring is an Ethereum 2 client that errors at a given rate.

func (*Erroring) Address 

func (s *Erroring) Address() string

Address returns the address of the client.

func (*Erroring) AggregateAttestation 

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

AggregateAttestation fetches the aggregate attestation for the given options.

func (*Erroring) AttestationData 

func (s *Erroring) 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 (*Erroring) AttestationPool 

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

AttestationPool fetches the attestation pool for the given slot.

func (*Erroring) AttestationRewards 

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

AttestationRewards provides rewards to the given validators for attesting.

func (*Erroring) AttesterDuties 

func (s *Erroring) 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 (*Erroring) BeaconBlockHeader 

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

BeaconBlockHeader provides the block header of a given block ID.

func (*Erroring) BeaconBlockRoot 

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

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

func (*Erroring) BeaconCommitteeSelections added in v0.1.0 

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

BeaconCommitteeSelections submits beacon committee selections.

func (*Erroring) BeaconCommittees 

func (s *Erroring) 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 (*Erroring) BeaconState 

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

BeaconState fetches a beacon state.

func (*Erroring) BeaconStateRoot 

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

BeaconStateRoot fetches a beacon state root given a state ID.

func (*Erroring) BlobSidecars 

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

BlobSidecars fetches the blobs given a block ID.

func (*Erroring) Blobs 

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

Blobs fetches the blobs given a block ID.

func (*Erroring) BlockRewards 

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

BlockRewards provides rewards for proposing a block.

func (*Erroring) DepositContract 

func (s *Erroring) 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 (*Erroring) Domain 

func (s *Erroring) 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 (*Erroring) EpochFromStateID deprecated 

func (s *Erroring) EpochFromStateID(ctx context.Context, stateID string) (phase0.Epoch, error)

EpochFromStateID converts a state ID to its epoch.

Deprecated: use chaintime.

func (*Erroring) Events 

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

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

func (*Erroring) FarFutureEpoch 

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

FarFutureEpoch provides the far future epoch of the chain.

func (*Erroring) Finality 

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

Finality provides the finality given a state ID.

func (*Erroring) Fork 

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

Fork fetches fork information for the given state.

func (*Erroring) ForkChoice 

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

ForkChoice fetches the node's current fork choice context.

func (*Erroring) ForkSchedule 

func (s *Erroring) 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 (*Erroring) Genesis 

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

Genesis fetches genesis information for the chain.

func (*Erroring) GenesisDomain 

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

GenesisDomain provides a domain for a given domain type.

func (*Erroring) GenesisTime deprecated 

func (s *Erroring) GenesisTime(ctx context.Context) (time.Time, error)

GenesisTime provides the genesis time of the chain.

Deprecated: use Genesis().

func (*Erroring) IsActive 

func (*Erroring) IsActive() bool

IsActive returns true if the client is active.

func (*Erroring) IsSynced 

func (*Erroring) IsSynced() bool

IsSynced returns true if the client is synced.

func (*Erroring) Name 

func (s *Erroring) Name() string

Name returns the name of the client implementation.

func (*Erroring) NodePeers 

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

NodePeers provides the peers of the node.

func (*Erroring) NodeSyncing 

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

NodeSyncing provides the state of the node's synchronization with the chain.

func (*Erroring) NodeVersion 

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

NodeVersion returns a free-text string with the node version.

func (*Erroring) PendingDeposits 

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

PendingDeposits provides the pending deposits for a given state.

func (*Erroring) Proposal 

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

Proposal fetches a proposal for signing.

func (*Erroring) ProposerDuties 

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

ProposerDuties obtains proposer duties for the given epoch.

func (*Erroring) SignedBeaconBlock 

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

SignedBeaconBlock fetches a signed beacon block given a block ID.

func (*Erroring) SlotDuration deprecated 

func (s *Erroring) SlotDuration(ctx context.Context) (time.Duration, error)

SlotDuration provides the duration of a slot of the chain.

Deprecated: use Spec().

func (*Erroring) SlotFromStateID deprecated 

func (s *Erroring) SlotFromStateID(ctx context.Context, stateID string) (phase0.Slot, error)

SlotFromStateID converts a state ID to its slot.

Deprecated: use chaintime.

func (*Erroring) SlotsPerEpoch deprecated 

func (s *Erroring) SlotsPerEpoch(ctx context.Context) (uint64, error)

SlotsPerEpoch provides the slots per epoch of the chain.

Deprecated: use Spec().

func (*Erroring) Spec 

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

Spec provides the spec information of the chain.

func (*Erroring) SubmitAggregateAttestations 

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

SubmitAggregateAttestations submits aggregate attestations.

func (*Erroring) SubmitAttestations 

func (s *Erroring) SubmitAttestations(ctx context.Context, attestations *api.SubmitAttestationsOpts) error

SubmitAttestations submits attestations.

func (*Erroring) SubmitBeaconBlock deprecated 

func (s *Erroring) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) error

SubmitBeaconBlock submits a beacon block.

Deprecated: this will not work from the deneb hard-fork onwards. Use SubmitProposal() instead.

func (*Erroring) SubmitBeaconCommitteeSubscriptions 

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

SubmitBeaconCommitteeSubscriptions subscribes to beacon committees.

func (*Erroring) SubmitBlindedBeaconBlock deprecated 

func (s *Erroring) SubmitBlindedBeaconBlock(ctx context.Context,
	block *api.VersionedSignedBlindedBeaconBlock,
) error

SubmitBlindedBeaconBlock submits a blinded beacon block.

Deprecated: this will not work from the deneb hard-fork onwards. Use SubmitBlindedProposal() instead.

func (*Erroring) SubmitProposalPreparations 

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

SubmitProposalPreparations submits proposal preparations.

func (*Erroring) SubmitSyncCommitteeContributions 

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

SubmitSyncCommitteeContributions submits sync committee contributions.

func (*Erroring) SubmitSyncCommitteeMessages 

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

SubmitSyncCommitteeMessages submits sync committee messages.

func (*Erroring) SubmitSyncCommitteeSubscriptions 

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

SubmitSyncCommitteeSubscriptions subscribes to sync committees.

func (*Erroring) SubmitValidatorRegistrations 

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

SubmitValidatorRegistrations submits a validator registration.

func (*Erroring) SubmitVoluntaryExit 

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

SubmitVoluntaryExit submits a voluntary exit.

func (*Erroring) SyncCommittee 

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

SyncCommittee fetches the sync committee for the given state.

func (*Erroring) SyncCommitteeContribution 

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

SyncCommitteeContribution provides a sync committee contribution.

func (*Erroring) SyncCommitteeDuties 

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

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

func (*Erroring) SyncCommitteeRewards 

func (s *Erroring) 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 (*Erroring) TargetAggregatorsPerCommittee deprecated 

func (s *Erroring) TargetAggregatorsPerCommittee(ctx context.Context) (uint64, error)

TargetAggregatorsPerCommittee provides the target number of aggregators for each attestation committee.

Deprecated: use Spec().

func (*Erroring) ValidatorBalances 

func (s *Erroring) 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 (*Erroring) ValidatorLiveness 

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

ValidatorLiveness provides the liveness data to the given validators.

func (*Erroring) Validators 

func (s *Erroring) 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 (*Erroring) VoluntaryExitPool 

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

VoluntaryExitPool fetches the voluntary exit pool.

type Sleepy 

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

Sleepy is an Ethereum 2 client that sleeps for a random amount of time within a set of bounds before continuing.

func (*Sleepy) Address 

func (s *Sleepy) Address() string

Address returns the address of the client.

func (*Sleepy) AggregateAttestation 

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

AggregateAttestation fetches the aggregate attestation for the given options.

func (*Sleepy) AttestationData 

func (s *Sleepy) 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 (*Sleepy) AttestationPool 

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

AttestationPool fetches the attestation pool for the given slot.

func (*Sleepy) AttestationRewards 

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

AttestationRewards provides rewards to the given validators for attesting.

func (*Sleepy) AttesterDuties 

func (s *Sleepy) 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 (*Sleepy) BeaconBlockHeader 

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

BeaconBlockHeader provides the block header of a given block ID.

func (*Sleepy) BeaconCommitteeSelections added in v0.1.0 

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

BeaconCommitteeSelections submits beacon committee selections.

func (*Sleepy) BeaconState 

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

BeaconState fetches a beacon state.

func (*Sleepy) BlobSidecars 

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

BlobSidecars fetches the blobs sidecars given options.

func (*Sleepy) Blobs 

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

Blobs fetches the blobs given a block ID.

func (*Sleepy) BlockRewards 

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

BlockRewards provides rewards for proposing a block.

func (*Sleepy) Domain 

func (s *Sleepy) 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 (*Sleepy) EpochFromStateID deprecated 

func (s *Sleepy) EpochFromStateID(ctx context.Context, stateID string) (phase0.Epoch, error)

EpochFromStateID converts a state ID to its epoch.

Deprecated: use chaintime.

func (*Sleepy) Events 

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

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

func (*Sleepy) FarFutureEpoch 

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

FarFutureEpoch provides the far future epoch of the chain.

func (*Sleepy) Finality 

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

Finality provides the finality given a state ID.

func (*Sleepy) Fork 

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

Fork fetches fork information for the given state.

func (*Sleepy) ForkChoice 

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

ForkChoice fetches the node's current fork choice context.

func (*Sleepy) ForkSchedule 

func (s *Sleepy) 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 (*Sleepy) Genesis 

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

Genesis fetches genesis information for the chain.

func (*Sleepy) GenesisDomain 

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

GenesisDomain provides a domain for a given domain type at genesis.

func (*Sleepy) GenesisTime deprecated 

func (s *Sleepy) GenesisTime(ctx context.Context) (time.Time, error)

GenesisTime provides the genesis time of the chain.

Deprecated: use Genesis().

func (*Sleepy) IsActive 

func (*Sleepy) IsActive() bool

IsActive returns true if the client is active.

func (*Sleepy) IsSynced 

func (*Sleepy) IsSynced() bool

IsSynced returns true if the client is synced.

func (*Sleepy) Name 

func (s *Sleepy) Name() string

Name returns the name of the client implementation.

func (*Sleepy) NodePeers 

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

NodePeers provides the peers of the node.

func (*Sleepy) NodeSyncing 

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

NodeSyncing provides the state of the node's synchronization with the chain.

func (*Sleepy) NodeVersion 

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

NodeVersion returns a free-text string with the node version.

func (*Sleepy) PendingConsolidations 

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

PendingConsolidations provides the pending consolidations for a given state.

func (*Sleepy) PendingDeposits 

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

PendingDeposits provides the pending deposits for a given state.

func (*Sleepy) PendingPartialWithdrawals 

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

PendingPartialWithdrawals provides the pending partial withdrawals for a given state.

func (*Sleepy) Proposal 

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

Proposal fetches a proposal for signing.

func (*Sleepy) ProposerDuties 

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

ProposerDuties obtains proposer duties for the given epoch.

func (*Sleepy) SlotDuration deprecated 

func (s *Sleepy) SlotDuration(ctx context.Context) (time.Duration, error)

SlotDuration provides the duration of a slot of the chain.

Deprecated: use Spec().

func (*Sleepy) SlotFromStateID deprecated 

func (s *Sleepy) SlotFromStateID(ctx context.Context, stateID string) (phase0.Slot, error)

SlotFromStateID converts a state ID to its slot.

Deprecated: use chaintime.

func (*Sleepy) SlotsPerEpoch deprecated 

func (s *Sleepy) SlotsPerEpoch(ctx context.Context) (uint64, error)

SlotsPerEpoch provides the slots per epoch of the chain.

Deprecated: use Spec().

func (*Sleepy) Spec 

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

Spec provides the spec information of the chain.

func (*Sleepy) SubmitAggregateAttestations 

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

SubmitAggregateAttestations submits aggregate attestations.

func (*Sleepy) SubmitAttestations 

func (s *Sleepy) SubmitAttestations(ctx context.Context, attestations *api.SubmitAttestationsOpts) error

SubmitAttestations submits attestations.

func (*Sleepy) SubmitBeaconBlock deprecated 

func (s *Sleepy) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) error

SubmitBeaconBlock submits a beacon block.

Deprecated: this will not work from the deneb hard-fork onwards. Use SubmitProposal() instead.

func (*Sleepy) SubmitBeaconCommitteeSubscriptions 

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

SubmitBeaconCommitteeSubscriptions subscribes to beacon committees.

func (*Sleepy) SubmitBlindedBeaconBlock deprecated 

func (s *Sleepy) SubmitBlindedBeaconBlock(ctx context.Context, block *api.VersionedSignedBlindedBeaconBlock) error

SubmitBlindedBeaconBlock submits a beacon block.

Deprecated: this will not work from the deneb hard-fork onwards. Use SubmitBlindedProposal() instead.

func (*Sleepy) SubmitProposalPreparations 

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

SubmitProposalPreparations submits proposal preparations.

func (*Sleepy) SubmitValidatorRegistrations 

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

SubmitValidatorRegistrations submits a validator registration.

func (*Sleepy) SubmitVoluntaryExit 

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

SubmitVoluntaryExit submits a voluntary exit.

func (*Sleepy) SyncCommitteeRewards 

func (s *Sleepy) 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 (*Sleepy) TargetAggregatorsPerCommittee deprecated 

func (s *Sleepy) TargetAggregatorsPerCommittee(ctx context.Context) (uint64, error)

TargetAggregatorsPerCommittee provides the target number of aggregators for each attestation committee.

Deprecated: use Spec().

func (*Sleepy) ValidatorBalances 

func (s *Sleepy) 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 (*Sleepy) ValidatorLiveness 

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

ValidatorLiveness provides the liveness data to the given validators.

func (*Sleepy) Validators 

func (s *Sleepy) 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 (*Sleepy) VoluntaryExitPool 

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

VoluntaryExitPool fetches the voluntary exit pool.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.