backend

Nov 8, 2024

Changes in this version

type MockBackend

+ func (m *MockBackend) CrossDerivedFrom(ctx context.Context, chainID types.ChainID, derived eth.BlockID) (derivedFrom eth.BlockRef, err error)

+ func (m *MockBackend) Finalized(ctx context.Context, chainID types.ChainID) (eth.BlockID, error)

+ func (m *MockBackend) SafeView(ctx context.Context, chainID types.ChainID, safe types.ReferenceView) (types.ReferenceView, error)

+ func (m *MockBackend) UnsafeView(ctx context.Context, chainID types.ChainID, unsafe types.ReferenceView) (types.ReferenceView, error)

+ func (m *MockBackend) UpdateFinalizedL1(ctx context.Context, chainID types.ChainID, finalized eth.BlockRef) error

+ func (m *MockBackend) UpdateLocalSafe(ctx context.Context, chainID types.ChainID, derivedFrom eth.BlockRef, ...) error

+ func (m *MockBackend) UpdateLocalUnsafe(ctx context.Context, chainID types.ChainID, head eth.BlockRef) error

type SupervisorBackend

+ func (su *SupervisorBackend) AttachProcessorSource(chainID types.ChainID, src processors.Source) error

+ func (su *SupervisorBackend) CrossDerivedFrom(ctx context.Context, chainID types.ChainID, derived eth.BlockID) (derivedFrom eth.BlockRef, err error)

+ func (su *SupervisorBackend) DependencySet() depset.DependencySet

+ func (su *SupervisorBackend) Finalized(ctx context.Context, chainID types.ChainID) (eth.BlockID, error)

+ func (su *SupervisorBackend) SafeView(ctx context.Context, chainID types.ChainID, safe types.ReferenceView) (types.ReferenceView, error)

+ func (su *SupervisorBackend) SyncCrossSafe(chainID types.ChainID) error

+ func (su *SupervisorBackend) SyncCrossUnsafe(chainID types.ChainID) error

+ func (su *SupervisorBackend) SyncEvents(chainID types.ChainID) error

+ func (su *SupervisorBackend) UnsafeView(ctx context.Context, chainID types.ChainID, unsafe types.ReferenceView) (types.ReferenceView, error)

+ func (su *SupervisorBackend) UpdateFinalizedL1(ctx context.Context, chainID types.ChainID, finalized eth.BlockRef) error

+ func (su *SupervisorBackend) UpdateLocalSafe(ctx context.Context, chainID types.ChainID, derivedFrom eth.BlockRef, ...) error

+ func (su *SupervisorBackend) UpdateLocalUnsafe(ctx context.Context, chainID types.ChainID, head eth.BlockRef) error

Sep 25, 2024

Changes in this version

type MockBackend

+ func (m *MockBackend) AddL2RPC(ctx context.Context, rpc string) error

type SupervisorBackend

+ func (su *SupervisorBackend) AddL2RPC(ctx context.Context, rpc string) error

Aug 28, 2024

Changes in this version

type MockBackend

+ func (m *MockBackend) CheckMessages(messages []types.Message, minSafety types.SafetyLevel) error

type SupervisorBackend

+ func (su *SupervisorBackend) CheckMessages(messages []types.Message, minSafety types.SafetyLevel) error

Jul 17, 2024

Changes in this version

+ type Config struct

+ type Metrics interface

+ CacheAdd func(chainID types.ChainID, label string, cacheSize int, evicted bool)

+ CacheGet func(chainID types.ChainID, label string, hit bool)

+ RecordDBEntryCount func(chainID types.ChainID, count int64)

+ RecordDBSearchEntriesRead func(chainID types.ChainID, count int64)

+ type MockBackend struct

+ func NewMockBackend() *MockBackend

+ func (m *MockBackend) CheckBlock(chainID *hexutil.U256, blockHash common.Hash, blockNumber hexutil.Uint64) (types.SafetyLevel, error)

+ func (m *MockBackend) CheckMessage(identifier types.Identifier, payloadHash common.Hash) (types.SafetyLevel, error)

+ func (m *MockBackend) Close() error

+ func (m *MockBackend) Start(ctx context.Context) error

+ func (m *MockBackend) Stop(ctx context.Context) error

+ type SupervisorBackend struct

+ func NewSupervisorBackend(ctx context.Context, logger log.Logger, m Metrics, cfg *config.Config) (*SupervisorBackend, error)

+ func (su *SupervisorBackend) CheckBlock(chainID *hexutil.U256, blockHash common.Hash, blockNumber hexutil.Uint64) (types.SafetyLevel, error)

+ func (su *SupervisorBackend) CheckMessage(identifier types.Identifier, payloadHash common.Hash) (types.SafetyLevel, error)

+ func (su *SupervisorBackend) Close() error

+ func (su *SupervisorBackend) Start(ctx context.Context) error

+ func (su *SupervisorBackend) Stop(ctx context.Context) error