dutydb

Documentation

Index

• type MemDB
  • func NewMemDB(deadliner core.Deadliner) *MemDB
  • func (db *MemDB) AwaitAggAttestation(ctx context.Context, slot int64, attestationRoot eth2p0.Root) (*eth2p0.Attestation, error)
  • 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) AwaitBlindedBeaconBlock(ctx context.Context, slot int64) (*eth2api.VersionedBlindedBeaconBlock, error)
  • func (db *MemDB) AwaitSyncContribution(ctx context.Context, slot, subcommIdx int64, beaconBlockRoot eth2p0.Root) (*altair.SyncCommitteeContribution, 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 an in-memory dutyDB implementation. It is a placeholder for the badgerDB implementation.

func NewMemDB

func NewMemDB(deadliner core.Deadliner) *MemDB

NewMemDB returns a new in-memory dutyDB instance.

func (*MemDB) AwaitAggAttestation

func (db *MemDB) AwaitAggAttestation(ctx context.Context, slot int64, attestationRoot eth2p0.Root,
) (*eth2p0.Attestation, error)

AwaitAggAttestation blocks and returns the aggregated attestation for the slot and attestation when available.

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) AwaitBlindedBeaconBlock

func (db *MemDB) AwaitBlindedBeaconBlock(ctx context.Context, slot int64) (*eth2api.VersionedBlindedBeaconBlock, error)

AwaitBlindedBeaconBlock implements core.DutyDB, see its godoc.

func (*MemDB) AwaitSyncContribution

func (db *MemDB) AwaitSyncContribution(ctx context.Context, slot, subcommIdx int64, beaconBlockRoot eth2p0.Root) (*altair.SyncCommitteeContribution, error)

AwaitSyncContribution blocks and returns the sync committee contribution data for the slot and the subcommittee and the beacon block root when available.

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 only 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.