jobrunaggregatorapi

type AggregatedTestRunRow struct {
	AggregationStartDate time.Time
	TestName             string
	// TODO work out how to avoid the bigquery dep
	TestSuiteName     bigquery.NullString
	JobName           string
	PassCount         int
	FailCount         int
	FlakeCount        int
	PassPercentage    float64
	WorkingPercentage float64
	DominantCluster   string
}

type AlertHistoricalDataRow struct {
	AlertName      string
	AlertNamespace string
	AlertLevel     string
	FirstObserved  time.Time
	LastObserved   time.Time
	HistoricalJobData
	P95 string
	P99 string
	P75 string
	P50 string
}

type AlertRow struct {
	Name               string
	Namespace          string
	Level              string
	AlertSeconds       int
	JobName            bigquery.NullString
	JobRunName         string
	JobRunStartTime    bigquery.NullTimestamp
	JobRunEndTime      bigquery.NullTimestamp
	Cluster            bigquery.NullString
	ReleaseTag         bigquery.NullString
	MasterNodesUpdated bigquery.NullString
	JobRunStatus       bigquery.NullString
}

type BackendDisruptionRow struct {
	BackendName        string
	DisruptionSeconds  int
	JobName            bigquery.NullString
	JobRunName         string
	JobRunStartTime    bigquery.NullTimestamp
	JobRunEndTime      bigquery.NullTimestamp
	Cluster            bigquery.NullString
	ReleaseTag         bigquery.NullString
	MasterNodesUpdated bigquery.NullString
	JobRunStatus       bigquery.NullString
}

type BackendDisruptionStatisticsRow struct {
	BackendName       string
	Mean              float64
	StandardDeviation float64
	P1                float64
	P2                float64
	P3                float64
	P4                float64
	P5                float64
	P6                float64
	P7                float64
	P8                float64
	P9                float64
	P10               float64
	P11               float64
	P12               float64
	P13               float64
	P14               float64
	P15               float64
	P16               float64
	P17               float64
	P18               float64
	P19               float64
	P20               float64
	P21               float64
	P22               float64
	P23               float64
	P24               float64
	P25               float64
	P26               float64
	P27               float64
	P28               float64
	P29               float64
	P30               float64
	P31               float64
	P32               float64
	P33               float64
	P34               float64
	P35               float64
	P36               float64
	P37               float64
	P38               float64
	P39               float64
	P40               float64
	P41               float64
	P42               float64
	P43               float64
	P44               float64
	P45               float64
	P46               float64
	P47               float64
	P48               float64
	P49               float64
	P50               float64
	P51               float64
	P52               float64
	P53               float64
	P54               float64
	P55               float64
	P56               float64
	P57               float64
	P58               float64
	P59               float64
	P60               float64
	P61               float64
	P62               float64
	P63               float64
	P64               float64
	P65               float64
	P66               float64
	P67               float64
	P68               float64
	P69               float64
	P70               float64
	P71               float64
	P72               float64
	P73               float64
	P74               float64
	P75               float64
	P76               float64
	P77               float64
	P78               float64
	P79               float64
	P80               float64
	P81               float64
	P82               float64
	P83               float64
	P84               float64
	P85               float64
	P86               float64
	P87               float64
	P88               float64
	P89               float64
	P90               float64
	P91               float64
	P92               float64
	P93               float64
	P94               float64
	P95               float64
	P96               float64
	P97               float64
	P98               float64
	P99               float64
}

type DisruptionHistoricalDataRow struct {
	BackendName string
	HistoricalJobData
	P95 string
	P99 string
	P75 string
	P50 string
}

type HistoricalData interface {
	GetJobData() HistoricalJobData
	GetName() string
	GetP99() string
	GetP95() string
	GetP75() string
	GetP50() string
	GetKey() string
	GetJobRuns() int
}

type HistoricalJobData struct {
	Release            string
	FromRelease        string
	Platform           string
	Architecture       string
	Network            string
	Topology           string
	MasterNodesUpdated bigquery.NullString
	// JobRuns is the number of job runs that were included when we queried the historical data.
	JobRuns int
}

type JobRow struct {
	JobName                     string
	GCSBucketName               string
	GCSJobHistoryLocationPrefix string
	CollectDisruption           bool
	CollectTestRuns             bool
	Platform                    string
	Architecture                string
	Network                     string
	IPMode                      string
	Topology                    string
	Release                     string
	FromRelease                 string
	RunsUpgrade                 bool
	RunsE2EParallel             bool
	RunsE2ESerial               bool
}

