core

Jan 17, 2023

Changes in this version

+ var ErrNotFound = errors.NewSentinel("not found")

Nov 21, 2022

Changes in this version

+ func VerifyEth2SignedData(ctx context.Context, eth2Cl eth2wrap.Client, data Eth2SignedData, ...) error

type Attestation

+ func (Attestation) DomainName() signing.DomainName

+ func (a Attestation) Epoch(_ context.Context, _ eth2wrap.Client) (eth2p0.Epoch, error)

+ func (a Attestation) MessageRoot() ([32]byte, error)

type BeaconCommitteeSelection

+ func (BeaconCommitteeSelection) DomainName() signing.DomainName

+ func (s BeaconCommitteeSelection) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s BeaconCommitteeSelection) MessageRoot() ([32]byte, error)

type Duty

+ func NewInfoSyncDuty(slot int64) Duty

type DutyDB

+ AwaitSyncContribution func(ctx context.Context, slot, subcommIdx int64, beaconBlockRoot eth2p0.Root) (*altair.SyncCommitteeContribution, error)

type DutyDefinition

+ func NewSyncCommitteeDefinition(duty *eth2v1.SyncCommitteeDuty) DutyDefinition

type DutyType

+ const DutyInfoSync

+ type Eth2SignedData interface

+ DomainName func() signing.DomainName

+ Epoch func(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

type ParSignedData

+ func NewPartialSignedSyncCommitteeSelection(selection *eth2exp.SyncCommitteeSelection, shareIdx int) ParSignedData

+ func NewPartialSignedSyncContributionAndProof(proof *altair.SignedContributionAndProof, shareIdx int) ParSignedData

+ func NewPartialSyncContributionAndProof(proof *altair.ContributionAndProof, shareIdx int) ParSignedData

type Signature

+ func (Signature) MessageRoot() ([32]byte, error)

type SignedAggregateAndProof

+ func (SignedAggregateAndProof) DomainName() signing.DomainName

+ func (s SignedAggregateAndProof) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SignedAggregateAndProof) MessageRoot() ([32]byte, error)

type SignedData

+ MessageRoot func() ([32]byte, error)

type SignedRandao

+ func (SignedRandao) DomainName() signing.DomainName

+ func (s SignedRandao) Epoch(_ context.Context, _ eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SignedRandao) MessageRoot() ([32]byte, error)

type SignedSyncContributionAndProof

+ func NewSignedSyncContributionAndProof(proof *altair.SignedContributionAndProof) SignedSyncContributionAndProof

+ func (SignedSyncContributionAndProof) DomainName() signing.DomainName

+ func (s SignedSyncContributionAndProof) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SignedSyncContributionAndProof) MessageRoot() ([32]byte, error)

type SignedSyncMessage

+ func (SignedSyncMessage) DomainName() signing.DomainName

+ func (s SignedSyncMessage) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SignedSyncMessage) MessageRoot() ([32]byte, error)

type SignedVoluntaryExit

+ func (SignedVoluntaryExit) DomainName() signing.DomainName

+ func (e SignedVoluntaryExit) Epoch(_ context.Context, _ eth2wrap.Client) (eth2p0.Epoch, error)

+ func (e SignedVoluntaryExit) MessageRoot() ([32]byte, error)

+ type SyncCommitteeSelection struct

+ func NewSyncCommitteeSelection(selection *eth2exp.SyncCommitteeSelection) SyncCommitteeSelection

+ func (SyncCommitteeSelection) DomainName() signing.DomainName

+ func (s *SyncCommitteeSelection) UnmarshalJSON(input []byte) error

+ func (s SyncCommitteeSelection) Clone() (SignedData, error)

+ func (s SyncCommitteeSelection) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SyncCommitteeSelection) MarshalJSON() ([]byte, error)

+ func (s SyncCommitteeSelection) MessageRoot() ([32]byte, error)

+ func (s SyncCommitteeSelection) SetSignature(sig Signature) (SignedData, error)

+ func (s SyncCommitteeSelection) Signature() Signature

type SyncContribution

+ func NewSyncContribution(c *altair.SyncCommitteeContribution) SyncContribution

+ type SyncContributionAndProof struct

+ func NewSyncContributionAndProof(proof *altair.ContributionAndProof) SyncContributionAndProof

