testclients

package
v0.19.6 Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2023 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 added in v0.9.0

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 added in v0.9.0

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

BeaconState fetches a beacon state.

func (*Erroring) BeaconStateRoot added in v0.9.0

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 added in v0.19.0

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 added in v0.9.0

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

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

EpochFromStateID converts a state ID to its epoch.

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 added in v0.18.1

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 added in v0.15.5

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 added in v0.19.0

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 added in v0.19.0

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 added in v0.9.0

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

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

SlotFromStateID converts a state ID to its slot.

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 added in v0.11.6

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 added in v0.11.6

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

SubmitProposalPreparations submits proposal preparations.

func (*Erroring) SubmitSyncCommitteeContributions added in v0.9.2

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

SubmitSyncCommitteeContributions submits sync committee contributions.

func (*Erroring) SubmitSyncCommitteeMessages added in v0.9.0

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

SubmitSyncCommitteeMessages submits sync committee messages.

func (*Erroring) SubmitSyncCommitteeSubscriptions added in v0.9.0

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

SubmitSyncCommitteeSubscriptions subscribes to sync committees.

func (*Erroring) SubmitValidatorRegistrations added in v0.12.0

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 added in v0.9.2

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 added in v0.9.2

SyncCommitteeContribution provides a sync committee contribution.

func (*Erroring) SyncCommitteeDuties added in v0.9.0

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 added in v0.18.2

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

BeaconState fetches a beacon state.

func (*Sleepy) BlobSidecars added in v0.19.0

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

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

EpochFromStateID converts a state ID to its epoch.

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 added in v0.18.1

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 added in v0.15.5

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 added in v0.19.0

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 added in v0.19.0

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

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

SlotFromStateID converts a state ID to its slot.

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 added in v0.11.6

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 added in v0.11.6

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

SubmitProposalPreparations submits proposal preparations.

func (*Sleepy) SubmitValidatorRegistrations added in v0.12.0

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 added in v0.18.2

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

VoluntaryExitPool fetches the voluntary exit pool.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL