ingest

Documentation

Overview

Package ingest implements ingestion of benchmark results.

Index

• type Ingester
  • func New(d *db.DB, l *results.Loader) *Ingester
  • func (i *Ingester) SetLogger(l *zap.Logger)
  • func (i *Ingester) Task(ctx context.Context, id uuid.UUID) error

Types

type Ingester

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

Ingester loads task results files and inserts them in to the database.

func New

func New(d *db.DB, l *results.Loader) *Ingester

New builds an ingester.

func (*Ingester) SetLogger

func (i *Ingester) SetLogger(l *zap.Logger)

SetLogger configures Ingester logging.

func (*Ingester) Task

func (i *Ingester) Task(ctx context.Context, id uuid.UUID) error

Task ingests results for the given task.