job

Documentation

Index

• type FailedReport
• type Feed
  • func NewFeed() Feed
• type JobStatus
  • func NewJobStatus(object *batchv1.Job, statusGeneration uint64, isTrackerFailed bool, ...) JobStatus
• type PodAddedReport
• type PodErrorReport
• type Tracker
  • func NewTracker(name, namespace string, kube kubernetes.Interface, opts tracker.Options) *Tracker
  • func (job *Tracker) Track(ctx context.Context) error

Types

type FailedReport

type FailedReport struct {
	FailedReason string
	JobStatus    JobStatus
}

type Feed

type Feed interface {
	OnAdded(func() error)
	OnSucceeded(func() error)
	OnFailed(func(reason string) error)
	OnEventMsg(func(msg string) error)
	OnAddedPod(func(podName string) error)
	OnPodLogChunk(func(*pod.PodLogChunk) error)
	OnPodError(func(pod.PodError) error)
	OnStatus(func(JobStatus) error)

	GetStatus() JobStatus
	Track(name, namespace string, kube kubernetes.Interface, opts tracker.Options) error
}

func NewFeed

func NewFeed() Feed

type JobStatus

type JobStatus struct {
	batchv1.JobStatus

	StatusGeneration uint64

	SucceededIndicator *indicators.Int32EqualConditionIndicator
	Duration           string
	Age                string

	WaitingForMessages []string

	IsSucceeded  bool
	IsFailed     bool
	FailedReason string

	Pods map[string]pod.PodStatus
}

func NewJobStatus

func NewJobStatus(object *batchv1.Job, statusGeneration uint64, isTrackerFailed bool, trackerFailedReason string, podsStatuses map[string]pod.PodStatus, trackedPodsNames []string) JobStatus

type PodAddedReport

type PodAddedReport struct {
	PodName   string
	JobStatus JobStatus
}

type PodErrorReport

type PodErrorReport struct {
	PodError  pod.PodError
	JobStatus JobStatus
}

type Tracker

type Tracker struct {
	tracker.Tracker
	LogsFromTime time.Time

	Added     chan JobStatus
	Succeeded chan JobStatus
	Failed    chan JobStatus
	Status    chan JobStatus

	EventMsg    chan string
	AddedPod    chan PodAddedReport
	PodLogChunk chan *pod.PodLogChunk
	PodError    chan PodErrorReport

	State            tracker.TrackerState
	TrackedPodsNames []string
	// contains filtered or unexported fields
}

func NewTracker

func NewTracker(name, namespace string, kube kubernetes.Interface, opts tracker.Options) *Tracker

func (*Tracker) Track

func (job *Tracker) Track(ctx context.Context) error