backfill

Documentation

Index

• func FillIndex(store shared.Datastore, logger shared.Logger, rt monitor.Runtime, ...) (monitor.Monitor, error)
• func GetDatastore(projectID string, gcpCredentialsFile *string, _ shared.Logger) (shared.Datastore, error)

Functions

func FillIndex

func FillIndex(
	store shared.Datastore,
	logger shared.Logger,
	rt monitor.Runtime,
	interval time.Duration,
	maxIngestedRuns uint,
	maxBytes uint64,
	evictionPercent float64,
	idx index.Index,
) (monitor.Monitor, error)

FillIndex starts backfilling an index given a series of configuration parameters for run fetching and index monitoring. The backfilling process will halt either: The first time a run is evicted from the index.Index via EvictAnyRun(), OR the first time the returned monitor.Monitor is stopped via Stop(). nolint:ireturn // TODO: Fix ireturn lint error

func GetDatastore

func GetDatastore(projectID string, gcpCredentialsFile *string, _ shared.Logger) (shared.Datastore, error)

GetDatastore constructs a shared.Datastore interface that loads runs from Datastore in reverse cronological order, by shared.TestRun.TimeStart. nolint:ireturn // TODO: Fix ireturn lint error