+ func (SyncContributionAndProof) DomainName() signing.DomainName

+ func (s *SyncContributionAndProof) UnmarshalJSON(input []byte) error

+ func (s SyncContributionAndProof) Clone() (SignedData, error)

+ func (s SyncContributionAndProof) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (s SyncContributionAndProof) MarshalJSON() ([]byte, error)

+ func (s SyncContributionAndProof) MessageRoot() ([32]byte, error)

+ func (s SyncContributionAndProof) SetSignature(sig Signature) (SignedData, error)

+ func (s SyncContributionAndProof) Signature() Signature

type ValidatorAPI

+ RegisterAwaitSyncContribution func(...)

type VersionedSignedBeaconBlock

+ func (VersionedSignedBeaconBlock) DomainName() signing.DomainName

+ func (b VersionedSignedBeaconBlock) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (b VersionedSignedBeaconBlock) MessageRoot() ([32]byte, error)

type VersionedSignedBlindedBeaconBlock

+ func (VersionedSignedBlindedBeaconBlock) DomainName() signing.DomainName

+ func (b VersionedSignedBlindedBeaconBlock) Epoch(ctx context.Context, eth2Cl eth2wrap.Client) (eth2p0.Epoch, error)

+ func (b VersionedSignedBlindedBeaconBlock) MessageRoot() ([32]byte, error)

type VersionedSignedValidatorRegistration

+ func (VersionedSignedValidatorRegistration) DomainName() signing.DomainName

+ func (VersionedSignedValidatorRegistration) Epoch(context.Context, eth2wrap.Client) (eth2p0.Epoch, error)

+ func (r VersionedSignedValidatorRegistration) MessageRoot() ([32]byte, error)

Oct 20, 2022

Changes in this version

+ type BeaconCommitteeSelection struct

+ func NewBeaconCommitteeSelection(selection *eth2exp.BeaconCommitteeSelection) BeaconCommitteeSelection

+ func (s *BeaconCommitteeSelection) UnmarshalJSON(input []byte) error

+ func (s BeaconCommitteeSelection) Clone() (SignedData, error)

+ func (s BeaconCommitteeSelection) MarshalJSON() ([]byte, error)

+ func (s BeaconCommitteeSelection) SetSignature(sig Signature) (SignedData, error)

+ func (s BeaconCommitteeSelection) Signature() Signature

type Duty

+ func NewPrepareSyncContributionDuty(slot int64) Duty

+ func NewSyncContributionDuty(slot int64) Duty

+ func NewSyncMessageDuty(slot int64) Duty

type ParSignedData

+ func NewPartialSignedBeaconCommitteeSelection(selection *eth2exp.BeaconCommitteeSelection, shareIdx int) ParSignedData

+ func NewPartialSignedSyncMessage(data *altair.SyncCommitteeMessage, shareIdx int) ParSignedData

type PubKey

+ func PubKeyFrom48Bytes(bytes [48]byte) PubKey

+ type SignedSyncContributionAndProof struct

+ func (s *SignedSyncContributionAndProof) UnmarshalJSON(input []byte) error

+ func (s SignedSyncContributionAndProof) Clone() (SignedData, error)

+ func (s SignedSyncContributionAndProof) MarshalJSON() ([]byte, error)

+ func (s SignedSyncContributionAndProof) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedSyncContributionAndProof) Signature() Signature

type SignedSyncMessage

+ func NewSignedSyncMessage(data *altair.SyncCommitteeMessage) SignedSyncMessage

Sep 30, 2022

Changes in this version

+ type AggregatedAttestation struct

+ func NewAggregatedAttestation(att *eth2p0.Attestation) AggregatedAttestation

+ func (a *AggregatedAttestation) UnmarshalJSON(input []byte) error

+ func (a AggregatedAttestation) Clone() (UnsignedData, error)

+ func (a AggregatedAttestation) MarshalJSON() ([]byte, error)

type Duty

+ func NewAggregatorDuty(slot int64) Duty

+ func NewPrepareAggregatorDuty(slot int64) Duty

type DutyDB

+ AwaitAggAttestation func(ctx context.Context, slot int64, attestationRoot eth2p0.Root) (*eth2p0.Attestation, error)

type DutyDefinition

+ func NewSyncCommitteDefinition(duty *eth2v1.SyncCommitteeDuty) DutyDefinition

