updater

Documentation

Overview

Package updater reads the latest test results and saves updated state.

Index

• Variables
• func Update(parent context.Context, client gcs.ConditionalClient, configPath gcs.Path, ...) error
• type GroupUpdater
  • func GCS(groupTimeout, buildTimeout time.Duration, concurrency int, write bool) GroupUpdater

Variables

var AllowMultiplePaths = map[string]bool{}

AllowMultiplePaths enables combining multiple jobs together using a comma.

This feature is undocumented and poorly tested, so restrict to specific groups. TODO(fejta): redesign this feature (using symlinks?), ensure it works correctly.

Functions

func Update

func Update(parent context.Context, client gcs.ConditionalClient, configPath gcs.Path, gridPrefix string, groupConcurrency int, group string, updateGroup GroupUpdater) error

Update performs a single update pass of all all test groups specified by the config.

Types

type GroupUpdater

type GroupUpdater func(parent context.Context, log logrus.FieldLogger, client gcs.Client, tg *configpb.TestGroup, gridPath gcs.Path) error

GroupUpdater will compile the grid state proto for the specified group and upload it.

This typically involves downloading the existing state, dropping old columns, compiling any new columns and inserting them into the front and then uploading the proto to GCS.

func GCS

func GCS(groupTimeout, buildTimeout time.Duration, concurrency int, write bool) GroupUpdater

GCS returns a GCS-based GroupUpdater, which knows how to process result data stored in GCS.