reporter

Documentation

Index

• func CreateEventForCurrentState(pod *v1.Pod, clusterId string) (*armadaevents.EventSequence, error)
• func CreateJobFailedEvent(pod *v1.Pod, reason string, cause armadaevents.KubernetesReason, ...) (*armadaevents.EventSequence, error)
• func CreateJobIngressInfoEvent(pod *v1.Pod, clusterId string, associatedServices []*v1.Service, ...) (*armadaevents.EventSequence, error)
• func CreateJobUnableToScheduleEvent(pod *v1.Pod, reason string, clusterId string) (*armadaevents.EventSequence, error)
• func CreateJobUtilisationEvent(pod *v1.Pod, utilisationData *domain.UtilisationData, clusterId string) (*armadaevents.EventSequence, error)
• func CreateMinimalJobFailedEvent(jobIdStr string, runIdStr string, jobSet string, queue string, ...) (*armadaevents.EventSequence, error)
• func CreateReturnLeaseEvent(pod *v1.Pod, reason string, debugMessage string, clusterId string, ...) (*armadaevents.EventSequence, error)
• func CreateSimpleJobFailedEvent(pod *v1.Pod, reason string, debugMessage string, clusterId string, ...) (*armadaevents.EventSequence, error)
• func CreateSimpleJobPreemptedEvent(pod *v1.Pod) (*armadaevents.EventSequence, error)
• type EventMessage
• type EventReporter
• type EventSender
• type ExecutorApiEventSender
  • func NewExecutorApiEventSender(executorApiClient executorapi.ExecutorApiClient, maxMessageSize int) *ExecutorApiEventSender
  • func (eventSender *ExecutorApiEventSender) SendEvents(events []EventMessage) error
• type JobEventReporter
  • func NewJobEventReporter(clusterContext clusterContext.ClusterContext, ...) (*JobEventReporter, chan bool, error)
  • func (eventReporter *JobEventReporter) QueueEvent(event EventMessage, callback func(error))
  • func (eventReporter *JobEventReporter) Report(events []EventMessage) error
  • func (eventReporter *JobEventReporter) ReportMissingJobEvents()

Functions

func CreateEventForCurrentState

func CreateEventForCurrentState(pod *v1.Pod, clusterId string) (*armadaevents.EventSequence, error)

func CreateJobFailedEvent

func CreateJobFailedEvent(pod *v1.Pod, reason string, cause armadaevents.KubernetesReason, debugMessage string,
	containerStatuses []*armadaevents.ContainerError, clusterId string,
) (*armadaevents.EventSequence, error)

func CreateJobIngressInfoEvent

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

func CreateJobUnableToScheduleEvent

func CreateJobUnableToScheduleEvent(pod *v1.Pod, reason string, clusterId string) (*armadaevents.EventSequence, error)

func CreateJobUtilisationEvent

func CreateJobUtilisationEvent(pod *v1.Pod, utilisationData *domain.UtilisationData, clusterId string) (*armadaevents.EventSequence, error)

func CreateMinimalJobFailedEvent

func CreateMinimalJobFailedEvent(jobIdStr string, runIdStr string, jobSet string, queue string, clusterId string, message string) (*armadaevents.EventSequence, error)

func CreateReturnLeaseEvent

func CreateReturnLeaseEvent(pod *v1.Pod, reason string, debugMessage string, clusterId string, runAttempted bool) (*armadaevents.EventSequence, error)

func CreateSimpleJobFailedEvent

func CreateSimpleJobFailedEvent(pod *v1.Pod, reason string, debugMessage string, clusterId string, cause armadaevents.KubernetesReason) (*armadaevents.EventSequence, error)

func CreateSimpleJobPreemptedEvent

func CreateSimpleJobPreemptedEvent(pod *v1.Pod) (*armadaevents.EventSequence, error)

Types

type EventMessage

type EventMessage struct {
	Event    *armadaevents.EventSequence
	JobRunId string
}

type EventReporter

type EventReporter interface {
	Report(events []EventMessage) error
	QueueEvent(event EventMessage, callback func(error))
}

type EventSender

type EventSender interface {
	SendEvents(events []EventMessage) error
}

type ExecutorApiEventSender

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

func NewExecutorApiEventSender

func NewExecutorApiEventSender(
	executorApiClient executorapi.ExecutorApiClient,
	maxMessageSize int,
) *ExecutorApiEventSender

func (*ExecutorApiEventSender) SendEvents

func (eventSender *ExecutorApiEventSender) SendEvents(events []EventMessage) error

type JobEventReporter

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

func NewJobEventReporter

func NewJobEventReporter(
	clusterContext clusterContext.ClusterContext,
	jobRunState *job.JobRunStateStore,
	eventSender EventSender,
	clock clock.WithTicker,
	maxBatchSize int,
) (*JobEventReporter, chan bool, error)

func (*JobEventReporter) QueueEvent

func (eventReporter *JobEventReporter) QueueEvent(event EventMessage, callback func(error))

func (*JobEventReporter) Report

func (eventReporter *JobEventReporter) Report(events []EventMessage) error

func (*JobEventReporter) ReportMissingJobEvents

func (eventReporter *JobEventReporter) ReportMissingJobEvents()