operations

Documentation

Overview

Package operations defines the life-cycle of beacon block operations.

Index

• type Config
• type Service
  • func NewOperationService(ctx context.Context, cfg *Config) *Service
  • func (s *Service) IncomingAttFeed() *event.Feed
  • func (s *Service) IncomingExitFeed() *event.Feed
  • func (s *Service) Start()
  • func (s *Service) Status() error
  • func (s *Service) Stop() error

Types

type Config

type Config struct {
	BeaconDB       *db.BeaconDB
	ReceiveExitBuf int
	ReceiveAttBuf  int
}

Config options for the service.

type Service

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

Service represents a service that handles the internal logic of beacon block operations.

func NewOperationService

func NewOperationService(ctx context.Context, cfg *Config) *Service

NewOperationService instantiates a new service instance that will be registered into a running beacon node.

func (*Service) IncomingAttFeed

func (s *Service) IncomingAttFeed() *event.Feed

IncomingAttFeed returns a feed that any service can send incoming p2p attestations into. The beacon block operation service will subscribe to this feed in order to relay incoming attestations.

func (*Service) IncomingExitFeed

func (s *Service) IncomingExitFeed() *event.Feed

IncomingExitFeed returns a feed that any service can send incoming p2p exits object into. The beacon block operation service will subscribe to this feed in order to relay incoming exits.

func (*Service) Start

func (s *Service) Start()

Start an beacon block operation service's main event loop.

func (*Service) Status

func (s *Service) Status() error

Status returns the current service error if there's any.

func (*Service) Stop

func (s *Service) Stop() error

Stop the beacon block operation service's main event loop and associated goroutines.