type JobRunInfo interface {
	IsFinished(ctx context.Context) bool

	GetJobName() string
	GetJobRunID() string

	// GetHumanURL returns prow job URL for this job run.
	GetHumanURL() string

	// GetGCSArtifactURL returns the URL for this job run's artifacts in GCS.
	GetGCSArtifactURL() string

	GetGCSProwJobPath() string
	GetGCSJunitPaths() []string
	SetGCSProwJobPath(gcsProwJobPath string)
	AddGCSJunitPaths(junitPaths ...string)
	AddGCSProwJobFileNames(fileNames ...string)

	GetProwJob(ctx context.Context) (*prowjobv1.ProwJob, error)
	GetJobRunFromGCS(ctx context.Context) error
	GetCombinedJUnitTestSuites(ctx context.Context) (*junit.TestSuites, error)
	// GetOpenShiftTestsFilesWithPrefix checks the datasource for "openshift-e2e-test/artifacts/junit/<prefix>*"
	// and returns that content indexed by local filename.  This is useful for things like back-disruption and alerts.
	GetOpenShiftTestsFilesWithPrefix(ctx context.Context, prefix string) (map[string]string, error)
	GetContent(ctx context.Context, path string) ([]byte, error)
	ClearAllContent()

	WriteCache(ctx context.Context, parentDir string) error
}

type JobRunRow struct {
	Name               string
	JobName            string
	Status             string
	StartTime          time.Time
	EndTime            time.Time
	ReleaseTag         string
	Cluster            string
	MasterNodesUpdated bigquery.NullString
}

type KnownAlertRow struct {
	AlertName      string
	AlertNamespace string
	AlertLevel     string
	Release        string
	FirstObserved  time.Time
	LastObserved   time.Time
	Results        int
}

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

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

type ReleaseJobRunRow struct {
	// Name contains the Prow name of this job run.
	Name string `bigquery:"name"`

	// ReleaseTag is the OpenShift version, e.g. 4.8.0-0.nightly-2021-10-28-013428.
	ReleaseTag string `bigquery:"releaseTag"`

	// JobName contains the job name as known by the release controller --
	// this is a shortened form like "aws-serial"
	JobName string `bigquery:"jobName"`

	// Kind contains the job run kind, i.e. whether it's Blocking or Informing.
	Kind string `bigquery:"kind"`

	// State holds the overall status of the job, such as Failed.
	State string `bigquery:"state"`

	// URL contains a link to Prow.
	URL string `bigquery:"url"`

	// Transition time contains the transition time from the release
	// controller.
	TransitionTime time.Time `bigquery:"transitionTime"`

	// Retries contains the number of retries were performed on this job,
	// for this release tag.
	Retries int `bigquery:"retries"`

	// UpgradesFrom contains the source version when this job run is
	// an upgrade.
	UpgradesFrom string `bigquery:"upgradesFrom"`

	// UpgradesTo contains the target version when this job run is
	// an upgrade.
	UpgradesTo string `bigquery:"upgradesTo"`

	// Upgrade is a flag that indicates whether this job run was an upgrade or not.
	Upgrade bool `bigquery:"upgrade"`
}

type ReleasePullRequestRow struct {
	// PullRequestID contains the GitHub pull request number.
	PullRequestID string `bigquery:"pullRequestID"`

	// ReleaseTag is the OpenShift version, e.g. 4.8.0-0.nightly-2021-10-28-013428.
	ReleaseTag string `bigquery:"releaseTag"`

	// Name contains the names as the repository is known in the release payload.
	Name string `bigquery:"name"`

	// Description is the PR description.
	Description string `bigquery:"description"`

	// URL is a link to the pull request.
	URL string `bigquery:"url"`

	// BugURL links to the bug, if any.
	BugURL string `bigquery:"bugURL"`
}

type ReleaseRepositoryRow struct {
	// Name contains the repositories names as they are known in the release payload. It
	// is often but not always the repository name.
	Name string `bigquery:"name"`

	// ReleaseTag is the OpenShift version, e.g. 4.8.0-0.nightly-2021-10-28-013428.
	ReleaseTag string `bigquery:"releaseTag"`

	// Head contains a link to the repository head of this repo.
	Head string `bigquery:"repositoryHead"`

	// FullChangelog contains a link that diffs the contents of this repo
	// from the prior accepted release.
	FullChangelog string `bigquery:"fullChangeLog"`
}

