jobrunaggregatoranalyzer

Documentation

Index

• func NewJobRunsAnalyzerCommand() *cobra.Command
• type AggregationConfiguration
• type JobRunAggregatorAnalyzerOptions
  • func (o *JobRunAggregatorAnalyzerOptions) CalculateDisruptionTestSuite(ctx context.Context, jobGCSBucketRoot string, ...) (*junit.TestSuite, error)
  • func (o *JobRunAggregatorAnalyzerOptions) GetRelatedJobRuns(ctx context.Context) ([]jobrunaggregatorapi.JobRunInfo, error)
  • func (o *JobRunAggregatorAnalyzerOptions) GetRelatedJobRunsFromIdentifiers(ctx context.Context, jobRunIdentifiers []jobrunaggregatorlib.JobRunIdentifier) ([]jobrunaggregatorapi.JobRunInfo, error)
  • func (o *JobRunAggregatorAnalyzerOptions) Run(ctx context.Context) error
• type JobRunInfo
• type JobRunsAnalyzerFlags
  • func NewJobRunsAnalyzerFlags() *JobRunsAnalyzerFlags
  • func (f *JobRunsAnalyzerFlags) BindFlags(fs *pflag.FlagSet)
  • func (f *JobRunsAnalyzerFlags) ToOptions(ctx context.Context) (*JobRunAggregatorAnalyzerOptions, error)
  • func (f *JobRunsAnalyzerFlags) Validate() error
• type TestInfo
• type TestKey

Functions

func NewJobRunsAnalyzerCommand

func NewJobRunsAnalyzerCommand() *cobra.Command

Types

type AggregationConfiguration

type AggregationConfiguration struct {
	UnfinishedJobs []JobRunInfo
	FinishedJobs   []JobRunInfo
}

type JobRunAggregatorAnalyzerOptions

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

JobRunAggregatorAnalyzerOptions 1. reads a local cache of prowjob.json and junit files for a particular job. 2. finds jobruns for the the specified payload tag 3. reads all junit for the each jobrun 4. constructs a synthentic junit that includes every test and assigns pass/fail to each test

func (*JobRunAggregatorAnalyzerOptions) CalculateDisruptionTestSuite

func (o *JobRunAggregatorAnalyzerOptions) CalculateDisruptionTestSuite(ctx context.Context, jobGCSBucketRoot string, finishedJobsToAggregate []jobrunaggregatorapi.JobRunInfo, masterNodesUpdated string) (*junit.TestSuite, error)

func (*JobRunAggregatorAnalyzerOptions) GetRelatedJobRuns

func (o *JobRunAggregatorAnalyzerOptions) GetRelatedJobRuns(ctx context.Context) ([]jobrunaggregatorapi.JobRunInfo, error)

GetRelatedJobRuns gets all related job runs for analysis

func (*JobRunAggregatorAnalyzerOptions) GetRelatedJobRunsFromIdentifiers

func (o *JobRunAggregatorAnalyzerOptions) GetRelatedJobRunsFromIdentifiers(ctx context.Context, jobRunIdentifiers []jobrunaggregatorlib.JobRunIdentifier) ([]jobrunaggregatorapi.JobRunInfo, error)

func (*JobRunAggregatorAnalyzerOptions) Run

func (o *JobRunAggregatorAnalyzerOptions) Run(ctx context.Context) error

type JobRunInfo

type JobRunInfo struct {
	JobName      string
	JobRunID     string
	HumanURL     string
	GCSBucketURL string

	Status string
}

type JobRunsAnalyzerFlags

type JobRunsAnalyzerFlags struct {
	DataCoordinates *jobrunaggregatorlib.BigQueryDataCoordinates
	Authentication  *jobrunaggregatorlib.GoogleAuthenticationFlags

	JobName                     string
	WorkingDir                  string
	PayloadTag                  string
	AggregationID               string
	ExplicitGCSPrefix           string
	Timeout                     time.Duration
	EstimatedJobStartTimeString string
	JobStateQuerySource         string

	StaticJobRunIdentifierPath string
	StaticJobRunIdentifierJSON string
	GCSBucket                  string
}

func NewJobRunsAnalyzerFlags

func NewJobRunsAnalyzerFlags() *JobRunsAnalyzerFlags

func (*JobRunsAnalyzerFlags) BindFlags

func (f *JobRunsAnalyzerFlags) BindFlags(fs *pflag.FlagSet)

func (*JobRunsAnalyzerFlags) ToOptions

func (f *JobRunsAnalyzerFlags) ToOptions(ctx context.Context) (*JobRunAggregatorAnalyzerOptions, error)

ToOptions goes from the user input to the runtime values need to run the command. Expect to see unit tests on the options, but not on the flags which are simply value mappings.

func (*JobRunsAnalyzerFlags) Validate

func (f *JobRunsAnalyzerFlags) Validate() error

Validate checks to see if the user-input is likely to produce functional runtime options

type TestInfo

type TestInfo struct {
	JobRuns []JobRunInfo
	Name    string
	Status  string
	Parents []string
	Summary string
}

type TestKey

type TestKey struct {
	TestCaseName          string
	CombinedTestSuiteName string
}