Versions in this module Expand all Collapse all v0 v0.1.1 Apr 22, 2026 v0.1.0 Apr 14, 2026 Changes in this version + const StreamBlockEvent + const StreamExecutionPayloadEvent + const StreamFinalizedEvent + const StreamHeadEvent + type BeaconClient struct + func NewBeaconClient(name, url string, headers map[string]string) (*BeaconClient, error) + func (bc *BeaconClient) GetAttestationData(ctx context.Context, slot, committeeIndex uint64) (*phase0.AttestationData, error) + func (bc *BeaconClient) GetBlockBodyByBlockroot(ctx context.Context, blockroot phase0.Root) (*spec.VersionedSignedBeaconBlock, error) + func (bc *BeaconClient) GetBlockHeaderByBlockroot(ctx context.Context, blockroot phase0.Root) (*v1.BeaconBlockHeader, error) + func (bc *BeaconClient) GetBlockHeaderBySlot(ctx context.Context, slot phase0.Slot) (*v1.BeaconBlockHeader, error) + func (bc *BeaconClient) GetCommitteeDuties(ctx context.Context, stateRef string, epoch uint64) ([]*v1.BeaconCommittee, error) + func (bc *BeaconClient) GetConfigSpecs(ctx context.Context) (map[string]interface{}, error) + func (bc *BeaconClient) GetExecutionPayloadByBlockroot(ctx context.Context, blockroot phase0.Root) (*gloas.SignedExecutionPayloadEnvelope, error) + func (bc *BeaconClient) GetFinalityCheckpoints(ctx context.Context) (*v1.Finality, error) + func (bc *BeaconClient) GetForkState(ctx context.Context, stateRef string) (*phase0.Fork, error) + func (bc *BeaconClient) GetGenesis(ctx context.Context) (*v1.Genesis, error) + func (bc *BeaconClient) GetLatestBlockHead(ctx context.Context) (*v1.BeaconBlockHeader, error) + func (bc *BeaconClient) GetNodeIdentity(ctx context.Context) (*NodeIdentity, error) + func (bc *BeaconClient) GetNodeSyncStatus(ctx context.Context) (*SyncStatus, error) + func (bc *BeaconClient) GetNodeSyncing(ctx context.Context) (*v1.SyncState, error) + func (bc *BeaconClient) GetNodeVersion(ctx context.Context) (string, error) + func (bc *BeaconClient) GetProposerDuties(ctx context.Context, epoch uint64) ([]*v1.ProposerDuty, error) + func (bc *BeaconClient) GetState(ctx context.Context, stateRef string) (*spec.VersionedBeaconState, error) + func (bc *BeaconClient) GetStateValidators(ctx context.Context, stateRef string) (map[phase0.ValidatorIndex]*v1.Validator, error) + func (bc *BeaconClient) Initialize(ctx context.Context) error + func (bc *BeaconClient) NewBlockStream(ctx context.Context, events uint16) *BeaconStream + func (bc *BeaconClient) SubmitAttestations(ctx context.Context, attestations []*SingleAttestation) error + func (bc *BeaconClient) SubmitAttesterSlashing(ctx context.Context, slashing *phase0.AttesterSlashing) error + func (bc *BeaconClient) SubmitBLSToExecutionChanges(ctx context.Context, blsChanges []*capella.SignedBLSToExecutionChange) error + func (bc *BeaconClient) SubmitProposerSlashing(ctx context.Context, slashing *phase0.ProposerSlashing) error + func (bc *BeaconClient) SubmitVoluntaryExits(ctx context.Context, exit *phase0.SignedVoluntaryExit) error + type BeaconStream struct + EventChan chan *BeaconStreamEvent + ReadyChan chan bool + func (bs *BeaconStream) Close() + type BeaconStreamEvent struct + Data interface{} + Event uint16 + type NodeIdentity struct + DiscoveryAddresses []string + ENR string + Metadata struct{ ... } + P2PAddresses []string + PeerID string + type SingleAttestation struct + AttesterIndex uint64 + CommitteeIndex uint64 + Data *phase0.AttestationData + Signature string + type SyncStatus struct + EstimatedHighestHeadSlot uint64 + HeadSlot uint64 + IsOptimistic bool + IsSyncing bool + SyncDistance uint64 + func NewSyncStatus(state *v1.SyncState) SyncStatus + func (s *SyncStatus) Percent() float64