mirror of
https://github.com/weaveworks/scope.git
synced 2026-05-06 01:08:03 +00:00
36361d6b7d
This covers: - Implementation of the job resource in probe - Reporter changes for the job - Add Describe Control to the job - Pass job object to the kube controller renderer ToDo: - Need to decide the shape for the Job. Signed-off-by: Satyam Zode <satyamzode@gmail.com>
48 lines
931 B
Go
48 lines
931 B
Go
package kubernetes
|
|
|
|
import (
|
|
batchv1 "k8s.io/api/batch/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/labels"
|
|
|
|
"github.com/weaveworks/scope/report"
|
|
)
|
|
|
|
//Job represents a Kubernetes job
|
|
type Job interface {
|
|
Meta
|
|
Selector() (labels.Selector, error)
|
|
GetNode(probeID string) report.Node
|
|
}
|
|
|
|
type job struct {
|
|
*batchv1.Job
|
|
Meta
|
|
}
|
|
|
|
// NewJob creates a new job.
|
|
func NewJob(j *batchv1.Job) Job {
|
|
return &job{
|
|
Job: j,
|
|
Meta: meta{j.ObjectMeta},
|
|
}
|
|
}
|
|
|
|
func (j *job) Selector() (labels.Selector, error) {
|
|
selector, err := metav1.LabelSelectorAsSelector(j.Spec.Selector)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return selector, nil
|
|
}
|
|
|
|
func (j *job) GetNode(probeID string) report.Node {
|
|
latests := map[string]string{
|
|
NodeType: "Job",
|
|
report.ControlProbeID: probeID,
|
|
}
|
|
return j.MetaNode(report.MakeJobNodeID(j.UID())).
|
|
WithLatests(latests).
|
|
WithLatestActiveControls(Describe)
|
|
}
|