type DutyType

+ const DutyAggregator

+ const DutyPrepareAggregator

+ const DutyPrepareSyncContribution

+ const DutySyncContribution

+ const DutySyncMessage

+ type EmptyDefinition struct

+ func NewEmptyDefinition() EmptyDefinition

+ func (EmptyDefinition) Clone() (DutyDefinition, error)

+ func (EmptyDefinition) MarshalJSON() ([]byte, error)

type Fetcher

+ RegisterAwaitAttData func(...)

type ParSignedData

+ func NewPartialSignedAggregateAndProof(data *eth2p0.SignedAggregateAndProof, shareIdx int) ParSignedData

+ func NewPartialSignedBeaconCommitteeSubscription(sub *eth2exp.BeaconCommitteeSubscription, shareIdx int) ParSignedData

+ type SignedAggregateAndProof struct

+ func NewSignedAggregateAndProof(data *eth2p0.SignedAggregateAndProof) SignedAggregateAndProof

+ func (s *SignedAggregateAndProof) UnmarshalJSON(input []byte) error

+ func (s SignedAggregateAndProof) Clone() (SignedData, error)

+ func (s SignedAggregateAndProof) MarshalJSON() ([]byte, error)

+ func (s SignedAggregateAndProof) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedAggregateAndProof) Signature() Signature

+ type SignedBeaconCommitteeSubscription struct

+ func NewBeaconCommitteeSubscription(sub *eth2exp.BeaconCommitteeSubscription) SignedBeaconCommitteeSubscription

+ func (s *SignedBeaconCommitteeSubscription) UnmarshalJSON(input []byte) error

+ func (s SignedBeaconCommitteeSubscription) Clone() (SignedData, error)

+ func (s SignedBeaconCommitteeSubscription) MarshalJSON() ([]byte, error)

+ func (s SignedBeaconCommitteeSubscription) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedBeaconCommitteeSubscription) Signature() Signature

+ type SignedSyncContribution struct

+ func (s *SignedSyncContribution) UnmarshalJSON(input []byte) error

+ func (s SignedSyncContribution) Clone() (SignedData, error)

+ func (s SignedSyncContribution) MarshalJSON() ([]byte, error)

+ func (s SignedSyncContribution) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedSyncContribution) Signature() Signature

+ type SignedSyncMessage struct

+ func (s *SignedSyncMessage) UnmarshalJSON(input []byte) error

+ func (s SignedSyncMessage) Clone() (SignedData, error)

+ func (s SignedSyncMessage) MarshalJSON() ([]byte, error)

+ func (s SignedSyncMessage) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedSyncMessage) Signature() Signature

+ type SyncCommitteeDefinition struct

+ func (s SyncCommitteeDefinition) Clone() (DutyDefinition, error)

+ func (s SyncCommitteeDefinition) MarshalJSON() ([]byte, error)

+ type SyncContribution struct

+ func (s *SyncContribution) UnmarshalJSON(input []byte) error

+ func (s SyncContribution) Clone() (UnsignedData, error)

+ func (s SyncContribution) MarshalJSON() ([]byte, error)

type ValidatorAPI

+ RegisterAwaitAggAttestation func(...)

+ RegisterAwaitAggSigDB func(func(context.Context, Duty, PubKey) (SignedData, error))

Aug 24, 2022

Changes in this version

type Deadliner

+ func NewDeadlinerForT(ctx context.Context, t *testing.T, deadlineFunc func(Duty) (time.Time, bool), ...) Deadliner

type Duty

+ func NewBuilderRegistrationDuty(slot int64) Duty

+ func NewSignatureDuty(slot int64) Duty

type DutyDB

+ AwaitBlindedBeaconBlock func(ctx context.Context, slot int64) (*eth2api.VersionedBlindedBeaconBlock, error)

type DutyType

+ const DutyBuilderRegistration

+ const DutySignature

type ParSignedData

+ func NewPartialSignedRandao(epoch eth2p0.Epoch, randao eth2p0.BLSSignature, shareIdx int) ParSignedData

+ func NewPartialVersionedSignedValidatorRegistration(registration *eth2api.VersionedSignedValidatorRegistration, shareIdx int) (ParSignedData, error)

type Scheduler

+ SubscribeDuties func(func(context.Context, Duty, DutyDefinitionSet) error)

