backend

package
v1.9.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 8, 2024 License: MIT Imports: 22 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
}

type Metrics 

type Metrics interface {
	CacheAdd(chainID types.ChainID, label string, cacheSize int, evicted bool)
	CacheGet(chainID types.ChainID, label string, hit bool)

	RecordDBEntryCount(chainID types.ChainID, kind string, count int64)
	RecordDBSearchEntriesRead(chainID types.ChainID, count int64)
}

type MockBackend 

type MockBackend struct {
	// contains filtered or unexported fields
}

func NewMockBackend 

func NewMockBackend() *MockBackend

func (*MockBackend) AddL2RPC added in v1.9.3 

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

func (*MockBackend) CheckMessage 

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

func (*MockBackend) CheckMessages added in v1.9.1 

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

func (*MockBackend) Close 

func (m *MockBackend) Close() error

func (*MockBackend) CrossDerivedFrom added in v1.9.5 

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

func (*MockBackend) Finalized added in v1.9.5 

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

func (*MockBackend) SafeView added in v1.9.5 

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

func (*MockBackend) Start 

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

func (*MockBackend) Stop 

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

func (*MockBackend) UnsafeView added in v1.9.5 

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

func (*MockBackend) UpdateFinalizedL1 added in v1.9.5 

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

func (*MockBackend) UpdateLocalSafe added in v1.9.5 

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

func (*MockBackend) UpdateLocalUnsafe added in v1.9.5 

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

type SupervisorBackend 

type SupervisorBackend struct {
	// contains filtered or unexported fields
}

func NewSupervisorBackend 

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

func (*SupervisorBackend) AddL2RPC added in v1.9.3 

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

AddL2RPC attaches an RPC as the RPC for the given chain, overriding the previous RPC source, if any.

func (*SupervisorBackend) AttachProcessorSource added in v1.9.5 

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

func (*SupervisorBackend) CheckMessage 

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

func (*SupervisorBackend) CheckMessages added in v1.9.1 

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

func (*SupervisorBackend) CrossDerivedFrom added in v1.9.5 

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

func (*SupervisorBackend) DependencySet added in v1.9.5 

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

func (*SupervisorBackend) Finalized added in v1.9.5 

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

func (*SupervisorBackend) SafeView added in v1.9.5 

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

func (*SupervisorBackend) Start 

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

func (*SupervisorBackend) Stop 

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

func (*SupervisorBackend) SyncCrossSafe added in v1.9.5 

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

func (*SupervisorBackend) SyncCrossUnsafe added in v1.9.5 

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

func (*SupervisorBackend) SyncEvents added in v1.9.5 

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

func (*SupervisorBackend) UnsafeView added in v1.9.5 

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

func (*SupervisorBackend) UpdateFinalizedL1 added in v1.9.5 

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

func (*SupervisorBackend) UpdateLocalSafe added in v1.9.5 

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

func (*SupervisorBackend) UpdateLocalUnsafe added in v1.9.5 

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

Source Files

View all Source files

Directories

Path Synopsis
db
entrydb
fromda
logs

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.