execution

Dec 11, 2024

Changes in this version

type Block

+ func (block *Block) AwaitSeenBy(ctx context.Context, client *Client) bool

Mar 9, 2024

Changes in this version

type ClientType

+ var AnyClient ClientType

type Pool

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

Jan 31, 2024

Changes in this version

+ type Block struct

+ Hash common.Hash

+ Number uint64

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

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

+ func (block *Block) GetBlock() *types.Block

+ func (block *Block) GetParentHash() *common.Hash

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

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

+ type BlockCache struct

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

+ func (cache *BlockCache) AddBlock(hash common.Hash, number uint64) (*Block, bool)

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

+ func (cache *BlockCache) GetCachedBlockByRoot(hash common.Hash) *Block

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

+ func (cache *BlockCache) GetChainID() *big.Int

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

+ func (cache *BlockCache) IsCanonicalBlock(blockRoot, headRoot common.Hash) bool

+ func (cache *BlockCache) SetClientSpecs(specs *rpc.ChainSpec) error

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

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

+ func (cache *BlockCache) UnsubscribeBlockEvent(subscription *Subscription[*Block])

+ 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() (uint64, common.Hash)

+ func (client *Client) GetName() string

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

+ func (client *Client) GetStatus() ClientStatus

+ func (client *Client) GetVersion() string

+ func (client *Client) NotifyNewBlock(hash common.Hash, number uint64)

+ type ClientConfig struct

+ Headers map[string]string

+ Name string

+ URL string

+ type ClientStatus uint8

+ var ClientStatusOffline ClientStatus = 2

+ var ClientStatusOnline ClientStatus = 1

+ var ClientStatusSynchronizing ClientStatus = 3

+ type ClientType int8

+ var BesuClient ClientType = 1

+ var ErigonClient ClientType = 2

+ var EthjsClient ClientType = 3

+ var GethClient ClientType = 4

+ var NethermindClient ClientType = 5

+ var RethClient ClientType = 6

+ 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 HeadFork struct

+ AllClients []*Client

+ Hash common.Hash

+ Number uint64

+ ReadyClients []*Client

+ 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) GetReadyEndpoints() []*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()