+ SubscribeSlots func(func(context.Context, Slot) error)

+ type SignedRandao struct

+ func (s *SignedRandao) UnmarshalJSON(input []byte) error

+ func (s SignedRandao) Clone() (SignedData, error)

+ func (s SignedRandao) MarshalJSON() ([]byte, error)

+ func (s SignedRandao) SetSignature(sig Signature) (SignedData, error)

+ func (s SignedRandao) Signature() Signature

+ type Slot struct

+ Slot int64

+ SlotDuration time.Duration

+ SlotsPerEpoch int64

+ Time time.Time

+ func (s Slot) Epoch() int64

+ func (s Slot) FirstInEpoch() bool

+ func (s Slot) LastInEpoch() bool

+ func (s Slot) Next() Slot

type ValidatorAPI

+ RegisterAwaitBlindedBeaconBlock func(...)

+ type VersionedSignedValidatorRegistration struct

+ func NewVersionedSignedValidatorRegistration(registration *eth2api.VersionedSignedValidatorRegistration) (VersionedSignedValidatorRegistration, error)

+ func (r *VersionedSignedValidatorRegistration) UnmarshalJSON(input []byte) error

+ func (r VersionedSignedValidatorRegistration) Clone() (SignedData, error)

+ func (r VersionedSignedValidatorRegistration) MarshalJSON() ([]byte, error)

+ func (r VersionedSignedValidatorRegistration) SetSignature(sig Signature) (SignedData, error)

+ func (r VersionedSignedValidatorRegistration) Signature() Signature

Jul 21, 2022

Changes in this version

+ type Deadline struct

+ func NewDeadliner(ctx context.Context, deadlineFunc func(Duty) time.Time) *Deadline

+ func NewForT(ctx context.Context, t *testing.T, deadlineFunc func(Duty) time.Time, ...) *Deadline

+ func (d *Deadline) Add(duty Duty) bool

+ func (d *Deadline) C() <-chan Duty

+ type Deadliner interface

+ Add func(duty Duty) bool

+ C func() <-chan Duty

type Duty

+ func NewBuilderProposerDuty(slot int64) Duty

+ func NewVoluntaryExit(slot int64) Duty

type DutyType

+ const DutyBuilderProposer

type ParSignedData

+ func NewPartialVersionedSignedBlindedBeaconBlock(block *eth2api.VersionedSignedBlindedBeaconBlock, shareIdx int) (ParSignedData, error)

type ValidatorAPI

+ Subscribe func(func(context.Context, Duty, ParSignedDataSet) error)

+ type VersionedBlindedBeaconBlock struct

+ func NewVersionedBlindedBeaconBlock(block *eth2api.VersionedBlindedBeaconBlock) (VersionedBlindedBeaconBlock, error)

+ func (b *VersionedBlindedBeaconBlock) UnmarshalJSON(input []byte) error

+ func (b VersionedBlindedBeaconBlock) Clone() (UnsignedData, error)

+ func (b VersionedBlindedBeaconBlock) MarshalJSON() ([]byte, error)

+ type VersionedSignedBlindedBeaconBlock struct

+ func NewVersionedSignedBlindedBeaconBlock(block *eth2api.VersionedSignedBlindedBeaconBlock) (VersionedSignedBlindedBeaconBlock, error)

+ func (b *VersionedSignedBlindedBeaconBlock) UnmarshalJSON(input []byte) error

+ func (b VersionedSignedBlindedBeaconBlock) Clone() (SignedData, error)

+ func (b VersionedSignedBlindedBeaconBlock) MarshalJSON() ([]byte, error)

+ func (b VersionedSignedBlindedBeaconBlock) SetSignature(sig Signature) (SignedData, error)

+ func (b VersionedSignedBlindedBeaconBlock) Signature() Signature

Jun 22, 2022

Changes in this version

+ type Attestation struct

+ func NewAttestation(att *eth2p0.Attestation) Attestation

+ func (a *Attestation) UnmarshalJSON(b []byte) error

+ func (a Attestation) Clone() (SignedData, error)

+ func (a Attestation) MarshalJSON() ([]byte, error)

+ func (a Attestation) SetSignature(sig Signature) (SignedData, error)

+ func (a Attestation) Signature() Signature

type AttestationData

+ func (a *AttestationData) UnmarshalJSON(data []byte) error

