blockaggregator

Documentation

Index

• func HexToHash(s string) (ret phase0.Hash32, err error)
• type BlockAggregatorService
  • func NewBlockAggregatorService() *BlockAggregatorService
  • func (b *BlockAggregatorService) CliCommand() *cli.Command
  • func (b *BlockAggregatorService) Configure(moduleFlags common.ModuleFlags) error
  • func (b *BlockAggregatorService) ConnectBlockSource(moduleName string) error
  • func (b *BlockAggregatorService) ConnectCore(coreClient *coreCommon.Client, pingId string) error
  • func (b *BlockAggregatorService) DisconnectBlockSource(moduleName string) error
  • func (b *BlockAggregatorService) ExcludeFromNotifications(moduleName string) error
  • func (b *BlockAggregatorService) GetHeader(slot uint64, parentHash, proposerPubkey string) (res []spec.VersionedSignedBuilderBid, err error)
  • func (b *BlockAggregatorService) GetPayload(...) (...)
  • func (b *BlockAggregatorService) IncludeInNotifications(moduleName string) error
  • func (b *BlockAggregatorService) Name() string
  • func (b *BlockAggregatorService) RegisterValidator(payload []apiv1.SignedValidatorRegistration) error
  • func (b *BlockAggregatorService) Start() error
  • func (b *BlockAggregatorService) Status() error
  • func (b *BlockAggregatorService) Stop() error

Functions

func HexToHash

func HexToHash(s string) (ret phase0.Hash32, err error)

HexToHash takes a hex string and returns a Hash

Types

type BlockAggregatorService

type BlockAggregatorService struct {
	Data                         *data.AggregatorData
	ConnectedBLockSources        []string
	ModuleNotificationExclusions []string
	// contains filtered or unexported fields
}

func NewBlockAggregatorService

func NewBlockAggregatorService() *BlockAggregatorService

func (*BlockAggregatorService) CliCommand

func (b *BlockAggregatorService) CliCommand() *cli.Command

func (*BlockAggregatorService) Configure

func (b *BlockAggregatorService) Configure(moduleFlags common.ModuleFlags) error

func (*BlockAggregatorService) ConnectBlockSource

func (b *BlockAggregatorService) ConnectBlockSource(moduleName string) error

func (*BlockAggregatorService) ConnectCore

func (b *BlockAggregatorService) ConnectCore(coreClient *coreCommon.Client, pingId string) error

func (*BlockAggregatorService) DisconnectBlockSource

func (b *BlockAggregatorService) DisconnectBlockSource(moduleName string) error

func (*BlockAggregatorService) ExcludeFromNotifications

func (b *BlockAggregatorService) ExcludeFromNotifications(moduleName string) error

func (*BlockAggregatorService) GetHeader

func (b *BlockAggregatorService) GetHeader(slot uint64, parentHash, proposerPubkey string) (res []spec.VersionedSignedBuilderBid, err error)

func (*BlockAggregatorService) GetPayload

func (b *BlockAggregatorService) GetPayload(VersionedSignedBlindedBeaconBlock *commonTypes.VersionedSignedBlindedBeaconBlock) (versionedExecutionPayload []commonTypes.VersionedExecutionPayloadV2WithVersionName, err error)

func (*BlockAggregatorService) IncludeInNotifications

func (b *BlockAggregatorService) IncludeInNotifications(moduleName string) error

func (*BlockAggregatorService) Name

func (b *BlockAggregatorService) Name() string

func (*BlockAggregatorService) RegisterValidator

func (b *BlockAggregatorService) RegisterValidator(payload []apiv1.SignedValidatorRegistration) error

Move this to a different module later for validator management

func (*BlockAggregatorService) Start

func (b *BlockAggregatorService) Start() error

func (*BlockAggregatorService) Status

func (b *BlockAggregatorService) Status() error

func (*BlockAggregatorService) Stop

func (b *BlockAggregatorService) Stop() error