reporter

Documentation

Index

• func CreateEventForCurrentState(pod *v1.Pod, clusterId string) (api.Event, error)
• func CreateJobFailedEvent(pod *v1.Pod, reason string, cause api.Cause, ...) api.Event
• func CreateJobIngressInfoEvent(pod *v1.Pod, clusterId string, associatedServices []*v1.Service, ...) (api.Event, error)
• func CreateJobPreemptedEvent(clusterEvent *v1.Event, clusterId string) (event *api.JobPreemptedEvent, err error)
• func CreateJobTerminatedEvent(pod *v1.Pod, reason string, clusterId string) api.Event
• func CreateJobUnableToScheduleEvent(pod *v1.Pod, reason string, clusterId string) api.Event
• func CreateJobUtilisationEvent(pod *v1.Pod, utilisationData *domain.UtilisationData, clusterId string) api.Event
• func CreateSimpleJobFailedEvent(pod *v1.Pod, reason string, clusterId string, cause api.Cause) api.Event
• type EventReporter
• type JobEventReporter
  • func NewJobEventReporter(clusterContext clusterContext.ClusterContext, eventClient api.EventClient) (*JobEventReporter, chan bool)
  • func (eventReporter *JobEventReporter) QueueEvent(event api.Event, callback func(error))
  • func (eventReporter *JobEventReporter) Report(event api.Event) error
  • func (eventReporter *JobEventReporter) ReportMissingJobEvents()

Functions

func CreateEventForCurrentState

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

func CreateJobFailedEvent

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

func CreateJobIngressInfoEvent

func CreateJobIngressInfoEvent(pod *v1.Pod, clusterId string, associatedServices []*v1.Service, associatedIngresses []*networking.Ingress) (api.Event, error)

func CreateJobPreemptedEvent

func CreateJobPreemptedEvent(clusterEvent *v1.Event, clusterId string) (event *api.JobPreemptedEvent, err error)

func CreateJobTerminatedEvent

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

func CreateJobUnableToScheduleEvent

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

func CreateJobUtilisationEvent

func CreateJobUtilisationEvent(pod *v1.Pod, utilisationData *domain.UtilisationData, clusterId string) api.Event

func CreateSimpleJobFailedEvent

func CreateSimpleJobFailedEvent(pod *v1.Pod, reason string, clusterId string, cause api.Cause) api.Event

Types

type EventReporter

type EventReporter interface {
	Report(event api.Event) error
	QueueEvent(event api.Event, callback func(error))
}

type JobEventReporter

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

func NewJobEventReporter

func NewJobEventReporter(clusterContext clusterContext.ClusterContext, eventClient api.EventClient) (*JobEventReporter, chan bool)

func (*JobEventReporter) QueueEvent

func (eventReporter *JobEventReporter) QueueEvent(event api.Event, callback func(error))

func (*JobEventReporter) Report

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

func (*JobEventReporter) ReportMissingJobEvents

func (eventReporter *JobEventReporter) ReportMissingJobEvents()