dutydb

Documentation

Index

• type MemDB
  • func NewMemDB() *MemDB
  • func (db *MemDB) AwaitAttestation(ctx context.Context, slot int64, commIdx int64) (*eth2p0.AttestationData, error)
  • func (db *MemDB) AwaitBeaconBlock(ctx context.Context, slot int64) (*spec.VersionedBeaconBlock, error)
  • func (db *MemDB) PubKeyByAttestation(_ context.Context, slot, commIdx, valCommIdx int64) (core.PubKey, error)
  • func (db *MemDB) Shutdown()
  • func (db *MemDB) Store(_ context.Context, duty core.Duty, unsignedSet core.UnsignedDataSet) error

Types

type MemDB

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

MemDB is a in-memory dutyDB implementation. It is a placeholder for the badgerDB implementation.

func NewMemDB

func NewMemDB() *MemDB

NewMemDB returns a new in-memory dutyDB instance.

func (*MemDB) AwaitAttestation

func (db *MemDB) AwaitAttestation(ctx context.Context, slot int64, commIdx int64) (*eth2p0.AttestationData, error)

AwaitAttestation implements core.DutyDB, see its godoc.

func (*MemDB) AwaitBeaconBlock

func (db *MemDB) AwaitBeaconBlock(ctx context.Context, slot int64) (*spec.VersionedBeaconBlock, error)

AwaitBeaconBlock implements core.DutyDB, see its godoc.

func (*MemDB) PubKeyByAttestation

func (db *MemDB) PubKeyByAttestation(_ context.Context, slot, commIdx, valCommIdx int64) (core.PubKey, error)

PubKeyByAttestation implements core.DutyDB, see its godoc.

func (*MemDB) Shutdown

func (db *MemDB) Shutdown()

Shutdown results in all blocking queries to return shutdown errors. Note this may once be called *once*.

func (*MemDB) Store

func (db *MemDB) Store(_ context.Context, duty core.Duty, unsignedSet core.UnsignedDataSet) error

Store implements core.DutyDB, see its godoc.