The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- func ErrorReasonToGRPC(reason ErrorReason) codes.Code
- func ErrorReasonToHTTP(reason ErrorReason) int
- func RegisterSyncSubnetCurrentPeriod(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, ...) error
- func RegisterSyncSubnetCurrentPeriodProto(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, ...) error
- func RegisterSyncSubnetNextPeriod(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, ...) error
- func RegisterSyncSubnetNextPeriodProto(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, ...) error
- type AggregateBroadcastFailedError
- type ErrorReason
- type RpcError
- type Service
- func (s *Service) AggregatedSigAndAggregationBits(ctx context.Context, req *ethpb.AggregatedSigAndAggregationBitsRequest) ([]byte, []byte, error)
- func (s *Service) ComputeValidatorPerformance(ctx context.Context, req *ethpb.ValidatorPerformanceRequest) (*ethpb.ValidatorPerformanceResponse, *RpcError)
- func (s *Service) GetAttestationData(ctx context.Context, req *ethpb.AttestationDataRequest) (*ethpb.AttestationData, *RpcError)
- func (s *Service) SubmitSignedAggregateSelectionProof(ctx context.Context, req *ethpb.SignedAggregateSubmitRequest) *RpcError
- func (s *Service) SubmitSignedContributionAndProof(ctx context.Context, req *ethpb.SignedContributionAndProof) *RpcError
- func (s *Service) SubmitSyncMessage(ctx context.Context, msg *ethpb.SyncCommitteeMessage) *RpcError
Constants ¶
const ( Internal = iota BadRequest NotFound )
Variables ¶
This section is empty.
Functions ¶
func ErrorReasonToGRPC ¶
func ErrorReasonToGRPC(reason ErrorReason) codes.Code
func ErrorReasonToHTTP ¶
func ErrorReasonToHTTP(reason ErrorReason) int
func RegisterSyncSubnetCurrentPeriod ¶ added in v4.2.0
func RegisterSyncSubnetCurrentPeriod(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, status validator.Status) error
RegisterSyncSubnetCurrentPeriod registers a persistent subnet for the current sync committee period.
func RegisterSyncSubnetCurrentPeriodProto ¶ added in v4.2.0
func RegisterSyncSubnetCurrentPeriodProto(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, status ethpb.ValidatorStatus) error
RegisterSyncSubnetCurrentPeriodProto registers a persistent subnet for the current sync committee period.
func RegisterSyncSubnetNextPeriod ¶ added in v4.2.0
func RegisterSyncSubnetNextPeriod(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, status validator.Status) error
RegisterSyncSubnetNextPeriod registers a persistent subnet for the next sync committee period.
func RegisterSyncSubnetNextPeriodProto ¶ added in v4.2.0
func RegisterSyncSubnetNextPeriodProto(s beaconState.BeaconState, epoch primitives.Epoch, pubKey []byte, status ethpb.ValidatorStatus) error
RegisterSyncSubnetNextPeriodProto registers a persistent subnet for the next sync committee period.
Types ¶
type AggregateBroadcastFailedError ¶ added in v4.0.8
type AggregateBroadcastFailedError struct {
// contains filtered or unexported fields
}
AggregateBroadcastFailedError represents an error scenario where broadcasting an aggregate selection proof failed.
func NewAggregateBroadcastFailedError ¶ added in v4.0.8
func NewAggregateBroadcastFailedError(err error) AggregateBroadcastFailedError
NewAggregateBroadcastFailedError creates a new error instance.
func (*AggregateBroadcastFailedError) Error ¶ added in v4.0.8
func (e *AggregateBroadcastFailedError) Error() string
Error returns the underlying error message.
type ErrorReason ¶
type ErrorReason uint8
type RpcError ¶
type RpcError struct {
Err error
Reason ErrorReason
}
type Service ¶ added in v4.0.8
type Service struct {
HeadFetcher blockchain.HeadFetcher
FinalizedFetcher blockchain.FinalizationFetcher
GenesisTimeFetcher blockchain.TimeFetcher
SyncChecker sync.Checker
Broadcaster p2p.Broadcaster
SyncCommitteePool synccommittee.Pool
OperationNotifier opfeed.Notifier
AttestationCache *cache.AttestationCache
StateGen stategen.StateManager
P2P p2p.Broadcaster
OptimisticModeFetcher blockchain.OptimisticModeFetcher
}
func (*Service) AggregatedSigAndAggregationBits ¶ added in v4.1.0
func (s *Service) AggregatedSigAndAggregationBits( ctx context.Context, req *ethpb.AggregatedSigAndAggregationBitsRequest) ([]byte, []byte, error)
AggregatedSigAndAggregationBits returns the aggregated signature and aggregation bits associated with a particular set of sync committee messages.
func (*Service) ComputeValidatorPerformance ¶ added in v4.0.8
func (s *Service) ComputeValidatorPerformance( ctx context.Context, req *ethpb.ValidatorPerformanceRequest, ) (*ethpb.ValidatorPerformanceResponse, *RpcError)
ComputeValidatorPerformance reports the validator's latest balance along with other important metrics on rewards and penalties throughout its lifecycle in the beacon chain.
func (*Service) GetAttestationData ¶ added in v4.1.0
func (s *Service) GetAttestationData( ctx context.Context, req *ethpb.AttestationDataRequest, ) (*ethpb.AttestationData, *RpcError)
GetAttestationData requests that the beacon node produces attestation data for the requested committee index and slot based on the nodes current head.
func (*Service) SubmitSignedAggregateSelectionProof ¶ added in v4.0.8
func (s *Service) SubmitSignedAggregateSelectionProof( ctx context.Context, req *ethpb.SignedAggregateSubmitRequest, ) *RpcError
SubmitSignedAggregateSelectionProof verifies given aggregate and proofs and publishes them on appropriate gossipsub topic.
func (*Service) SubmitSignedContributionAndProof ¶ added in v4.0.8
func (s *Service) SubmitSignedContributionAndProof( ctx context.Context, req *ethpb.SignedContributionAndProof, ) *RpcError
SubmitSignedContributionAndProof is called by a sync committee aggregator to submit signed contribution and proof object.
func (*Service) SubmitSyncMessage ¶ added in v4.1.0
SubmitSyncMessage submits the sync committee message to the network. It also saves the sync committee message into the pending pool for block inclusion.
Source Files