tabulator

Documentation

Overview

Package tabulator processes test group state into tab state.

Index

• func TabStatePath(configPath gcs.Path, tabPrefix, dashboardName, tabName string) (*gcs.Path, error)
• func Update(ctx context.Context, client gcs.ConditionalClient, mets *Metrics, ...) error
• type Fixer
  • func FixGCS(client pubsub.Subscriber, log logrus.FieldLogger, projID, subID string, ...) (Fixer, error)
  • func FixPersistent(log logrus.FieldLogger, client queue.PersistClient, path gcs.Path, ...) Fixer
• type Metrics
  • func CreateMetrics(factory metrics.Factory) *Metrics

Functions

func TabStatePath

func TabStatePath(configPath gcs.Path, tabPrefix, dashboardName, tabName string) (*gcs.Path, error)

TabStatePath returns the path for a given tab.

func Update

func Update(ctx context.Context, client gcs.ConditionalClient, mets *Metrics, configPath gcs.Path, readConcurrency, writeConcurrency int, gridPathPrefix, tabsPathPrefix string, allowedGroups []string, confirm, calculateStats, useTabAlertSettings, extendState bool, freq time.Duration, fixers ...Fixer) error

Update tab state with the given frequency continuously. If freq == 0, runs only once.

Copies the grid into the tab state, removing unneeded data. Observes each test group in allowedGroups, or all of them in the config if not specified

Types

type Fixer

type Fixer func(context.Context, *config.TestGroupQueue) error

Fixer should adjust the queue until the context expires.

func FixGCS

func FixGCS(client pubsub.Subscriber, log logrus.FieldLogger, projID, subID string, configPath gcs.Path, gridPathPrefix string) (Fixer, error)

FixGCS listens for GCS changes to test groups and schedules another update of its dashboards ~immediately.

Returns when the context is canceled or a processing error occurs.

func FixPersistent

func FixPersistent(log logrus.FieldLogger, client queue.PersistClient, path gcs.Path, tick <-chan time.Time) Fixer

FixPersistent persists the updater queue using queue.FixPersistent.

type Metrics

type Metrics struct {
	UpdateState  metrics.Cyclic
	DelaySeconds metrics.Duration
}

Metrics holds metrics relevant to this controller.

func CreateMetrics

func CreateMetrics(factory metrics.Factory) *Metrics

CreateMetrics creates metrics for this controller