testclients

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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[*phase0.Attestation],
	error,
)

AggregateAttestation fetches the aggregate attestation given an attestation.

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[[]*phase0.Attestation],
	error,
)

AttestationPool fetches the attestation pool for the given slot.

func (*Erroring) AttesterDuties 

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

AttesterDuties obtains attester duties. If validatorIndicess 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) 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) 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, topics []string, handler consensusclient.EventHandlerFunc) 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) 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) 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]interface{}], error)

Spec provides the spec information of the chain.

func (*Erroring) SubmitAggregateAttestations 

func (s *Erroring) SubmitAggregateAttestations(ctx context.Context, aggregateAndProofs []*phase0.SignedAggregateAndProof) error

SubmitAggregateAttestations submits aggregate attestations.

func (*Erroring) SubmitAttestations 

func (s *Erroring) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) 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 validatorIndicess is nil it will return all duties for the given epoch.

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) 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[*phase0.Attestation],
	error,
)

AggregateAttestation fetches the aggregate attestation given an attestation.

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[[]*phase0.Attestation],
	error,
)

AttestationPool fetches the attestation pool for the given slot.

func (*Sleepy) AttesterDuties 

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

AttesterDuties obtains attester duties. If validatorIndicess 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) 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) 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, topics []string, handler consensusclient.EventHandlerFunc) 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) 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) 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]interface{}], error)

Spec provides the spec information of the chain.

func (*Sleepy) SubmitAggregateAttestations 

func (s *Sleepy) SubmitAggregateAttestations(ctx context.Context, aggregateAndProofs []*phase0.SignedAggregateAndProof) error

SubmitAggregateAttestations submits aggregate attestations.

func (*Sleepy) SubmitAttestations 

func (s *Sleepy) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) 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) 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) 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.