service

Documentation

Index

• Constants
• Variables
• type API
  • func NewAPI(metrics m.Metricer, logger log.Logger, archiver *Archiver) *API
• type Archiver
  • func NewArchiver(l log.Logger, cfg flags.ArchiverConfig, dataStoreClient storage.DataStore, ...) (*Archiver, error)
  • func (a *Archiver) Start(ctx context.Context) error
  • func (a *Archiver) Stop(ctx context.Context) error
• type ArchiverService
  • func NewService(l log.Logger, cfg flags.ArchiverConfig, api *API, archiver *Archiver, ...) (*ArchiverService, error)
  • func (a *ArchiverService) Start(ctx context.Context) error
  • func (a *ArchiverService) Stop(ctx context.Context) error
  • func (a *ArchiverService) Stopped() bool
• type BeaconClient

Constants

const LockTimeout = int64(20) // 20 seconds

const LockUpdateInterval = 10 * time.Second

Variables

var ErrAlreadyStopped = errors.New("already stopped")

var ObtainLockRetryInterval = 10 * time.Second

Types

type API

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

func NewAPI

func NewAPI(metrics m.Metricer, logger log.Logger, archiver *Archiver) *API

NewAPI creates a new Archiver API instance. This API exposes an admin interface to control the archiver.

type Archiver

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

func NewArchiver

func NewArchiver(l log.Logger, cfg flags.ArchiverConfig, dataStoreClient storage.DataStore, client BeaconClient, m metrics.Metricer) (*Archiver, error)

func (*Archiver) Start

func (a *Archiver) Start(ctx context.Context) error

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.

func (*Archiver) Stop

func (a *Archiver) Stop(ctx context.Context) error

Stops the archiver service.

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
}