+ func (a AttestationData) Clone() (UnsignedData, error)

+ func (a AttestationData) MarshalJSON() ([]byte, error)

+ type AttesterDefinition struct

+ func NewAttesterDefinition(duty *eth2v1.AttesterDuty) AttesterDefinition

+ func (d AttesterDefinition) Clone() (DutyDefinition, error)

+ func (d AttesterDefinition) MarshalJSON() ([]byte, error)

+ type DutyDefinition interface

+ Clone func() (DutyDefinition, error)

+ type DutyDefinitionSet map[PubKey]DutyDefinition

+ func (s DutyDefinitionSet) Clone() (DutyDefinitionSet, error)

type ParSignedData

+ func NewPartialAttestation(att *eth2p0.Attestation, shareIdx int) ParSignedData

+ func NewPartialSignature(sig Signature, shareIdx int) ParSignedData

+ func NewPartialSignedVoluntaryExit(exit *eth2p0.SignedVoluntaryExit, shareIdx int) ParSignedData

+ func NewPartialVersionedSignedBeaconBlock(block *spec.VersionedSignedBeaconBlock, shareIdx int) (ParSignedData, error)

+ func (d ParSignedData) Clone() (ParSignedData, error)

type ParSignedDataSet

+ func (s ParSignedDataSet) Clone() (ParSignedDataSet, error)

+ type ProposerDefinition struct

+ func NewProposerDefinition(duty *eth2v1.ProposerDuty) ProposerDefinition

+ func (d ProposerDefinition) Clone() (DutyDefinition, error)

+ func (d ProposerDefinition) MarshalJSON() ([]byte, error)

type Scheduler

+ GetDutyDefinition func(context.Context, Duty) (DutyDefinitionSet, error)

type Signature

+ func (Signature) SetSignature(sig Signature) (SignedData, error)

+ func (s *Signature) UnmarshalJSON(b []byte) error

+ func (s Signature) Clone() (SignedData, error)

+ func (s Signature) MarshalJSON() ([]byte, error)

+ func (s Signature) Signature() Signature

+ type SignedData interface

+ Clone func() (SignedData, error)

+ SetSignature func(Signature) (SignedData, error)

+ Signature func() Signature

+ type SignedVoluntaryExit struct

+ func NewSignedVoluntaryExit(exit *eth2p0.SignedVoluntaryExit) SignedVoluntaryExit

+ func (e *SignedVoluntaryExit) UnmarshalJSON(b []byte) error

+ func (e SignedVoluntaryExit) Clone() (SignedData, error)

+ func (e SignedVoluntaryExit) MarshalJSON() ([]byte, error)

+ func (e SignedVoluntaryExit) SetSignature(sig Signature) (SignedData, error)

+ func (e SignedVoluntaryExit) Signature() Signature

type UnsignedData

+ func UnmarshalUnsignedData(typ DutyType, data []byte) (UnsignedData, error)

+ Clone func() (UnsignedData, error)

type UnsignedDataSet

+ func (s UnsignedDataSet) Clone() (UnsignedDataSet, error)

type ValidatorAPI

+ RegisterGetDutyDefinition func(func(context.Context, Duty) (DutyDefinitionSet, error))

+ type VersionedBeaconBlock struct

+ func NewVersionedBeaconBlock(block *spec.VersionedBeaconBlock) (VersionedBeaconBlock, error)

+ func (b *VersionedBeaconBlock) UnmarshalJSON(input []byte) error

+ func (b VersionedBeaconBlock) Clone() (UnsignedData, error)

+ func (b VersionedBeaconBlock) MarshalJSON() ([]byte, error)

+ type VersionedSignedBeaconBlock struct

+ func NewVersionedSignedBeaconBlock(block *spec.VersionedSignedBeaconBlock) (VersionedSignedBeaconBlock, error)

+ func (b *VersionedSignedBeaconBlock) UnmarshalJSON(input []byte) error

+ func (b VersionedSignedBeaconBlock) Clone() (SignedData, error)

+ func (b VersionedSignedBeaconBlock) MarshalJSON() ([]byte, error)

+ func (b VersionedSignedBeaconBlock) SetSignature(sig Signature) (SignedData, error)

+ func (b VersionedSignedBeaconBlock) Signature() Signature

Jun 7, 2022

