reporter

Documentation

Index

• func CreateEventForCurrentState(pod *v1.Pod, clusterId string) (api.Event, error)
• func CreateJobFailedEvent(pod *v1.Pod, reason string, exitCodes map[string]int32, clusterId string) api.Event
• func CreateJobLeaseReturnedEvent(pod *v1.Pod, reason string, clusterId string) api.Event
• func CreateJobUnableToScheduleEvent(pod *v1.Pod, reason string, clusterId string) api.Event
• func HasCurrentStateBeenReported(pod *v1.Pod) bool
• func HasPodBeenInStateForLongerThanGivenDuration(pod *v1.Pod, duration time.Duration) bool
• type EventReporter
• type JobEventReporter
  • func NewJobEventReporter(clusterContext *context.KubernetesClusterContext, eventClient api.EventClient) *JobEventReporter
  • func (eventReporter *JobEventReporter) Report(event api.Event) error
  • func (eventReporter *JobEventReporter) ReportCurrentStatus(pod *v1.Pod)
  • func (eventReporter *JobEventReporter) ReportMissingJobEvents()
  • func (eventReporter *JobEventReporter) ReportStatusUpdate(old *v1.Pod, new *v1.Pod)

Functions

func CreateEventForCurrentState

func CreateEventForCurrentState(pod *v1.Pod, clusterId string) (api.Event, error)

func CreateJobFailedEvent

func CreateJobFailedEvent(pod *v1.Pod, reason string, exitCodes map[string]int32, clusterId string) api.Event

func CreateJobLeaseReturnedEvent

func CreateJobLeaseReturnedEvent(pod *v1.Pod, reason string, clusterId string) api.Event

func CreateJobUnableToScheduleEvent

func CreateJobUnableToScheduleEvent(pod *v1.Pod, reason string, clusterId string) api.Event

func HasCurrentStateBeenReported

func HasCurrentStateBeenReported(pod *v1.Pod) bool

func HasPodBeenInStateForLongerThanGivenDuration

func HasPodBeenInStateForLongerThanGivenDuration(pod *v1.Pod, duration time.Duration) bool

Types

type EventReporter

type EventReporter interface {
	Report(event api.Event) error
	ReportCurrentStatus(pod *v1.Pod)
	ReportStatusUpdate(old *v1.Pod, new *v1.Pod)
}

type JobEventReporter

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

func NewJobEventReporter

func NewJobEventReporter(clusterContext *context.KubernetesClusterContext, eventClient api.EventClient) *JobEventReporter

func (*JobEventReporter) Report

func (eventReporter *JobEventReporter) Report(event api.Event) error

func (*JobEventReporter) ReportCurrentStatus

func (eventReporter *JobEventReporter) ReportCurrentStatus(pod *v1.Pod)

func (*JobEventReporter) ReportMissingJobEvents

func (eventReporter *JobEventReporter) ReportMissingJobEvents()

func (*JobEventReporter) ReportStatusUpdate

func (eventReporter *JobEventReporter) ReportStatusUpdate(old *v1.Pod, new *v1.Pod)