safedb

Documentation

Index

• Variables
• type DisabledDB
  • func (d *DisabledDB) Close() error
  • func (d *DisabledDB) Enabled() bool
  • func (d *DisabledDB) SafeHeadAtL1(_ context.Context, _ uint64) (l1 eth.BlockID, safeHead eth.BlockID, err error)
  • func (d *DisabledDB) SafeHeadReset(_ eth.L2BlockRef) error
  • func (d *DisabledDB) SafeHeadUpdated(_ eth.L2BlockRef, _ eth.BlockID) error
• type SafeDB
  • func NewSafeDB(logger log.Logger, path string) (*SafeDB, error)
  • func (d *SafeDB) Close() error
  • func (d *SafeDB) Enabled() bool
  • func (d *SafeDB) SafeHeadAtL1(ctx context.Context, l1BlockNum uint64) (l1Block eth.BlockID, safeHead eth.BlockID, err error)
  • func (d *SafeDB) SafeHeadReset(safeHead eth.L2BlockRef) error
  • func (d *SafeDB) SafeHeadUpdated(safeHead eth.L2BlockRef, l1Head eth.BlockID) error

Variables

var (
	Disabled      = &DisabledDB{}
	ErrNotEnabled = errors.New("safe head database not enabled")
)

var (
	ErrNotFound     = errors.New("not found")
	ErrInvalidEntry = errors.New("invalid db entry")
)

Types

type DisabledDB

type DisabledDB struct{}

func (*DisabledDB) Close

func (d *DisabledDB) Close() error

func (*DisabledDB) Enabled

func (d *DisabledDB) Enabled() bool

func (*DisabledDB) SafeHeadAtL1

func (d *DisabledDB) SafeHeadAtL1(_ context.Context, _ uint64) (l1 eth.BlockID, safeHead eth.BlockID, err error)

func (*DisabledDB) SafeHeadReset

func (d *DisabledDB) SafeHeadReset(_ eth.L2BlockRef) error

func (*DisabledDB) SafeHeadUpdated

func (d *DisabledDB) SafeHeadUpdated(_ eth.L2BlockRef, _ eth.BlockID) error

type SafeDB

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

func NewSafeDB

func NewSafeDB(logger log.Logger, path string) (*SafeDB, error)

func (*SafeDB) Close

func (d *SafeDB) Close() error

func (*SafeDB) Enabled

func (d *SafeDB) Enabled() bool

func (*SafeDB) SafeHeadAtL1

func (d *SafeDB) SafeHeadAtL1(ctx context.Context, l1BlockNum uint64) (l1Block eth.BlockID, safeHead eth.BlockID, err error)

func (*SafeDB) SafeHeadReset

func (d *SafeDB) SafeHeadReset(safeHead eth.L2BlockRef) error

func (*SafeDB) SafeHeadUpdated

func (d *SafeDB) SafeHeadUpdated(safeHead eth.L2BlockRef, l1Head eth.BlockID) error