consensus

package

Go to main page

Versions in this module

v1

v1.13.1

Dec 17, 2024

v1.13.0

Dec 6, 2024

v1.12.1

Nov 25, 2024

Changes in this version

type ChainSpec

+ CustodyRequirement *uint64

+ DataColumnSidecarSubnetCount *uint64

+ DepositChainId uint64

+ MaxConsolidationRequestsPerPayload uint64

+ MaxWithdrawalRequestsPerPayload uint64

+ MinActivationBalance uint64

+ NumberOfColumns *uint64

v1.12.0

Sep 18, 2024

v1.11.3

Sep 11, 2024

v1.11.2

Sep 9, 2024

Changes in this version

type Client

+ func (client *Client) GetNodeIdentity() *rpc.NodeIdentity

v1.11.1

Aug 26, 2024

Changes in this version

type ClientConfig

+ DisableSSZ bool

v1.11.0

Aug 19, 2024

Changes in this version

+ var NullRoot phase0.Root = phase0.Root

+ type ChainSpec struct

+ AltairForkEpoch *uint64

+ AltairForkVersion phase0.Version

+ BellatrixForkEpoch *uint64

+ BellatrixForkVersion phase0.Version

+ CapellaForkEpoch *uint64

+ CapellaForkVersion phase0.Version

+ ChurnLimitQuotient uint64

+ ConfigName string

+ DenebForkEpoch *uint64

+ DenebForkVersion phase0.Version

+ DepositContractAddress []byte

+ DomainBeaconAttester phase0.DomainType

+ DomainBeaconProposer phase0.DomainType

+ DomainSyncCommittee phase0.DomainType

+ Eip7594ForkEpoch *uint64

+ Eip7594ForkVersion phase0.Version

+ ElectraForkEpoch *uint64

+ ElectraForkVersion phase0.Version

+ EpochsPerHistoricalVector uint64

+ EpochsPerSlashingVector uint64

+ EpochsPerSyncCommitteePeriod uint64

+ GenesisForkVersion phase0.Version

+ MaxCommitteesPerSlot uint64

+ MaxEffectiveBalance uint64

+ MaxEffectiveBalanceElectra uint64

+ MinGenesisTime time.Time

+ MinPerEpochChurnLimit uint64

+ MinSeedLookahead uint64

+ PresetBase string

+ SecondsPerSlot time.Duration

+ ShuffleRoundCount uint64

+ SlotsPerEpoch uint64

+ SyncCommitteeSize uint64

+ TargetCommitteeSize uint64

+ WhiskForkEpoch *uint64

+ func (chain *ChainSpec) CheckMismatch(chain2 *ChainSpec) []string

+ func (chain *ChainSpec) Clone() *ChainSpec

+ type ChainState struct

+ func (cs *ChainState) CurrentEpoch() phase0.Epoch

+ func (cs *ChainState) CurrentSlot() phase0.Slot

+ func (cs *ChainState) EpochOfSlot(slot phase0.Slot) phase0.Epoch

+ func (cs *ChainState) EpochStartSlot(epoch phase0.Epoch) phase0.Slot

+ func (cs *ChainState) EpochToSlot(epoch phase0.Epoch) phase0.Slot

+ func (cs *ChainState) EpochToTime(epoch phase0.Epoch) time.Time

+ func (cs *ChainState) GetFinalizedCheckpoint() (phase0.Epoch, phase0.Root)

+ func (cs *ChainState) GetFinalizedSlot() phase0.Slot

+ func (cs *ChainState) GetGenesis() *v1.Genesis

+ func (cs *ChainState) GetJustifiedCheckpoint() (phase0.Epoch, phase0.Root)

+ func (cs *ChainState) GetSpecs() *ChainSpec

+ func (cs *ChainState) GetValidatorChurnLimit(validatorCount uint64) uint64

+ func (cs *ChainState) SlotToSlotIndex(slot phase0.Slot) phase0.Slot

