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 CreateReturnLeaseEvent(pod *v1.Pod, reason string, clusterId string, runAttempted bool) api.Event
- func CreateSimpleJobFailedEvent(pod *v1.Pod, reason string, clusterId string, cause api.Cause) api.Event
- type EventMessage
- type EventReporter
- type EventSender
- type ExecutorApiEventSender
- type JobEventReporter
- type LegacyApiEventSender
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateJobFailedEvent ¶
func CreateJobPreemptedEvent ¶
func CreateReturnLeaseEvent ¶ added in v0.3.47
Types ¶
type EventMessage ¶ added in v0.3.47
type EventReporter ¶
type EventReporter interface { Report(events []EventMessage) error QueueEvent(event EventMessage, callback func(error)) }
type EventSender ¶ added in v0.3.47
type EventSender interface {
SendEvents(events []EventMessage) error
}
type ExecutorApiEventSender ¶ added in v0.3.47
type ExecutorApiEventSender struct {
// contains filtered or unexported fields
}
func NewExecutorApiEventSender ¶ added in v0.3.47
func NewExecutorApiEventSender( executorApiClient executorapi.ExecutorApiClient, ) *ExecutorApiEventSender
func (*ExecutorApiEventSender) SendEvents ¶ added in v0.3.47
func (eventSender *ExecutorApiEventSender) SendEvents(events []EventMessage) error
type JobEventReporter ¶
type JobEventReporter struct {
// contains filtered or unexported fields
}
func NewJobEventReporter ¶
func NewJobEventReporter(clusterContext clusterContext.ClusterContext, eventSender EventSender) (*JobEventReporter, chan bool)
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()
type LegacyApiEventSender ¶ added in v0.3.47
type LegacyApiEventSender struct {
// contains filtered or unexported fields
}
func NewLegacyApiEventSender ¶ added in v0.3.47
func NewLegacyApiEventSender(eventClient api.EventClient) *LegacyApiEventSender
func (*LegacyApiEventSender) SendEvents ¶ added in v0.3.47
func (eventSender *LegacyApiEventSender) SendEvents(events []EventMessage) error
Click to show internal directories.
Click to hide internal directories.