Documentation
¶
Index ¶
- Constants
- func DaysBetween(start, end time.Time) []string
- func GatherLabelsFromBQ(ctx context.Context, bqClient *bqcachedclient.Client, buildIDs []string, ...) (map[string]pq.StringArray, error)
- func GetClusterDataBytes(ctx context.Context, bkt *storage.BucketHandle, path string, matches []string) ([]byte, error)
- func GetGCSPathForProwJobURL(pjLog log.FieldLogger, prowJobURL string) (string, error)
- func NextDay(dateStr string) (string, error)
- func ParseVariantDataFile(bytes []byte) (map[string]string, error)
- type DateTimeName
- type ProwLoader
Constants ¶
View Source
const DefaultLookbackDays = 14
View Source
const LabelsDatasetEnv = "JOB_LABELS_DATASET"
View Source
const LabelsTableName = "job_labels"
Variables ¶
This section is empty.
Functions ¶
func DaysBetween ¶
DaysBetween returns a slice of strings representing each day in YYYY-MM-DD format between two dates
func GatherLabelsFromBQ ¶
func GatherLabelsFromBQ(ctx context.Context, bqClient *bqcachedclient.Client, buildIDs []string, startTime time.Time) (map[string]pq.StringArray, error)
GatherLabelsFromBQ queries BigQuery for labels for multiple job runs. Large ID lists are automatically batched to avoid exceeding BigQuery's request size limit. The startTime is used to constrain the scan to recent date partitions. Returns a map of buildID → labels. If a batch fails, the returned map contains labels from previously completed batches and the error is also returned.
func GetClusterDataBytes ¶
func GetGCSPathForProwJobURL ¶
func GetGCSPathForProwJobURL(pjLog log.FieldLogger, prowJobURL string) (string, error)
Types ¶
type DateTimeName ¶
type ProwLoader ¶
type ProwLoader struct {
// contains filtered or unexported fields
}
func New ¶
func New( ctx context.Context, dbc *db.DB, gcsClient *storage.Client, bigQueryClient *bqcachedclient.Client, githubClient *github.Client, variantManager testidentification.VariantManager, syntheticTestManager synthetictests.SyntheticTestManager, releases []string, config *v1config.SippyConfig, ghCommenter *commenter.GitHubCommenter, promPusher *push.Pusher, loadSince *time.Time, syntheticReleaseJobOverrides *releaseoverride.SyntheticReleaseOverrides) *ProwLoader
func (*ProwLoader) Errors ¶
func (pl *ProwLoader) Errors() []error
func (*ProwLoader) Load ¶
func (pl *ProwLoader) Load()
func (*ProwLoader) Name ¶
func (pl *ProwLoader) Name() string
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.