prow

type Accumulator interface {
	Artifacts(context.Context, <-chan *storage.ObjectAttrs, chan<- *storage.ObjectAttrs) error
	AddSuites(context.Context, junit.Suites)
	AddMetadata(context.Context, *gcs.Started, *gcs.Finished) (ok bool, err error)
	Finished(context.Context)

	Started() int64
	// LastUpdate is the finished or started date.
	LastUpdate() int64
}

type Build = gcs.Build

type Builds = gcs.Builds

type CachingLister struct {
	Lister JobLister
	// contains filtered or unexported fields
}

type Client struct {
	Base    url.URL
	Client  *http.Client
	Retries int
}

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

type Index struct {
	Bucket    string
	IndexName string

	FromKey string
	ToKey   string
}

type Job struct {
	metav1.TypeMeta
	metav1.ObjectMeta `json:"metadata"`

	Spec   JobSpec   `json:"spec"`
	Status JobStatus `json:"status"`
}

type JobAccessor interface {
	Get(name string) (*Job, error)
	List(labels.Selector) ([]*Job, error)
	JobStats(name string, names sets.String, from, to time.Time) JobStats
}

type JobList struct {
	metav1.TypeMeta
	metav1.ListMeta

	Items []*Job `json:"items"`
}

type JobLister interface {
	ListJobs(ctx context.Context) ([]*Job, error)
}

type JobSpec struct {
	Type string `json:"type"`
	Job  string `json:"job"`
}

type JobStats struct {
	Jobs     int
	Count    int
	Failures int
}

type JobStatus struct {
	// Valid states are "aborted", "error", "failure", "success"
	State          string      `json:"state"`
	StartTime      metav1.Time `json:"startTime"`
	CompletionTime metav1.Time `json:"completionTime"`
	URL            string      `json:"url"`
	BuildID        string      `json:"build_id"`
}

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

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

type ListerFunc func(ctx context.Context) ([]*Job, error)

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

type PathNotifier interface {
	Notify(paths []string)
}

type Summarizer interface {
	New(*gcs.Build) Accumulator
}