type ReleaseRow struct {
	// Release contains the X.Y version of the payload, e.g. 4.8
	Release string `bigquery:"release"`

	// Major contains the major part of the release, e.g. 4
	Major int `bigquery:"Major"`

	// Minor contains the minor part of the release, e.g. 8
	Minor int `bigquery:"Minor"`

	// GADate contains GA date for the release, i.e. the -YYYY-MM-DD
	GADate bigquery.NullDate `bigquery:"GADate"`

	// DevelStartDate contains start date of development of the release, i.e. the -YYYY-MM-DD
	DevelStartDate civil.Date `bigquery:"DevelStartDate"`

	// Product contains the product for the release, e.g. OCP
	Product bigquery.NullString `bigquery:"Product"`

	// Patch contains the patch version number of the release, e.g. 1
	Patch bigquery.NullInt64 `bigquery:"Patch"`
}

type ReleaseTagRow struct {
	// Phase contains the overall status of a payload: e.g. Ready, Accepted,
	// Rejected. We do not store Ready payloads in bigquery, as we only want
	// the release after it's "fully baked."
	Phase string `bigquery:"phase"`

	// Release contains the X.Y version of the payload, e.g. 4.8
	Release string `bigquery:"release"`

	// Stream contains the stream of the payload, e.g. nightly or ci
	Stream string `bigquery:"stream"`

	// Architecture contains the architecture for the release, e.g. amd64
	Architecture string `bigquery:"architecture"`

	// ReleaseTag contains the release version, e.g. 4.8.0-0.nightly-2021-10-28-013428.
	ReleaseTag string `bigquery:"releaseTag"`

	// ReleaseTime contains the time the release was created, i.e. the -YYYY-MM-DD-HHMMSS suffix
	// of 4.8.0-0.nightly-2021-10-28-013428.
	ReleaseTime time.Time `bigquery:"releaseTime"`

	// PreviousReleaseTag contains the previously accepted build, on which any
	// changelog is based from.
	PreviousReleaseTag string `bigquery:"previousReleaseTag"`

	// KubernetesVersion contains the kube version, i.e. 1.22.1.
	KubernetesVersion string `bigquery:"kubernetesVersion"`

	// CurrentOSVersion contains the current machine OS version.
	CurrentOSVersion string `bigquery:"currentOSVersion"`

	// PreviousOSVersion, if any, indicates this release included a machine OS
	// upgrade and this field contains the prior version.
	PreviousOSVersion string `bigquery:"previousOSVersion"`

	// CurrentOSURL is a link to the release page for this machine OS version.
	CurrentOSURL string `bigquery:"currentOSURL"`

	// PreviousOSURL is a link to the release page for the previous machine OS version.
	PreviousOSURL string `bigquery:"previousOSURL"`

	// OSDiffURL is a link to the release page diffing the two OS versions.
	OSDiffURL string `bigquery:"osDiffURL"`
}

type TestPlatformProwJobRow struct {
	JobName        string    `bigquery:"prowjob_job_name"`
	State          string    `bigquery:"prowjob_state"`
	BuildID        string    `bigquery:"prowjob_build_id"`
	Type           string    `bigquery:"prowjob_type"`
	Cluster        string    `bigquery:"prowjob_cluster"`
	StartTime      time.Time `bigquery:"prowjob_start_ts"`
	CompletionTime time.Time `bigquery:"prowjob_completion_ts"`
	URL            string    `bigquery:"prowjob_url"`
}

type TestRunRow struct {
	Name               string
	Status             string
	TestSuite          string
	JobName            bigquery.NullString
	JobRunName         string
	JobRunStartTime    bigquery.NullTimestamp
	JobRunEndTime      bigquery.NullTimestamp
	Cluster            bigquery.NullString
	ReleaseTag         bigquery.NullString
	MasterNodesUpdated bigquery.NullString
	JobRunStatus       bigquery.NullString
}

type UnifiedTestRunRow struct {
	TestName        string
	JobRunName      string
	JobName         string
	TestStatus      string
	JobRunStartTime time.Time
	ReleaseTag      string
	Cluster         string
}