Changes in this version

+ func DecodeExitAggSignedData(data AggSignedData) (*eth2p0.SignedVoluntaryExit, error)

+ func DecodeExitParSignedData(data ParSignedData) (*eth2p0.SignedVoluntaryExit, error)

+ func NewDutyDeadlineFunc(ctx context.Context, eth2Svc eth2client.Service) (func(Duty) time.Time, error)

type AggSignedData

+ func EncodeExitAggSignedData(exit *eth2p0.SignedVoluntaryExit) (AggSignedData, error)

type DutyType

+ const DutyExit

type ParSignedData

+ func EncodeExitParSignedData(exit *eth2p0.SignedVoluntaryExit, shareIdx int) (ParSignedData, error)

May 13, 2022

Changes in this version

+ func DecodeBlockAggSignedData(data AggSignedData) (*spec.VersionedSignedBeaconBlock, error)

+ func UnsignedDataSetToProto(set UnsignedDataSet) *pbv1.UnsignedDataSet

type AggSignedData

+ func EncodeBlockAggSignedData(block *spec.VersionedSignedBeaconBlock) (AggSignedData, error)

type Scheduler

+ GetDuty func(context.Context, Duty) (FetchArgSet, error)

type UnsignedDataSet

+ func UnsignedDataSetFromProto(set *pbv1.UnsignedDataSet) UnsignedDataSet

type ValidatorAPI

+ RegisterGetDutyFunc func(func(context.Context, Duty) (FetchArgSet, error))

Apr 12, 2022

Changes in this version

+ func DecodeBlockParSignedData(data ParSignedData) (*spec.VersionedSignedBeaconBlock, error)

+ func DutyToProto(duty Duty) *pbv1.Duty

+ func ParSignedDataSetToProto(set ParSignedDataSet) *pbv1.ParSignedDataSet

+ func ParSignedDataToProto(data ParSignedData) *pbv1.ParSignedData

type Duty

+ func DutyFromProto(duty *pbv1.Duty) Duty

+ func NewProposerDuty(slot int64) Duty

+ func NewRandaoDuty(slot int64) Duty

type DutyDB

+ AwaitBeaconBlock func(ctx context.Context, slot int64) (PubKey, *spec.VersionedBeaconBlock, error)

type ParSignedData

+ func EncodeBlockParSignedData(block *spec.VersionedSignedBeaconBlock, shareIdx int) (ParSignedData, error)

+ func ParSignedDataFromProto(data *pbv1.ParSignedData) ParSignedData

type ParSignedDataSet

+ func ParSignedDataSetFromProto(set *pbv1.ParSignedDataSet) ParSignedDataSet

type ValidatorAPI

+ RegisterAwaitBeaconBlock func(...)

type WireOption

+ func WithAsyncRetry(retryer *retry.Retryer) WireOption

Mar 30, 2022

Changes in this version

+ const DutyAttester

+ const DutyProposer

+ const DutyRandao

+ const DutyUnknown

+ func DecodeAttestationAggSignedData(data AggSignedData) (*eth2p0.Attestation, error)

+ func DecodeAttestationParSignedData(data ParSignedData) (*eth2p0.Attestation, error)

+ func DecodeAttesterFetchArg(fetchArg FetchArg) (*eth2v1.AttesterDuty, error)

+ func DecodeProposerFetchArg(fetchArg FetchArg) (*eth2v1.ProposerDuty, error)

+ func DecodeProposerUnsignedData(unsignedData UnsignedData) (*spec.VersionedBeaconBlock, error)

+ func DecodeRandaoAggSignedData(data AggSignedData) eth2p0.BLSSignature

+ func DecodeRandaoParSignedData(data ParSignedData) eth2p0.BLSSignature