+ func (cs *ChainState) SlotToTime(slot phase0.Slot) time.Time

+ func (cs *ChainState) TimeToSlot(timestamp time.Time) phase0.Slot

+ type Client struct

+ func (client *Client) GetClientType() ClientType

+ func (client *Client) GetContext() context.Context

+ func (client *Client) GetEndpointConfig() *ClientConfig

+ func (client *Client) GetFinalityCheckpoint() (finalitedEpoch phase0.Epoch, finalizedRoot phase0.Root, ...)

+ func (client *Client) GetIndex() uint16

+ func (client *Client) GetLastClientError() error

+ func (client *Client) GetLastError() error

+ func (client *Client) GetLastEventTime() time.Time

+ func (client *Client) GetLastHead() (phase0.Slot, phase0.Root)

+ func (client *Client) GetName() string

+ func (client *Client) GetNodePeers() []*v1.Peer

+ func (client *Client) GetPeerID() string

+ func (client *Client) GetPool() *Pool

+ func (client *Client) GetRPCClient() *rpc.BeaconClient

+ func (client *Client) GetStatus() ClientStatus

+ func (client *Client) GetVersion() string

+ func (client *Client) SubscribeBlockEvent(capacity int, blocking bool) *Subscription[*v1.BlockEvent]

+ func (client *Client) SubscribeFinalizedEvent(capacity int) *Subscription[*v1.Finality]

+ func (client *Client) SubscribeHeadEvent(capacity int, blocking bool) *Subscription[*v1.HeadEvent]

+ type ClientConfig struct

+ Headers map[string]string

+ Name string

+ SshConfig *sshtunnel.SshConfig

+ URL string

+ type ClientStatus uint8

+ var ClientStatusOffline ClientStatus = 2

+ var ClientStatusOnline ClientStatus = 1

+ var ClientStatusOptimistic ClientStatus = 4

+ var ClientStatusSynchronizing ClientStatus = 3

+ func (s ClientStatus) String() string

+ type ClientType int8

+ var AnyClient ClientType

+ var CaplinClient ClientType = 7

+ var GrandineClient ClientType = 6

+ var LighthouseClient ClientType = 1

+ var LodestarClient ClientType = 2

+ var NimbusClient ClientType = 3

+ var PrysmClient ClientType = 4

+ var TekuClient ClientType = 5

+ var UnknownClient ClientType = -1

+ func ParseClientType(name string) ClientType

+ func (clientType ClientType) String() string

+ type Dispatcher struct

+ func (d *Dispatcher[T]) Fire(data T)

+ func (d *Dispatcher[T]) Subscribe(capacity int, blocking bool) *Subscription[T]

+ func (d *Dispatcher[T]) Unsubscribe(subscription *Subscription[T])

+ type ForkVersion struct

+ CurrentVersion []byte

+ Epoch uint64

+ PreviousVersion []byte

+ type Pool struct

+ func NewPool(ctx context.Context, logger logrus.FieldLogger) *Pool

+ func (pool *Pool) AddEndpoint(endpoint *ClientConfig) (*Client, error)

+ func (pool *Pool) AwaitReadyEndpoint(ctx context.Context, clientType ClientType) *Client

+ func (pool *Pool) GetAllEndpoints() []*Client

+ func (pool *Pool) GetChainState() *ChainState

+ func (pool *Pool) GetReadyEndpoint(clientType ClientType) *Client

+ func (pool *Pool) SubscribeFinalizedEvent(capacity int) *Subscription[*v1.Finality]

+ func (pool *Pool) SubscribeWallclockEpochEvent(capacity int) *Subscription[*ethwallclock.Epoch]

+ func (pool *Pool) SubscribeWallclockSlotEvent(capacity int) *Subscription[*ethwallclock.Slot]

+ type Subscription struct

+ func (s *Subscription[T]) Channel() <-chan T

+ func (s *Subscription[T]) Unsubscribe()

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