jobrunbigqueryloader

Documentation

Index

• func NewBigQueryAlertUploadFlagsCommand() *cobra.Command
• func NewBigQueryDisruptionUploadFlagsCommand() *cobra.Command
• type Alert
• type AlertByKey
  • func (a AlertByKey) Len() int
  • func (a AlertByKey) Less(i, j int) bool
  • func (a AlertByKey) Swap(i, j int)
• type AlertKey
• type AlertLevel
• type AlertList
• type BigQueryAlertUploadFlags
  • func NewBigQueryAlertUploadFlags() *BigQueryAlertUploadFlags
  • func (f *BigQueryAlertUploadFlags) BindFlags(fs *pflag.FlagSet)
  • func (f *BigQueryAlertUploadFlags) ToOptions(ctx context.Context) (*allJobsLoaderOptions, error)
  • func (f *BigQueryAlertUploadFlags) Validate() error
• type BigQueryDisruptionUploadFlags
  • func NewBigQueryDisruptionUploadFlags() *BigQueryDisruptionUploadFlags
  • func (f *BigQueryDisruptionUploadFlags) BindFlags(fs *pflag.FlagSet)
  • func (f *BigQueryDisruptionUploadFlags) ToOptions(ctx context.Context) (*allJobsLoaderOptions, error)
  • func (f *BigQueryDisruptionUploadFlags) Validate() error
• type JobRunUploaderRegistry
  • func (j *JobRunUploaderRegistry) Deregister(name string)
  • func (j *JobRunUploaderRegistry) Register(name string, jobRunUploader uploader)
• type KnownAlertsCache
  • func (k *KnownAlertsCache) ListAllKnownAlertsForRelease(release string) []*jobrunaggregatorapi.KnownAlertRow

Functions

func NewBigQueryAlertUploadFlagsCommand

func NewBigQueryAlertUploadFlagsCommand() *cobra.Command

func NewBigQueryDisruptionUploadFlagsCommand

func NewBigQueryDisruptionUploadFlagsCommand() *cobra.Command

Types

type Alert

type Alert struct {
	AlertKey `json:",inline"`
	Duration metav1.Duration
}

type AlertByKey

type AlertByKey []Alert

func (AlertByKey) Len

func (a AlertByKey) Len() int

func (AlertByKey) Less

func (a AlertByKey) Less(i, j int) bool

func (AlertByKey) Swap

func (a AlertByKey) Swap(i, j int)

type AlertKey

type AlertKey struct {
	Name      string
	Namespace string
	Level     AlertLevel
}

name and namespace are consistent (usually) for every CI run

type AlertLevel

type AlertLevel string

var (
	UnknownAlertLevel  AlertLevel = "Unknown"
	WarningAlertLevel  AlertLevel = "Warning"
	CriticalAlertLevel AlertLevel = "Critical"
)

type AlertList

type AlertList struct {
	// Alerts is keyed by name to make the consumption easier
	Alerts []Alert
}

type BigQueryAlertUploadFlags

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

	DryRun    bool
	LogLevel  string
	GCSBucket string
}

func NewBigQueryAlertUploadFlags

func NewBigQueryAlertUploadFlags() *BigQueryAlertUploadFlags

func (*BigQueryAlertUploadFlags) BindFlags

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

func (*BigQueryAlertUploadFlags) ToOptions

func (f *BigQueryAlertUploadFlags) ToOptions(ctx context.Context) (*allJobsLoaderOptions, 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 (*BigQueryAlertUploadFlags) Validate

func (f *BigQueryAlertUploadFlags) Validate() error

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

type BigQueryDisruptionUploadFlags

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

	DryRun    bool
	LogLevel  string
	GCSBucket string
}

func NewBigQueryDisruptionUploadFlags

func NewBigQueryDisruptionUploadFlags() *BigQueryDisruptionUploadFlags

func (*BigQueryDisruptionUploadFlags) BindFlags

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

func (*BigQueryDisruptionUploadFlags) ToOptions

func (f *BigQueryDisruptionUploadFlags) ToOptions(ctx context.Context) (*allJobsLoaderOptions, 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 (*BigQueryDisruptionUploadFlags) Validate

func (f *BigQueryDisruptionUploadFlags) Validate() error

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

type JobRunUploaderRegistry

type JobRunUploaderRegistry struct {
	JobRunUploaders map[string]uploader
}

func (*JobRunUploaderRegistry) Deregister

func (j *JobRunUploaderRegistry) Deregister(name string)

func (*JobRunUploaderRegistry) Register

func (j *JobRunUploaderRegistry) Register(name string, jobRunUploader uploader)

type KnownAlertsCache

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

func (*KnownAlertsCache) ListAllKnownAlertsForRelease

func (k *KnownAlertsCache) ListAllKnownAlertsForRelease(release string) []*jobrunaggregatorapi.KnownAlertRow