tabulator

package

v0.0.125 Latest Latest Go to latest Published: Mar 23, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/GoogleCloudPlatform/testgrid

Links

Open Source Insights

Documentation ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func TabStatePath ¶ added in v0.0.125

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

func Update ¶

func Update(ctx context.Context, client gcs.ConditionalClient, mets *Metrics, configPath gcs.Path, concurrency int, gridPathPrefix, tabsPathPrefix string, confirm bool, freq time.Duration, fixers ...Fixer) error

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

For each dashboard/tab in the config, copy the testgroup state into the tab state.

Types ¶

type Fixer ¶

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

Fixer should adjust the dashboard queue until the context expires.

func FixGCS ¶ added in v0.0.125

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 ¶ added in v0.0.125

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL