Documentation ¶
Index ¶
- func NewErroring(_ context.Context, errorRate float64, next consensusclient.Service) (consensusclient.Service, error)
- func NewSleepy(_ context.Context, minSleep time.Duration, maxSleep time.Duration, ...) (consensusclient.Service, error)
- type Erroring
- func (s *Erroring) Address() string
- func (s *Erroring) AggregateAttestation(ctx context.Context, opts *api.AggregateAttestationOpts) (*api.Response[*phase0.Attestation], error)
- func (s *Erroring) AttestationData(ctx context.Context, opts *api.AttestationDataOpts) (*api.Response[*phase0.AttestationData], error)
- func (s *Erroring) AttestationPool(ctx context.Context, opts *api.AttestationPoolOpts) (*api.Response[[]*phase0.Attestation], error)
- func (s *Erroring) AttesterDuties(ctx context.Context, opts *api.AttesterDutiesOpts) (*api.Response[[]*apiv1.AttesterDuty], error)
- func (s *Erroring) BeaconBlockHeader(ctx context.Context, opts *api.BeaconBlockHeaderOpts) (*api.Response[*apiv1.BeaconBlockHeader], error)
- func (s *Erroring) BeaconBlockRoot(ctx context.Context, opts *api.BeaconBlockRootOpts) (*api.Response[*phase0.Root], error)
- func (s *Erroring) BeaconCommittees(ctx context.Context, opts *api.BeaconCommitteesOpts) (*api.Response[[]*apiv1.BeaconCommittee], error)
- func (s *Erroring) BeaconState(ctx context.Context, opts *api.BeaconStateOpts) (*api.Response[*spec.VersionedBeaconState], error)
- func (s *Erroring) BeaconStateRoot(ctx context.Context, opts *api.BeaconStateRootOpts) (*api.Response[*phase0.Root], error)
- func (s *Erroring) BlobSidecars(ctx context.Context, opts *api.BlobSidecarsOpts) (*api.Response[[]*deneb.BlobSidecar], error)
- func (s *Erroring) DepositContract(ctx context.Context, opts *api.DepositContractOpts) (*api.Response[*apiv1.DepositContract], error)
- func (s *Erroring) Domain(ctx context.Context, domainType phase0.DomainType, epoch phase0.Epoch) (phase0.Domain, error)
- func (s *Erroring) EpochFromStateID(ctx context.Context, stateID string) (phase0.Epoch, error)
- func (s *Erroring) Events(ctx context.Context, topics []string, handler consensusclient.EventHandlerFunc) error
- func (s *Erroring) FarFutureEpoch(ctx context.Context) (phase0.Epoch, error)
- func (s *Erroring) Finality(ctx context.Context, opts *api.FinalityOpts) (*api.Response[*apiv1.Finality], error)
- func (s *Erroring) Fork(ctx context.Context, opts *api.ForkOpts) (*api.Response[*phase0.Fork], error)
- func (s *Erroring) ForkChoice(ctx context.Context, opts *api.ForkChoiceOpts) (*api.Response[*apiv1.ForkChoice], error)
- func (s *Erroring) ForkSchedule(ctx context.Context, opts *api.ForkScheduleOpts) (*api.Response[[]*phase0.Fork], error)
- func (s *Erroring) Genesis(ctx context.Context, opts *api.GenesisOpts) (*api.Response[*apiv1.Genesis], error)
- func (s *Erroring) GenesisDomain(ctx context.Context, domainType phase0.DomainType) (phase0.Domain, error)
- func (s *Erroring) GenesisTime(ctx context.Context) (time.Time, error)deprecated
- func (s *Erroring) Name() string
- func (s *Erroring) NodePeers(ctx context.Context, opts *api.NodePeersOpts) (*api.Response[[]*apiv1.Peer], error)
- func (s *Erroring) NodeSyncing(ctx context.Context, opts *api.NodeSyncingOpts) (*api.Response[*apiv1.SyncState], error)
- func (s *Erroring) NodeVersion(ctx context.Context, opts *api.NodeVersionOpts) (*api.Response[string], error)
- func (s *Erroring) Proposal(ctx context.Context, opts *api.ProposalOpts) (*api.Response[*api.VersionedProposal], error)
- func (s *Erroring) ProposerDuties(ctx context.Context, opts *api.ProposerDutiesOpts) (*api.Response[[]*apiv1.ProposerDuty], error)
- func (s *Erroring) SignedBeaconBlock(ctx context.Context, opts *api.SignedBeaconBlockOpts) (*api.Response[*spec.VersionedSignedBeaconBlock], error)
- func (s *Erroring) SlotDuration(ctx context.Context) (time.Duration, error)deprecated
- func (s *Erroring) SlotFromStateID(ctx context.Context, stateID string) (phase0.Slot, error)
- func (s *Erroring) SlotsPerEpoch(ctx context.Context) (uint64, error)deprecated
- func (s *Erroring) Spec(ctx context.Context, opts *api.SpecOpts) (*api.Response[map[string]interface{}], error)
- func (s *Erroring) SubmitAggregateAttestations(ctx context.Context, aggregateAndProofs []*phase0.SignedAggregateAndProof) error
- func (s *Erroring) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) error
- func (s *Erroring) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) errordeprecated
- func (s *Erroring) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.BeaconCommitteeSubscription) error
- func (s *Erroring) SubmitBlindedBeaconBlock(ctx context.Context, block *api.VersionedSignedBlindedBeaconBlock) errordeprecated
- func (s *Erroring) SubmitProposalPreparations(ctx context.Context, preparations []*apiv1.ProposalPreparation) error
- func (s *Erroring) SubmitSyncCommitteeContributions(ctx context.Context, ...) error
- func (s *Erroring) SubmitSyncCommitteeMessages(ctx context.Context, messages []*altair.SyncCommitteeMessage) error
- func (s *Erroring) SubmitSyncCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.SyncCommitteeSubscription) error
- func (s *Erroring) SubmitValidatorRegistrations(ctx context.Context, registrations []*api.VersionedSignedValidatorRegistration) error
- func (s *Erroring) SubmitVoluntaryExit(ctx context.Context, voluntaryExit *phase0.SignedVoluntaryExit) error
- func (s *Erroring) SyncCommittee(ctx context.Context, opts *api.SyncCommitteeOpts) (*api.Response[*apiv1.SyncCommittee], error)
- func (s *Erroring) SyncCommitteeContribution(ctx context.Context, opts *api.SyncCommitteeContributionOpts) (*api.Response[*altair.SyncCommitteeContribution], error)
- func (s *Erroring) SyncCommitteeDuties(ctx context.Context, opts *api.SyncCommitteeDutiesOpts) (*api.Response[[]*apiv1.SyncCommitteeDuty], error)
- func (s *Erroring) TargetAggregatorsPerCommittee(ctx context.Context) (uint64, error)deprecated
- func (s *Erroring) ValidatorBalances(ctx context.Context, opts *api.ValidatorBalancesOpts) (*api.Response[map[phase0.ValidatorIndex]phase0.Gwei], error)
- func (s *Erroring) Validators(ctx context.Context, opts *api.ValidatorsOpts) (*api.Response[map[phase0.ValidatorIndex]*apiv1.Validator], error)
- func (s *Erroring) VoluntaryExitPool(ctx context.Context, opts *api.VoluntaryExitPoolOpts) (*api.Response[[]*phase0.SignedVoluntaryExit], error)
- type Sleepy
- func (s *Sleepy) Address() string
- func (s *Sleepy) AggregateAttestation(ctx context.Context, opts *api.AggregateAttestationOpts) (*api.Response[*phase0.Attestation], error)
- func (s *Sleepy) AttestationData(ctx context.Context, opts *api.AttestationDataOpts) (*api.Response[*phase0.AttestationData], error)
- func (s *Sleepy) AttestationPool(ctx context.Context, opts *api.AttestationPoolOpts) (*api.Response[[]*phase0.Attestation], error)
- func (s *Sleepy) AttesterDuties(ctx context.Context, opts *api.AttesterDutiesOpts) (*api.Response[[]*apiv1.AttesterDuty], error)
- func (s *Sleepy) BeaconBlockHeader(ctx context.Context, opts *api.BeaconBlockHeaderOpts) (*api.Response[*apiv1.BeaconBlockHeader], error)
- func (s *Sleepy) BeaconState(ctx context.Context, opts *api.BeaconStateOpts) (*api.Response[*spec.VersionedBeaconState], error)
- func (s *Sleepy) BlobSidecars(ctx context.Context, opts *api.BlobSidecarsOpts) (*api.Response[[]*deneb.BlobSidecar], error)
- func (s *Sleepy) Domain(ctx context.Context, domainType phase0.DomainType, epoch phase0.Epoch) (phase0.Domain, error)
- func (s *Sleepy) EpochFromStateID(ctx context.Context, stateID string) (phase0.Epoch, error)
- func (s *Sleepy) Events(ctx context.Context, topics []string, handler consensusclient.EventHandlerFunc) error
- func (s *Sleepy) FarFutureEpoch(ctx context.Context) (phase0.Epoch, error)
- func (s *Sleepy) Finality(ctx context.Context, opts *api.FinalityOpts) (*api.Response[*apiv1.Finality], error)
- func (s *Sleepy) Fork(ctx context.Context, opts *api.ForkOpts) (*api.Response[*phase0.Fork], error)
- func (s *Sleepy) ForkChoice(ctx context.Context, opts *api.ForkChoiceOpts) (*api.Response[*apiv1.ForkChoice], error)
- func (s *Sleepy) ForkSchedule(ctx context.Context, opts *api.ForkScheduleOpts) (*api.Response[[]*phase0.Fork], error)
- func (s *Sleepy) Genesis(ctx context.Context, opts *api.GenesisOpts) (*api.Response[*apiv1.Genesis], error)
- func (s *Sleepy) GenesisDomain(ctx context.Context, domainType phase0.DomainType) (phase0.Domain, error)
- func (s *Sleepy) GenesisTime(ctx context.Context) (time.Time, error)deprecated
- func (s *Sleepy) Name() string
- func (s *Sleepy) NodePeers(ctx context.Context, opts *api.NodePeersOpts) (*api.Response[[]*apiv1.Peer], error)
- func (s *Sleepy) NodeSyncing(ctx context.Context, opts *api.NodeSyncingOpts) (*api.Response[*apiv1.SyncState], error)
- func (s *Sleepy) NodeVersion(ctx context.Context, opts *api.NodeVersionOpts) (*api.Response[string], error)
- func (s *Sleepy) Proposal(ctx context.Context, opts *api.ProposalOpts) (*api.Response[*api.VersionedProposal], error)
- func (s *Sleepy) ProposerDuties(ctx context.Context, opts *api.ProposerDutiesOpts) (*api.Response[[]*apiv1.ProposerDuty], error)
- func (s *Sleepy) SlotDuration(ctx context.Context) (time.Duration, error)deprecated
- func (s *Sleepy) SlotFromStateID(ctx context.Context, stateID string) (phase0.Slot, error)
- func (s *Sleepy) SlotsPerEpoch(ctx context.Context) (uint64, error)deprecated
- func (s *Sleepy) Spec(ctx context.Context, opts *api.SpecOpts) (*api.Response[map[string]interface{}], error)
- func (s *Sleepy) SubmitAggregateAttestations(ctx context.Context, aggregateAndProofs []*phase0.SignedAggregateAndProof) error
- func (s *Sleepy) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) error
- func (s *Sleepy) SubmitBeaconBlock(ctx context.Context, block *spec.VersionedSignedBeaconBlock) errordeprecated
- func (s *Sleepy) SubmitBeaconCommitteeSubscriptions(ctx context.Context, subscriptions []*apiv1.BeaconCommitteeSubscription) error
- func (s *Sleepy) SubmitBlindedBeaconBlock(ctx context.Context, block *api.VersionedSignedBlindedBeaconBlock) errordeprecated
- func (s *Sleepy) SubmitProposalPreparations(ctx context.Context, preparations []*apiv1.ProposalPreparation) error
- func (s *Sleepy) SubmitValidatorRegistrations(ctx context.Context, registrations []*api.VersionedSignedValidatorRegistration) error
- func (s *Sleepy) SubmitVoluntaryExit(ctx context.Context, voluntaryExit *phase0.SignedVoluntaryExit) error
- func (s *Sleepy) TargetAggregatorsPerCommittee(ctx context.Context) (uint64, error)deprecated
- func (s *Sleepy) ValidatorBalances(ctx context.Context, opts *api.ValidatorBalancesOpts) (*api.Response[map[phase0.ValidatorIndex]phase0.Gwei], error)
- func (s *Sleepy) Validators(ctx context.Context, opts *api.ValidatorsOpts) (*api.Response[map[phase0.ValidatorIndex]*apiv1.Validator], error)
- func (s *Sleepy) VoluntaryExitPool(ctx context.Context, opts *api.VoluntaryExitPoolOpts) (*api.Response[[]*phase0.SignedVoluntaryExit], error)
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) 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 ¶
func (s *Erroring) BeaconState(ctx context.Context, opts *api.BeaconStateOpts) (*api.Response[*spec.VersionedBeaconState], error)
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 ¶
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 ¶
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) 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
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) SlotFromStateID ¶
SlotFromStateID converts a state ID to its slot.
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 (*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 (*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
func (s *Erroring) SyncCommitteeContribution(ctx context.Context, opts *api.SyncCommitteeContributionOpts) (*api.Response[*altair.SyncCommitteeContribution], error)
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) 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) 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 ¶ 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 ¶
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 ¶
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) 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) SlotFromStateID ¶
SlotFromStateID converts a state ID to its slot.
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 ¶
SubmitAttestations submits attestations.
func (*Sleepy) SubmitBeaconBlock
deprecated
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 (*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) 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.