builder

Documentation

Index

• Variables
• type BlockBuilder
• type Option
  • func FlagOptions(c *cli.Context) ([]Option, error)
  • func WithBuilderClient(client builder.BuilderClient) Option
  • func WithDatabase(beaconDB db.HeadAccessDatabase) Option
  • func WithHeadFetcher(svc blockchain.HeadFetcher) Option
  • func WithRegistrationCache() Option
• type Service
  • func NewService(ctx context.Context, opts ...Option) (*Service, error)
  • func (s *Service) Configured() bool
  • func (s *Service) GetHeader(ctx context.Context, slot primitives.Slot, parentHash [32]byte, ...) (builder.SignedBid, error)
  • func (s *Service) RegisterValidator(ctx context.Context, reg []*ethpb.SignedValidatorRegistrationV1) error
  • func (s *Service) RegistrationByValidatorID(ctx context.Context, id primitives.ValidatorIndex) (*ethpb.ValidatorRegistrationV1, error)
  • func (s *Service) Start()
  • func (s *Service) Status() error
  • func (s *Service) Stop() error
  • func (s *Service) SubmitBlindedBlock(ctx context.Context, b interfaces.ReadOnlySignedBeaconBlock, ...) (interfaces.ExecutionData, *v1.BlobsBundle, error)

Variables

var ErrNoBuilder = errors.New("builder endpoint not configured")

ErrNoBuilder is used when builder endpoint is not configured.

Types

type BlockBuilder

type BlockBuilder interface {
	SubmitBlindedBlock(ctx context.Context, block interfaces.ReadOnlySignedBeaconBlock, blobs []*ethpb.SignedBlindedBlobSidecar) (interfaces.ExecutionData, *v1.BlobsBundle, error)
	GetHeader(ctx context.Context, slot primitives.Slot, parentHash [32]byte, pubKey [48]byte) (builder.SignedBid, error)
	RegisterValidator(ctx context.Context, reg []*ethpb.SignedValidatorRegistrationV1) error
	RegistrationByValidatorID(ctx context.Context, id primitives.ValidatorIndex) (*ethpb.ValidatorRegistrationV1, error)
	Configured() bool
}

BlockBuilder defines the interface for interacting with the block builder

type Option

type Option func(s *Service) error

func FlagOptions

func FlagOptions(c *cli.Context) ([]Option, error)

FlagOptions for builder service flag configurations.

func WithBuilderClient

func WithBuilderClient(client builder.BuilderClient) Option

WithBuilderClient sets the builder client for the beacon chain builder service.

func WithDatabase

func WithDatabase(beaconDB db.HeadAccessDatabase) Option

WithDatabase for head access.

func WithHeadFetcher

func WithHeadFetcher(svc blockchain.HeadFetcher) Option

WithHeadFetcher gets the head info from chain service.

func WithRegistrationCache

func WithRegistrationCache() Option

WithRegistrationCache uses a cache for the validator registrations instead of a persistent db.

type Service

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

Service defines a service that provides a client for interacting with the beacon chain and MEV relay network.

func NewService

func NewService(ctx context.Context, opts ...Option) (*Service, error)

NewService instantiates a new service.

func (*Service) Configured

func (s *Service) Configured() bool

Configured returns true if the user has configured a builder client.

func (*Service) GetHeader

func (s *Service) GetHeader(ctx context.Context, slot primitives.Slot, parentHash [32]byte, pubKey [48]byte) (builder.SignedBid, error)

GetHeader retrieves the header for a given slot and parent hash from the builder relay network.

func (*Service) RegisterValidator

func (s *Service) RegisterValidator(ctx context.Context, reg []*ethpb.SignedValidatorRegistrationV1) error

RegisterValidator registers a validator with the builder relay network. It also saves the registration object to the DB.

func (*Service) RegistrationByValidatorID

func (s *Service) RegistrationByValidatorID(ctx context.Context, id primitives.ValidatorIndex) (*ethpb.ValidatorRegistrationV1, error)

RegistrationByValidatorID returns either the values from the cache or db.

func (*Service) Start

func (s *Service) Start()

Start initializes the service.

func (*Service) Status

func (s *Service) Status() error

Status retrieves the status of the builder relay network.

func (*Service) Stop

func (s *Service) Stop() error

Stop halts the service.

func (*Service) SubmitBlindedBlock

func (s *Service) SubmitBlindedBlock(ctx context.Context, b interfaces.ReadOnlySignedBeaconBlock, blobs []*ethpb.SignedBlindedBlobSidecar) (interfaces.ExecutionData, *v1.BlobsBundle, error)

SubmitBlindedBlock submits a blinded block to the builder relay network.