http

Dec 11, 2024

Changes in this version

type Parameter

+ func WithHTTPClient(client *http.Client) Parameter

May 12, 2024

Changes in this version

type Parameter

+ func WithCustomSpecSupport(customSpecSupport bool) Parameter

Apr 22, 2024

Changes in this version

+ var ErrIncorrectType = errors.New("incorrect response type")

Mar 26, 2024

Changes in this version

type Parameter

+ func WithReducedMemoryUsage(reducedMemoryUsage bool) Parameter

Mar 15, 2024

Changes in this version

+ type HookFunc func(ctx context.Context, s *Service)

+ type Hooks struct

+ OnActive HookFunc

+ OnDesynced HookFunc

+ OnInactive HookFunc

+ OnSynced HookFunc

type Parameter

+ func WithAllowDelayedStart(allowDelayedStart bool) Parameter

+ func WithHooks(hooks *Hooks) Parameter

type Service

+ func (s *Service) CheckConnectionState(ctx context.Context)

+ func (s *Service) IsActive() bool

+ func (s *Service) IsSynced() bool

Dec 7, 2023

Changes in this version

type Parameter

+ func WithMonitor(monitor metrics.Service) Parameter

Oct 25, 2023

Changes in this version

type Parameter

+ func WithEnforceJSON(enforceJSON bool) Parameter

type Service

+ func (s *Service) BlindedProposal(ctx context.Context, opts *api.BlindedProposalOpts) (*api.Response[*api.VersionedBlindedProposal], error)

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

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

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

+ func (s *Service) SubmitAttesterSlashing(ctx context.Context, slashing *phase0.AttesterSlashing) error

+ func (s *Service) SubmitBlindedProposal(ctx context.Context, proposal *api.VersionedSignedBlindedProposal) error

+ func (s *Service) SubmitProposal(ctx context.Context, proposal *api.VersionedSignedProposal) error

+ func (s *Service) SubmitProposalSlashing(ctx context.Context, slashing phase0.ProposerSlashing) error

Aug 22, 2023

Changes in this version

type Service

+ func (s *Service) VoluntaryExitPool(ctx context.Context) ([]*phase0.SignedVoluntaryExit, error)

Aug 1, 2023

Changes in this version

type Service

+ func (s *Service) ForkChoice(ctx context.Context) (*api.ForkChoice, error)

Jul 9, 2023

Changes in this version

+ type ContentType int

+ const ContentTypeJSON

+ const ContentTypeSSZ

+ const ContentTypeUnknown

+ func ParseFromMediaType(input string) (ContentType, error)

+ func (c *ContentType) MarshalJSON() ([]byte, error)

+ func (c *ContentType) UnmarshalJSON(input []byte) error

+ func (c ContentType) MediaType() string

+ func (c ContentType) String() string

Jun 12, 2023

Changes in this version

type Service

+ func (s *Service) BeaconBlockBlobs(ctx context.Context, blockID string) ([]*deneb.BlobSidecar, error)

Feb 18, 2023

Changes in this version

type Service

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

Feb 16, 2023

Changes in this version

type Parameter

+ func WithExtraHeaders(headers map[string]string) Parameter

Dec 16, 2022

Changes in this version

type Service

+ func (s *Service) SubmitBLSToExecutionChanges(ctx context.Context, ...) error

Oct 22, 2022

Changes in this version

+ type Error struct

+ Data []byte

+ Endpoint string

+ Method string

+ StatusCode int

+ func (e Error) Error() string

type Service

+ func (s *Service) BeaconStateRandao(ctx context.Context, stateID string) (*phase0.Root, error)

Oct 2, 2022

Changes in this version

type Service

+ func (s *Service) SubmitBLSToExecutionChange(ctx context.Context, blsToExecutionChange *capella.SignedBLSToExecutionChange) error

Jul 30, 2022

Changes in this version

type Service

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

Jul 11, 2022

Changes in this version

type Service

+ func (s *Service) NodeClient(ctx context.Context) (string, error)

Mar 8, 2022

Changes in this version

type Service

+ func (s *Service) BlindedBeaconBlockProposal(ctx context.Context, slot phase0.Slot, randaoReveal phase0.BLSSignature, ...) (*api.VersionedBlindedBeaconBlock, error)

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

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

Jan 1, 2022

Changes in this version

type Service

+ func (s *Service) BeaconStateRoot(ctx context.Context, stateID string) (*spec.Root, error)

Nov 3, 2021

Changes in this version

type Parameter

+ func WithIndexChunkSize(indexChunkSize int) Parameter

