metrics

package
v0.0.0-...-41a5b5c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetColumnNames 

func GetColumnNames(columns []Column) []string

Types

type AggregatedPipelinePerformance 

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

func CreateAggregatedPipelinePerformance 

func CreateAggregatedPipelinePerformance(client clients.BuildkiteClient, lastNBuilds int, pipelines ...*data.PipelineID) *AggregatedPipelinePerformance

CREATE TABLE aggregated_pipeline_performance (org VARCHAR(255), pipeline VARCHAR(255), build INT, scheduled DATETIME, total_time_seconds FLOAT, skipped_tasks VARCHAR(255), result VARCHAR(16), PRIMARY KEY(org, pipeline, build));

func (*AggregatedPipelinePerformance) Collect 

func (app *AggregatedPipelinePerformance) Collect() (data.DataSet, error)

func (*AggregatedPipelinePerformance) Columns 

func (app *AggregatedPipelinePerformance) Columns() []Column

func (*AggregatedPipelinePerformance) Name 

func (app *AggregatedPipelinePerformance) Name() string

func (*AggregatedPipelinePerformance) RelevantDelta 

func (*AggregatedPipelinePerformance) RelevantDelta() int

func (*AggregatedPipelinePerformance) Type 

func (*AggregatedPipelinePerformance) Type() MetricType

type BuildSuccess 

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

func CreateBuildSuccess 

func CreateBuildSuccess(client clients.BuildkiteClient, builds int, pipelines ...*data.PipelineID) *BuildSuccess

CREATE TABLE build_success (org VARCHAR(255), pipeline VARCHAR(255), build INT, linux VARCHAR(255), macos VARCHAR(255), windows VARCHAR(255), rbe VARCHAR(255), PRIMARY KEY(org, pipeline, build));

func (*BuildSuccess) Collect 

func (bs *BuildSuccess) Collect() (data.DataSet, error)

func (*BuildSuccess) Columns 

func (bs *BuildSuccess) Columns() []Column

func (*BuildSuccess) Name 

func (bs *BuildSuccess) Name() string

type BuildsPerChange 

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

func CreateBuildsPerChange 

func CreateBuildsPerChange(client clients.BuildkiteClient, builds int, pipelines ...*data.PipelineID) *BuildsPerChange

CREATE TABLE builds_per_change (org VARCHAR(255), pipeline VARCHAR(255), changelist INT, builds INT, PRIMARY KEY(org, pipeline, changelist));

func (*BuildsPerChange) Collect 

func (bps *BuildsPerChange) Collect() (data.DataSet, error)

func (*BuildsPerChange) Columns 

func (bps *BuildsPerChange) Columns() []Column

func (*BuildsPerChange) Name 

func (bps *BuildsPerChange) Name() string

type CloudBuildStatus 

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

func CreateCloudBuildStatus 

func CreateCloudBuildStatus(ctx context.Context, projectID, subscriptionID string) (*CloudBuildStatus, error)

CREATE TABLE cloud_build_status (timestamp DATETIME, build VARCHAR(255), source VARCHAR(255), success BOOL, PRIMARY KEY(timestamp, build));

func (*CloudBuildStatus) Collect 

func (cbs *CloudBuildStatus) Collect() (data.DataSet, error)

func (*CloudBuildStatus) Columns 

func (cbs *CloudBuildStatus) Columns() []Column

func (*CloudBuildStatus) Name 

func (cbs *CloudBuildStatus) Name() string

func (*CloudBuildStatus) RelevantDelta 

func (*CloudBuildStatus) RelevantDelta() int

func (*CloudBuildStatus) Type 

func (*CloudBuildStatus) Type() MetricType

type Column 

type Column struct {
	Name  string
	IsKey bool
}

type CriticalPath 

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

func CreateCriticalPath 

func CreateCriticalPath(client clients.BuildkiteClient, lastNBuilds int, pipelines ...*data.PipelineID) *CriticalPath

CREATE TABLE critical_path (org VARCHAR(255), pipeline VARCHAR(255), build INT, wait_time_seconds FLOAT, run_time_seconds FLOAT, longest_task_name VARCHAR(255), longest_task_time_seconds FLOAT, result VARCHAR(255), PRIMARY KEY(org, pipeline, build));

func (*CriticalPath) Collect 

func (cp *CriticalPath) Collect() (data.DataSet, error)

func (*CriticalPath) Columns 

func (cp *CriticalPath) Columns() []Column

func (*CriticalPath) Name 

