standard

Documentation

Index

• type Parameter
  • func WithAttestationDataProvider(provider eth2client.AttestationDataProvider) Parameter
  • func WithAttestationsSubmitter(submitter submitter.AttestationsSubmitter) Parameter
  • func WithBeaconAttestationsSigner(signer signer.BeaconAttestationsSigner) Parameter
  • func WithChainTimeService(service chaintime.Service) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.AttestationMonitor) Parameter
  • func WithProcessConcurrency(concurrency int64) Parameter
  • func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) Parameter
  • func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) Attest(ctx context.Context, data interface{}) ([]*phase0.Attestation, error)

Types

type Parameter

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

Parameter is the interface for service parameters.

func WithAttestationDataProvider

func WithAttestationDataProvider(provider eth2client.AttestationDataProvider) Parameter

WithAttestationDataProvider sets the attestation data provider.

func WithAttestationsSubmitter

func WithAttestationsSubmitter(submitter submitter.AttestationsSubmitter) Parameter

WithAttestationsSubmitter sets the attestations submitter.

func WithBeaconAttestationsSigner

func WithBeaconAttestationsSigner(signer signer.BeaconAttestationsSigner) Parameter

WithBeaconAttestationsSigner sets the beacon attestations signer.

func WithChainTimeService

func WithChainTimeService(service chaintime.Service) Parameter

WithChainTime sets the chain time service.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.AttestationMonitor) Parameter

WithMonitor sets the monitor for this module.

func WithProcessConcurrency

func WithProcessConcurrency(concurrency int64) Parameter

WithProcessConcurrency sets the concurrency for the service.

func WithSlotsPerEpochProvider

func WithSlotsPerEpochProvider(provider eth2client.SlotsPerEpochProvider) Parameter

WithSlotsPerEpochProvider sets the slots per epoch provider.

func WithValidatingAccountsProvider

func WithValidatingAccountsProvider(provider accountmanager.ValidatingAccountsProvider) Parameter

WithValidatingAccountsProvider sets the account manager.

type Service

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

Service is a beacon block attester.

func New

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

New creates a new beacon block attester.

func (*Service) Attest

func (s *Service) Attest(ctx context.Context, data interface{}) ([]*phase0.Attestation, error)

Attest carries out attestations for a slot. It returns a map of attestations made, keyed on the validator index.