+ func WithPubKeyChunkSize(pubKeyChunkSize int) Parameter

type Service

+ func (s *Service) BeaconCommitteesAtEpoch(ctx context.Context, stateID string, epoch phase0.Epoch) ([]*api.BeaconCommittee, error)

+ func (s *Service) SyncCommitteeAtEpoch(ctx context.Context, stateID string, epoch phase0.Epoch) (*api.SyncCommittee, error)

Aug 4, 2021

Changes in this version

+ type Parameter interface

+ func WithAddress(address string) Parameter

+ func WithLogLevel(logLevel zerolog.Level) Parameter

+ func WithTimeout(timeout time.Duration) Parameter

+ type Service struct

+ func New(ctx context.Context, params ...Parameter) (*Service, error)

+ func (s *Service) Address() string

+ func (s *Service) AggregateAttestation(ctx context.Context, slot phase0.Slot, attestationDataRoot phase0.Root) (*phase0.Attestation, error)

+ func (s *Service) AttestationData(ctx context.Context, slot phase0.Slot, committeeIndex phase0.CommitteeIndex) (*phase0.AttestationData, error)

+ func (s *Service) AttestationPool(ctx context.Context, slot phase0.Slot) ([]*phase0.Attestation, error)

+ func (s *Service) AttesterDuties(ctx context.Context, epoch phase0.Epoch, ...) ([]*api.AttesterDuty, error)

+ func (s *Service) BeaconBlockHeader(ctx context.Context, blockID string) (*api.BeaconBlockHeader, error)

+ func (s *Service) BeaconBlockProposal(ctx context.Context, slot phase0.Slot, randaoReveal phase0.BLSSignature, ...) (*spec.VersionedBeaconBlock, error)

+ func (s *Service) BeaconBlockRoot(ctx context.Context, blockID string) (*phase0.Root, error)

+ func (s *Service) BeaconCommittees(ctx context.Context, stateID string) ([]*api.BeaconCommittee, error)

+ func (s *Service) BeaconState(ctx context.Context, stateID string) (*phase0.BeaconState, error)

+ func (s *Service) DepositContract(ctx context.Context) (*api.DepositContract, error)

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

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

+ func (s *Service) Events(ctx context.Context, topics []string, handler client.EventHandlerFunc) error

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

+ func (s *Service) Finality(ctx context.Context, stateID string) (*api.Finality, error)

+ func (s *Service) Fork(ctx context.Context, stateID string) (*phase0.Fork, error)

+ func (s *Service) ForkSchedule(ctx context.Context) ([]*phase0.Fork, error)

+ func (s *Service) Genesis(ctx context.Context) (*api.Genesis, error)

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

+ func (s *Service) Name() string

+ func (s *Service) NodeSyncing(ctx context.Context) (*api.SyncState, error)

+ func (s *Service) NodeVersion(ctx context.Context) (string, error)

+ func (s *Service) ProposerDuties(ctx context.Context, epoch phase0.Epoch, ...) ([]*api.ProposerDuty, error)

+ func (s *Service) SignedBeaconBlock(ctx context.Context, blockID string) (*spec.VersionedSignedBeaconBlock, error)

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

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

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

+ func (s *Service) Spec(ctx context.Context) (map[string]interface{}, error)

+ func (s *Service) StateRoot(ctx context.Context, stateID string) ([]byte, error)

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

+ func (s *Service) SubmitAttestations(ctx context.Context, attestations []*phase0.Attestation) error

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

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

+ func (s *Service) SubmitSyncCommitteeContributions(ctx context.Context, ...) error

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

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

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

+ func (s *Service) SyncCommittee(ctx context.Context, stateID string) (*api.SyncCommittee, error)

+ func (s *Service) SyncCommitteeContribution(ctx context.Context, slot phase0.Slot, subcommitteeIndex uint64, ...) (*altair.SyncCommitteeContribution, error)

+ func (s *Service) SyncCommitteeDuties(ctx context.Context, epoch phase0.Epoch, ...) ([]*api.SyncCommitteeDuty, error)

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

+ func (s *Service) ValidatorBalances(ctx context.Context, stateID string, validatorIndices []phase0.ValidatorIndex) (map[phase0.ValidatorIndex]phase0.Gwei, error)

+ func (s *Service) Validators(ctx context.Context, stateID string, validatorIndices []phase0.ValidatorIndex) (map[phase0.ValidatorIndex]*api.Validator, error)

+ func (s *Service) ValidatorsByPubKey(ctx context.Context, stateID string, validatorPubKeys []phase0.BLSPubKey) (map[phase0.ValidatorIndex]*api.Validator, error)