consensus

package

Go to main page

Versions in this module

v0

v0.0.12

Dec 11, 2024

Changes in this version

type ChainSpec

+ MaxCommitteesPerSlot uint64

v0.0.11

Sep 12, 2024

Changes in this version

type BlockCache

+ func (cache *BlockCache) GetSpecValues() map[string]interface{}

v0.0.10

Aug 15, 2024

Changes in this version

+ func GetBlockBody(v *spec.VersionedSignedBeaconBlock) any

type ClientType

+ var CaplinClient ClientType = 7

v0.0.9

May 7, 2024

Changes in this version

+ func GetExecutionExtraData(v *spec.VersionedSignedBeaconBlock) ([]byte, error)

v0.0.8

Mar 11, 2024

v0.0.6

Mar 9, 2024

Changes in this version

type ClientType

+ var AnyClient ClientType

type Pool

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

v0.0.5

Feb 29, 2024

Changes in this version

type Pool

+ func (pool *Pool) GetValidatorSet() map[phase0.ValidatorIndex]*v1.Validator

v0.0.4

Feb 22, 2024

v0.0.3

Feb 14, 2024

v0.0.2

Feb 5, 2024

v0.0.1

Jan 31, 2024

Changes in this version

+ type Block struct

+ Root phase0.Root

+ Slot phase0.Slot

+ func (block *Block) AwaitBlock(ctx context.Context, timeout time.Duration) *spec.VersionedSignedBeaconBlock

+ func (block *Block) AwaitHeader(ctx context.Context, timeout time.Duration) *phase0.SignedBeaconBlockHeader

+ func (block *Block) EnsureBlock(loadBlock func() (*spec.VersionedSignedBeaconBlock, error)) (bool, error)

+ func (block *Block) EnsureHeader(loadHeader func() (*phase0.SignedBeaconBlockHeader, error)) error

+ func (block *Block) GetBlock() *spec.VersionedSignedBeaconBlock

+ func (block *Block) GetHeader() *phase0.SignedBeaconBlockHeader

+ func (block *Block) GetParentRoot() *phase0.Root

+ func (block *Block) GetSeenBy() []*Client

+ func (block *Block) SetHeader(header *phase0.SignedBeaconBlockHeader)

+ func (block *Block) SetSeenBy(client *Client)

+ type BlockCache struct

+ func NewBlockCache(logger logrus.FieldLogger, followDistance uint64) (*BlockCache, error)

+ func (cache *BlockCache) AddBlock(root phase0.Root, slot phase0.Slot) (*Block, bool)

+ func (cache *BlockCache) GetBlockDistance(blockRoot, headRoot phase0.Root) (linked bool, distance uint64)

+ func (cache *BlockCache) GetCachedBlockByRoot(root phase0.Root) *Block

+ func (cache *BlockCache) GetCachedBlocks() []*Block

+ func (cache *BlockCache) GetCachedBlocksBySlot(slot phase0.Slot) []*Block

+ func (cache *BlockCache) GetFinalizedCheckpoint() (phase0.Epoch, phase0.Root)

+ func (cache *BlockCache) GetGenesis() *v1.Genesis

+ func (cache *BlockCache) GetSpecs() *ChainSpec

+ func (cache *BlockCache) GetWallclock() *ethwallclock.EthereumBeaconChain

+ func (cache *BlockCache) InitWallclock()

+ func (cache *BlockCache) IsCanonicalBlock(blockRoot, headRoot phase0.Root) bool

+ func (cache *BlockCache) SetClientSpecs(specValues map[string]interface{}) error

+ func (cache *BlockCache) SetFinalizedCheckpoint(finalizedEpoch phase0.Epoch, finalizedRoot phase0.Root)

+ func (cache *BlockCache) SetGenesis(genesis *v1.Genesis) error

+ func (cache *BlockCache) SetMinFollowDistance(followDistance uint64)

+ func (cache *BlockCache) SubscribeBlockEvent(capacity int) *Subscription[*Block]

+ func (cache *BlockCache) SubscribeFinalizedEvent(capacity int) *Subscription[*FinalizedCheckpoint]

+ func (cache *BlockCache) SubscribeWallclockEpochEvent(capacity int) *Subscription[*ethwallclock.Epoch]

+ func (cache *BlockCache) SubscribeWallclockSlotEvent(capacity int) *Subscription[*ethwallclock.Slot]

+ type ChainSpec struct

+ AltairForkEpoch uint64

+ AltairForkVersion phase0.Version

+ BellatrixForkEpoch uint64

+ BellatrixForkVersion phase0.Version

+ CappellaForkEpoch uint64

+ CappellaForkVersion phase0.Version

+ ConfigName string

+ GenesisForkVersion phase0.Version

+ MinGenesisTime time.Time

+ PresetBase string

+ SecondsPerSlot time.Duration

+ SlotsPerEpoch uint64

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

+ type Client struct

+ func (client *Client) GetClientType() ClientType

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

+ func (client *Client) GetIndex() uint16

+ 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) GetRPCClient() *rpc.BeaconClient

+ func (client *Client) GetStatus() ClientStatus

+ func (client *Client) GetVersion() string

+ func (client *Client) SubscribeBlockEvent(capacity int) *Subscription[*Block]

+ func (client *Client) SubscribeFinalizedEvent(capacity int) *Subscription[*FinalizedCheckpoint]

+ func (client *Client) UnsubscribeBlockEvent(subscription *Subscription[*Block])

+ func (client *Client) UnsubscribeFinalizedEvent(subscription *Subscription[*FinalizedCheckpoint])

+ type ClientConfig struct

+ Headers map[string]string

+ Name string

+ URL string

+ type ClientStatus uint8

+ var ClientStatusOffline ClientStatus = 2

+ var ClientStatusOnline ClientStatus = 1

+ var ClientStatusOptimistic ClientStatus = 4

+ var ClientStatusSynchronizing ClientStatus = 3

+ type ClientType int8

+ 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

+ var UnspecifiedClient ClientType

+ 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) *Subscription[T]

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

+ type FinalizedCheckpoint struct

+ Epoch phase0.Epoch

+ Root phase0.Root

+ type ForkVersion struct

+ CurrentVersion []byte

+ Epoch uint64

+ PreviousVersion []byte

+ type HeadFork struct

+ AllClients []*Client

+ ReadyClients []*Client

+ Root phase0.Root

+ Slot phase0.Slot

+ func (fork *HeadFork) IsClientReady(client *Client) bool

+ type Pool struct

+ func NewPool(config *PoolConfig, logger logrus.FieldLogger) (*Pool, error)

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

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

+ func (pool *Pool) GetBlockCache() *BlockCache

+ func (pool *Pool) GetCanonicalFork(forkDistance int64) *HeadFork

+ func (pool *Pool) GetHeadForks(forkDistance int64) []*HeadFork

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

+ func (pool *Pool) IsClientReady(client *Client) bool

+ type PoolConfig struct

+ FollowDistance uint64

+ ForkDistance uint64

+ SchedulerMode string

+ type SchedulerMode uint8

+ var RoundRobinScheduler SchedulerMode = 1

+ 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