syncnode

Jul 11, 2025

Changes in this version

type RPCSyncNode

+ func (rs *RPCSyncNode) L2BlockRefByNumber(ctx context.Context, number uint64) (eth.L2BlockRef, error)

type SyncControl

+ L2BlockRefByNumber func(ctx context.Context, number uint64) (eth.L2BlockRef, error)

type SyncSource

+ L2BlockRefByNumber func(ctx context.Context, number uint64) (eth.L2BlockRef, error)

Jun 17, 2025

Changes in this version

type RPCSyncNode

+ func (rs *RPCSyncNode) ResetPreInterop(ctx context.Context) error

type SyncControl

+ ResetPreInterop func(ctx context.Context) error

May 15, 2025

Changes in this version

type RPCSyncNode

+ func (rs *RPCSyncNode) Contains(ctx context.Context, query types.ContainsQuery) (types.BlockSeal, error)

+ func (rs *RPCSyncNode) ReconnectRPC(ctx context.Context) error

type SyncControl

+ ReconnectRPC func(ctx context.Context) error

type SyncSource

+ Contains func(ctx context.Context, query types.ContainsQuery) (includedIn types.BlockSeal, err error)

Mar 10, 2025

Changes in this version

type ManagedNode

+ func (m *ManagedNode) OnResetReady(lUnsafe, xUnsafe, lSafe, xSafe, finalized eth.BlockID)

type SyncControl

+ BlockRefByNumber func(ctx context.Context, number uint64) (eth.BlockRef, error)

Feb 10, 2025

Changes in this version

+ type CLISyncNodes struct

+ Endpoints []string

+ JWTSecretPaths []string

+ func (p *CLISyncNodes) Check() error

+ func (p *CLISyncNodes) Load(ctx context.Context, logger log.Logger) ([]SyncNodeSetup, error)

+ type ManagedNode struct

+ Node SyncControl

+ func NewManagedNode(log log.Logger, id eth.ChainID, node SyncControl, backend backend, ...) *ManagedNode

+ func (m *ManagedNode) AttachEmitter(em event.Emitter)

+ func (m *ManagedNode) Close() error

+ func (m *ManagedNode) OnEvent(ev event.Event) bool

+ func (m *ManagedNode) PullEvents(ctx context.Context) (pulledAny bool, err error)

+ func (m *ManagedNode) Start()

+ func (m *ManagedNode) SubscribeToNodeEvents()

+ func (m *ManagedNode) WatchSubscriptionErrors()

+ type Node interface

+ PullEvents func(ctx context.Context) (pulledAny bool, err error)

+ type RPCDialSetup struct

+ Endpoint string

+ JWTSecret eth.Bytes32

+ func (r *RPCDialSetup) Setup(ctx context.Context, logger log.Logger) (SyncNode, error)

+ type RPCSyncNode struct

+ func NewRPCSyncNode(name string, cl client.RPC) *RPCSyncNode

+ func (rs *RPCSyncNode) AnchorPoint(ctx context.Context) (types.DerivedBlockRefPair, error)

+ func (rs *RPCSyncNode) BlockRefByNumber(ctx context.Context, number uint64) (eth.BlockRef, error)

+ func (rs *RPCSyncNode) ChainID(ctx context.Context) (eth.ChainID, error)

+ func (rs *RPCSyncNode) FetchReceipts(ctx context.Context, blockHash common.Hash) (gethtypes.Receipts, error)

+ func (rs *RPCSyncNode) InvalidateBlock(ctx context.Context, seal types.BlockSeal) error

+ func (rs *RPCSyncNode) L2BlockRefByTimestamp(ctx context.Context, timestamp uint64) (eth.L2BlockRef, error)

+ func (rs *RPCSyncNode) OutputV0AtTimestamp(ctx context.Context, timestamp uint64) (*eth.OutputV0, error)

+ func (rs *RPCSyncNode) PendingOutputV0AtTimestamp(ctx context.Context, timestamp uint64) (*eth.OutputV0, error)

+ func (rs *RPCSyncNode) ProvideL1(ctx context.Context, nextL1 eth.BlockRef) error

+ func (rs *RPCSyncNode) PullEvent(ctx context.Context) (*types.ManagedEvent, error)

+ func (rs *RPCSyncNode) Reset(ctx context.Context, unsafe, safe, finalized eth.BlockID) error

+ func (rs *RPCSyncNode) String() string

+ func (rs *RPCSyncNode) SubscribeEvents(ctx context.Context, dest chan *types.ManagedEvent) (ethereum.Subscription, error)

+ func (rs *RPCSyncNode) UpdateCrossSafe(ctx context.Context, derived eth.BlockID, derivedFrom eth.BlockID) error

+ func (rs *RPCSyncNode) UpdateCrossUnsafe(ctx context.Context, id eth.BlockID) error

+ func (rs *RPCSyncNode) UpdateFinalized(ctx context.Context, id eth.BlockID) error

+ type SyncControl interface

+ AnchorPoint func(ctx context.Context) (types.DerivedBlockRefPair, error)

+ InvalidateBlock func(ctx context.Context, seal types.BlockSeal) error

+ ProvideL1 func(ctx context.Context, nextL1 eth.BlockRef) error

+ PullEvent func(ctx context.Context) (*types.ManagedEvent, error)

+ Reset func(ctx context.Context, unsafe, safe, finalized eth.BlockID) error

+ SubscribeEvents func(ctx context.Context, c chan *types.ManagedEvent) (ethereum.Subscription, error)

+ UpdateCrossSafe func(ctx context.Context, derived eth.BlockID, derivedFrom eth.BlockID) error

+ UpdateCrossUnsafe func(ctx context.Context, id eth.BlockID) error

+ UpdateFinalized func(ctx context.Context, id eth.BlockID) error

+ type SyncNode interface

+ type SyncNodeCollection interface

+ Check func() error

+ Load func(ctx context.Context, logger log.Logger) ([]SyncNodeSetup, error)

+ type SyncNodeSetup interface

+ Setup func(ctx context.Context, logger log.Logger) (SyncNode, error)

+ type SyncNodesController struct

+ func NewSyncNodesController(l log.Logger, depset depset.DependencySet, eventSys event.System, ...) *SyncNodesController

+ func (snc *SyncNodesController) AttachEmitter(em event.Emitter)

+ func (snc *SyncNodesController) AttachNodeController(chainID eth.ChainID, ctrl SyncControl, noSubscribe bool) (Node, error)

+ func (snc *SyncNodesController) Close() error

+ func (snc *SyncNodesController) OnEvent(ev event.Event) bool

+ type SyncSource interface

+ BlockRefByNumber func(ctx context.Context, number uint64) (eth.BlockRef, error)

+ ChainID func(ctx context.Context) (eth.ChainID, error)

+ FetchReceipts func(ctx context.Context, blockHash common.Hash) (gethtypes.Receipts, error)

+ L2BlockRefByTimestamp func(ctx context.Context, timestamp uint64) (eth.L2BlockRef, error)

+ OutputV0AtTimestamp func(ctx context.Context, timestamp uint64) (*eth.OutputV0, error)

+ PendingOutputV0AtTimestamp func(ctx context.Context, timestamp uint64) (*eth.OutputV0, error)

+ String func() string