+ func StartDutyTrace(ctx context.Context, duty Duty, spanName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

+ func Wire(sched Scheduler, fetch Fetcher, cons Consensus, dutyDB DutyDB, ...)

+ type AggSigDB interface

+ Await func(context.Context, Duty, PubKey) (AggSignedData, error)

+ Store func(context.Context, Duty, PubKey, AggSignedData) error

+ type AggSignedData struct

+ Data []byte

+ Signature Signature

+ func EncodeAttestationAggSignedData(att *eth2p0.Attestation) (AggSignedData, error)

+ func EncodeRandaoAggSignedData(randao eth2p0.BLSSignature) AggSignedData

+ func (a AggSignedData) Equal(b AggSignedData) bool

+ type AttestationData struct

+ Data eth2p0.AttestationData

+ Duty eth2v1.AttesterDuty

+ func DecodeAttesterUnsignedData(unsignedData UnsignedData) (*AttestationData, error)

+ type Broadcaster interface

+ Broadcast func(context.Context, Duty, PubKey, AggSignedData) error

+ type Consensus interface

+ Propose func(context.Context, Duty, UnsignedDataSet) error

+ Subscribe func(func(context.Context, Duty, UnsignedDataSet) error)

+ type Duty struct

+ Slot int64

+ Type DutyType

+ func NewAttesterDuty(slot int64) Duty

+ func (d Duty) String() string

+ type DutyDB interface

+ AwaitAttestation func(ctx context.Context, slot, commIdx int64) (*eth2p0.AttestationData, error)

+ PubKeyByAttestation func(ctx context.Context, slot, commIdx, valCommIdx int64) (PubKey, error)

+ Store func(context.Context, Duty, UnsignedDataSet) error

+ type DutyType int

+ func AllDutyTypes() []DutyType

+ func (d DutyType) String() string

+ func (d DutyType) Valid() bool

+ type FetchArg []byte

+ func EncodeAttesterFetchArg(attDuty *eth2v1.AttesterDuty) (FetchArg, error)

+ func EncodeProposerFetchArg(proDuty *eth2v1.ProposerDuty) (FetchArg, error)

+ type FetchArgSet map[PubKey]FetchArg

+ type Fetcher interface

+ Fetch func(context.Context, Duty, FetchArgSet) error

+ RegisterAggSigDB func(func(context.Context, Duty, PubKey) (AggSignedData, error))

+ Subscribe func(func(context.Context, Duty, UnsignedDataSet) error)

+ type ParSigDB interface

+ StoreExternal func(context.Context, Duty, ParSignedDataSet) error

+ StoreInternal func(context.Context, Duty, ParSignedDataSet) error

+ SubscribeInternal func(func(context.Context, Duty, ParSignedDataSet) error)

+ SubscribeThreshold func(func(context.Context, Duty, PubKey, []ParSignedData) error)

+ type ParSigEx interface

+ Broadcast func(context.Context, Duty, ParSignedDataSet) error

+ Subscribe func(func(context.Context, Duty, ParSignedDataSet) error)

+ type ParSignedData struct

+ Data []byte

+ ShareIdx int

+ Signature Signature

+ func EncodeAttestationParSignedData(att *eth2p0.Attestation, shareIdx int) (ParSignedData, error)

+ func EncodeRandaoParSignedData(randao eth2p0.BLSSignature, shareIdx int) ParSignedData

+ type ParSignedDataSet map[PubKey]ParSignedData

+ type PubKey string

+ func PubKeyFromBytes(bytes []byte) (PubKey, error)

+ func (k PubKey) Bytes() ([]byte, error)

+ func (k PubKey) String() string

+ func (k PubKey) ToETH2() (eth2p0.BLSPubKey, error)

+ type Scheduler interface

+ Subscribe func(func(context.Context, Duty, FetchArgSet) error)

+ type SigAgg interface

+ Aggregate func(context.Context, Duty, PubKey, []ParSignedData) error

+ Subscribe func(func(context.Context, Duty, PubKey, AggSignedData) error)

+ type Signature []byte

+ func SigFromETH2(sig eth2p0.BLSSignature) Signature

+ func (s Signature) ToETH2() eth2p0.BLSSignature

+ type UnsignedData []byte

+ func EncodeAttesterUnsignedData(attData *AttestationData) (UnsignedData, error)

+ func EncodeProposerUnsignedData(proData *spec.VersionedBeaconBlock) (UnsignedData, error)

+ type UnsignedDataSet map[PubKey]UnsignedData

+ type ValidatorAPI interface

+ RegisterAwaitAttestation func(...)

+ RegisterParSigDB func(func(context.Context, Duty, ParSignedDataSet) error)

+ RegisterPubKeyByAttestation func(func(ctx context.Context, slot, commIdx, valCommIdx int64) (PubKey, error))

+ type WireOption func(*wireFuncs)

+ func WithTracing() WireOption