standard

Documentation

Index

• type Parameter
  • func WithActivitySem(sem *semaphore.Weighted) Parameter
  • func WithChainDB(chainDB chaindb.Service) Parameter
  • func WithChainTime(chainTime chaintime.Service) Parameter
  • func WithETH2Client(eth2Client eth2client.Service) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.Service) Parameter
  • func WithRefetch(refetch bool) Parameter
  • func WithStartSlot(startSlot int64) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) OnBeaconChainHeadUpdated(ctx context.Context, slot phase0.Slot, blockRoot phase0.Root, ...)
  • func (s *Service) OnBlock(ctx context.Context, signedBlock *spec.VersionedSignedBeaconBlock) error
  • func (s *Service) UpdateSlot(ctx context.Context, md *metadata, slot phase0.Slot) error

Types

type Parameter

type Parameter interface {
	// contains filtered or unexported methods
}

Parameter is the interface for service parameters.

func WithActivitySem

func WithActivitySem(sem *semaphore.Weighted) Parameter

WithActivitySem sets the activity semaphore for this module.

func WithChainDB

func WithChainDB(chainDB chaindb.Service) Parameter

WithChainDB sets the chain database for this module.

func WithChainTime

func WithChainTime(chainTime chaintime.Service) Parameter

WithChainTime sets the chain time service for this module.

func WithETH2Client

func WithETH2Client(eth2Client eth2client.Service) Parameter

WithETH2Client sets the Ethereum 2 client for this module.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.Service) Parameter

WithMonitor sets the monitor for the module.

func WithRefetch

func WithRefetch(refetch bool) Parameter

WithRefetch sets the refetch flag for this module.

func WithStartSlot

func WithStartSlot(startSlot int64) Parameter

WithStartSlot sets the start slot for this module.

type Service

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

Service is a chain database service.

func New

func New(ctx context.Context, params ...Parameter) (*Service, error)

New creates a new service.

func (*Service) OnBeaconChainHeadUpdated

func (s *Service) OnBeaconChainHeadUpdated(
	ctx context.Context,
	slot phase0.Slot,
	blockRoot phase0.Root,
	stateRoot phase0.Root,

	epochTransition bool,
)

OnBeaconChainHeadUpdated receives beacon chain head updated notifications.

func (*Service) OnBlock

func (s *Service) OnBlock(ctx context.Context, signedBlock *spec.VersionedSignedBeaconBlock) error

OnBlock handles a block. This requires the context to hold an active transaction.

func (*Service) UpdateSlot

func (s *Service) UpdateSlot(ctx context.Context, md *metadata, slot phase0.Slot) error

UpdateSlot updates block for the given slot.