Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAlreadyStopped = errors.New("already stopped")
Functions ¶
This section is empty.
Types ¶
type BlobSidecarClient ¶
type BlobSidecarClient interface {
// FetchSidecars fetches the sidecars for a given slot from the blob sidecar API. It returns the HTTP status code and
// the sidecars.
FetchSidecars(id string, format Format) (int, storage.BlobSidecars, error)
}
BlobSidecarClient is a minimal client for fetching sidecars from the blob service. This client is used instead of an existing client for two reasons. 1) Does not require any endpoints except /eth/v1/blob_sidecar, which is the only endpoint that the Blob API supports 2) Exposes implementation details, e.g. status code, as well as allowing us to specify the format
func NewBlobSidecarClient ¶
func NewBlobSidecarClient(url string) BlobSidecarClient
NewBlobSidecarClient creates a new BlobSidecarClient that fetches sidecars from the given URL.
type CheckBlobResult ¶
type CheckBlobResult struct {
// ErrorFetching contains the list of slots for which the blob-api or beacon-node returned an error
ErrorFetching []string
// MismatchedStatus contains the list of slots for which the status code from the blob-api and beacon-node did not match
MismatchedStatus []string
// MismatchedData contains the list of slots for which the data from the blob-api and beacon-node did not match
MismatchedData []string
}
CheckBlobResult contains the summary of the blob checks
type ValidatorService ¶
type ValidatorService struct {
// contains filtered or unexported fields
}
func NewValidator ¶
func NewValidator(l log.Logger, headerClient client.BeaconBlockHeadersProvider, beaconAPI BlobSidecarClient, blobAPI BlobSidecarClient, app context.CancelCauseFunc) *ValidatorService
func (*ValidatorService) Start ¶
func (a *ValidatorService) Start(ctx context.Context) error
Start starts the validator service. This will fetch the current range of blocks to validate and start the validation process.
func (*ValidatorService) Stop ¶
func (a *ValidatorService) Stop(ctx context.Context) error
Stops the validator service.
func (*ValidatorService) Stopped ¶
func (a *ValidatorService) Stopped() bool
Source Files
Click to show internal directories.
Click to hide internal directories.