func (cp *CriticalPath) Name() string

func (*CriticalPath) RelevantDelta 

func (*CriticalPath) RelevantDelta() int

func (*CriticalPath) Type 

func (*CriticalPath) Type() MetricType

type DailyPerformance 

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

func CreateDailyPerformance 

func CreateDailyPerformance(client clients.BuildkiteClient, lastNBuilds int, pipelines ...*data.PipelineID) *DailyPerformance

CREATE TABLE daily_performance (org VARCHAR(255), pipeline VARCHAR(255), day DATE, passed_builds INT, median_seconds FLOAT, p90_seconds FLOAT, p95_seconds FLOAT, p99_seconds FLOAT, PRIMARY KEY(org, pipeline, day));

func (*DailyPerformance) Collect 

func (dp *DailyPerformance) Collect() (data.DataSet, error)

func (*DailyPerformance) Columns 

func (dp *DailyPerformance) Columns() []Column

func (*DailyPerformance) Name 

func (dp *DailyPerformance) Name() string

type Flakiness 

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

func CreateFlakiness 

func CreateFlakiness(client *clients.CloudStorageClient, gcsBucket, gcsBasePath string, pipelines ...*data.PipelineID) *Flakiness

CREATE TABLE flakiness (org VARCHAR(255), pipeline VARCHAR(255), build INT, target VARCHAR(255), passed_count INT, failed_count INT, PRIMARY KEY(org, pipeline, build, target));

func (*Flakiness) Collect 

func (f *Flakiness) Collect() (data.DataSet, error)

func (*Flakiness) Columns 

func (f *Flakiness) Columns() []Column

func (*Flakiness) Name 

func (f *Flakiness) Name() string

type GarbageCollectedMetric 

type GarbageCollectedMetric interface {
	Metric
	Type() MetricType
	RelevantDelta() int
}

type MacPerformance 

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

func CreateMacPerformance 

func CreateMacPerformance(client clients.BuildkiteClient, lastNBuilds int, pipelines ...*data.PipelineID) *MacPerformance

CREATE TABLE mac_performance (org VARCHAR(255), pipeline VARCHAR(255), build INT, shard INT, wait_time_seconds FLOAT, run_time_seconds FLOAT, skipped BOOL, PRIMARY KEY(org, pipeline, build, shard));

func (*MacPerformance) Collect 

func (mp *MacPerformance) Collect() (data.DataSet, error)

func (*MacPerformance) Columns 

func (mp *MacPerformance) Columns() []Column

func (*MacPerformance) Name 

func (mp *MacPerformance) Name() string

type Metric 

type Metric interface {
	Name() string
	Columns() []Column
	Collect() (data.DataSet, error)
}

type MetricType 

type MetricType int
const (
	TimeBasedMetric MetricType = iota
	BuildBasedMetric
)

type PipelinePerformance 

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

func CreatePipelinePerformance 

func CreatePipelinePerformance(client clients.BuildkiteClient, lastNBuilds int, pipelines ...*data.PipelineID) *PipelinePerformance

CREATE TABLE pipeline_performance (org VARCHAR(255), pipeline VARCHAR(255), build INT, job VARCHAR(255), creation_time DATETIME, wait_time_seconds FLOAT, run_time_seconds FLOAT, skipped_tasks VARCHAR(255), PRIMARY KEY(org, pipeline, build, job));

func (*PipelinePerformance) Collect 

func (pp *PipelinePerformance) Collect() (data.DataSet, error)

func (*PipelinePerformance) Columns 

func (pp *PipelinePerformance) Columns() []Column

func (*PipelinePerformance) Name 

func (pp *PipelinePerformance) Name() string

func (*PipelinePerformance) RelevantDelta 

func (*PipelinePerformance) RelevantDelta() int

func (*PipelinePerformance) Type 

func (*PipelinePerformance) Type() MetricType

type PlatformLoad 

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

func CreatePlatformLoad 

func CreatePlatformLoad(client clients.BuildkiteClient, builds int, orgs ...string) *PlatformLoad

CREATE TABLE platform_load (timestamp DATETIME, org VARCHAR(255), platform VARCHAR(255), waiting_jobs INT, running_jobs INT, PRIMARY KEY(org, timestamp, platform));

func (*PlatformLoad) Collect 

func (pl *PlatformLoad) Collect() (data.DataSet, error)

func (*PlatformLoad) Columns 

func (pl *PlatformLoad) Columns() []Column

func (*PlatformLoad) Name 

