Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAlreadyStopped = errors.New("already stopped")
Functions ¶
This section is empty.
Types ¶
type Archiver ¶
type Archiver struct {
// contains filtered or unexported fields
}
func NewArchiver ¶
func (*Archiver) Start ¶
Start starts archiving blobs. It begins polling the beacon node for the latest blocks and persisting blobs for them. Concurrently it'll also begin a backfill process (see backfillBlobs) to store all blobs from the current head to the previously stored blocks. This ensures that during restarts or outages of an archiver, any gaps will be filled in.
type ArchiverService ¶
type ArchiverService struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(l log.Logger, cfg flags.ArchiverConfig, api *API, archiver *Archiver, m metrics.Metricer) (*ArchiverService, error)
func (*ArchiverService) Start ¶
func (a *ArchiverService) Start(ctx context.Context) error
Start starts the archiver service. It'll start the API's as well as the archiving process.
func (*ArchiverService) Stop ¶
func (a *ArchiverService) Stop(ctx context.Context) error
Stops the archiver service.
func (*ArchiverService) Stopped ¶
func (a *ArchiverService) Stopped() bool
type BeaconClient ¶
type BeaconClient interface {
client.BlobSidecarsProvider
client.BeaconBlockHeadersProvider
}
Source Files
Click to show internal directories.
Click to hide internal directories.