func (pl *PlatformLoad) Name() string

func (*PlatformLoad) RelevantDelta 

func (*PlatformLoad) RelevantDelta() int

func (*PlatformLoad) Type 

func (*PlatformLoad) Type() MetricType

type PlatformSignificance 

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

func CreatePlatformSignificance 

func CreatePlatformSignificance(client clients.BuildkiteClient, builds int, pipelines ...*data.PipelineID) *PlatformSignificance

CREATE TABLE platform_significance (org VARCHAR(255), pipeline VARCHAR(255), total_builds INT, passing_builds INT, canceled_builds INT, setup_failed INT, linux_failures INT, macos_failures INT, windows_failures INT, rbe_failures INT, multi_platform_failures INT, PRIMARY KEY(org, pipeline));

func (*PlatformSignificance) Collect 

func (ps *PlatformSignificance) Collect() (data.DataSet, error)

func (*PlatformSignificance) Columns 

func (ps *PlatformSignificance) Columns() []Column

func (*PlatformSignificance) Name 

func (ps *PlatformSignificance) Name() string

type PlatformUsage 

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

func CreatePlatformUsage 

func CreatePlatformUsage(client clients.BuildkiteClient, builds int, orgs ...string) *PlatformUsage

CREATE TABLE platform_usage (org VARCHAR(255), pipeline VARCHAR(255), build INT, platform VARCHAR(255), usage_seconds FLOAT, PRIMARY KEY(org, pipeline, build, platform));

func (*PlatformUsage) Collect 

func (pu *PlatformUsage) Collect() (data.DataSet, error)

func (*PlatformUsage) Columns 

func (pu *PlatformUsage) Columns() []Column

func (*PlatformUsage) Name 

func (pu *PlatformUsage) Name() string

func (*PlatformUsage) RelevantDelta 

func (*PlatformUsage) RelevantDelta() int

func (*PlatformUsage) Type 

func (*PlatformUsage) Type() MetricType

type ReleaseDownloads 

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

func CreateReleaseDownloads 

func CreateReleaseDownloads(org string, repo string, token string, minSizeBytes int) *ReleaseDownloads

CREATE TABLE release_downloads (release_name VARCHAR(255), artifact VARCHAR(255), downloads INT, PRIMARY KEY(release_name, artifact));

func (*ReleaseDownloads) Collect 

func (rd *ReleaseDownloads) Collect() (data.DataSet, error)

func (*ReleaseDownloads) Columns 

func (rd *ReleaseDownloads) Columns() []Column

func (*ReleaseDownloads) Name 

func (rd *ReleaseDownloads) Name() string

type WorkerAvailability 

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

func CreateWorkerAvailability 

func CreateWorkerAvailability(client clients.BuildkiteClient, orgs ...string) *WorkerAvailability

CREATE TABLE worker_availability (timestamp DATETIME, org VARCHAR(255), platform VARCHAR(255), idle_count INT, busy_count INT, PRIMARY KEY(timestamp, org, platform));

func (*WorkerAvailability) Collect 

func (wa *WorkerAvailability) Collect() (data.DataSet, error)

func (*WorkerAvailability) Columns 

func (wa *WorkerAvailability) Columns() []Column

func (*WorkerAvailability) Name 

func (wa *WorkerAvailability) Name() string

func (*WorkerAvailability) RelevantDelta 

func (wa *WorkerAvailability) RelevantDelta() int

func (*WorkerAvailability) Type 

func (wa *WorkerAvailability) Type() MetricType

type ZombieInstances 

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

func CreateZombieInstances 

func CreateZombieInstances(computeClient *clients.ComputeEngineClient, cloudProjects []string, bkClient clients.BuildkiteClient, bkOrgs []string, gracePeriod time.Duration) *ZombieInstances

CREATE TABLE zombie_instances (cloud_project VARCHAR(255), zone VARCHAR(255), instance VARCHAR(255), status VARCHAR(255), seconds_online FLOAT, timestamp DATETIME, PRIMARY KEY(cloud_project, zone, instance));

func (*ZombieInstances) Collect 

func (zi *ZombieInstances) Collect() (data.DataSet, error)

func (*ZombieInstances) Columns 

func (zi *ZombieInstances) Columns() []Column

func (*ZombieInstances) Name 

func (zi *ZombieInstances) Name() string

func (*ZombieInstances) RelevantDelta 

func (*ZombieInstances) RelevantDelta() int

func (*ZombieInstances) Type 

func (*ZombieInstances) Type() MetricType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.