Documentation ¶
Index ¶
- Variables
- func JobIdFromEvent(event *EventSequence_Event) (string, error)
- type CancelJob
- func (*CancelJob) Descriptor() ([]byte, []int)
- func (m *CancelJob) GetJobId() string
- func (m *CancelJob) GetReason() string
- func (m *CancelJob) Marshal() (dAtA []byte, err error)
- func (m *CancelJob) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelJob) ProtoMessage()
- func (m *CancelJob) Reset()
- func (m *CancelJob) Size() (n int)
- func (m *CancelJob) String() string
- func (m *CancelJob) Unmarshal(dAtA []byte) error
- func (m *CancelJob) XXX_DiscardUnknown()
- func (m *CancelJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelJob) XXX_Merge(src proto.Message)
- func (m *CancelJob) XXX_Size() int
- func (m *CancelJob) XXX_Unmarshal(b []byte) error
- type CancelJobSet
- func (*CancelJobSet) Descriptor() ([]byte, []int)
- func (m *CancelJobSet) GetReason() string
- func (m *CancelJobSet) GetStates() []JobState
- func (m *CancelJobSet) Marshal() (dAtA []byte, err error)
- func (m *CancelJobSet) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelJobSet) ProtoMessage()
- func (m *CancelJobSet) Reset()
- func (m *CancelJobSet) Size() (n int)
- func (m *CancelJobSet) String() string
- func (m *CancelJobSet) Unmarshal(dAtA []byte) error
- func (m *CancelJobSet) XXX_DiscardUnknown()
- func (m *CancelJobSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelJobSet) XXX_Merge(src proto.Message)
- func (m *CancelJobSet) XXX_Size() int
- func (m *CancelJobSet) XXX_Unmarshal(b []byte) error
- type CancelledJob
- func (*CancelledJob) Descriptor() ([]byte, []int)
- func (m *CancelledJob) GetJobId() string
- func (m *CancelledJob) GetReason() string
- func (m *CancelledJob) Marshal() (dAtA []byte, err error)
- func (m *CancelledJob) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelledJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelledJob) ProtoMessage()
- func (m *CancelledJob) Reset()
- func (m *CancelledJob) Size() (n int)
- func (m *CancelledJob) String() string
- func (m *CancelledJob) Unmarshal(dAtA []byte) error
- func (m *CancelledJob) XXX_DiscardUnknown()
- func (m *CancelledJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelledJob) XXX_Merge(src proto.Message)
- func (m *CancelledJob) XXX_Size() int
- func (m *CancelledJob) XXX_Unmarshal(b []byte) error
- type ContainerError
- func (*ContainerError) Descriptor() ([]byte, []int)
- func (m *ContainerError) GetExitCode() int32
- func (m *ContainerError) GetKubernetesReason() KubernetesReason
- func (m *ContainerError) GetMessage() string
- func (m *ContainerError) GetObjectMeta() *ObjectMeta
- func (m *ContainerError) GetReason() string
- func (m *ContainerError) Marshal() (dAtA []byte, err error)
- func (m *ContainerError) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainerError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainerError) ProtoMessage()
- func (m *ContainerError) Reset()
- func (m *ContainerError) Size() (n int)
- func (m *ContainerError) String() string
- func (m *ContainerError) Unmarshal(dAtA []byte) error
- func (m *ContainerError) XXX_DiscardUnknown()
- func (m *ContainerError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerError) XXX_Merge(src proto.Message)
- func (m *ContainerError) XXX_Size() int
- func (m *ContainerError) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetContainerError() *ContainerError
- func (m *Error) GetExecutorError() *ExecutorError
- func (m *Error) GetGangJobUnschedulable() *GangJobUnschedulable
- func (m *Error) GetJobRejected() *JobRejected
- func (m *Error) GetJobRunPreemptedError() *JobRunPreemptedError
- func (m *Error) GetKubernetesError() *KubernetesError
- func (m *Error) GetLeaseExpired() *LeaseExpired
- func (m *Error) GetMaxRunsExceeded() *MaxRunsExceeded
- func (m *Error) GetPodError() *PodError
- func (m *Error) GetPodLeaseReturned() *PodLeaseReturned
- func (m *Error) GetPodUnschedulable() *PodUnschedulable
- func (m *Error) GetReason() isError_Reason
- func (m *Error) GetTerminal() bool
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (*Error) XXX_OneofWrappers() []interface{}
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type Error_ContainerError
- type Error_ExecutorError
- type Error_GangJobUnschedulable
- type Error_JobRejected
- type Error_JobRunPreemptedError
- type Error_KubernetesError
- type Error_LeaseExpired
- type Error_MaxRunsExceeded
- type Error_PodError
- type Error_PodLeaseReturned
- type Error_PodUnschedulable
- type EventSequence
- func (*EventSequence) Descriptor() ([]byte, []int)
- func (m *EventSequence) GetEvents() []*EventSequence_Event
- func (m *EventSequence) GetGroups() []string
- func (m *EventSequence) GetJobSetName() string
- func (m *EventSequence) GetQueue() string
- func (m *EventSequence) GetUserId() string
- func (m *EventSequence) Marshal() (dAtA []byte, err error)
- func (m *EventSequence) MarshalTo(dAtA []byte) (int, error)
- func (m *EventSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventSequence) ProtoMessage()
- func (m *EventSequence) Reset()
- func (m *EventSequence) Size() (n int)
- func (m *EventSequence) String() string
- func (m *EventSequence) Unmarshal(dAtA []byte) error
- func (m *EventSequence) XXX_DiscardUnknown()
- func (m *EventSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventSequence) XXX_Merge(src proto.Message)
- func (m *EventSequence) XXX_Size() int
- func (m *EventSequence) XXX_Unmarshal(b []byte) error
- type EventSequence_Event
- func (*EventSequence_Event) Descriptor() ([]byte, []int)
- func (m *EventSequence_Event) GetCancelJob() *CancelJob
- func (m *EventSequence_Event) GetCancelJobSet() *CancelJobSet
- func (m *EventSequence_Event) GetCancelledJob() *CancelledJob
- func (m *EventSequence_Event) GetCreated() *types.Timestamp
- func (m *EventSequence_Event) GetEvent() isEventSequence_Event_Event
- func (ev *EventSequence_Event) GetEventName() string
- func (m *EventSequence_Event) GetJobErrors() *JobErrors
- func (m *EventSequence_Event) GetJobPreemptionRequested() *JobPreemptionRequested
- func (m *EventSequence_Event) GetJobRequeued() *JobRequeued
- func (m *EventSequence_Event) GetJobRunAssigned() *JobRunAssigned
- func (m *EventSequence_Event) GetJobRunCancelled() *JobRunCancelled
- func (m *EventSequence_Event) GetJobRunErrors() *JobRunErrors
- func (m *EventSequence_Event) GetJobRunLeased() *JobRunLeased
- func (m *EventSequence_Event) GetJobRunPreempted() *JobRunPreempted
- func (m *EventSequence_Event) GetJobRunPreemptionRequested() *JobRunPreemptionRequested
- func (m *EventSequence_Event) GetJobRunRunning() *JobRunRunning
- func (m *EventSequence_Event) GetJobRunSucceeded() *JobRunSucceeded
- func (m *EventSequence_Event) GetJobSucceeded() *JobSucceeded
- func (m *EventSequence_Event) GetJobValidated() *JobValidated
- func (m *EventSequence_Event) GetPartitionMarker() *PartitionMarker
- func (m *EventSequence_Event) GetReprioritiseJob() *ReprioritiseJob
- func (m *EventSequence_Event) GetReprioritiseJobSet() *ReprioritiseJobSet
- func (m *EventSequence_Event) GetReprioritisedJob() *ReprioritisedJob
- func (m *EventSequence_Event) GetResourceUtilisation() *ResourceUtilisation
- func (m *EventSequence_Event) GetStandaloneIngressInfo() *StandaloneIngressInfo
- func (m *EventSequence_Event) GetSubmitJob() *SubmitJob
- func (m *EventSequence_Event) Marshal() (dAtA []byte, err error)
- func (m *EventSequence_Event) MarshalTo(dAtA []byte) (int, error)
- func (m *EventSequence_Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventSequence_Event) ProtoMessage()
- func (m *EventSequence_Event) Reset()
- func (m *EventSequence_Event) Size() (n int)
- func (m *EventSequence_Event) String() string
- func (m *EventSequence_Event) Unmarshal(dAtA []byte) error
- func (m *EventSequence_Event) XXX_DiscardUnknown()
- func (m *EventSequence_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventSequence_Event) XXX_Merge(src proto.Message)
- func (*EventSequence_Event) XXX_OneofWrappers() []interface{}
- func (m *EventSequence_Event) XXX_Size() int
- func (m *EventSequence_Event) XXX_Unmarshal(b []byte) error
- type EventSequence_Event_CancelJob
- type EventSequence_Event_CancelJobSet
- type EventSequence_Event_CancelledJob
- type EventSequence_Event_JobErrors
- type EventSequence_Event_JobPreemptionRequested
- type EventSequence_Event_JobRequeued
- type EventSequence_Event_JobRunAssigned
- type EventSequence_Event_JobRunCancelled
- type EventSequence_Event_JobRunErrors
- type EventSequence_Event_JobRunLeased
- type EventSequence_Event_JobRunPreempted
- type EventSequence_Event_JobRunPreemptionRequested
- type EventSequence_Event_JobRunRunning
- type EventSequence_Event_JobRunSucceeded
- type EventSequence_Event_JobSucceeded
- type EventSequence_Event_JobValidated
- type EventSequence_Event_PartitionMarker
- type EventSequence_Event_ReprioritiseJob
- type EventSequence_Event_ReprioritiseJobSet
- type EventSequence_Event_ReprioritisedJob
- type EventSequence_Event_ResourceUtilisation
- type EventSequence_Event_StandaloneIngressInfo
- type EventSequence_Event_SubmitJob
- type ExecutorError
- func (*ExecutorError) Descriptor() ([]byte, []int)
- func (m *ExecutorError) Marshal() (dAtA []byte, err error)
- func (m *ExecutorError) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutorError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExecutorError) ProtoMessage()
- func (m *ExecutorError) Reset()
- func (m *ExecutorError) Size() (n int)
- func (m *ExecutorError) String() string
- func (m *ExecutorError) Unmarshal(dAtA []byte) error
- func (m *ExecutorError) XXX_DiscardUnknown()
- func (m *ExecutorError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutorError) XXX_Merge(src proto.Message)
- func (m *ExecutorError) XXX_Size() int
- func (m *ExecutorError) XXX_Unmarshal(b []byte) error
- type ExperimentalPriceInfo
- func (*ExperimentalPriceInfo) Descriptor() ([]byte, []int)
- func (m *ExperimentalPriceInfo) GetBidPrice() float64
- func (m *ExperimentalPriceInfo) Marshal() (dAtA []byte, err error)
- func (m *ExperimentalPriceInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *ExperimentalPriceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExperimentalPriceInfo) ProtoMessage()
- func (m *ExperimentalPriceInfo) Reset()
- func (m *ExperimentalPriceInfo) Size() (n int)
- func (m *ExperimentalPriceInfo) String() string
- func (m *ExperimentalPriceInfo) Unmarshal(dAtA []byte) error
- func (m *ExperimentalPriceInfo) XXX_DiscardUnknown()
- func (m *ExperimentalPriceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExperimentalPriceInfo) XXX_Merge(src proto.Message)
- func (m *ExperimentalPriceInfo) XXX_Size() int
- func (m *ExperimentalPriceInfo) XXX_Unmarshal(b []byte) error
- type GangJobUnschedulable
- func (*GangJobUnschedulable) Descriptor() ([]byte, []int)
- func (m *GangJobUnschedulable) GetMessage() string
- func (m *GangJobUnschedulable) Marshal() (dAtA []byte, err error)
- func (m *GangJobUnschedulable) MarshalTo(dAtA []byte) (int, error)
- func (m *GangJobUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GangJobUnschedulable) ProtoMessage()
- func (m *GangJobUnschedulable) Reset()
- func (m *GangJobUnschedulable) Size() (n int)
- func (m *GangJobUnschedulable) String() string
- func (m *GangJobUnschedulable) Unmarshal(dAtA []byte) error
- func (m *GangJobUnschedulable) XXX_DiscardUnknown()
- func (m *GangJobUnschedulable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GangJobUnschedulable) XXX_Merge(src proto.Message)
- func (m *GangJobUnschedulable) XXX_Size() int
- func (m *GangJobUnschedulable) XXX_Unmarshal(b []byte) error
- type IngressInfo
- func (*IngressInfo) Descriptor() ([]byte, []int)
- func (m *IngressInfo) GetIngressAddresses() map[int32]string
- func (m *IngressInfo) GetNodeName() string
- func (m *IngressInfo) Marshal() (dAtA []byte, err error)
- func (m *IngressInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *IngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IngressInfo) ProtoMessage()
- func (m *IngressInfo) Reset()
- func (m *IngressInfo) Size() (n int)
- func (m *IngressInfo) String() string
- func (m *IngressInfo) Unmarshal(dAtA []byte) error
- func (m *IngressInfo) XXX_DiscardUnknown()
- func (m *IngressInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IngressInfo) XXX_Merge(src proto.Message)
- func (m *IngressInfo) XXX_Size() int
- func (m *IngressInfo) XXX_Unmarshal(b []byte) error
- type JobErrors
- func (*JobErrors) Descriptor() ([]byte, []int)
- func (m *JobErrors) GetErrors() []*Error
- func (m *JobErrors) GetJobId() string
- func (m *JobErrors) Marshal() (dAtA []byte, err error)
- func (m *JobErrors) MarshalTo(dAtA []byte) (int, error)
- func (m *JobErrors) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobErrors) ProtoMessage()
- func (m *JobErrors) Reset()
- func (m *JobErrors) Size() (n int)
- func (m *JobErrors) String() string
- func (m *JobErrors) Unmarshal(dAtA []byte) error
- func (m *JobErrors) XXX_DiscardUnknown()
- func (m *JobErrors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobErrors) XXX_Merge(src proto.Message)
- func (m *JobErrors) XXX_Size() int
- func (m *JobErrors) XXX_Unmarshal(b []byte) error
- type JobPreemptionRequested
- func (*JobPreemptionRequested) Descriptor() ([]byte, []int)
- func (m *JobPreemptionRequested) GetJobId() string
- func (m *JobPreemptionRequested) GetReason() string
- func (m *JobPreemptionRequested) Marshal() (dAtA []byte, err error)
- func (m *JobPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
- func (m *JobPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobPreemptionRequested) ProtoMessage()
- func (m *JobPreemptionRequested) Reset()
- func (m *JobPreemptionRequested) Size() (n int)
- func (m *JobPreemptionRequested) String() string
- func (m *JobPreemptionRequested) Unmarshal(dAtA []byte) error
- func (m *JobPreemptionRequested) XXX_DiscardUnknown()
- func (m *JobPreemptionRequested) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobPreemptionRequested) XXX_Merge(src proto.Message)
- func (m *JobPreemptionRequested) XXX_Size() int
- func (m *JobPreemptionRequested) XXX_Unmarshal(b []byte) error
- type JobRejected
- func (*JobRejected) Descriptor() ([]byte, []int)
- func (m *JobRejected) GetMessage() string
- func (m *JobRejected) Marshal() (dAtA []byte, err error)
- func (m *JobRejected) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRejected) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRejected) ProtoMessage()
- func (m *JobRejected) Reset()
- func (m *JobRejected) Size() (n int)
- func (m *JobRejected) String() string
- func (m *JobRejected) Unmarshal(dAtA []byte) error
- func (m *JobRejected) XXX_DiscardUnknown()
- func (m *JobRejected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRejected) XXX_Merge(src proto.Message)
- func (m *JobRejected) XXX_Size() int
- func (m *JobRejected) XXX_Unmarshal(b []byte) error
- type JobRequeued
- func (*JobRequeued) Descriptor() ([]byte, []int)
- func (m *JobRequeued) GetJobId() string
- func (m *JobRequeued) GetSchedulingInfo() *schedulerobjects.JobSchedulingInfo
- func (m *JobRequeued) GetUpdateSequenceNumber() int32
- func (m *JobRequeued) Marshal() (dAtA []byte, err error)
- func (m *JobRequeued) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRequeued) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRequeued) ProtoMessage()
- func (m *JobRequeued) Reset()
- func (m *JobRequeued) Size() (n int)
- func (m *JobRequeued) String() string
- func (m *JobRequeued) Unmarshal(dAtA []byte) error
- func (m *JobRequeued) XXX_DiscardUnknown()
- func (m *JobRequeued) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRequeued) XXX_Merge(src proto.Message)
- func (m *JobRequeued) XXX_Size() int
- func (m *JobRequeued) XXX_Unmarshal(b []byte) error
- type JobRunAssigned
- func (*JobRunAssigned) Descriptor() ([]byte, []int)
- func (m *JobRunAssigned) GetJobId() string
- func (m *JobRunAssigned) GetResourceInfos() []*KubernetesResourceInfo
- func (m *JobRunAssigned) GetRunId() string
- func (m *JobRunAssigned) Marshal() (dAtA []byte, err error)
- func (m *JobRunAssigned) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunAssigned) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunAssigned) ProtoMessage()
- func (m *JobRunAssigned) Reset()
- func (m *JobRunAssigned) Size() (n int)
- func (m *JobRunAssigned) String() string
- func (m *JobRunAssigned) Unmarshal(dAtA []byte) error
- func (m *JobRunAssigned) XXX_DiscardUnknown()
- func (m *JobRunAssigned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunAssigned) XXX_Merge(src proto.Message)
- func (m *JobRunAssigned) XXX_Size() int
- func (m *JobRunAssigned) XXX_Unmarshal(b []byte) error
- type JobRunCancelled
- func (*JobRunCancelled) Descriptor() ([]byte, []int)
- func (m *JobRunCancelled) GetJobId() string
- func (m *JobRunCancelled) GetRunId() string
- func (m *JobRunCancelled) Marshal() (dAtA []byte, err error)
- func (m *JobRunCancelled) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunCancelled) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunCancelled) ProtoMessage()
- func (m *JobRunCancelled) Reset()
- func (m *JobRunCancelled) Size() (n int)
- func (m *JobRunCancelled) String() string
- func (m *JobRunCancelled) Unmarshal(dAtA []byte) error
- func (m *JobRunCancelled) XXX_DiscardUnknown()
- func (m *JobRunCancelled) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunCancelled) XXX_Merge(src proto.Message)
- func (m *JobRunCancelled) XXX_Size() int
- func (m *JobRunCancelled) XXX_Unmarshal(b []byte) error
- type JobRunErrors
- func (*JobRunErrors) Descriptor() ([]byte, []int)
- func (m *JobRunErrors) GetErrors() []*Error
- func (m *JobRunErrors) GetJobId() string
- func (m *JobRunErrors) GetRunId() string
- func (m *JobRunErrors) Marshal() (dAtA []byte, err error)
- func (m *JobRunErrors) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunErrors) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunErrors) ProtoMessage()
- func (m *JobRunErrors) Reset()
- func (m *JobRunErrors) Size() (n int)
- func (m *JobRunErrors) String() string
- func (m *JobRunErrors) Unmarshal(dAtA []byte) error
- func (m *JobRunErrors) XXX_DiscardUnknown()
- func (m *JobRunErrors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunErrors) XXX_Merge(src proto.Message)
- func (m *JobRunErrors) XXX_Size() int
- func (m *JobRunErrors) XXX_Unmarshal(b []byte) error
- type JobRunLeased
- func (*JobRunLeased) Descriptor() ([]byte, []int)
- func (m *JobRunLeased) GetExecutorId() string
- func (m *JobRunLeased) GetHasScheduledAtPriority() bool
- func (m *JobRunLeased) GetJobId() string
- func (m *JobRunLeased) GetNodeId() string
- func (m *JobRunLeased) GetPodRequirementsOverlay() *schedulerobjects.PodRequirements
- func (m *JobRunLeased) GetPool() string
- func (m *JobRunLeased) GetRunId() string
- func (m *JobRunLeased) GetScheduledAtPriority() int32
- func (m *JobRunLeased) GetUpdateSequenceNumber() int32
- func (m *JobRunLeased) Marshal() (dAtA []byte, err error)
- func (m *JobRunLeased) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunLeased) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunLeased) ProtoMessage()
- func (m *JobRunLeased) Reset()
- func (m *JobRunLeased) Size() (n int)
- func (m *JobRunLeased) String() string
- func (m *JobRunLeased) Unmarshal(dAtA []byte) error
- func (m *JobRunLeased) XXX_DiscardUnknown()
- func (m *JobRunLeased) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunLeased) XXX_Merge(src proto.Message)
- func (m *JobRunLeased) XXX_Size() int
- func (m *JobRunLeased) XXX_Unmarshal(b []byte) error
- type JobRunPreempted
- func (*JobRunPreempted) Descriptor() ([]byte, []int)
- func (m *JobRunPreempted) GetPreemptedJobId() string
- func (m *JobRunPreempted) GetPreemptedRunId() string
- func (m *JobRunPreempted) GetReason() string
- func (m *JobRunPreempted) Marshal() (dAtA []byte, err error)
- func (m *JobRunPreempted) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunPreempted) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunPreempted) ProtoMessage()
- func (m *JobRunPreempted) Reset()
- func (m *JobRunPreempted) Size() (n int)
- func (m *JobRunPreempted) String() string
- func (m *JobRunPreempted) Unmarshal(dAtA []byte) error
- func (m *JobRunPreempted) XXX_DiscardUnknown()
- func (m *JobRunPreempted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunPreempted) XXX_Merge(src proto.Message)
- func (m *JobRunPreempted) XXX_Size() int
- func (m *JobRunPreempted) XXX_Unmarshal(b []byte) error
- type JobRunPreemptedError
- func (*JobRunPreemptedError) Descriptor() ([]byte, []int)
- func (m *JobRunPreemptedError) GetReason() string
- func (m *JobRunPreemptedError) Marshal() (dAtA []byte, err error)
- func (m *JobRunPreemptedError) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunPreemptedError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunPreemptedError) ProtoMessage()
- func (m *JobRunPreemptedError) Reset()
- func (m *JobRunPreemptedError) Size() (n int)
- func (m *JobRunPreemptedError) String() string
- func (m *JobRunPreemptedError) Unmarshal(dAtA []byte) error
- func (m *JobRunPreemptedError) XXX_DiscardUnknown()
- func (m *JobRunPreemptedError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunPreemptedError) XXX_Merge(src proto.Message)
- func (m *JobRunPreemptedError) XXX_Size() int
- func (m *JobRunPreemptedError) XXX_Unmarshal(b []byte) error
- type JobRunPreemptionRequested
- func (*JobRunPreemptionRequested) Descriptor() ([]byte, []int)
- func (m *JobRunPreemptionRequested) GetJobId() string
- func (m *JobRunPreemptionRequested) GetRunId() string
- func (m *JobRunPreemptionRequested) Marshal() (dAtA []byte, err error)
- func (m *JobRunPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunPreemptionRequested) ProtoMessage()
- func (m *JobRunPreemptionRequested) Reset()
- func (m *JobRunPreemptionRequested) Size() (n int)
- func (m *JobRunPreemptionRequested) String() string
- func (m *JobRunPreemptionRequested) Unmarshal(dAtA []byte) error
- func (m *JobRunPreemptionRequested) XXX_DiscardUnknown()
- func (m *JobRunPreemptionRequested) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunPreemptionRequested) XXX_Merge(src proto.Message)
- func (m *JobRunPreemptionRequested) XXX_Size() int
- func (m *JobRunPreemptionRequested) XXX_Unmarshal(b []byte) error
- type JobRunRunning
- func (*JobRunRunning) Descriptor() ([]byte, []int)
- func (m *JobRunRunning) GetJobId() string
- func (m *JobRunRunning) GetResourceInfos() []*KubernetesResourceInfo
- func (m *JobRunRunning) GetRunId() string
- func (m *JobRunRunning) Marshal() (dAtA []byte, err error)
- func (m *JobRunRunning) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunRunning) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunRunning) ProtoMessage()
- func (m *JobRunRunning) Reset()
- func (m *JobRunRunning) Size() (n int)
- func (m *JobRunRunning) String() string
- func (m *JobRunRunning) Unmarshal(dAtA []byte) error
- func (m *JobRunRunning) XXX_DiscardUnknown()
- func (m *JobRunRunning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunRunning) XXX_Merge(src proto.Message)
- func (m *JobRunRunning) XXX_Size() int
- func (m *JobRunRunning) XXX_Unmarshal(b []byte) error
- type JobRunSucceeded
- func (*JobRunSucceeded) Descriptor() ([]byte, []int)
- func (m *JobRunSucceeded) GetJobId() string
- func (m *JobRunSucceeded) GetResourceInfos() []*KubernetesResourceInfo
- func (m *JobRunSucceeded) GetRunId() string
- func (m *JobRunSucceeded) Marshal() (dAtA []byte, err error)
- func (m *JobRunSucceeded) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunSucceeded) ProtoMessage()
- func (m *JobRunSucceeded) Reset()
- func (m *JobRunSucceeded) Size() (n int)
- func (m *JobRunSucceeded) String() string
- func (m *JobRunSucceeded) Unmarshal(dAtA []byte) error
- func (m *JobRunSucceeded) XXX_DiscardUnknown()
- func (m *JobRunSucceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunSucceeded) XXX_Merge(src proto.Message)
- func (m *JobRunSucceeded) XXX_Size() int
- func (m *JobRunSucceeded) XXX_Unmarshal(b []byte) error
- type JobSetFilter
- func (*JobSetFilter) Descriptor() ([]byte, []int)
- func (m *JobSetFilter) GetStates() []JobState
- func (m *JobSetFilter) Marshal() (dAtA []byte, err error)
- func (m *JobSetFilter) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSetFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSetFilter) ProtoMessage()
- func (m *JobSetFilter) Reset()
- func (m *JobSetFilter) Size() (n int)
- func (m *JobSetFilter) String() string
- func (m *JobSetFilter) Unmarshal(dAtA []byte) error
- func (m *JobSetFilter) XXX_DiscardUnknown()
- func (m *JobSetFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSetFilter) XXX_Merge(src proto.Message)
- func (m *JobSetFilter) XXX_Size() int
- func (m *JobSetFilter) XXX_Unmarshal(b []byte) error
- type JobState
- type JobSucceeded
- func (*JobSucceeded) Descriptor() ([]byte, []int)
- func (m *JobSucceeded) GetJobId() string
- func (m *JobSucceeded) GetResourceInfos() []*KubernetesResourceInfo
- func (m *JobSucceeded) Marshal() (dAtA []byte, err error)
- func (m *JobSucceeded) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSucceeded) ProtoMessage()
- func (m *JobSucceeded) Reset()
- func (m *JobSucceeded) Size() (n int)
- func (m *JobSucceeded) String() string
- func (m *JobSucceeded) Unmarshal(dAtA []byte) error
- func (m *JobSucceeded) XXX_DiscardUnknown()
- func (m *JobSucceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSucceeded) XXX_Merge(src proto.Message)
- func (m *JobSucceeded) XXX_Size() int
- func (m *JobSucceeded) XXX_Unmarshal(b []byte) error
- type JobValidated
- func (*JobValidated) Descriptor() ([]byte, []int)
- func (m *JobValidated) GetJobId() string
- func (m *JobValidated) GetPools() []string
- func (m *JobValidated) Marshal() (dAtA []byte, err error)
- func (m *JobValidated) MarshalTo(dAtA []byte) (int, error)
- func (m *JobValidated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobValidated) ProtoMessage()
- func (m *JobValidated) Reset()
- func (m *JobValidated) Size() (n int)
- func (m *JobValidated) String() string
- func (m *JobValidated) Unmarshal(dAtA []byte) error
- func (m *JobValidated) XXX_DiscardUnknown()
- func (m *JobValidated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobValidated) XXX_Merge(src proto.Message)
- func (m *JobValidated) XXX_Size() int
- func (m *JobValidated) XXX_Unmarshal(b []byte) error
- type KubernetesError
- func (*KubernetesError) Descriptor() ([]byte, []int)
- func (m *KubernetesError) GetResourceType() string
- func (m *KubernetesError) Marshal() (dAtA []byte, err error)
- func (m *KubernetesError) MarshalTo(dAtA []byte) (int, error)
- func (m *KubernetesError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KubernetesError) ProtoMessage()
- func (m *KubernetesError) Reset()
- func (m *KubernetesError) Size() (n int)
- func (m *KubernetesError) String() string
- func (m *KubernetesError) Unmarshal(dAtA []byte) error
- func (m *KubernetesError) XXX_DiscardUnknown()
- func (m *KubernetesError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubernetesError) XXX_Merge(src proto.Message)
- func (m *KubernetesError) XXX_Size() int
- func (m *KubernetesError) XXX_Unmarshal(b []byte) error
- type KubernetesMainObject
- func (*KubernetesMainObject) Descriptor() ([]byte, []int)
- func (m *KubernetesMainObject) GetObject() isKubernetesMainObject_Object
- func (m *KubernetesMainObject) GetObjectMeta() *ObjectMeta
- func (m *KubernetesMainObject) GetPodSpec() *PodSpecWithAvoidList
- func (m *KubernetesMainObject) Marshal() (dAtA []byte, err error)
- func (m *KubernetesMainObject) MarshalTo(dAtA []byte) (int, error)
- func (m *KubernetesMainObject) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KubernetesMainObject) ProtoMessage()
- func (m *KubernetesMainObject) Reset()
- func (m *KubernetesMainObject) Size() (n int)
- func (m *KubernetesMainObject) String() string
- func (m *KubernetesMainObject) Unmarshal(dAtA []byte) error
- func (m *KubernetesMainObject) XXX_DiscardUnknown()
- func (m *KubernetesMainObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubernetesMainObject) XXX_Merge(src proto.Message)
- func (*KubernetesMainObject) XXX_OneofWrappers() []interface{}
- func (m *KubernetesMainObject) XXX_Size() int
- func (m *KubernetesMainObject) XXX_Unmarshal(b []byte) error
- type KubernetesMainObject_PodSpec
- type KubernetesObject
- func (*KubernetesObject) Descriptor() ([]byte, []int)
- func (m *KubernetesObject) GetConfigMap() *v11.ConfigMap
- func (m *KubernetesObject) GetIngress() *v1.IngressSpec
- func (m *KubernetesObject) GetObject() isKubernetesObject_Object
- func (m *KubernetesObject) GetObjectMeta() *ObjectMeta
- func (m *KubernetesObject) GetPodSpec() *PodSpecWithAvoidList
- func (m *KubernetesObject) GetService() *v11.ServiceSpec
- func (m *KubernetesObject) Marshal() (dAtA []byte, err error)
- func (m *KubernetesObject) MarshalTo(dAtA []byte) (int, error)
- func (m *KubernetesObject) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KubernetesObject) ProtoMessage()
- func (m *KubernetesObject) Reset()
- func (m *KubernetesObject) Size() (n int)
- func (m *KubernetesObject) String() string
- func (m *KubernetesObject) Unmarshal(dAtA []byte) error
- func (m *KubernetesObject) XXX_DiscardUnknown()
- func (m *KubernetesObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubernetesObject) XXX_Merge(src proto.Message)
- func (*KubernetesObject) XXX_OneofWrappers() []interface{}
- func (m *KubernetesObject) XXX_Size() int
- func (m *KubernetesObject) XXX_Unmarshal(b []byte) error
- type KubernetesObject_ConfigMap
- type KubernetesObject_Ingress
- type KubernetesObject_PodSpec
- type KubernetesObject_Service
- type KubernetesReason
- type KubernetesResourceInfo
- func (*KubernetesResourceInfo) Descriptor() ([]byte, []int)
- func (m *KubernetesResourceInfo) GetInfo() isKubernetesResourceInfo_Info
- func (m *KubernetesResourceInfo) GetIngressInfo() *IngressInfo
- func (m *KubernetesResourceInfo) GetObjectMeta() *ObjectMeta
- func (m *KubernetesResourceInfo) GetPodInfo() *PodInfo
- func (m *KubernetesResourceInfo) Marshal() (dAtA []byte, err error)
- func (m *KubernetesResourceInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *KubernetesResourceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KubernetesResourceInfo) ProtoMessage()
- func (m *KubernetesResourceInfo) Reset()
- func (m *KubernetesResourceInfo) Size() (n int)
- func (m *KubernetesResourceInfo) String() string
- func (m *KubernetesResourceInfo) Unmarshal(dAtA []byte) error
- func (m *KubernetesResourceInfo) XXX_DiscardUnknown()
- func (m *KubernetesResourceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KubernetesResourceInfo) XXX_Merge(src proto.Message)
- func (*KubernetesResourceInfo) XXX_OneofWrappers() []interface{}
- func (m *KubernetesResourceInfo) XXX_Size() int
- func (m *KubernetesResourceInfo) XXX_Unmarshal(b []byte) error
- type KubernetesResourceInfo_IngressInfo
- type KubernetesResourceInfo_PodInfo
- type LeaseExpired
- func (*LeaseExpired) Descriptor() ([]byte, []int)
- func (m *LeaseExpired) Marshal() (dAtA []byte, err error)
- func (m *LeaseExpired) MarshalTo(dAtA []byte) (int, error)
- func (m *LeaseExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeaseExpired) ProtoMessage()
- func (m *LeaseExpired) Reset()
- func (m *LeaseExpired) Size() (n int)
- func (m *LeaseExpired) String() string
- func (m *LeaseExpired) Unmarshal(dAtA []byte) error
- func (m *LeaseExpired) XXX_DiscardUnknown()
- func (m *LeaseExpired) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeaseExpired) XXX_Merge(src proto.Message)
- func (m *LeaseExpired) XXX_Size() int
- func (m *LeaseExpired) XXX_Unmarshal(b []byte) error
- type MaxRunsExceeded
- func (*MaxRunsExceeded) Descriptor() ([]byte, []int)
- func (m *MaxRunsExceeded) GetMessage() string
- func (m *MaxRunsExceeded) Marshal() (dAtA []byte, err error)
- func (m *MaxRunsExceeded) MarshalTo(dAtA []byte) (int, error)
- func (m *MaxRunsExceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MaxRunsExceeded) ProtoMessage()
- func (m *MaxRunsExceeded) Reset()
- func (m *MaxRunsExceeded) Size() (n int)
- func (m *MaxRunsExceeded) String() string
- func (m *MaxRunsExceeded) Unmarshal(dAtA []byte) error
- func (m *MaxRunsExceeded) XXX_DiscardUnknown()
- func (m *MaxRunsExceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaxRunsExceeded) XXX_Merge(src proto.Message)
- func (m *MaxRunsExceeded) XXX_Size() int
- func (m *MaxRunsExceeded) XXX_Unmarshal(b []byte) error
- type ObjectMeta
- func (*ObjectMeta) Descriptor() ([]byte, []int)
- func (m *ObjectMeta) GetAnnotations() map[string]string
- func (m *ObjectMeta) GetExecutorId() string
- func (m *ObjectMeta) GetKubernetesId() string
- func (m *ObjectMeta) GetLabels() map[string]string
- func (m *ObjectMeta) GetName() string
- func (m *ObjectMeta) GetNamespace() string
- func (m *ObjectMeta) Marshal() (dAtA []byte, err error)
- func (m *ObjectMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *ObjectMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ObjectMeta) ProtoMessage()
- func (m *ObjectMeta) Reset()
- func (m *ObjectMeta) Size() (n int)
- func (m *ObjectMeta) String() string
- func (m *ObjectMeta) Unmarshal(dAtA []byte) error
- func (m *ObjectMeta) XXX_DiscardUnknown()
- func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectMeta) XXX_Merge(src proto.Message)
- func (m *ObjectMeta) XXX_Size() int
- func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
- type PartitionMarker
- func (*PartitionMarker) Descriptor() ([]byte, []int)
- func (m *PartitionMarker) GetGroupId() string
- func (m *PartitionMarker) GetPartition() uint32
- func (m *PartitionMarker) Marshal() (dAtA []byte, err error)
- func (m *PartitionMarker) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionMarker) ProtoMessage()
- func (m *PartitionMarker) Reset()
- func (m *PartitionMarker) Size() (n int)
- func (m *PartitionMarker) String() string
- func (m *PartitionMarker) Unmarshal(dAtA []byte) error
- func (m *PartitionMarker) XXX_DiscardUnknown()
- func (m *PartitionMarker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionMarker) XXX_Merge(src proto.Message)
- func (m *PartitionMarker) XXX_Size() int
- func (m *PartitionMarker) XXX_Unmarshal(b []byte) error
- type PodError
- func (*PodError) Descriptor() ([]byte, []int)
- func (m *PodError) GetContainerErrors() []*ContainerError
- func (m *PodError) GetDebugMessage() string
- func (m *PodError) GetKubernetesReason() KubernetesReason
- func (m *PodError) GetMessage() string
- func (m *PodError) GetNodeName() string
- func (m *PodError) GetObjectMeta() *ObjectMeta
- func (m *PodError) GetPodNumber() int32
- func (m *PodError) Marshal() (dAtA []byte, err error)
- func (m *PodError) MarshalTo(dAtA []byte) (int, error)
- func (m *PodError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodError) ProtoMessage()
- func (m *PodError) Reset()
- func (m *PodError) Size() (n int)
- func (m *PodError) String() string
- func (m *PodError) Unmarshal(dAtA []byte) error
- func (m *PodError) XXX_DiscardUnknown()
- func (m *PodError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodError) XXX_Merge(src proto.Message)
- func (m *PodError) XXX_Size() int
- func (m *PodError) XXX_Unmarshal(b []byte) error
- type PodInfo
- func (*PodInfo) Descriptor() ([]byte, []int)
- func (m *PodInfo) GetNodeName() string
- func (m *PodInfo) GetPodNumber() int32
- func (m *PodInfo) Marshal() (dAtA []byte, err error)
- func (m *PodInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *PodInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodInfo) ProtoMessage()
- func (m *PodInfo) Reset()
- func (m *PodInfo) Size() (n int)
- func (m *PodInfo) String() string
- func (m *PodInfo) Unmarshal(dAtA []byte) error
- func (m *PodInfo) XXX_DiscardUnknown()
- func (m *PodInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodInfo) XXX_Merge(src proto.Message)
- func (m *PodInfo) XXX_Size() int
- func (m *PodInfo) XXX_Unmarshal(b []byte) error
- type PodLeaseReturned
- func (*PodLeaseReturned) Descriptor() ([]byte, []int)
- func (m *PodLeaseReturned) GetDebugMessage() string
- func (m *PodLeaseReturned) GetMessage() string
- func (m *PodLeaseReturned) GetObjectMeta() *ObjectMeta
- func (m *PodLeaseReturned) GetPodNumber() int32
- func (m *PodLeaseReturned) GetRunAttempted() bool
- func (m *PodLeaseReturned) Marshal() (dAtA []byte, err error)
- func (m *PodLeaseReturned) MarshalTo(dAtA []byte) (int, error)
- func (m *PodLeaseReturned) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodLeaseReturned) ProtoMessage()
- func (m *PodLeaseReturned) Reset()
- func (m *PodLeaseReturned) Size() (n int)
- func (m *PodLeaseReturned) String() string
- func (m *PodLeaseReturned) Unmarshal(dAtA []byte) error
- func (m *PodLeaseReturned) XXX_DiscardUnknown()
- func (m *PodLeaseReturned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodLeaseReturned) XXX_Merge(src proto.Message)
- func (m *PodLeaseReturned) XXX_Size() int
- func (m *PodLeaseReturned) XXX_Unmarshal(b []byte) error
- type PodSpecWithAvoidList
- func (*PodSpecWithAvoidList) Descriptor() ([]byte, []int)
- func (m *PodSpecWithAvoidList) GetNodeAvoidlist() []string
- func (m *PodSpecWithAvoidList) GetPodSpec() *v11.PodSpec
- func (m *PodSpecWithAvoidList) Marshal() (dAtA []byte, err error)
- func (m *PodSpecWithAvoidList) MarshalTo(dAtA []byte) (int, error)
- func (m *PodSpecWithAvoidList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodSpecWithAvoidList) ProtoMessage()
- func (m *PodSpecWithAvoidList) Reset()
- func (m *PodSpecWithAvoidList) Size() (n int)
- func (m *PodSpecWithAvoidList) String() string
- func (m *PodSpecWithAvoidList) Unmarshal(dAtA []byte) error
- func (m *PodSpecWithAvoidList) XXX_DiscardUnknown()
- func (m *PodSpecWithAvoidList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodSpecWithAvoidList) XXX_Merge(src proto.Message)
- func (m *PodSpecWithAvoidList) XXX_Size() int
- func (m *PodSpecWithAvoidList) XXX_Unmarshal(b []byte) error
- type PodTerminated
- func (*PodTerminated) Descriptor() ([]byte, []int)
- func (m *PodTerminated) GetMessage() string
- func (m *PodTerminated) GetNodeName() string
- func (m *PodTerminated) GetObjectMeta() *ObjectMeta
- func (m *PodTerminated) GetPodNumber() int32
- func (m *PodTerminated) Marshal() (dAtA []byte, err error)
- func (m *PodTerminated) MarshalTo(dAtA []byte) (int, error)
- func (m *PodTerminated) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodTerminated) ProtoMessage()
- func (m *PodTerminated) Reset()
- func (m *PodTerminated) Size() (n int)
- func (m *PodTerminated) String() string
- func (m *PodTerminated) Unmarshal(dAtA []byte) error
- func (m *PodTerminated) XXX_DiscardUnknown()
- func (m *PodTerminated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodTerminated) XXX_Merge(src proto.Message)
- func (m *PodTerminated) XXX_Size() int
- func (m *PodTerminated) XXX_Unmarshal(b []byte) error
- type PodUnschedulable
- func (*PodUnschedulable) Descriptor() ([]byte, []int)
- func (m *PodUnschedulable) GetMessage() string
- func (m *PodUnschedulable) GetNodeName() string
- func (m *PodUnschedulable) GetObjectMeta() *ObjectMeta
- func (m *PodUnschedulable) GetPodNumber() int32
- func (m *PodUnschedulable) Marshal() (dAtA []byte, err error)
- func (m *PodUnschedulable) MarshalTo(dAtA []byte) (int, error)
- func (m *PodUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodUnschedulable) ProtoMessage()
- func (m *PodUnschedulable) Reset()
- func (m *PodUnschedulable) Size() (n int)
- func (m *PodUnschedulable) String() string
- func (m *PodUnschedulable) Unmarshal(dAtA []byte) error
- func (m *PodUnschedulable) XXX_DiscardUnknown()
- func (m *PodUnschedulable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodUnschedulable) XXX_Merge(src proto.Message)
- func (m *PodUnschedulable) XXX_Size() int
- func (m *PodUnschedulable) XXX_Unmarshal(b []byte) error
- type ReprioritiseJob
- func (*ReprioritiseJob) Descriptor() ([]byte, []int)
- func (m *ReprioritiseJob) GetJobId() string
- func (m *ReprioritiseJob) GetPriority() uint32
- func (m *ReprioritiseJob) Marshal() (dAtA []byte, err error)
- func (m *ReprioritiseJob) MarshalTo(dAtA []byte) (int, error)
- func (m *ReprioritiseJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReprioritiseJob) ProtoMessage()
- func (m *ReprioritiseJob) Reset()
- func (m *ReprioritiseJob) Size() (n int)
- func (m *ReprioritiseJob) String() string
- func (m *ReprioritiseJob) Unmarshal(dAtA []byte) error
- func (m *ReprioritiseJob) XXX_DiscardUnknown()
- func (m *ReprioritiseJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReprioritiseJob) XXX_Merge(src proto.Message)
- func (m *ReprioritiseJob) XXX_Size() int
- func (m *ReprioritiseJob) XXX_Unmarshal(b []byte) error
- type ReprioritiseJobSet
- func (*ReprioritiseJobSet) Descriptor() ([]byte, []int)
- func (m *ReprioritiseJobSet) GetPriority() uint32
- func (m *ReprioritiseJobSet) Marshal() (dAtA []byte, err error)
- func (m *ReprioritiseJobSet) MarshalTo(dAtA []byte) (int, error)
- func (m *ReprioritiseJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReprioritiseJobSet) ProtoMessage()
- func (m *ReprioritiseJobSet) Reset()
- func (m *ReprioritiseJobSet) Size() (n int)
- func (m *ReprioritiseJobSet) String() string
- func (m *ReprioritiseJobSet) Unmarshal(dAtA []byte) error
- func (m *ReprioritiseJobSet) XXX_DiscardUnknown()
- func (m *ReprioritiseJobSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReprioritiseJobSet) XXX_Merge(src proto.Message)
- func (m *ReprioritiseJobSet) XXX_Size() int
- func (m *ReprioritiseJobSet) XXX_Unmarshal(b []byte) error
- type ReprioritisedJob
- func (*ReprioritisedJob) Descriptor() ([]byte, []int)
- func (m *ReprioritisedJob) GetJobId() string
- func (m *ReprioritisedJob) GetPriority() uint32
- func (m *ReprioritisedJob) Marshal() (dAtA []byte, err error)
- func (m *ReprioritisedJob) MarshalTo(dAtA []byte) (int, error)
- func (m *ReprioritisedJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReprioritisedJob) ProtoMessage()
- func (m *ReprioritisedJob) Reset()
- func (m *ReprioritisedJob) Size() (n int)
- func (m *ReprioritisedJob) String() string
- func (m *ReprioritisedJob) Unmarshal(dAtA []byte) error
- func (m *ReprioritisedJob) XXX_DiscardUnknown()
- func (m *ReprioritisedJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReprioritisedJob) XXX_Merge(src proto.Message)
- func (m *ReprioritisedJob) XXX_Size() int
- func (m *ReprioritisedJob) XXX_Unmarshal(b []byte) error
- type ResourceUtilisation
- func (*ResourceUtilisation) Descriptor() ([]byte, []int)
- func (m *ResourceUtilisation) GetJobId() string
- func (m *ResourceUtilisation) GetMaxResourcesForPeriod() map[string]*resource.Quantity
- func (m *ResourceUtilisation) GetResourceInfo() *KubernetesResourceInfo
- func (m *ResourceUtilisation) GetRunId() string
- func (m *ResourceUtilisation) GetTotalCumulativeUsage() map[string]*resource.Quantity
- func (m *ResourceUtilisation) Marshal() (dAtA []byte, err error)
- func (m *ResourceUtilisation) MarshalTo(dAtA []byte) (int, error)
- func (m *ResourceUtilisation) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResourceUtilisation) ProtoMessage()
- func (m *ResourceUtilisation) Reset()
- func (m *ResourceUtilisation) Size() (n int)
- func (m *ResourceUtilisation) String() string
- func (m *ResourceUtilisation) Unmarshal(dAtA []byte) error
- func (m *ResourceUtilisation) XXX_DiscardUnknown()
- func (m *ResourceUtilisation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResourceUtilisation) XXX_Merge(src proto.Message)
- func (m *ResourceUtilisation) XXX_Size() int
- func (m *ResourceUtilisation) XXX_Unmarshal(b []byte) error
- type StandaloneIngressInfo
- func (*StandaloneIngressInfo) Descriptor() ([]byte, []int)
- func (m *StandaloneIngressInfo) GetIngressAddresses() map[int32]string
- func (m *StandaloneIngressInfo) GetJobId() string
- func (m *StandaloneIngressInfo) GetNodeName() string
- func (m *StandaloneIngressInfo) GetObjectMeta() *ObjectMeta
- func (m *StandaloneIngressInfo) GetPodName() string
- func (m *StandaloneIngressInfo) GetPodNamespace() string
- func (m *StandaloneIngressInfo) GetPodNumber() int32
- func (m *StandaloneIngressInfo) GetRunId() string
- func (m *StandaloneIngressInfo) Marshal() (dAtA []byte, err error)
- func (m *StandaloneIngressInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *StandaloneIngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StandaloneIngressInfo) ProtoMessage()
- func (m *StandaloneIngressInfo) Reset()
- func (m *StandaloneIngressInfo) Size() (n int)
- func (m *StandaloneIngressInfo) String() string
- func (m *StandaloneIngressInfo) Unmarshal(dAtA []byte) error
- func (m *StandaloneIngressInfo) XXX_DiscardUnknown()
- func (m *StandaloneIngressInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StandaloneIngressInfo) XXX_Merge(src proto.Message)
- func (m *StandaloneIngressInfo) XXX_Size() int
- func (m *StandaloneIngressInfo) XXX_Unmarshal(b []byte) error
- type SubmitJob
- func (*SubmitJob) Descriptor() ([]byte, []int)
- func (m *SubmitJob) GetAtMostOnce() bool
- func (m *SubmitJob) GetConcurrencySafe() bool
- func (m *SubmitJob) GetDeduplicationId() string
- func (m *SubmitJob) GetExperimentalPriceInfo() *ExperimentalPriceInfo
- func (m *SubmitJob) GetIsDuplicate() bool
- func (m *SubmitJob) GetJobId() string
- func (m *SubmitJob) GetLifetime() uint32
- func (m *SubmitJob) GetMainObject() *KubernetesMainObject
- func (m *SubmitJob) GetObjectMeta() *ObjectMeta
- func (m *SubmitJob) GetObjects() []*KubernetesObject
- func (m *SubmitJob) GetPreemptible() bool
- func (m *SubmitJob) GetPriority() uint32
- func (m *SubmitJob) GetScheduler() string
- func (m *SubmitJob) Marshal() (dAtA []byte, err error)
- func (m *SubmitJob) MarshalTo(dAtA []byte) (int, error)
- func (m *SubmitJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubmitJob) ProtoMessage()
- func (m *SubmitJob) Reset()
- func (m *SubmitJob) Size() (n int)
- func (m *SubmitJob) String() string
- func (m *SubmitJob) Unmarshal(dAtA []byte) error
- func (m *SubmitJob) XXX_DiscardUnknown()
- func (m *SubmitJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubmitJob) XXX_Merge(src proto.Message)
- func (m *SubmitJob) XXX_Size() int
- func (m *SubmitJob) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") )
var JobState_name = map[int32]string{
0: "QUEUED",
1: "PENDING",
2: "RUNNING",
}
var JobState_value = map[string]int32{
"QUEUED": 0,
"PENDING": 1,
"RUNNING": 2,
}
var KubernetesReason_name = map[int32]string{
0: "AppError",
1: "Evicted",
2: "OOM",
3: "DeadlineExceeded",
}
var KubernetesReason_value = map[string]int32{
"AppError": 0,
"Evicted": 1,
"OOM": 2,
"DeadlineExceeded": 3,
}
Functions ¶
func JobIdFromEvent ¶
func JobIdFromEvent(event *EventSequence_Event) (string, error)
Types ¶
type CancelJob ¶
type CancelJob struct { Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
A request to cancel a particular job. This will cancel all runs (preempting it if running) for the job (i.e., move them to the failed state) and then cancel job itself (i.e., move it to the failed state).
func (*CancelJob) Descriptor ¶
func (*CancelJob) MarshalToSizedBuffer ¶
func (*CancelJob) ProtoMessage ¶
func (*CancelJob) ProtoMessage()
func (*CancelJob) XXX_DiscardUnknown ¶
func (m *CancelJob) XXX_DiscardUnknown()
func (*CancelJob) XXX_Marshal ¶
func (*CancelJob) XXX_Unmarshal ¶
type CancelJobSet ¶
type CancelJobSet struct { States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=armadaevents.JobState" json:"states,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` }
Request to cancel all jobs in a job set. Empty set of states means all states
func (*CancelJobSet) Descriptor ¶
func (*CancelJobSet) Descriptor() ([]byte, []int)
func (*CancelJobSet) GetReason ¶ added in v0.3.68
func (m *CancelJobSet) GetReason() string
func (*CancelJobSet) GetStates ¶ added in v0.3.49
func (m *CancelJobSet) GetStates() []JobState
func (*CancelJobSet) Marshal ¶
func (m *CancelJobSet) Marshal() (dAtA []byte, err error)
func (*CancelJobSet) MarshalToSizedBuffer ¶
func (m *CancelJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CancelJobSet) ProtoMessage ¶
func (*CancelJobSet) ProtoMessage()
func (*CancelJobSet) Reset ¶
func (m *CancelJobSet) Reset()
func (*CancelJobSet) Size ¶
func (m *CancelJobSet) Size() (n int)
func (*CancelJobSet) String ¶
func (m *CancelJobSet) String() string
func (*CancelJobSet) Unmarshal ¶
func (m *CancelJobSet) Unmarshal(dAtA []byte) error
func (*CancelJobSet) XXX_DiscardUnknown ¶
func (m *CancelJobSet) XXX_DiscardUnknown()
func (*CancelJobSet) XXX_Marshal ¶
func (m *CancelJobSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelJobSet) XXX_Merge ¶
func (m *CancelJobSet) XXX_Merge(src proto.Message)
func (*CancelJobSet) XXX_Size ¶
func (m *CancelJobSet) XXX_Size() int
func (*CancelJobSet) XXX_Unmarshal ¶
func (m *CancelJobSet) XXX_Unmarshal(b []byte) error
type CancelledJob ¶
type CancelledJob struct { Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
Generated by the scheduler in response to CancelJob and CancelJobSet. One such message is generated per job that was cancelled.
func (*CancelledJob) Descriptor ¶
func (*CancelledJob) Descriptor() ([]byte, []int)
func (*CancelledJob) GetJobId ¶
func (m *CancelledJob) GetJobId() string
func (*CancelledJob) GetReason ¶ added in v0.3.68
func (m *CancelledJob) GetReason() string
func (*CancelledJob) Marshal ¶
func (m *CancelledJob) Marshal() (dAtA []byte, err error)
func (*CancelledJob) MarshalToSizedBuffer ¶
func (m *CancelledJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CancelledJob) ProtoMessage ¶
func (*CancelledJob) ProtoMessage()
func (*CancelledJob) Reset ¶
func (m *CancelledJob) Reset()
func (*CancelledJob) Size ¶
func (m *CancelledJob) Size() (n int)
func (*CancelledJob) String ¶
func (m *CancelledJob) String() string
func (*CancelledJob) Unmarshal ¶
func (m *CancelledJob) Unmarshal(dAtA []byte) error
func (*CancelledJob) XXX_DiscardUnknown ¶
func (m *CancelledJob) XXX_DiscardUnknown()
func (*CancelledJob) XXX_Marshal ¶
func (m *CancelledJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelledJob) XXX_Merge ¶
func (m *CancelledJob) XXX_Merge(src proto.Message)
func (*CancelledJob) XXX_Size ¶
func (m *CancelledJob) XXX_Size() int
func (*CancelledJob) XXX_Unmarshal ¶
func (m *CancelledJob) XXX_Unmarshal(b []byte) error
type ContainerError ¶
type ContainerError struct { // this ObjectMeta identifies the container ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` // Exit code of the application running in the container. ExitCode int32 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exitCode,omitempty"` // Corresponds to v1.ContainerStateTerminated.Message Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // Corresponds to v1.ContainerStateTerminated.Reason Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"` // Reason reported by Kubernetes. KubernetesReason KubernetesReason `` /* 144-byte string literal not displayed */ }
func (*ContainerError) Descriptor ¶
func (*ContainerError) Descriptor() ([]byte, []int)
func (*ContainerError) GetExitCode ¶
func (m *ContainerError) GetExitCode() int32
func (*ContainerError) GetKubernetesReason ¶
func (m *ContainerError) GetKubernetesReason() KubernetesReason
func (*ContainerError) GetMessage ¶
func (m *ContainerError) GetMessage() string
func (*ContainerError) GetObjectMeta ¶
func (m *ContainerError) GetObjectMeta() *ObjectMeta
func (*ContainerError) GetReason ¶
func (m *ContainerError) GetReason() string
func (*ContainerError) Marshal ¶
func (m *ContainerError) Marshal() (dAtA []byte, err error)
func (*ContainerError) MarshalToSizedBuffer ¶
func (m *ContainerError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerError) ProtoMessage ¶
func (*ContainerError) ProtoMessage()
func (*ContainerError) Reset ¶
func (m *ContainerError) Reset()
func (*ContainerError) Size ¶
func (m *ContainerError) Size() (n int)
func (*ContainerError) String ¶
func (m *ContainerError) String() string
func (*ContainerError) Unmarshal ¶
func (m *ContainerError) Unmarshal(dAtA []byte) error
func (*ContainerError) XXX_DiscardUnknown ¶
func (m *ContainerError) XXX_DiscardUnknown()
func (*ContainerError) XXX_Marshal ¶
func (m *ContainerError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerError) XXX_Merge ¶
func (m *ContainerError) XXX_Merge(src proto.Message)
func (*ContainerError) XXX_Size ¶
func (m *ContainerError) XXX_Size() int
func (*ContainerError) XXX_Unmarshal ¶
func (m *ContainerError) XXX_Unmarshal(b []byte) error
type Error ¶
type Error struct { // If true, this error represents an unrecoverable failure and Armada has given up on this job or job run. Terminal bool `protobuf:"varint,1,opt,name=terminal,proto3" json:"terminal,omitempty"` // Additional information for this particular combination of component and error. May be set to nil. // // Types that are valid to be assigned to Reason: // *Error_KubernetesError // *Error_ContainerError // *Error_ExecutorError // *Error_PodUnschedulable // *Error_LeaseExpired // *Error_MaxRunsExceeded // *Error_PodError // *Error_PodLeaseReturned // *Error_JobRunPreemptedError // *Error_GangJobUnschedulable // *Error_JobRejected Reason isError_Reason `protobuf_oneof:"reason"` }
Represents a failure that took place in the course of a job run (i.e., an attempt to run a job). Each failure is either a resource failure or a system-level failure. Resource failures correspond to a problem with a specific Kubernetes resource (e.g., if a container terminates with a non-zero exit code). System-level failure messages are created by the executor (e.g., a failure by the executor to write to Kubernetes).
This message may only be published to the log as part of a JobRunError message. TODO: Check if the container status contained any useful info for non-failed containers.
func (*Error) Descriptor ¶
func (*Error) GetContainerError ¶
func (m *Error) GetContainerError() *ContainerError
func (*Error) GetExecutorError ¶
func (m *Error) GetExecutorError() *ExecutorError
func (*Error) GetGangJobUnschedulable ¶ added in v0.3.95
func (m *Error) GetGangJobUnschedulable() *GangJobUnschedulable
func (*Error) GetJobRejected ¶ added in v0.4.50
func (m *Error) GetJobRejected() *JobRejected
func (*Error) GetJobRunPreemptedError ¶ added in v0.3.54
func (m *Error) GetJobRunPreemptedError() *JobRunPreemptedError
func (*Error) GetKubernetesError ¶
func (m *Error) GetKubernetesError() *KubernetesError
func (*Error) GetLeaseExpired ¶
func (m *Error) GetLeaseExpired() *LeaseExpired
func (*Error) GetMaxRunsExceeded ¶
func (m *Error) GetMaxRunsExceeded() *MaxRunsExceeded
func (*Error) GetPodError ¶
func (*Error) GetPodLeaseReturned ¶
func (m *Error) GetPodLeaseReturned() *PodLeaseReturned
func (*Error) GetPodUnschedulable ¶
func (m *Error) GetPodUnschedulable() *PodUnschedulable
func (*Error) GetTerminal ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_OneofWrappers ¶
func (*Error) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Error) XXX_Unmarshal ¶
type Error_ContainerError ¶
type Error_ContainerError struct {
ContainerError *ContainerError `protobuf:"bytes,3,opt,name=containerError,proto3,oneof" json:"containerError,omitempty"`
}
func (*Error_ContainerError) MarshalTo ¶
func (m *Error_ContainerError) MarshalTo(dAtA []byte) (int, error)
func (*Error_ContainerError) MarshalToSizedBuffer ¶
func (m *Error_ContainerError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_ContainerError) Size ¶
func (m *Error_ContainerError) Size() (n int)
type Error_ExecutorError ¶
type Error_ExecutorError struct {
ExecutorError *ExecutorError `protobuf:"bytes,4,opt,name=executorError,proto3,oneof" json:"executorError,omitempty"`
}
func (*Error_ExecutorError) MarshalTo ¶
func (m *Error_ExecutorError) MarshalTo(dAtA []byte) (int, error)
func (*Error_ExecutorError) MarshalToSizedBuffer ¶
func (m *Error_ExecutorError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_ExecutorError) Size ¶
func (m *Error_ExecutorError) Size() (n int)
type Error_GangJobUnschedulable ¶ added in v0.3.95
type Error_GangJobUnschedulable struct {
GangJobUnschedulable *GangJobUnschedulable `protobuf:"bytes,12,opt,name=gangJobUnschedulable,proto3,oneof" json:"gangJobUnschedulable,omitempty"`
}
func (*Error_GangJobUnschedulable) MarshalTo ¶ added in v0.3.95
func (m *Error_GangJobUnschedulable) MarshalTo(dAtA []byte) (int, error)
func (*Error_GangJobUnschedulable) MarshalToSizedBuffer ¶ added in v0.3.95
func (m *Error_GangJobUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_GangJobUnschedulable) Size ¶ added in v0.3.95
func (m *Error_GangJobUnschedulable) Size() (n int)
type Error_JobRejected ¶ added in v0.4.50
type Error_JobRejected struct {
JobRejected *JobRejected `protobuf:"bytes,13,opt,name=jobRejected,proto3,oneof" json:"jobRejected,omitempty"`
}
func (*Error_JobRejected) MarshalTo ¶ added in v0.4.50
func (m *Error_JobRejected) MarshalTo(dAtA []byte) (int, error)
func (*Error_JobRejected) MarshalToSizedBuffer ¶ added in v0.4.50
func (m *Error_JobRejected) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_JobRejected) Size ¶ added in v0.4.50
func (m *Error_JobRejected) Size() (n int)
type Error_JobRunPreemptedError ¶ added in v0.3.54
type Error_JobRunPreemptedError struct {
JobRunPreemptedError *JobRunPreemptedError `protobuf:"bytes,11,opt,name=jobRunPreemptedError,proto3,oneof" json:"jobRunPreemptedError,omitempty"`
}
func (*Error_JobRunPreemptedError) MarshalTo ¶ added in v0.3.54
func (m *Error_JobRunPreemptedError) MarshalTo(dAtA []byte) (int, error)
func (*Error_JobRunPreemptedError) MarshalToSizedBuffer ¶ added in v0.3.54
func (m *Error_JobRunPreemptedError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_JobRunPreemptedError) Size ¶ added in v0.3.54
func (m *Error_JobRunPreemptedError) Size() (n int)
type Error_KubernetesError ¶
type Error_KubernetesError struct {
KubernetesError *KubernetesError `protobuf:"bytes,2,opt,name=kubernetesError,proto3,oneof" json:"kubernetesError,omitempty"`
}
func (*Error_KubernetesError) MarshalTo ¶
func (m *Error_KubernetesError) MarshalTo(dAtA []byte) (int, error)
func (*Error_KubernetesError) MarshalToSizedBuffer ¶
func (m *Error_KubernetesError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_KubernetesError) Size ¶
func (m *Error_KubernetesError) Size() (n int)
type Error_LeaseExpired ¶
type Error_LeaseExpired struct {
LeaseExpired *LeaseExpired `protobuf:"bytes,6,opt,name=leaseExpired,proto3,oneof" json:"leaseExpired,omitempty"`
}
func (*Error_LeaseExpired) MarshalTo ¶
func (m *Error_LeaseExpired) MarshalTo(dAtA []byte) (int, error)
func (*Error_LeaseExpired) MarshalToSizedBuffer ¶
func (m *Error_LeaseExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_LeaseExpired) Size ¶
func (m *Error_LeaseExpired) Size() (n int)
type Error_MaxRunsExceeded ¶
type Error_MaxRunsExceeded struct {
MaxRunsExceeded *MaxRunsExceeded `protobuf:"bytes,7,opt,name=maxRunsExceeded,proto3,oneof" json:"maxRunsExceeded,omitempty"`
}
func (*Error_MaxRunsExceeded) MarshalTo ¶
func (m *Error_MaxRunsExceeded) MarshalTo(dAtA []byte) (int, error)
func (*Error_MaxRunsExceeded) MarshalToSizedBuffer ¶
func (m *Error_MaxRunsExceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_MaxRunsExceeded) Size ¶
func (m *Error_MaxRunsExceeded) Size() (n int)
type Error_PodError ¶
type Error_PodError struct {
PodError *PodError `protobuf:"bytes,8,opt,name=podError,proto3,oneof" json:"podError,omitempty"`
}
func (*Error_PodError) MarshalToSizedBuffer ¶
func (m *Error_PodError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_PodError) Size ¶
func (m *Error_PodError) Size() (n int)
type Error_PodLeaseReturned ¶
type Error_PodLeaseReturned struct {
PodLeaseReturned *PodLeaseReturned `protobuf:"bytes,9,opt,name=podLeaseReturned,proto3,oneof" json:"podLeaseReturned,omitempty"`
}
func (*Error_PodLeaseReturned) MarshalTo ¶
func (m *Error_PodLeaseReturned) MarshalTo(dAtA []byte) (int, error)
func (*Error_PodLeaseReturned) MarshalToSizedBuffer ¶
func (m *Error_PodLeaseReturned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_PodLeaseReturned) Size ¶
func (m *Error_PodLeaseReturned) Size() (n int)
type Error_PodUnschedulable ¶
type Error_PodUnschedulable struct {
PodUnschedulable *PodUnschedulable `protobuf:"bytes,5,opt,name=podUnschedulable,proto3,oneof" json:"podUnschedulable,omitempty"`
}
func (*Error_PodUnschedulable) MarshalTo ¶
func (m *Error_PodUnschedulable) MarshalTo(dAtA []byte) (int, error)
func (*Error_PodUnschedulable) MarshalToSizedBuffer ¶
func (m *Error_PodUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Error_PodUnschedulable) Size ¶
func (m *Error_PodUnschedulable) Size() (n int)
type EventSequence ¶
type EventSequence struct { // The system is namespaced by queue, and all events are associated with a job set. // Hence, these are included with every message. Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` // Each job set has a unique name. JobSetName string `protobuf:"bytes,2,opt,name=job_set_name,json=jobSetName,proto3" json:"jobSetName,omitempty"` // Id of the user submitting the message. Is passed on to Kubernetes. // Leave empty for messages generated by Armada itself. UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"userId,omitempty"` // List of groups the user is member of. Is passed on to Kubernetes. Groups []string `protobuf:"bytes,4,rep,name=groups,proto3" json:"groups,omitempty"` // For efficiency, we bundle several events (i.e., state transitions) in a single log message. Events []*EventSequence_Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"` }
Message representing a sequence of state transitions. This is the only message type that should ever be published to the log.
func (*EventSequence) Descriptor ¶
func (*EventSequence) Descriptor() ([]byte, []int)
func (*EventSequence) GetEvents ¶
func (m *EventSequence) GetEvents() []*EventSequence_Event
func (*EventSequence) GetGroups ¶
func (m *EventSequence) GetGroups() []string
func (*EventSequence) GetJobSetName ¶
func (m *EventSequence) GetJobSetName() string
func (*EventSequence) GetQueue ¶
func (m *EventSequence) GetQueue() string
func (*EventSequence) GetUserId ¶
func (m *EventSequence) GetUserId() string
func (*EventSequence) Marshal ¶
func (m *EventSequence) Marshal() (dAtA []byte, err error)
func (*EventSequence) MarshalToSizedBuffer ¶
func (m *EventSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence) ProtoMessage ¶
func (*EventSequence) ProtoMessage()
func (*EventSequence) Reset ¶
func (m *EventSequence) Reset()
func (*EventSequence) Size ¶
func (m *EventSequence) Size() (n int)
func (*EventSequence) String ¶
func (m *EventSequence) String() string
func (*EventSequence) Unmarshal ¶
func (m *EventSequence) Unmarshal(dAtA []byte) error
func (*EventSequence) XXX_DiscardUnknown ¶
func (m *EventSequence) XXX_DiscardUnknown()
func (*EventSequence) XXX_Marshal ¶
func (m *EventSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSequence) XXX_Merge ¶
func (m *EventSequence) XXX_Merge(src proto.Message)
func (*EventSequence) XXX_Size ¶
func (m *EventSequence) XXX_Size() int
func (*EventSequence) XXX_Unmarshal ¶
func (m *EventSequence) XXX_Unmarshal(b []byte) error
type EventSequence_Event ¶
type EventSequence_Event struct { Created *types.Timestamp `protobuf:"bytes,18,opt,name=created,proto3" json:"created,omitempty"` // Types that are valid to be assigned to Event: // *EventSequence_Event_SubmitJob // *EventSequence_Event_ReprioritiseJob // *EventSequence_Event_ReprioritiseJobSet // *EventSequence_Event_ReprioritisedJob // *EventSequence_Event_CancelJob // *EventSequence_Event_CancelJobSet // *EventSequence_Event_CancelledJob // *EventSequence_Event_JobSucceeded // *EventSequence_Event_JobErrors // *EventSequence_Event_JobRunLeased // *EventSequence_Event_JobRunAssigned // *EventSequence_Event_JobRunRunning // *EventSequence_Event_JobRunSucceeded // *EventSequence_Event_JobRunErrors // *EventSequence_Event_StandaloneIngressInfo // *EventSequence_Event_ResourceUtilisation // *EventSequence_Event_JobRunPreempted // *EventSequence_Event_PartitionMarker // *EventSequence_Event_JobRunPreemptionRequested // *EventSequence_Event_JobRequeued // *EventSequence_Event_JobPreemptionRequested // *EventSequence_Event_JobRunCancelled // *EventSequence_Event_JobValidated Event isEventSequence_Event_Event `protobuf_oneof:"event"` }
List of possible events, i.e., state transitions.
func (*EventSequence_Event) Descriptor ¶
func (*EventSequence_Event) Descriptor() ([]byte, []int)
func (*EventSequence_Event) GetCancelJob ¶
func (m *EventSequence_Event) GetCancelJob() *CancelJob
func (*EventSequence_Event) GetCancelJobSet ¶
func (m *EventSequence_Event) GetCancelJobSet() *CancelJobSet
func (*EventSequence_Event) GetCancelledJob ¶
func (m *EventSequence_Event) GetCancelledJob() *CancelledJob
func (*EventSequence_Event) GetCreated ¶
func (m *EventSequence_Event) GetCreated() *types.Timestamp
func (*EventSequence_Event) GetEvent ¶
func (m *EventSequence_Event) GetEvent() isEventSequence_Event_Event
func (*EventSequence_Event) GetEventName ¶ added in v0.8.3
func (ev *EventSequence_Event) GetEventName() string
func (*EventSequence_Event) GetJobErrors ¶
func (m *EventSequence_Event) GetJobErrors() *JobErrors
func (*EventSequence_Event) GetJobPreemptionRequested ¶ added in v0.4.41
func (m *EventSequence_Event) GetJobPreemptionRequested() *JobPreemptionRequested
func (*EventSequence_Event) GetJobRequeued ¶ added in v0.3.63
func (m *EventSequence_Event) GetJobRequeued() *JobRequeued
func (*EventSequence_Event) GetJobRunAssigned ¶
func (m *EventSequence_Event) GetJobRunAssigned() *JobRunAssigned
func (*EventSequence_Event) GetJobRunCancelled ¶ added in v0.4.48
func (m *EventSequence_Event) GetJobRunCancelled() *JobRunCancelled
func (*EventSequence_Event) GetJobRunErrors ¶
func (m *EventSequence_Event) GetJobRunErrors() *JobRunErrors
func (*EventSequence_Event) GetJobRunLeased ¶
func (m *EventSequence_Event) GetJobRunLeased() *JobRunLeased
func (*EventSequence_Event) GetJobRunPreempted ¶
func (m *EventSequence_Event) GetJobRunPreempted() *JobRunPreempted
func (*EventSequence_Event) GetJobRunPreemptionRequested ¶ added in v0.3.53
func (m *EventSequence_Event) GetJobRunPreemptionRequested() *JobRunPreemptionRequested
func (*EventSequence_Event) GetJobRunRunning ¶
func (m *EventSequence_Event) GetJobRunRunning() *JobRunRunning
func (*EventSequence_Event) GetJobRunSucceeded ¶
func (m *EventSequence_Event) GetJobRunSucceeded() *JobRunSucceeded
func (*EventSequence_Event) GetJobSucceeded ¶
func (m *EventSequence_Event) GetJobSucceeded() *JobSucceeded
func (*EventSequence_Event) GetJobValidated ¶ added in v0.4.50
func (m *EventSequence_Event) GetJobValidated() *JobValidated
func (*EventSequence_Event) GetPartitionMarker ¶ added in v0.3.48
func (m *EventSequence_Event) GetPartitionMarker() *PartitionMarker
func (*EventSequence_Event) GetReprioritiseJob ¶
func (m *EventSequence_Event) GetReprioritiseJob() *ReprioritiseJob
func (*EventSequence_Event) GetReprioritiseJobSet ¶
func (m *EventSequence_Event) GetReprioritiseJobSet() *ReprioritiseJobSet
func (*EventSequence_Event) GetReprioritisedJob ¶
func (m *EventSequence_Event) GetReprioritisedJob() *ReprioritisedJob
func (*EventSequence_Event) GetResourceUtilisation ¶
func (m *EventSequence_Event) GetResourceUtilisation() *ResourceUtilisation
func (*EventSequence_Event) GetStandaloneIngressInfo ¶
func (m *EventSequence_Event) GetStandaloneIngressInfo() *StandaloneIngressInfo
func (*EventSequence_Event) GetSubmitJob ¶
func (m *EventSequence_Event) GetSubmitJob() *SubmitJob
func (*EventSequence_Event) Marshal ¶
func (m *EventSequence_Event) Marshal() (dAtA []byte, err error)
func (*EventSequence_Event) MarshalTo ¶
func (m *EventSequence_Event) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event) MarshalToSizedBuffer ¶
func (m *EventSequence_Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event) ProtoMessage ¶
func (*EventSequence_Event) ProtoMessage()
func (*EventSequence_Event) Reset ¶
func (m *EventSequence_Event) Reset()
func (*EventSequence_Event) Size ¶
func (m *EventSequence_Event) Size() (n int)
func (*EventSequence_Event) String ¶
func (m *EventSequence_Event) String() string
func (*EventSequence_Event) Unmarshal ¶
func (m *EventSequence_Event) Unmarshal(dAtA []byte) error
func (*EventSequence_Event) XXX_DiscardUnknown ¶
func (m *EventSequence_Event) XXX_DiscardUnknown()
func (*EventSequence_Event) XXX_Marshal ¶
func (m *EventSequence_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSequence_Event) XXX_Merge ¶
func (m *EventSequence_Event) XXX_Merge(src proto.Message)
func (*EventSequence_Event) XXX_OneofWrappers ¶
func (*EventSequence_Event) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*EventSequence_Event) XXX_Size ¶
func (m *EventSequence_Event) XXX_Size() int
func (*EventSequence_Event) XXX_Unmarshal ¶
func (m *EventSequence_Event) XXX_Unmarshal(b []byte) error
type EventSequence_Event_CancelJob ¶
type EventSequence_Event_CancelJob struct {
CancelJob *CancelJob `protobuf:"bytes,5,opt,name=cancelJob,proto3,oneof" json:"cancelJob,omitempty"`
}
func (*EventSequence_Event_CancelJob) MarshalTo ¶
func (m *EventSequence_Event_CancelJob) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelJob) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_CancelJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelJob) Size ¶
func (m *EventSequence_Event_CancelJob) Size() (n int)
type EventSequence_Event_CancelJobSet ¶
type EventSequence_Event_CancelJobSet struct {
CancelJobSet *CancelJobSet `protobuf:"bytes,6,opt,name=cancelJobSet,proto3,oneof" json:"cancelJobSet,omitempty"`
}
func (*EventSequence_Event_CancelJobSet) MarshalTo ¶
func (m *EventSequence_Event_CancelJobSet) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelJobSet) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_CancelJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelJobSet) Size ¶
func (m *EventSequence_Event_CancelJobSet) Size() (n int)
type EventSequence_Event_CancelledJob ¶
type EventSequence_Event_CancelledJob struct {
CancelledJob *CancelledJob `protobuf:"bytes,7,opt,name=cancelledJob,proto3,oneof" json:"cancelledJob,omitempty"`
}
func (*EventSequence_Event_CancelledJob) MarshalTo ¶
func (m *EventSequence_Event_CancelledJob) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelledJob) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_CancelledJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_CancelledJob) Size ¶
func (m *EventSequence_Event_CancelledJob) Size() (n int)
type EventSequence_Event_JobErrors ¶
type EventSequence_Event_JobErrors struct {
JobErrors *JobErrors `protobuf:"bytes,9,opt,name=jobErrors,proto3,oneof" json:"jobErrors,omitempty"`
}
func (*EventSequence_Event_JobErrors) MarshalTo ¶
func (m *EventSequence_Event_JobErrors) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobErrors) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobErrors) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobErrors) Size ¶
func (m *EventSequence_Event_JobErrors) Size() (n int)
type EventSequence_Event_JobPreemptionRequested ¶ added in v0.4.41
type EventSequence_Event_JobPreemptionRequested struct {
JobPreemptionRequested *JobPreemptionRequested `protobuf:"bytes,23,opt,name=jobPreemptionRequested,proto3,oneof" json:"jobPreemptionRequested,omitempty"`
}
func (*EventSequence_Event_JobPreemptionRequested) MarshalTo ¶ added in v0.4.41
func (m *EventSequence_Event_JobPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobPreemptionRequested) MarshalToSizedBuffer ¶ added in v0.4.41
func (m *EventSequence_Event_JobPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobPreemptionRequested) Size ¶ added in v0.4.41
func (m *EventSequence_Event_JobPreemptionRequested) Size() (n int)
type EventSequence_Event_JobRequeued ¶ added in v0.3.63
type EventSequence_Event_JobRequeued struct {
JobRequeued *JobRequeued `protobuf:"bytes,22,opt,name=jobRequeued,proto3,oneof" json:"jobRequeued,omitempty"`
}
func (*EventSequence_Event_JobRequeued) MarshalTo ¶ added in v0.3.63
func (m *EventSequence_Event_JobRequeued) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRequeued) MarshalToSizedBuffer ¶ added in v0.3.63
func (m *EventSequence_Event_JobRequeued) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRequeued) Size ¶ added in v0.3.63
func (m *EventSequence_Event_JobRequeued) Size() (n int)
type EventSequence_Event_JobRunAssigned ¶
type EventSequence_Event_JobRunAssigned struct {
JobRunAssigned *JobRunAssigned `protobuf:"bytes,11,opt,name=jobRunAssigned,proto3,oneof" json:"jobRunAssigned,omitempty"`
}
func (*EventSequence_Event_JobRunAssigned) MarshalTo ¶
func (m *EventSequence_Event_JobRunAssigned) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunAssigned) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunAssigned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunAssigned) Size ¶
func (m *EventSequence_Event_JobRunAssigned) Size() (n int)
type EventSequence_Event_JobRunCancelled ¶ added in v0.4.48
type EventSequence_Event_JobRunCancelled struct {
JobRunCancelled *JobRunCancelled `protobuf:"bytes,24,opt,name=jobRunCancelled,proto3,oneof" json:"jobRunCancelled,omitempty"`
}
func (*EventSequence_Event_JobRunCancelled) MarshalTo ¶ added in v0.4.48
func (m *EventSequence_Event_JobRunCancelled) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunCancelled) MarshalToSizedBuffer ¶ added in v0.4.48
func (m *EventSequence_Event_JobRunCancelled) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunCancelled) Size ¶ added in v0.4.48
func (m *EventSequence_Event_JobRunCancelled) Size() (n int)
type EventSequence_Event_JobRunErrors ¶
type EventSequence_Event_JobRunErrors struct {
JobRunErrors *JobRunErrors `protobuf:"bytes,14,opt,name=jobRunErrors,proto3,oneof" json:"jobRunErrors,omitempty"`
}
func (*EventSequence_Event_JobRunErrors) MarshalTo ¶
func (m *EventSequence_Event_JobRunErrors) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunErrors) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunErrors) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunErrors) Size ¶
func (m *EventSequence_Event_JobRunErrors) Size() (n int)
type EventSequence_Event_JobRunLeased ¶
type EventSequence_Event_JobRunLeased struct {
JobRunLeased *JobRunLeased `protobuf:"bytes,10,opt,name=jobRunLeased,proto3,oneof" json:"jobRunLeased,omitempty"`
}
func (*EventSequence_Event_JobRunLeased) MarshalTo ¶
func (m *EventSequence_Event_JobRunLeased) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunLeased) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunLeased) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunLeased) Size ¶
func (m *EventSequence_Event_JobRunLeased) Size() (n int)
type EventSequence_Event_JobRunPreempted ¶
type EventSequence_Event_JobRunPreempted struct {
JobRunPreempted *JobRunPreempted `protobuf:"bytes,19,opt,name=jobRunPreempted,proto3,oneof" json:"jobRunPreempted,omitempty"`
}
func (*EventSequence_Event_JobRunPreempted) MarshalTo ¶
func (m *EventSequence_Event_JobRunPreempted) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunPreempted) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunPreempted) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunPreempted) Size ¶
func (m *EventSequence_Event_JobRunPreempted) Size() (n int)
type EventSequence_Event_JobRunPreemptionRequested ¶ added in v0.3.53
type EventSequence_Event_JobRunPreemptionRequested struct {
JobRunPreemptionRequested *JobRunPreemptionRequested `protobuf:"bytes,21,opt,name=jobRunPreemptionRequested,proto3,oneof" json:"jobRunPreemptionRequested,omitempty"`
}
func (*EventSequence_Event_JobRunPreemptionRequested) MarshalTo ¶ added in v0.3.53
func (m *EventSequence_Event_JobRunPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunPreemptionRequested) MarshalToSizedBuffer ¶ added in v0.3.53
func (m *EventSequence_Event_JobRunPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunPreemptionRequested) Size ¶ added in v0.3.53
func (m *EventSequence_Event_JobRunPreemptionRequested) Size() (n int)
type EventSequence_Event_JobRunRunning ¶
type EventSequence_Event_JobRunRunning struct {
JobRunRunning *JobRunRunning `protobuf:"bytes,12,opt,name=jobRunRunning,proto3,oneof" json:"jobRunRunning,omitempty"`
}
func (*EventSequence_Event_JobRunRunning) MarshalTo ¶
func (m *EventSequence_Event_JobRunRunning) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunRunning) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunRunning) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunRunning) Size ¶
func (m *EventSequence_Event_JobRunRunning) Size() (n int)
type EventSequence_Event_JobRunSucceeded ¶
type EventSequence_Event_JobRunSucceeded struct {
JobRunSucceeded *JobRunSucceeded `protobuf:"bytes,13,opt,name=jobRunSucceeded,proto3,oneof" json:"jobRunSucceeded,omitempty"`
}
func (*EventSequence_Event_JobRunSucceeded) MarshalTo ¶
func (m *EventSequence_Event_JobRunSucceeded) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunSucceeded) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobRunSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobRunSucceeded) Size ¶
func (m *EventSequence_Event_JobRunSucceeded) Size() (n int)
type EventSequence_Event_JobSucceeded ¶
type EventSequence_Event_JobSucceeded struct {
JobSucceeded *JobSucceeded `protobuf:"bytes,8,opt,name=jobSucceeded,proto3,oneof" json:"jobSucceeded,omitempty"`
}
func (*EventSequence_Event_JobSucceeded) MarshalTo ¶
func (m *EventSequence_Event_JobSucceeded) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobSucceeded) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_JobSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobSucceeded) Size ¶
func (m *EventSequence_Event_JobSucceeded) Size() (n int)
type EventSequence_Event_JobValidated ¶ added in v0.4.50
type EventSequence_Event_JobValidated struct {
JobValidated *JobValidated `protobuf:"bytes,25,opt,name=jobValidated,proto3,oneof" json:"jobValidated,omitempty"`
}
func (*EventSequence_Event_JobValidated) MarshalTo ¶ added in v0.4.50
func (m *EventSequence_Event_JobValidated) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_JobValidated) MarshalToSizedBuffer ¶ added in v0.4.50
func (m *EventSequence_Event_JobValidated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_JobValidated) Size ¶ added in v0.4.50
func (m *EventSequence_Event_JobValidated) Size() (n int)
type EventSequence_Event_PartitionMarker ¶ added in v0.3.48
type EventSequence_Event_PartitionMarker struct {
PartitionMarker *PartitionMarker `protobuf:"bytes,20,opt,name=partitionMarker,proto3,oneof" json:"partitionMarker,omitempty"`
}
func (*EventSequence_Event_PartitionMarker) MarshalTo ¶ added in v0.3.48
func (m *EventSequence_Event_PartitionMarker) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_PartitionMarker) MarshalToSizedBuffer ¶ added in v0.3.48
func (m *EventSequence_Event_PartitionMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_PartitionMarker) Size ¶ added in v0.3.48
func (m *EventSequence_Event_PartitionMarker) Size() (n int)
type EventSequence_Event_ReprioritiseJob ¶
type EventSequence_Event_ReprioritiseJob struct {
ReprioritiseJob *ReprioritiseJob `protobuf:"bytes,2,opt,name=reprioritiseJob,proto3,oneof" json:"reprioritiseJob,omitempty"`
}
func (*EventSequence_Event_ReprioritiseJob) MarshalTo ¶
func (m *EventSequence_Event_ReprioritiseJob) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritiseJob) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_ReprioritiseJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritiseJob) Size ¶
func (m *EventSequence_Event_ReprioritiseJob) Size() (n int)
type EventSequence_Event_ReprioritiseJobSet ¶
type EventSequence_Event_ReprioritiseJobSet struct {
ReprioritiseJobSet *ReprioritiseJobSet `protobuf:"bytes,3,opt,name=reprioritiseJobSet,proto3,oneof" json:"reprioritiseJobSet,omitempty"`
}
func (*EventSequence_Event_ReprioritiseJobSet) MarshalTo ¶
func (m *EventSequence_Event_ReprioritiseJobSet) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritiseJobSet) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_ReprioritiseJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritiseJobSet) Size ¶
func (m *EventSequence_Event_ReprioritiseJobSet) Size() (n int)
type EventSequence_Event_ReprioritisedJob ¶
type EventSequence_Event_ReprioritisedJob struct {
ReprioritisedJob *ReprioritisedJob `protobuf:"bytes,4,opt,name=reprioritisedJob,proto3,oneof" json:"reprioritisedJob,omitempty"`
}
func (*EventSequence_Event_ReprioritisedJob) MarshalTo ¶
func (m *EventSequence_Event_ReprioritisedJob) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritisedJob) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_ReprioritisedJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_ReprioritisedJob) Size ¶
func (m *EventSequence_Event_ReprioritisedJob) Size() (n int)
type EventSequence_Event_ResourceUtilisation ¶
type EventSequence_Event_ResourceUtilisation struct {
ResourceUtilisation *ResourceUtilisation `protobuf:"bytes,17,opt,name=resourceUtilisation,proto3,oneof" json:"resourceUtilisation,omitempty"`
}
func (*EventSequence_Event_ResourceUtilisation) MarshalTo ¶
func (m *EventSequence_Event_ResourceUtilisation) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_ResourceUtilisation) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_ResourceUtilisation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_ResourceUtilisation) Size ¶
func (m *EventSequence_Event_ResourceUtilisation) Size() (n int)
type EventSequence_Event_StandaloneIngressInfo ¶
type EventSequence_Event_StandaloneIngressInfo struct {
StandaloneIngressInfo *StandaloneIngressInfo `protobuf:"bytes,16,opt,name=standaloneIngressInfo,proto3,oneof" json:"standaloneIngressInfo,omitempty"`
}
func (*EventSequence_Event_StandaloneIngressInfo) MarshalTo ¶
func (m *EventSequence_Event_StandaloneIngressInfo) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_StandaloneIngressInfo) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_StandaloneIngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_StandaloneIngressInfo) Size ¶
func (m *EventSequence_Event_StandaloneIngressInfo) Size() (n int)
type EventSequence_Event_SubmitJob ¶
type EventSequence_Event_SubmitJob struct {
SubmitJob *SubmitJob `protobuf:"bytes,1,opt,name=submitJob,proto3,oneof" json:"submitJob,omitempty"`
}
func (*EventSequence_Event_SubmitJob) MarshalTo ¶
func (m *EventSequence_Event_SubmitJob) MarshalTo(dAtA []byte) (int, error)
func (*EventSequence_Event_SubmitJob) MarshalToSizedBuffer ¶
func (m *EventSequence_Event_SubmitJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSequence_Event_SubmitJob) Size ¶
func (m *EventSequence_Event_SubmitJob) Size() (n int)
type ExecutorError ¶
type ExecutorError struct { }
func (*ExecutorError) Descriptor ¶
func (*ExecutorError) Descriptor() ([]byte, []int)
func (*ExecutorError) Marshal ¶
func (m *ExecutorError) Marshal() (dAtA []byte, err error)
func (*ExecutorError) MarshalToSizedBuffer ¶
func (m *ExecutorError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExecutorError) ProtoMessage ¶
func (*ExecutorError) ProtoMessage()
func (*ExecutorError) Reset ¶
func (m *ExecutorError) Reset()
func (*ExecutorError) Size ¶
func (m *ExecutorError) Size() (n int)
func (*ExecutorError) String ¶
func (m *ExecutorError) String() string
func (*ExecutorError) Unmarshal ¶
func (m *ExecutorError) Unmarshal(dAtA []byte) error
func (*ExecutorError) XXX_DiscardUnknown ¶
func (m *ExecutorError) XXX_DiscardUnknown()
func (*ExecutorError) XXX_Marshal ¶
func (m *ExecutorError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutorError) XXX_Merge ¶
func (m *ExecutorError) XXX_Merge(src proto.Message)
func (*ExecutorError) XXX_Size ¶
func (m *ExecutorError) XXX_Size() int
func (*ExecutorError) XXX_Unmarshal ¶
func (m *ExecutorError) XXX_Unmarshal(b []byte) error
type ExperimentalPriceInfo ¶ added in v0.15.7
type ExperimentalPriceInfo struct {
BidPrice float64 `protobuf:"fixed64,1,opt,name=bidPrice,proto3" json:"bidPrice,omitempty"`
}
func (*ExperimentalPriceInfo) Descriptor ¶ added in v0.15.7
func (*ExperimentalPriceInfo) Descriptor() ([]byte, []int)
func (*ExperimentalPriceInfo) GetBidPrice ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) GetBidPrice() float64
func (*ExperimentalPriceInfo) Marshal ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) Marshal() (dAtA []byte, err error)
func (*ExperimentalPriceInfo) MarshalTo ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) MarshalTo(dAtA []byte) (int, error)
func (*ExperimentalPriceInfo) MarshalToSizedBuffer ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExperimentalPriceInfo) ProtoMessage ¶ added in v0.15.7
func (*ExperimentalPriceInfo) ProtoMessage()
func (*ExperimentalPriceInfo) Reset ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) Reset()
func (*ExperimentalPriceInfo) Size ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) Size() (n int)
func (*ExperimentalPriceInfo) String ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) String() string
func (*ExperimentalPriceInfo) Unmarshal ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) Unmarshal(dAtA []byte) error
func (*ExperimentalPriceInfo) XXX_DiscardUnknown ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) XXX_DiscardUnknown()
func (*ExperimentalPriceInfo) XXX_Marshal ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExperimentalPriceInfo) XXX_Merge ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) XXX_Merge(src proto.Message)
func (*ExperimentalPriceInfo) XXX_Size ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) XXX_Size() int
func (*ExperimentalPriceInfo) XXX_Unmarshal ¶ added in v0.15.7
func (m *ExperimentalPriceInfo) XXX_Unmarshal(b []byte) error
type GangJobUnschedulable ¶ added in v0.3.95
type GangJobUnschedulable struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}
func (*GangJobUnschedulable) Descriptor ¶ added in v0.3.95
func (*GangJobUnschedulable) Descriptor() ([]byte, []int)
func (*GangJobUnschedulable) GetMessage ¶ added in v0.3.95
func (m *GangJobUnschedulable) GetMessage() string
func (*GangJobUnschedulable) Marshal ¶ added in v0.3.95
func (m *GangJobUnschedulable) Marshal() (dAtA []byte, err error)
func (*GangJobUnschedulable) MarshalTo ¶ added in v0.3.95
func (m *GangJobUnschedulable) MarshalTo(dAtA []byte) (int, error)
func (*GangJobUnschedulable) MarshalToSizedBuffer ¶ added in v0.3.95
func (m *GangJobUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GangJobUnschedulable) ProtoMessage ¶ added in v0.3.95
func (*GangJobUnschedulable) ProtoMessage()
func (*GangJobUnschedulable) Reset ¶ added in v0.3.95
func (m *GangJobUnschedulable) Reset()
func (*GangJobUnschedulable) Size ¶ added in v0.3.95
func (m *GangJobUnschedulable) Size() (n int)
func (*GangJobUnschedulable) String ¶ added in v0.3.95
func (m *GangJobUnschedulable) String() string
func (*GangJobUnschedulable) Unmarshal ¶ added in v0.3.95
func (m *GangJobUnschedulable) Unmarshal(dAtA []byte) error
func (*GangJobUnschedulable) XXX_DiscardUnknown ¶ added in v0.3.95
func (m *GangJobUnschedulable) XXX_DiscardUnknown()
func (*GangJobUnschedulable) XXX_Marshal ¶ added in v0.3.95
func (m *GangJobUnschedulable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GangJobUnschedulable) XXX_Merge ¶ added in v0.3.95
func (m *GangJobUnschedulable) XXX_Merge(src proto.Message)
func (*GangJobUnschedulable) XXX_Size ¶ added in v0.3.95
func (m *GangJobUnschedulable) XXX_Size() int
func (*GangJobUnschedulable) XXX_Unmarshal ¶ added in v0.3.95
func (m *GangJobUnschedulable) XXX_Unmarshal(b []byte) error
type IngressInfo ¶
type IngressInfo struct { // TODO: Why a node name? NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` // TODO: Why a map? IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */ }
Runtime information of an ingress.
func (*IngressInfo) Descriptor ¶
func (*IngressInfo) Descriptor() ([]byte, []int)
func (*IngressInfo) GetIngressAddresses ¶
func (m *IngressInfo) GetIngressAddresses() map[int32]string
func (*IngressInfo) GetNodeName ¶
func (m *IngressInfo) GetNodeName() string
func (*IngressInfo) Marshal ¶
func (m *IngressInfo) Marshal() (dAtA []byte, err error)
func (*IngressInfo) MarshalToSizedBuffer ¶
func (m *IngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IngressInfo) ProtoMessage ¶
func (*IngressInfo) ProtoMessage()
func (*IngressInfo) Reset ¶
func (m *IngressInfo) Reset()
func (*IngressInfo) Size ¶
func (m *IngressInfo) Size() (n int)
func (*IngressInfo) String ¶
func (m *IngressInfo) String() string
func (*IngressInfo) Unmarshal ¶
func (m *IngressInfo) Unmarshal(dAtA []byte) error
func (*IngressInfo) XXX_DiscardUnknown ¶
func (m *IngressInfo) XXX_DiscardUnknown()
func (*IngressInfo) XXX_Marshal ¶
func (m *IngressInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IngressInfo) XXX_Merge ¶
func (m *IngressInfo) XXX_Merge(src proto.Message)
func (*IngressInfo) XXX_Size ¶
func (m *IngressInfo) XXX_Size() int
func (*IngressInfo) XXX_Unmarshal ¶
func (m *IngressInfo) XXX_Unmarshal(b []byte) error
type JobErrors ¶
type JobErrors struct { // A set of errors that occurred within some context. Errors []*Error `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
Message containing a set of errors associated with a particular job. Contains a flag, which if set to true indicates that the job has failed. Otherwise, this message represents a set of errors from which the system has recovered.
func (*JobErrors) Descriptor ¶
func (*JobErrors) MarshalToSizedBuffer ¶
func (*JobErrors) ProtoMessage ¶
func (*JobErrors) ProtoMessage()
func (*JobErrors) XXX_DiscardUnknown ¶
func (m *JobErrors) XXX_DiscardUnknown()
func (*JobErrors) XXX_Marshal ¶
func (*JobErrors) XXX_Unmarshal ¶
type JobPreemptionRequested ¶ added in v0.4.41
type JobPreemptionRequested struct { JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` }
Indicates that a user has requested for the job to be pre-empted.
func (*JobPreemptionRequested) Descriptor ¶ added in v0.4.41
func (*JobPreemptionRequested) Descriptor() ([]byte, []int)
func (*JobPreemptionRequested) GetJobId ¶ added in v0.4.41
func (m *JobPreemptionRequested) GetJobId() string
func (*JobPreemptionRequested) GetReason ¶ added in v0.15.4
func (m *JobPreemptionRequested) GetReason() string
func (*JobPreemptionRequested) Marshal ¶ added in v0.4.41
func (m *JobPreemptionRequested) Marshal() (dAtA []byte, err error)
func (*JobPreemptionRequested) MarshalTo ¶ added in v0.4.41
func (m *JobPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
func (*JobPreemptionRequested) MarshalToSizedBuffer ¶ added in v0.4.41
func (m *JobPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobPreemptionRequested) ProtoMessage ¶ added in v0.4.41
func (*JobPreemptionRequested) ProtoMessage()
func (*JobPreemptionRequested) Reset ¶ added in v0.4.41
func (m *JobPreemptionRequested) Reset()
func (*JobPreemptionRequested) Size ¶ added in v0.4.41
func (m *JobPreemptionRequested) Size() (n int)
func (*JobPreemptionRequested) String ¶ added in v0.4.41
func (m *JobPreemptionRequested) String() string
func (*JobPreemptionRequested) Unmarshal ¶ added in v0.4.41
func (m *JobPreemptionRequested) Unmarshal(dAtA []byte) error
func (*JobPreemptionRequested) XXX_DiscardUnknown ¶ added in v0.4.41
func (m *JobPreemptionRequested) XXX_DiscardUnknown()
func (*JobPreemptionRequested) XXX_Marshal ¶ added in v0.4.41
func (m *JobPreemptionRequested) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobPreemptionRequested) XXX_Merge ¶ added in v0.4.41
func (m *JobPreemptionRequested) XXX_Merge(src proto.Message)
func (*JobPreemptionRequested) XXX_Size ¶ added in v0.4.41
func (m *JobPreemptionRequested) XXX_Size() int
func (*JobPreemptionRequested) XXX_Unmarshal ¶ added in v0.4.41
func (m *JobPreemptionRequested) XXX_Unmarshal(b []byte) error
type JobRejected ¶ added in v0.4.50
type JobRejected struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}
func (*JobRejected) Descriptor ¶ added in v0.4.50
func (*JobRejected) Descriptor() ([]byte, []int)
func (*JobRejected) GetMessage ¶ added in v0.4.50
func (m *JobRejected) GetMessage() string
func (*JobRejected) Marshal ¶ added in v0.4.50
func (m *JobRejected) Marshal() (dAtA []byte, err error)
func (*JobRejected) MarshalTo ¶ added in v0.4.50
func (m *JobRejected) MarshalTo(dAtA []byte) (int, error)
func (*JobRejected) MarshalToSizedBuffer ¶ added in v0.4.50
func (m *JobRejected) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRejected) ProtoMessage ¶ added in v0.4.50
func (*JobRejected) ProtoMessage()
func (*JobRejected) Reset ¶ added in v0.4.50
func (m *JobRejected) Reset()
func (*JobRejected) Size ¶ added in v0.4.50
func (m *JobRejected) Size() (n int)
func (*JobRejected) String ¶ added in v0.4.50
func (m *JobRejected) String() string
func (*JobRejected) Unmarshal ¶ added in v0.4.50
func (m *JobRejected) Unmarshal(dAtA []byte) error
func (*JobRejected) XXX_DiscardUnknown ¶ added in v0.4.50
func (m *JobRejected) XXX_DiscardUnknown()
func (*JobRejected) XXX_Marshal ¶ added in v0.4.50
func (m *JobRejected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRejected) XXX_Merge ¶ added in v0.4.50
func (m *JobRejected) XXX_Merge(src proto.Message)
func (*JobRejected) XXX_Size ¶ added in v0.4.50
func (m *JobRejected) XXX_Size() int
func (*JobRejected) XXX_Unmarshal ¶ added in v0.4.50
func (m *JobRejected) XXX_Unmarshal(b []byte) error
type JobRequeued ¶ added in v0.3.63
type JobRequeued struct { SchedulingInfo *schedulerobjects.JobSchedulingInfo `protobuf:"bytes,2,opt,name=scheduling_info,json=schedulingInfo,proto3" json:"schedulingInfo,omitempty"` // Used by the scheduler to maintain a consistent state UpdateSequenceNumber int32 `protobuf:"varint,3,opt,name=update_sequence_number,json=updateSequenceNumber,proto3" json:"updateSequenceNumber,omitempty"` JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
func (*JobRequeued) Descriptor ¶ added in v0.3.63
func (*JobRequeued) Descriptor() ([]byte, []int)
func (*JobRequeued) GetJobId ¶ added in v0.3.63
func (m *JobRequeued) GetJobId() string
func (*JobRequeued) GetSchedulingInfo ¶ added in v0.3.63
func (m *JobRequeued) GetSchedulingInfo() *schedulerobjects.JobSchedulingInfo
func (*JobRequeued) GetUpdateSequenceNumber ¶ added in v0.3.63
func (m *JobRequeued) GetUpdateSequenceNumber() int32
func (*JobRequeued) Marshal ¶ added in v0.3.63
func (m *JobRequeued) Marshal() (dAtA []byte, err error)
func (*JobRequeued) MarshalTo ¶ added in v0.3.63
func (m *JobRequeued) MarshalTo(dAtA []byte) (int, error)
func (*JobRequeued) MarshalToSizedBuffer ¶ added in v0.3.63
func (m *JobRequeued) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRequeued) ProtoMessage ¶ added in v0.3.63
func (*JobRequeued) ProtoMessage()
func (*JobRequeued) Reset ¶ added in v0.3.63
func (m *JobRequeued) Reset()
func (*JobRequeued) Size ¶ added in v0.3.63
func (m *JobRequeued) Size() (n int)
func (*JobRequeued) String ¶ added in v0.3.63
func (m *JobRequeued) String() string
func (*JobRequeued) Unmarshal ¶ added in v0.3.63
func (m *JobRequeued) Unmarshal(dAtA []byte) error
func (*JobRequeued) XXX_DiscardUnknown ¶ added in v0.3.63
func (m *JobRequeued) XXX_DiscardUnknown()
func (*JobRequeued) XXX_Marshal ¶ added in v0.3.63
func (m *JobRequeued) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRequeued) XXX_Merge ¶ added in v0.3.63
func (m *JobRequeued) XXX_Merge(src proto.Message)
func (*JobRequeued) XXX_Size ¶ added in v0.3.63
func (m *JobRequeued) XXX_Size() int
func (*JobRequeued) XXX_Unmarshal ¶ added in v0.3.63
func (m *JobRequeued) XXX_Unmarshal(b []byte) error
type JobRunAssigned ¶
type JobRunAssigned struct { // Runtime information, e.g., which node the job is running on, its IP address etc, // for each resource created for the job run. // Included here and in JobRunRunning for compatibility with legacy messages. ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"` JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,5,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Indicates that a job has been assigned to nodes by Kubernetes.
func (*JobRunAssigned) Descriptor ¶
func (*JobRunAssigned) Descriptor() ([]byte, []int)
func (*JobRunAssigned) GetJobId ¶
func (m *JobRunAssigned) GetJobId() string
func (*JobRunAssigned) GetResourceInfos ¶
func (m *JobRunAssigned) GetResourceInfos() []*KubernetesResourceInfo
func (*JobRunAssigned) GetRunId ¶
func (m *JobRunAssigned) GetRunId() string
func (*JobRunAssigned) Marshal ¶
func (m *JobRunAssigned) Marshal() (dAtA []byte, err error)
func (*JobRunAssigned) MarshalToSizedBuffer ¶
func (m *JobRunAssigned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunAssigned) ProtoMessage ¶
func (*JobRunAssigned) ProtoMessage()
func (*JobRunAssigned) Reset ¶
func (m *JobRunAssigned) Reset()
func (*JobRunAssigned) Size ¶
func (m *JobRunAssigned) Size() (n int)
func (*JobRunAssigned) String ¶
func (m *JobRunAssigned) String() string
func (*JobRunAssigned) Unmarshal ¶
func (m *JobRunAssigned) Unmarshal(dAtA []byte) error
func (*JobRunAssigned) XXX_DiscardUnknown ¶
func (m *JobRunAssigned) XXX_DiscardUnknown()
func (*JobRunAssigned) XXX_Marshal ¶
func (m *JobRunAssigned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunAssigned) XXX_Merge ¶
func (m *JobRunAssigned) XXX_Merge(src proto.Message)
func (*JobRunAssigned) XXX_Size ¶
func (m *JobRunAssigned) XXX_Size() int
func (*JobRunAssigned) XXX_Unmarshal ¶
func (m *JobRunAssigned) XXX_Unmarshal(b []byte) error
type JobRunCancelled ¶ added in v0.4.48
type JobRunCancelled struct { JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Generated by the scheduler when a job is cancelled, all active job runs are also cancelled One such message is generated per job run that was cancelled.
func (*JobRunCancelled) Descriptor ¶ added in v0.4.48
func (*JobRunCancelled) Descriptor() ([]byte, []int)
func (*JobRunCancelled) GetJobId ¶ added in v0.4.48
func (m *JobRunCancelled) GetJobId() string
func (*JobRunCancelled) GetRunId ¶ added in v0.4.48
func (m *JobRunCancelled) GetRunId() string
func (*JobRunCancelled) Marshal ¶ added in v0.4.48
func (m *JobRunCancelled) Marshal() (dAtA []byte, err error)
func (*JobRunCancelled) MarshalTo ¶ added in v0.4.48
func (m *JobRunCancelled) MarshalTo(dAtA []byte) (int, error)
func (*JobRunCancelled) MarshalToSizedBuffer ¶ added in v0.4.48
func (m *JobRunCancelled) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunCancelled) ProtoMessage ¶ added in v0.4.48
func (*JobRunCancelled) ProtoMessage()
func (*JobRunCancelled) Reset ¶ added in v0.4.48
func (m *JobRunCancelled) Reset()
func (*JobRunCancelled) Size ¶ added in v0.4.48
func (m *JobRunCancelled) Size() (n int)
func (*JobRunCancelled) String ¶ added in v0.4.48
func (m *JobRunCancelled) String() string
func (*JobRunCancelled) Unmarshal ¶ added in v0.4.48
func (m *JobRunCancelled) Unmarshal(dAtA []byte) error
func (*JobRunCancelled) XXX_DiscardUnknown ¶ added in v0.4.48
func (m *JobRunCancelled) XXX_DiscardUnknown()
func (*JobRunCancelled) XXX_Marshal ¶ added in v0.4.48
func (m *JobRunCancelled) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunCancelled) XXX_Merge ¶ added in v0.4.48
func (m *JobRunCancelled) XXX_Merge(src proto.Message)
func (*JobRunCancelled) XXX_Size ¶ added in v0.4.48
func (m *JobRunCancelled) XXX_Size() int
func (*JobRunCancelled) XXX_Unmarshal ¶ added in v0.4.48
func (m *JobRunCancelled) XXX_Unmarshal(b []byte) error
type JobRunErrors ¶
type JobRunErrors struct { // A set of errors that occurred within some context. Errors []*Error `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"` JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,5,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Message containing a set of errors associated with a particular job run. Contains a flag, which if set to true indicates that the job run has failed. Otherwise, this message represents a set of errors from which the system has recovered.
Because each error may specify a parent error, the set of errors form a tree.
Services may listen for these messages to obtain realtime information about errors associated with jobs.
func (*JobRunErrors) Descriptor ¶
func (*JobRunErrors) Descriptor() ([]byte, []int)
func (*JobRunErrors) GetErrors ¶
func (m *JobRunErrors) GetErrors() []*Error
func (*JobRunErrors) GetJobId ¶
func (m *JobRunErrors) GetJobId() string
func (*JobRunErrors) GetRunId ¶
func (m *JobRunErrors) GetRunId() string
func (*JobRunErrors) Marshal ¶
func (m *JobRunErrors) Marshal() (dAtA []byte, err error)
func (*JobRunErrors) MarshalToSizedBuffer ¶
func (m *JobRunErrors) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunErrors) ProtoMessage ¶
func (*JobRunErrors) ProtoMessage()
func (*JobRunErrors) Reset ¶
func (m *JobRunErrors) Reset()
func (*JobRunErrors) Size ¶
func (m *JobRunErrors) Size() (n int)
func (*JobRunErrors) String ¶
func (m *JobRunErrors) String() string
func (*JobRunErrors) Unmarshal ¶
func (m *JobRunErrors) Unmarshal(dAtA []byte) error
func (*JobRunErrors) XXX_DiscardUnknown ¶
func (m *JobRunErrors) XXX_DiscardUnknown()
func (*JobRunErrors) XXX_Marshal ¶
func (m *JobRunErrors) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunErrors) XXX_Merge ¶
func (m *JobRunErrors) XXX_Merge(src proto.Message)
func (*JobRunErrors) XXX_Size ¶
func (m *JobRunErrors) XXX_Size() int
func (*JobRunErrors) XXX_Unmarshal ¶
func (m *JobRunErrors) XXX_Unmarshal(b []byte) error
type JobRunLeased ¶
type JobRunLeased struct { // Each cluster is represented by an executor. ExecutorId string `protobuf:"bytes,3,opt,name=executor_id,json=executorId,proto3" json:"executorId,omitempty"` NodeId string `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"nodeId,omitempty"` // Used by the scheduler to maintain a consistent state UpdateSequenceNumber int32 `protobuf:"varint,5,opt,name=update_sequence_number,json=updateSequenceNumber,proto3" json:"updateSequenceNumber,omitempty"` // This bool is here because it is the most ergonomic way of distinguishing // the case where `scheduled_at_priority` was explicitly set to zero from // the case where it was not set at all. HasScheduledAtPriority bool `` /* 129-byte string literal not displayed */ // Priority class priority that this job was scheduled at. // // This is usually equal to the priority of the job's priority class, except // in the case where the job was scheduled as an away job; this field is // used to distinguish this case from the case where the job was scheduled // as a home job. ScheduledAtPriority int32 `protobuf:"varint,7,opt,name=scheduled_at_priority,json=scheduledAtPriority,proto3" json:"scheduledAtPriority,omitempty"` // The scheduler uses this field to modify the pod requirements of a job; // for example, it may add additional tolerations to runs that are scheduled // as away jobs. PodRequirementsOverlay *schedulerobjects.PodRequirements `` /* 127-byte string literal not displayed */ JobId string `protobuf:"bytes,10,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,11,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` // pool is the pool this run was scheduled on to // This would be determined by the pool of the node this run was scheduled on to, at the time of scheduling Pool string `protobuf:"bytes,12,opt,name=pool,proto3" json:"pool,omitempty"` }
Indicates that a job has been leased to a cluster by the Armada scheduler.
func (*JobRunLeased) Descriptor ¶
func (*JobRunLeased) Descriptor() ([]byte, []int)
func (*JobRunLeased) GetExecutorId ¶
func (m *JobRunLeased) GetExecutorId() string
func (*JobRunLeased) GetHasScheduledAtPriority ¶ added in v0.4.8
func (m *JobRunLeased) GetHasScheduledAtPriority() bool
func (*JobRunLeased) GetJobId ¶
func (m *JobRunLeased) GetJobId() string
func (*JobRunLeased) GetNodeId ¶ added in v0.3.50
func (m *JobRunLeased) GetNodeId() string
func (*JobRunLeased) GetPodRequirementsOverlay ¶ added in v0.4.16
func (m *JobRunLeased) GetPodRequirementsOverlay() *schedulerobjects.PodRequirements
func (*JobRunLeased) GetPool ¶ added in v0.9.0
func (m *JobRunLeased) GetPool() string
func (*JobRunLeased) GetRunId ¶
func (m *JobRunLeased) GetRunId() string
func (*JobRunLeased) GetScheduledAtPriority ¶ added in v0.4.8
func (m *JobRunLeased) GetScheduledAtPriority() int32
func (*JobRunLeased) GetUpdateSequenceNumber ¶ added in v0.3.63
func (m *JobRunLeased) GetUpdateSequenceNumber() int32
func (*JobRunLeased) Marshal ¶
func (m *JobRunLeased) Marshal() (dAtA []byte, err error)
func (*JobRunLeased) MarshalToSizedBuffer ¶
func (m *JobRunLeased) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunLeased) ProtoMessage ¶
func (*JobRunLeased) ProtoMessage()
func (*JobRunLeased) Reset ¶
func (m *JobRunLeased) Reset()
func (*JobRunLeased) Size ¶
func (m *JobRunLeased) Size() (n int)
func (*JobRunLeased) String ¶
func (m *JobRunLeased) String() string
func (*JobRunLeased) Unmarshal ¶
func (m *JobRunLeased) Unmarshal(dAtA []byte) error
func (*JobRunLeased) XXX_DiscardUnknown ¶
func (m *JobRunLeased) XXX_DiscardUnknown()
func (*JobRunLeased) XXX_Marshal ¶
func (m *JobRunLeased) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunLeased) XXX_Merge ¶
func (m *JobRunLeased) XXX_Merge(src proto.Message)
func (*JobRunLeased) XXX_Size ¶
func (m *JobRunLeased) XXX_Size() int
func (*JobRunLeased) XXX_Unmarshal ¶
func (m *JobRunLeased) XXX_Unmarshal(b []byte) error
type JobRunPreempted ¶
type JobRunPreempted struct { PreemptedJobId string `protobuf:"bytes,5,opt,name=preempted_job_id,json=preemptedJobId,proto3" json:"preemptedJobId,omitempty"` PreemptedRunId string `protobuf:"bytes,6,opt,name=preempted_run_id,json=preemptedRunId,proto3" json:"preemptedRunId,omitempty"` Reason string `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason,omitempty"` }
Message to indicate that a JobRun has been preempted.
func (*JobRunPreempted) Descriptor ¶
func (*JobRunPreempted) Descriptor() ([]byte, []int)
func (*JobRunPreempted) GetPreemptedJobId ¶
func (m *JobRunPreempted) GetPreemptedJobId() string
func (*JobRunPreempted) GetPreemptedRunId ¶
func (m *JobRunPreempted) GetPreemptedRunId() string
func (*JobRunPreempted) GetReason ¶ added in v0.15.4
func (m *JobRunPreempted) GetReason() string
func (*JobRunPreempted) Marshal ¶
func (m *JobRunPreempted) Marshal() (dAtA []byte, err error)
func (*JobRunPreempted) MarshalToSizedBuffer ¶
func (m *JobRunPreempted) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunPreempted) ProtoMessage ¶
func (*JobRunPreempted) ProtoMessage()
func (*JobRunPreempted) Reset ¶
func (m *JobRunPreempted) Reset()
func (*JobRunPreempted) Size ¶
func (m *JobRunPreempted) Size() (n int)
func (*JobRunPreempted) String ¶
func (m *JobRunPreempted) String() string
func (*JobRunPreempted) Unmarshal ¶
func (m *JobRunPreempted) Unmarshal(dAtA []byte) error
func (*JobRunPreempted) XXX_DiscardUnknown ¶
func (m *JobRunPreempted) XXX_DiscardUnknown()
func (*JobRunPreempted) XXX_Marshal ¶
func (m *JobRunPreempted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunPreempted) XXX_Merge ¶
func (m *JobRunPreempted) XXX_Merge(src proto.Message)
func (*JobRunPreempted) XXX_Size ¶
func (m *JobRunPreempted) XXX_Size() int
func (*JobRunPreempted) XXX_Unmarshal ¶
func (m *JobRunPreempted) XXX_Unmarshal(b []byte) error
type JobRunPreemptedError ¶ added in v0.3.54
type JobRunPreemptedError struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
}
func (*JobRunPreemptedError) Descriptor ¶ added in v0.3.54
func (*JobRunPreemptedError) Descriptor() ([]byte, []int)
func (*JobRunPreemptedError) GetReason ¶ added in v0.15.4
func (m *JobRunPreemptedError) GetReason() string
func (*JobRunPreemptedError) Marshal ¶ added in v0.3.54
func (m *JobRunPreemptedError) Marshal() (dAtA []byte, err error)
func (*JobRunPreemptedError) MarshalTo ¶ added in v0.3.54
func (m *JobRunPreemptedError) MarshalTo(dAtA []byte) (int, error)
func (*JobRunPreemptedError) MarshalToSizedBuffer ¶ added in v0.3.54
func (m *JobRunPreemptedError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunPreemptedError) ProtoMessage ¶ added in v0.3.54
func (*JobRunPreemptedError) ProtoMessage()
func (*JobRunPreemptedError) Reset ¶ added in v0.3.54
func (m *JobRunPreemptedError) Reset()
func (*JobRunPreemptedError) Size ¶ added in v0.3.54
func (m *JobRunPreemptedError) Size() (n int)
func (*JobRunPreemptedError) String ¶ added in v0.3.54
func (m *JobRunPreemptedError) String() string
func (*JobRunPreemptedError) Unmarshal ¶ added in v0.3.54
func (m *JobRunPreemptedError) Unmarshal(dAtA []byte) error
func (*JobRunPreemptedError) XXX_DiscardUnknown ¶ added in v0.3.54
func (m *JobRunPreemptedError) XXX_DiscardUnknown()
func (*JobRunPreemptedError) XXX_Marshal ¶ added in v0.3.54
func (m *JobRunPreemptedError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunPreemptedError) XXX_Merge ¶ added in v0.3.54
func (m *JobRunPreemptedError) XXX_Merge(src proto.Message)
func (*JobRunPreemptedError) XXX_Size ¶ added in v0.3.54
func (m *JobRunPreemptedError) XXX_Size() int
func (*JobRunPreemptedError) XXX_Unmarshal ¶ added in v0.3.54
func (m *JobRunPreemptedError) XXX_Unmarshal(b []byte) error
type JobRunPreemptionRequested ¶ added in v0.3.53
type JobRunPreemptionRequested struct { JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Indicates that the scheduler has requested for the job run to be pre-empted.
func (*JobRunPreemptionRequested) Descriptor ¶ added in v0.3.53
func (*JobRunPreemptionRequested) Descriptor() ([]byte, []int)
func (*JobRunPreemptionRequested) GetJobId ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) GetJobId() string
func (*JobRunPreemptionRequested) GetRunId ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) GetRunId() string
func (*JobRunPreemptionRequested) Marshal ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) Marshal() (dAtA []byte, err error)
func (*JobRunPreemptionRequested) MarshalTo ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) MarshalTo(dAtA []byte) (int, error)
func (*JobRunPreemptionRequested) MarshalToSizedBuffer ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunPreemptionRequested) ProtoMessage ¶ added in v0.3.53
func (*JobRunPreemptionRequested) ProtoMessage()
func (*JobRunPreemptionRequested) Reset ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) Reset()
func (*JobRunPreemptionRequested) Size ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) Size() (n int)
func (*JobRunPreemptionRequested) String ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) String() string
func (*JobRunPreemptionRequested) Unmarshal ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) Unmarshal(dAtA []byte) error
func (*JobRunPreemptionRequested) XXX_DiscardUnknown ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) XXX_DiscardUnknown()
func (*JobRunPreemptionRequested) XXX_Marshal ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunPreemptionRequested) XXX_Merge ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) XXX_Merge(src proto.Message)
func (*JobRunPreemptionRequested) XXX_Size ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) XXX_Size() int
func (*JobRunPreemptionRequested) XXX_Unmarshal ¶ added in v0.3.53
func (m *JobRunPreemptionRequested) XXX_Unmarshal(b []byte) error
type JobRunRunning ¶
type JobRunRunning struct { // Runtime information, e.g., which node the job is running on, its IP address etc, // for each resource created for the job run. ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"` JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,5,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Indicates that the resources required by the job have been created and that the job is now running.
func (*JobRunRunning) Descriptor ¶
func (*JobRunRunning) Descriptor() ([]byte, []int)
func (*JobRunRunning) GetJobId ¶
func (m *JobRunRunning) GetJobId() string
func (*JobRunRunning) GetResourceInfos ¶
func (m *JobRunRunning) GetResourceInfos() []*KubernetesResourceInfo
func (*JobRunRunning) GetRunId ¶
func (m *JobRunRunning) GetRunId() string
func (*JobRunRunning) Marshal ¶
func (m *JobRunRunning) Marshal() (dAtA []byte, err error)
func (*JobRunRunning) MarshalToSizedBuffer ¶
func (m *JobRunRunning) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunRunning) ProtoMessage ¶
func (*JobRunRunning) ProtoMessage()
func (*JobRunRunning) Reset ¶
func (m *JobRunRunning) Reset()
func (*JobRunRunning) Size ¶
func (m *JobRunRunning) Size() (n int)
func (*JobRunRunning) String ¶
func (m *JobRunRunning) String() string
func (*JobRunRunning) Unmarshal ¶
func (m *JobRunRunning) Unmarshal(dAtA []byte) error
func (*JobRunRunning) XXX_DiscardUnknown ¶
func (m *JobRunRunning) XXX_DiscardUnknown()
func (*JobRunRunning) XXX_Marshal ¶
func (m *JobRunRunning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunRunning) XXX_Merge ¶
func (m *JobRunRunning) XXX_Merge(src proto.Message)
func (*JobRunRunning) XXX_Size ¶
func (m *JobRunRunning) XXX_Size() int
func (*JobRunRunning) XXX_Unmarshal ¶
func (m *JobRunRunning) XXX_Unmarshal(b []byte) error
type JobRunSucceeded ¶
type JobRunSucceeded struct { // Runtime information, e.g., which node the job is running on, its IP address etc, // for each resource created for the job run. // TODO: remove this once we have fixed the external api ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,3,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"` JobId string `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,5,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Indicates that the job finished successfully (i.e., in the expected manner).
func (*JobRunSucceeded) Descriptor ¶
func (*JobRunSucceeded) Descriptor() ([]byte, []int)
func (*JobRunSucceeded) GetJobId ¶
func (m *JobRunSucceeded) GetJobId() string
func (*JobRunSucceeded) GetResourceInfos ¶
func (m *JobRunSucceeded) GetResourceInfos() []*KubernetesResourceInfo
func (*JobRunSucceeded) GetRunId ¶
func (m *JobRunSucceeded) GetRunId() string
func (*JobRunSucceeded) Marshal ¶
func (m *JobRunSucceeded) Marshal() (dAtA []byte, err error)
func (*JobRunSucceeded) MarshalToSizedBuffer ¶
func (m *JobRunSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunSucceeded) ProtoMessage ¶
func (*JobRunSucceeded) ProtoMessage()
func (*JobRunSucceeded) Reset ¶
func (m *JobRunSucceeded) Reset()
func (*JobRunSucceeded) Size ¶
func (m *JobRunSucceeded) Size() (n int)
func (*JobRunSucceeded) String ¶
func (m *JobRunSucceeded) String() string
func (*JobRunSucceeded) Unmarshal ¶
func (m *JobRunSucceeded) Unmarshal(dAtA []byte) error
func (*JobRunSucceeded) XXX_DiscardUnknown ¶
func (m *JobRunSucceeded) XXX_DiscardUnknown()
func (*JobRunSucceeded) XXX_Marshal ¶
func (m *JobRunSucceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunSucceeded) XXX_Merge ¶
func (m *JobRunSucceeded) XXX_Merge(src proto.Message)
func (*JobRunSucceeded) XXX_Size ¶
func (m *JobRunSucceeded) XXX_Size() int
func (*JobRunSucceeded) XXX_Unmarshal ¶
func (m *JobRunSucceeded) XXX_Unmarshal(b []byte) error
type JobSetFilter ¶ added in v0.3.49
type JobSetFilter struct {
States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=armadaevents.JobState" json:"states,omitempty"`
}
Filter to be used when cancelling job sets This allows users to cancel all jobs in a given state for a specific job set
func (*JobSetFilter) Descriptor ¶ added in v0.3.49
func (*JobSetFilter) Descriptor() ([]byte, []int)
func (*JobSetFilter) GetStates ¶ added in v0.3.49
func (m *JobSetFilter) GetStates() []JobState
func (*JobSetFilter) Marshal ¶ added in v0.3.49
func (m *JobSetFilter) Marshal() (dAtA []byte, err error)
func (*JobSetFilter) MarshalTo ¶ added in v0.3.49
func (m *JobSetFilter) MarshalTo(dAtA []byte) (int, error)
func (*JobSetFilter) MarshalToSizedBuffer ¶ added in v0.3.49
func (m *JobSetFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSetFilter) ProtoMessage ¶ added in v0.3.49
func (*JobSetFilter) ProtoMessage()
func (*JobSetFilter) Reset ¶ added in v0.3.49
func (m *JobSetFilter) Reset()
func (*JobSetFilter) Size ¶ added in v0.3.49
func (m *JobSetFilter) Size() (n int)
func (*JobSetFilter) String ¶ added in v0.3.49
func (m *JobSetFilter) String() string
func (*JobSetFilter) Unmarshal ¶ added in v0.3.49
func (m *JobSetFilter) Unmarshal(dAtA []byte) error
func (*JobSetFilter) XXX_DiscardUnknown ¶ added in v0.3.49
func (m *JobSetFilter) XXX_DiscardUnknown()
func (*JobSetFilter) XXX_Marshal ¶ added in v0.3.49
func (m *JobSetFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSetFilter) XXX_Merge ¶ added in v0.3.49
func (m *JobSetFilter) XXX_Merge(src proto.Message)
func (*JobSetFilter) XXX_Size ¶ added in v0.3.49
func (m *JobSetFilter) XXX_Size() int
func (*JobSetFilter) XXX_Unmarshal ¶ added in v0.3.49
func (m *JobSetFilter) XXX_Unmarshal(b []byte) error
type JobState ¶ added in v0.3.49
type JobState int32
func (JobState) EnumDescriptor ¶ added in v0.3.49
type JobSucceeded ¶
type JobSucceeded struct { // Runtime information, e.g., which node the job is running on, its IP address etc, // for each resource created for the job run. // TODO: remove this once we have fixed the external api ResourceInfos []*KubernetesResourceInfo `protobuf:"bytes,2,rep,name=resourceInfos,proto3" json:"resourceInfos,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
func (*JobSucceeded) Descriptor ¶
func (*JobSucceeded) Descriptor() ([]byte, []int)
func (*JobSucceeded) GetJobId ¶
func (m *JobSucceeded) GetJobId() string
func (*JobSucceeded) GetResourceInfos ¶
func (m *JobSucceeded) GetResourceInfos() []*KubernetesResourceInfo
func (*JobSucceeded) Marshal ¶
func (m *JobSucceeded) Marshal() (dAtA []byte, err error)
func (*JobSucceeded) MarshalToSizedBuffer ¶
func (m *JobSucceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSucceeded) ProtoMessage ¶
func (*JobSucceeded) ProtoMessage()
func (*JobSucceeded) Reset ¶
func (m *JobSucceeded) Reset()
func (*JobSucceeded) Size ¶
func (m *JobSucceeded) Size() (n int)
func (*JobSucceeded) String ¶
func (m *JobSucceeded) String() string
func (*JobSucceeded) Unmarshal ¶
func (m *JobSucceeded) Unmarshal(dAtA []byte) error
func (*JobSucceeded) XXX_DiscardUnknown ¶
func (m *JobSucceeded) XXX_DiscardUnknown()
func (*JobSucceeded) XXX_Marshal ¶
func (m *JobSucceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSucceeded) XXX_Merge ¶
func (m *JobSucceeded) XXX_Merge(src proto.Message)
func (*JobSucceeded) XXX_Size ¶
func (m *JobSucceeded) XXX_Size() int
func (*JobSucceeded) XXX_Unmarshal ¶
func (m *JobSucceeded) XXX_Unmarshal(b []byte) error
type JobValidated ¶ added in v0.4.50
type JobValidated struct { Pools []string `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
Indicates that the scheduler is happy with the job
func (*JobValidated) Descriptor ¶ added in v0.4.50
func (*JobValidated) Descriptor() ([]byte, []int)
func (*JobValidated) GetJobId ¶ added in v0.4.50
func (m *JobValidated) GetJobId() string
func (*JobValidated) GetPools ¶ added in v0.5.0
func (m *JobValidated) GetPools() []string
func (*JobValidated) Marshal ¶ added in v0.4.50
func (m *JobValidated) Marshal() (dAtA []byte, err error)
func (*JobValidated) MarshalTo ¶ added in v0.4.50
func (m *JobValidated) MarshalTo(dAtA []byte) (int, error)
func (*JobValidated) MarshalToSizedBuffer ¶ added in v0.4.50
func (m *JobValidated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobValidated) ProtoMessage ¶ added in v0.4.50
func (*JobValidated) ProtoMessage()
func (*JobValidated) Reset ¶ added in v0.4.50
func (m *JobValidated) Reset()
func (*JobValidated) Size ¶ added in v0.4.50
func (m *JobValidated) Size() (n int)
func (*JobValidated) String ¶ added in v0.4.50
func (m *JobValidated) String() string
func (*JobValidated) Unmarshal ¶ added in v0.4.50
func (m *JobValidated) Unmarshal(dAtA []byte) error
func (*JobValidated) XXX_DiscardUnknown ¶ added in v0.4.50
func (m *JobValidated) XXX_DiscardUnknown()
func (*JobValidated) XXX_Marshal ¶ added in v0.4.50
func (m *JobValidated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobValidated) XXX_Merge ¶ added in v0.4.50
func (m *JobValidated) XXX_Merge(src proto.Message)
func (*JobValidated) XXX_Size ¶ added in v0.4.50
func (m *JobValidated) XXX_Size() int
func (*JobValidated) XXX_Unmarshal ¶ added in v0.4.50
func (m *JobValidated) XXX_Unmarshal(b []byte) error
type KubernetesError ¶
type KubernetesError struct { // Type of Kubernetes resource (e.g., ingress). ResourceType string `protobuf:"bytes,1,opt,name=resourceType,proto3" json:"resourceType,omitempty"` }
Represents an error associated with a particular Kubernetes resource.
func (*KubernetesError) Descriptor ¶
func (*KubernetesError) Descriptor() ([]byte, []int)
func (*KubernetesError) GetResourceType ¶
func (m *KubernetesError) GetResourceType() string
func (*KubernetesError) Marshal ¶
func (m *KubernetesError) Marshal() (dAtA []byte, err error)
func (*KubernetesError) MarshalToSizedBuffer ¶
func (m *KubernetesError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesError) ProtoMessage ¶
func (*KubernetesError) ProtoMessage()
func (*KubernetesError) Reset ¶
func (m *KubernetesError) Reset()
func (*KubernetesError) Size ¶
func (m *KubernetesError) Size() (n int)
func (*KubernetesError) String ¶
func (m *KubernetesError) String() string
func (*KubernetesError) Unmarshal ¶
func (m *KubernetesError) Unmarshal(dAtA []byte) error
func (*KubernetesError) XXX_DiscardUnknown ¶
func (m *KubernetesError) XXX_DiscardUnknown()
func (*KubernetesError) XXX_Marshal ¶
func (m *KubernetesError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KubernetesError) XXX_Merge ¶
func (m *KubernetesError) XXX_Merge(src proto.Message)
func (*KubernetesError) XXX_Size ¶
func (m *KubernetesError) XXX_Size() int
func (*KubernetesError) XXX_Unmarshal ¶
func (m *KubernetesError) XXX_Unmarshal(b []byte) error
type KubernetesMainObject ¶
type KubernetesMainObject struct { ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` // Types that are valid to be assigned to Object: // *KubernetesMainObject_PodSpec Object isKubernetesMainObject_Object `protobuf_oneof:"object"` }
Kubernetes objects that can serve as main objects for an Armada job.
func (*KubernetesMainObject) Descriptor ¶
func (*KubernetesMainObject) Descriptor() ([]byte, []int)
func (*KubernetesMainObject) GetObject ¶
func (m *KubernetesMainObject) GetObject() isKubernetesMainObject_Object
func (*KubernetesMainObject) GetObjectMeta ¶
func (m *KubernetesMainObject) GetObjectMeta() *ObjectMeta
func (*KubernetesMainObject) GetPodSpec ¶
func (m *KubernetesMainObject) GetPodSpec() *PodSpecWithAvoidList
func (*KubernetesMainObject) Marshal ¶
func (m *KubernetesMainObject) Marshal() (dAtA []byte, err error)
func (*KubernetesMainObject) MarshalTo ¶
func (m *KubernetesMainObject) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesMainObject) MarshalToSizedBuffer ¶
func (m *KubernetesMainObject) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesMainObject) ProtoMessage ¶
func (*KubernetesMainObject) ProtoMessage()
func (*KubernetesMainObject) Reset ¶
func (m *KubernetesMainObject) Reset()
func (*KubernetesMainObject) Size ¶
func (m *KubernetesMainObject) Size() (n int)
func (*KubernetesMainObject) String ¶
func (m *KubernetesMainObject) String() string
func (*KubernetesMainObject) Unmarshal ¶
func (m *KubernetesMainObject) Unmarshal(dAtA []byte) error
func (*KubernetesMainObject) XXX_DiscardUnknown ¶
func (m *KubernetesMainObject) XXX_DiscardUnknown()
func (*KubernetesMainObject) XXX_Marshal ¶
func (m *KubernetesMainObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KubernetesMainObject) XXX_Merge ¶
func (m *KubernetesMainObject) XXX_Merge(src proto.Message)
func (*KubernetesMainObject) XXX_OneofWrappers ¶
func (*KubernetesMainObject) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*KubernetesMainObject) XXX_Size ¶
func (m *KubernetesMainObject) XXX_Size() int
func (*KubernetesMainObject) XXX_Unmarshal ¶
func (m *KubernetesMainObject) XXX_Unmarshal(b []byte) error
type KubernetesMainObject_PodSpec ¶
type KubernetesMainObject_PodSpec struct {
PodSpec *PodSpecWithAvoidList `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3,oneof" json:"podSpec,omitempty"`
}
func (*KubernetesMainObject_PodSpec) MarshalTo ¶
func (m *KubernetesMainObject_PodSpec) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesMainObject_PodSpec) MarshalToSizedBuffer ¶
func (m *KubernetesMainObject_PodSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesMainObject_PodSpec) Size ¶
func (m *KubernetesMainObject_PodSpec) Size() (n int)
type KubernetesObject ¶
type KubernetesObject struct { ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` // Types that are valid to be assigned to Object: // *KubernetesObject_PodSpec // *KubernetesObject_Ingress // *KubernetesObject_Service // *KubernetesObject_ConfigMap Object isKubernetesObject_Object `protobuf_oneof:"object"` }
Kubernetes objects that can be created as part of an Armada.
func (*KubernetesObject) Descriptor ¶
func (*KubernetesObject) Descriptor() ([]byte, []int)
func (*KubernetesObject) GetConfigMap ¶
func (m *KubernetesObject) GetConfigMap() *v11.ConfigMap
func (*KubernetesObject) GetIngress ¶
func (m *KubernetesObject) GetIngress() *v1.IngressSpec
func (*KubernetesObject) GetObject ¶
func (m *KubernetesObject) GetObject() isKubernetesObject_Object
func (*KubernetesObject) GetObjectMeta ¶
func (m *KubernetesObject) GetObjectMeta() *ObjectMeta
func (*KubernetesObject) GetPodSpec ¶
func (m *KubernetesObject) GetPodSpec() *PodSpecWithAvoidList
func (*KubernetesObject) GetService ¶
func (m *KubernetesObject) GetService() *v11.ServiceSpec
func (*KubernetesObject) Marshal ¶
func (m *KubernetesObject) Marshal() (dAtA []byte, err error)
func (*KubernetesObject) MarshalToSizedBuffer ¶
func (m *KubernetesObject) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesObject) ProtoMessage ¶
func (*KubernetesObject) ProtoMessage()
func (*KubernetesObject) Reset ¶
func (m *KubernetesObject) Reset()
func (*KubernetesObject) Size ¶
func (m *KubernetesObject) Size() (n int)
func (*KubernetesObject) String ¶
func (m *KubernetesObject) String() string
func (*KubernetesObject) Unmarshal ¶
func (m *KubernetesObject) Unmarshal(dAtA []byte) error
func (*KubernetesObject) XXX_DiscardUnknown ¶
func (m *KubernetesObject) XXX_DiscardUnknown()
func (*KubernetesObject) XXX_Marshal ¶
func (m *KubernetesObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KubernetesObject) XXX_Merge ¶
func (m *KubernetesObject) XXX_Merge(src proto.Message)
func (*KubernetesObject) XXX_OneofWrappers ¶
func (*KubernetesObject) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*KubernetesObject) XXX_Size ¶
func (m *KubernetesObject) XXX_Size() int
func (*KubernetesObject) XXX_Unmarshal ¶
func (m *KubernetesObject) XXX_Unmarshal(b []byte) error
type KubernetesObject_ConfigMap ¶
type KubernetesObject_ConfigMap struct {
ConfigMap *v11.ConfigMap `protobuf:"bytes,5,opt,name=configMap,proto3,oneof" json:"configMap,omitempty"`
}
func (*KubernetesObject_ConfigMap) MarshalTo ¶
func (m *KubernetesObject_ConfigMap) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesObject_ConfigMap) MarshalToSizedBuffer ¶
func (m *KubernetesObject_ConfigMap) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesObject_ConfigMap) Size ¶
func (m *KubernetesObject_ConfigMap) Size() (n int)
type KubernetesObject_Ingress ¶
type KubernetesObject_Ingress struct {
Ingress *v1.IngressSpec `protobuf:"bytes,3,opt,name=ingress,proto3,oneof" json:"ingress,omitempty"`
}
func (*KubernetesObject_Ingress) MarshalTo ¶
func (m *KubernetesObject_Ingress) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesObject_Ingress) MarshalToSizedBuffer ¶
func (m *KubernetesObject_Ingress) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesObject_Ingress) Size ¶
func (m *KubernetesObject_Ingress) Size() (n int)
type KubernetesObject_PodSpec ¶
type KubernetesObject_PodSpec struct {
PodSpec *PodSpecWithAvoidList `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3,oneof" json:"podSpec,omitempty"`
}
func (*KubernetesObject_PodSpec) MarshalTo ¶
func (m *KubernetesObject_PodSpec) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesObject_PodSpec) MarshalToSizedBuffer ¶
func (m *KubernetesObject_PodSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesObject_PodSpec) Size ¶
func (m *KubernetesObject_PodSpec) Size() (n int)
type KubernetesObject_Service ¶
type KubernetesObject_Service struct {
Service *v11.ServiceSpec `protobuf:"bytes,4,opt,name=service,proto3,oneof" json:"service,omitempty"`
}
func (*KubernetesObject_Service) MarshalTo ¶
func (m *KubernetesObject_Service) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesObject_Service) MarshalToSizedBuffer ¶
func (m *KubernetesObject_Service) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesObject_Service) Size ¶
func (m *KubernetesObject_Service) Size() (n int)
type KubernetesReason ¶ added in v0.3.48
type KubernetesReason int32
Reason reported by Kubernetes.
const ( KubernetesReason_AppError KubernetesReason = 0 KubernetesReason_Evicted KubernetesReason = 1 KubernetesReason_OOM KubernetesReason = 2 KubernetesReason_DeadlineExceeded KubernetesReason = 3 )
func (KubernetesReason) EnumDescriptor ¶ added in v0.3.48
func (KubernetesReason) EnumDescriptor() ([]byte, []int)
func (KubernetesReason) String ¶ added in v0.3.48
func (x KubernetesReason) String() string
type KubernetesResourceInfo ¶
type KubernetesResourceInfo struct { ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` // Types that are valid to be assigned to Info: // *KubernetesResourceInfo_PodInfo // *KubernetesResourceInfo_IngressInfo Info isKubernetesResourceInfo_Info `protobuf_oneof:"info"` }
Message containing runtime information about some resource created for a job.
func (*KubernetesResourceInfo) Descriptor ¶
func (*KubernetesResourceInfo) Descriptor() ([]byte, []int)
func (*KubernetesResourceInfo) GetInfo ¶
func (m *KubernetesResourceInfo) GetInfo() isKubernetesResourceInfo_Info
func (*KubernetesResourceInfo) GetIngressInfo ¶
func (m *KubernetesResourceInfo) GetIngressInfo() *IngressInfo
func (*KubernetesResourceInfo) GetObjectMeta ¶
func (m *KubernetesResourceInfo) GetObjectMeta() *ObjectMeta
func (*KubernetesResourceInfo) GetPodInfo ¶
func (m *KubernetesResourceInfo) GetPodInfo() *PodInfo
func (*KubernetesResourceInfo) Marshal ¶
func (m *KubernetesResourceInfo) Marshal() (dAtA []byte, err error)
func (*KubernetesResourceInfo) MarshalTo ¶
func (m *KubernetesResourceInfo) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesResourceInfo) MarshalToSizedBuffer ¶
func (m *KubernetesResourceInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesResourceInfo) ProtoMessage ¶
func (*KubernetesResourceInfo) ProtoMessage()
func (*KubernetesResourceInfo) Reset ¶
func (m *KubernetesResourceInfo) Reset()
func (*KubernetesResourceInfo) Size ¶
func (m *KubernetesResourceInfo) Size() (n int)
func (*KubernetesResourceInfo) String ¶
func (m *KubernetesResourceInfo) String() string
func (*KubernetesResourceInfo) Unmarshal ¶
func (m *KubernetesResourceInfo) Unmarshal(dAtA []byte) error
func (*KubernetesResourceInfo) XXX_DiscardUnknown ¶
func (m *KubernetesResourceInfo) XXX_DiscardUnknown()
func (*KubernetesResourceInfo) XXX_Marshal ¶
func (m *KubernetesResourceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KubernetesResourceInfo) XXX_Merge ¶
func (m *KubernetesResourceInfo) XXX_Merge(src proto.Message)
func (*KubernetesResourceInfo) XXX_OneofWrappers ¶
func (*KubernetesResourceInfo) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*KubernetesResourceInfo) XXX_Size ¶
func (m *KubernetesResourceInfo) XXX_Size() int
func (*KubernetesResourceInfo) XXX_Unmarshal ¶
func (m *KubernetesResourceInfo) XXX_Unmarshal(b []byte) error
type KubernetesResourceInfo_IngressInfo ¶
type KubernetesResourceInfo_IngressInfo struct {
IngressInfo *IngressInfo `protobuf:"bytes,3,opt,name=ingressInfo,proto3,oneof" json:"ingressInfo,omitempty"`
}
func (*KubernetesResourceInfo_IngressInfo) MarshalTo ¶
func (m *KubernetesResourceInfo_IngressInfo) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesResourceInfo_IngressInfo) MarshalToSizedBuffer ¶
func (m *KubernetesResourceInfo_IngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesResourceInfo_IngressInfo) Size ¶
func (m *KubernetesResourceInfo_IngressInfo) Size() (n int)
type KubernetesResourceInfo_PodInfo ¶
type KubernetesResourceInfo_PodInfo struct {
PodInfo *PodInfo `protobuf:"bytes,2,opt,name=podInfo,proto3,oneof" json:"podInfo,omitempty"`
}
func (*KubernetesResourceInfo_PodInfo) MarshalTo ¶
func (m *KubernetesResourceInfo_PodInfo) MarshalTo(dAtA []byte) (int, error)
func (*KubernetesResourceInfo_PodInfo) MarshalToSizedBuffer ¶
func (m *KubernetesResourceInfo_PodInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KubernetesResourceInfo_PodInfo) Size ¶
func (m *KubernetesResourceInfo_PodInfo) Size() (n int)
type LeaseExpired ¶
type LeaseExpired struct { }
func (*LeaseExpired) Descriptor ¶
func (*LeaseExpired) Descriptor() ([]byte, []int)
func (*LeaseExpired) Marshal ¶
func (m *LeaseExpired) Marshal() (dAtA []byte, err error)
func (*LeaseExpired) MarshalToSizedBuffer ¶
func (m *LeaseExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LeaseExpired) ProtoMessage ¶
func (*LeaseExpired) ProtoMessage()
func (*LeaseExpired) Reset ¶
func (m *LeaseExpired) Reset()
func (*LeaseExpired) Size ¶
func (m *LeaseExpired) Size() (n int)
func (*LeaseExpired) String ¶
func (m *LeaseExpired) String() string
func (*LeaseExpired) Unmarshal ¶
func (m *LeaseExpired) Unmarshal(dAtA []byte) error
func (*LeaseExpired) XXX_DiscardUnknown ¶
func (m *LeaseExpired) XXX_DiscardUnknown()
func (*LeaseExpired) XXX_Marshal ¶
func (m *LeaseExpired) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LeaseExpired) XXX_Merge ¶
func (m *LeaseExpired) XXX_Merge(src proto.Message)
func (*LeaseExpired) XXX_Size ¶
func (m *LeaseExpired) XXX_Size() int
func (*LeaseExpired) XXX_Unmarshal ¶
func (m *LeaseExpired) XXX_Unmarshal(b []byte) error
type MaxRunsExceeded ¶
type MaxRunsExceeded struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}
func (*MaxRunsExceeded) Descriptor ¶
func (*MaxRunsExceeded) Descriptor() ([]byte, []int)
func (*MaxRunsExceeded) GetMessage ¶ added in v0.3.63
func (m *MaxRunsExceeded) GetMessage() string
func (*MaxRunsExceeded) Marshal ¶
func (m *MaxRunsExceeded) Marshal() (dAtA []byte, err error)
func (*MaxRunsExceeded) MarshalToSizedBuffer ¶
func (m *MaxRunsExceeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MaxRunsExceeded) ProtoMessage ¶
func (*MaxRunsExceeded) ProtoMessage()
func (*MaxRunsExceeded) Reset ¶
func (m *MaxRunsExceeded) Reset()
func (*MaxRunsExceeded) Size ¶
func (m *MaxRunsExceeded) Size() (n int)
func (*MaxRunsExceeded) String ¶
func (m *MaxRunsExceeded) String() string
func (*MaxRunsExceeded) Unmarshal ¶
func (m *MaxRunsExceeded) Unmarshal(dAtA []byte) error
func (*MaxRunsExceeded) XXX_DiscardUnknown ¶
func (m *MaxRunsExceeded) XXX_DiscardUnknown()
func (*MaxRunsExceeded) XXX_Marshal ¶
func (m *MaxRunsExceeded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaxRunsExceeded) XXX_Merge ¶
func (m *MaxRunsExceeded) XXX_Merge(src proto.Message)
func (*MaxRunsExceeded) XXX_Size ¶
func (m *MaxRunsExceeded) XXX_Size() int
func (*MaxRunsExceeded) XXX_Unmarshal ¶
func (m *MaxRunsExceeded) XXX_Unmarshal(b []byte) error
type ObjectMeta ¶
type ObjectMeta struct { // Unique id of the executor responsible for the Kubernetes cluster that created the object. // Is set by the executor on object creation. ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executorId,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // Unique id assigned to the object by Kubernetes (typically a 128-bit UUID). // Should be left empty on job creation, but should be set, e.g., when in the JobRunRunning message. // Stored as a string because Kubernetes doesn't always use UUIDs; see // https://github.com/kubernetes/apimachinery/blob/master/pkg/types/uid.go#L19 KubernetesId string `protobuf:"bytes,4,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` Annotations map[string]string `` /* 163-byte string literal not displayed */ Labels map[string]string `` /* 153-byte string literal not displayed */ }
Auxiliary information needed to instantiate the object in Kubernetes. Inspired by the Kubernetes ObjectMeta object; see: https://github.com/kubernetes/apimachinery/blob/master/pkg/apis/meta/v1/generated.proto#L641
func (*ObjectMeta) Descriptor ¶
func (*ObjectMeta) Descriptor() ([]byte, []int)
func (*ObjectMeta) GetAnnotations ¶
func (m *ObjectMeta) GetAnnotations() map[string]string
func (*ObjectMeta) GetExecutorId ¶
func (m *ObjectMeta) GetExecutorId() string
func (*ObjectMeta) GetKubernetesId ¶
func (m *ObjectMeta) GetKubernetesId() string
func (*ObjectMeta) GetLabels ¶
func (m *ObjectMeta) GetLabels() map[string]string
func (*ObjectMeta) GetName ¶
func (m *ObjectMeta) GetName() string
func (*ObjectMeta) GetNamespace ¶
func (m *ObjectMeta) GetNamespace() string
func (*ObjectMeta) Marshal ¶
func (m *ObjectMeta) Marshal() (dAtA []byte, err error)
func (*ObjectMeta) MarshalToSizedBuffer ¶
func (m *ObjectMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ObjectMeta) ProtoMessage ¶
func (*ObjectMeta) ProtoMessage()
func (*ObjectMeta) Reset ¶
func (m *ObjectMeta) Reset()
func (*ObjectMeta) Size ¶
func (m *ObjectMeta) Size() (n int)
func (*ObjectMeta) String ¶
func (m *ObjectMeta) String() string
func (*ObjectMeta) Unmarshal ¶
func (m *ObjectMeta) Unmarshal(dAtA []byte) error
func (*ObjectMeta) XXX_DiscardUnknown ¶
func (m *ObjectMeta) XXX_DiscardUnknown()
func (*ObjectMeta) XXX_Marshal ¶
func (m *ObjectMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectMeta) XXX_Merge ¶
func (m *ObjectMeta) XXX_Merge(src proto.Message)
func (*ObjectMeta) XXX_Size ¶
func (m *ObjectMeta) XXX_Size() int
func (*ObjectMeta) XXX_Unmarshal ¶
func (m *ObjectMeta) XXX_Unmarshal(b []byte) error
type PartitionMarker ¶
type PartitionMarker struct { // Group id identifies the group of partition markers, one per partition GroupId string `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3" json:"groupId,omitempty"` // The pulsar partition on which this message was sent Partition uint32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"` }
Message used internally by Armada to see if messages can be propagated through a pulsar partition
func (*PartitionMarker) Descriptor ¶
func (*PartitionMarker) Descriptor() ([]byte, []int)
func (*PartitionMarker) GetGroupId ¶
func (m *PartitionMarker) GetGroupId() string
func (*PartitionMarker) GetPartition ¶
func (m *PartitionMarker) GetPartition() uint32
func (*PartitionMarker) Marshal ¶
func (m *PartitionMarker) Marshal() (dAtA []byte, err error)
func (*PartitionMarker) MarshalToSizedBuffer ¶
func (m *PartitionMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionMarker) ProtoMessage ¶
func (*PartitionMarker) ProtoMessage()
func (*PartitionMarker) Reset ¶
func (m *PartitionMarker) Reset()
func (*PartitionMarker) Size ¶
func (m *PartitionMarker) Size() (n int)
func (*PartitionMarker) String ¶
func (m *PartitionMarker) String() string
func (*PartitionMarker) Unmarshal ¶
func (m *PartitionMarker) Unmarshal(dAtA []byte) error
func (*PartitionMarker) XXX_DiscardUnknown ¶
func (m *PartitionMarker) XXX_DiscardUnknown()
func (*PartitionMarker) XXX_Marshal ¶
func (m *PartitionMarker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionMarker) XXX_Merge ¶
func (m *PartitionMarker) XXX_Merge(src proto.Message)
func (*PartitionMarker) XXX_Size ¶
func (m *PartitionMarker) XXX_Size() int
func (*PartitionMarker) XXX_Unmarshal ¶
func (m *PartitionMarker) XXX_Unmarshal(b []byte) error
type PodError ¶
type PodError struct { // This ObjectMeta identifies the Pod. ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` ContainerErrors []*ContainerError `protobuf:"bytes,5,rep,name=containerErrors,proto3" json:"containerErrors,omitempty"` KubernetesReason KubernetesReason `` /* 144-byte string literal not displayed */ DebugMessage string `protobuf:"bytes,7,opt,name=debugMessage,proto3" json:"debugMessage,omitempty"` }
Indicates one or more of the containers in the pod failed.
func (*PodError) Descriptor ¶
func (*PodError) GetContainerErrors ¶
func (m *PodError) GetContainerErrors() []*ContainerError
func (*PodError) GetDebugMessage ¶ added in v0.4.47
func (*PodError) GetKubernetesReason ¶ added in v0.3.48
func (m *PodError) GetKubernetesReason() KubernetesReason
func (*PodError) GetMessage ¶
func (*PodError) GetNodeName ¶
func (*PodError) GetObjectMeta ¶
func (m *PodError) GetObjectMeta() *ObjectMeta
func (*PodError) GetPodNumber ¶
func (*PodError) MarshalToSizedBuffer ¶
func (*PodError) ProtoMessage ¶
func (*PodError) ProtoMessage()
func (*PodError) XXX_DiscardUnknown ¶
func (m *PodError) XXX_DiscardUnknown()
func (*PodError) XXX_Marshal ¶
func (*PodError) XXX_Unmarshal ¶
type PodInfo ¶
type PodInfo struct { NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,2,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` }
Runtime information of a pod.
func (*PodInfo) Descriptor ¶
func (*PodInfo) GetNodeName ¶
func (*PodInfo) GetPodNumber ¶
func (*PodInfo) MarshalToSizedBuffer ¶
func (*PodInfo) ProtoMessage ¶
func (*PodInfo) ProtoMessage()
func (*PodInfo) XXX_DiscardUnknown ¶
func (m *PodInfo) XXX_DiscardUnknown()
func (*PodInfo) XXX_Marshal ¶
func (*PodInfo) XXX_Unmarshal ¶
type PodLeaseReturned ¶
type PodLeaseReturned struct { ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` PodNumber int32 `protobuf:"varint,3,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` RunAttempted bool `protobuf:"varint,4,opt,name=run_attempted,json=runAttempted,proto3" json:"runAttempted,omitempty"` DebugMessage string `protobuf:"bytes,5,opt,name=debugMessage,proto3" json:"debugMessage,omitempty"` }
Indicates that the pod could not be scheduled for some reason.
func (*PodLeaseReturned) Descriptor ¶
func (*PodLeaseReturned) Descriptor() ([]byte, []int)
func (*PodLeaseReturned) GetDebugMessage ¶ added in v0.4.47
func (m *PodLeaseReturned) GetDebugMessage() string
func (*PodLeaseReturned) GetMessage ¶
func (m *PodLeaseReturned) GetMessage() string
func (*PodLeaseReturned) GetObjectMeta ¶
func (m *PodLeaseReturned) GetObjectMeta() *ObjectMeta
func (*PodLeaseReturned) GetPodNumber ¶
func (m *PodLeaseReturned) GetPodNumber() int32
func (*PodLeaseReturned) GetRunAttempted ¶ added in v0.3.48
func (m *PodLeaseReturned) GetRunAttempted() bool
func (*PodLeaseReturned) Marshal ¶
func (m *PodLeaseReturned) Marshal() (dAtA []byte, err error)
func (*PodLeaseReturned) MarshalToSizedBuffer ¶
func (m *PodLeaseReturned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodLeaseReturned) ProtoMessage ¶
func (*PodLeaseReturned) ProtoMessage()
func (*PodLeaseReturned) Reset ¶
func (m *PodLeaseReturned) Reset()
func (*PodLeaseReturned) Size ¶
func (m *PodLeaseReturned) Size() (n int)
func (*PodLeaseReturned) String ¶
func (m *PodLeaseReturned) String() string
func (*PodLeaseReturned) Unmarshal ¶
func (m *PodLeaseReturned) Unmarshal(dAtA []byte) error
func (*PodLeaseReturned) XXX_DiscardUnknown ¶
func (m *PodLeaseReturned) XXX_DiscardUnknown()
func (*PodLeaseReturned) XXX_Marshal ¶
func (m *PodLeaseReturned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PodLeaseReturned) XXX_Merge ¶
func (m *PodLeaseReturned) XXX_Merge(src proto.Message)
func (*PodLeaseReturned) XXX_Size ¶
func (m *PodLeaseReturned) XXX_Size() int
func (*PodLeaseReturned) XXX_Unmarshal ¶
func (m *PodLeaseReturned) XXX_Unmarshal(b []byte) error
type PodSpecWithAvoidList ¶
type PodSpecWithAvoidList struct { PodSpec *v11.PodSpec `protobuf:"bytes,1,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"` // List of nodes to avoid scheduling this pod on. // TODO: Could this be done with selectors, taints, etc? NodeAvoidlist []string `protobuf:"bytes,2,rep,name=node_avoidlist,json=nodeAvoidlist,proto3" json:"nodeAvoidlist,omitempty"` }
Kubernetes pod spec. with a bundled list of pods to avoid scheduling the pod to.
func (*PodSpecWithAvoidList) Descriptor ¶
func (*PodSpecWithAvoidList) Descriptor() ([]byte, []int)
func (*PodSpecWithAvoidList) GetNodeAvoidlist ¶
func (m *PodSpecWithAvoidList) GetNodeAvoidlist() []string
func (*PodSpecWithAvoidList) GetPodSpec ¶
func (m *PodSpecWithAvoidList) GetPodSpec() *v11.PodSpec
func (*PodSpecWithAvoidList) Marshal ¶
func (m *PodSpecWithAvoidList) Marshal() (dAtA []byte, err error)
func (*PodSpecWithAvoidList) MarshalTo ¶
func (m *PodSpecWithAvoidList) MarshalTo(dAtA []byte) (int, error)
func (*PodSpecWithAvoidList) MarshalToSizedBuffer ¶
func (m *PodSpecWithAvoidList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodSpecWithAvoidList) ProtoMessage ¶
func (*PodSpecWithAvoidList) ProtoMessage()
func (*PodSpecWithAvoidList) Reset ¶
func (m *PodSpecWithAvoidList) Reset()
func (*PodSpecWithAvoidList) Size ¶
func (m *PodSpecWithAvoidList) Size() (n int)
func (*PodSpecWithAvoidList) String ¶
func (m *PodSpecWithAvoidList) String() string
func (*PodSpecWithAvoidList) Unmarshal ¶
func (m *PodSpecWithAvoidList) Unmarshal(dAtA []byte) error
func (*PodSpecWithAvoidList) XXX_DiscardUnknown ¶
func (m *PodSpecWithAvoidList) XXX_DiscardUnknown()
func (*PodSpecWithAvoidList) XXX_Marshal ¶
func (m *PodSpecWithAvoidList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PodSpecWithAvoidList) XXX_Merge ¶
func (m *PodSpecWithAvoidList) XXX_Merge(src proto.Message)
func (*PodSpecWithAvoidList) XXX_Size ¶
func (m *PodSpecWithAvoidList) XXX_Size() int
func (*PodSpecWithAvoidList) XXX_Unmarshal ¶
func (m *PodSpecWithAvoidList) XXX_Unmarshal(b []byte) error
type PodTerminated ¶
type PodTerminated struct { // This ObjectMeta identifies the Pod. ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` }
Indicates that the lease on the job that the pod was part of could not be renewed. If this happens, the executor deletes the pod and generates a JobRunError with this message as the reason.
func (*PodTerminated) Descriptor ¶
func (*PodTerminated) Descriptor() ([]byte, []int)
func (*PodTerminated) GetMessage ¶
func (m *PodTerminated) GetMessage() string
func (*PodTerminated) GetNodeName ¶
func (m *PodTerminated) GetNodeName() string
func (*PodTerminated) GetObjectMeta ¶
func (m *PodTerminated) GetObjectMeta() *ObjectMeta
func (*PodTerminated) GetPodNumber ¶
func (m *PodTerminated) GetPodNumber() int32
func (*PodTerminated) Marshal ¶
func (m *PodTerminated) Marshal() (dAtA []byte, err error)
func (*PodTerminated) MarshalToSizedBuffer ¶
func (m *PodTerminated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodTerminated) ProtoMessage ¶
func (*PodTerminated) ProtoMessage()
func (*PodTerminated) Reset ¶
func (m *PodTerminated) Reset()
func (*PodTerminated) Size ¶
func (m *PodTerminated) Size() (n int)
func (*PodTerminated) String ¶
func (m *PodTerminated) String() string
func (*PodTerminated) Unmarshal ¶
func (m *PodTerminated) Unmarshal(dAtA []byte) error
func (*PodTerminated) XXX_DiscardUnknown ¶
func (m *PodTerminated) XXX_DiscardUnknown()
func (*PodTerminated) XXX_Marshal ¶
func (m *PodTerminated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PodTerminated) XXX_Merge ¶
func (m *PodTerminated) XXX_Merge(src proto.Message)
func (*PodTerminated) XXX_Size ¶
func (m *PodTerminated) XXX_Size() int
func (*PodTerminated) XXX_Unmarshal ¶
func (m *PodTerminated) XXX_Unmarshal(b []byte) error
type PodUnschedulable ¶
type PodUnschedulable struct { // this ObjectMeta identifies the Pod ObjectMeta *ObjectMeta `protobuf:"bytes,1,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,4,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` }
func (*PodUnschedulable) Descriptor ¶
func (*PodUnschedulable) Descriptor() ([]byte, []int)
func (*PodUnschedulable) GetMessage ¶
func (m *PodUnschedulable) GetMessage() string
func (*PodUnschedulable) GetNodeName ¶
func (m *PodUnschedulable) GetNodeName() string
func (*PodUnschedulable) GetObjectMeta ¶
func (m *PodUnschedulable) GetObjectMeta() *ObjectMeta
func (*PodUnschedulable) GetPodNumber ¶
func (m *PodUnschedulable) GetPodNumber() int32
func (*PodUnschedulable) Marshal ¶
func (m *PodUnschedulable) Marshal() (dAtA []byte, err error)
func (*PodUnschedulable) MarshalToSizedBuffer ¶
func (m *PodUnschedulable) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodUnschedulable) ProtoMessage ¶
func (*PodUnschedulable) ProtoMessage()
func (*PodUnschedulable) Reset ¶
func (m *PodUnschedulable) Reset()
func (*PodUnschedulable) Size ¶
func (m *PodUnschedulable) Size() (n int)
func (*PodUnschedulable) String ¶
func (m *PodUnschedulable) String() string
func (*PodUnschedulable) Unmarshal ¶
func (m *PodUnschedulable) Unmarshal(dAtA []byte) error
func (*PodUnschedulable) XXX_DiscardUnknown ¶
func (m *PodUnschedulable) XXX_DiscardUnknown()
func (*PodUnschedulable) XXX_Marshal ¶
func (m *PodUnschedulable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PodUnschedulable) XXX_Merge ¶
func (m *PodUnschedulable) XXX_Merge(src proto.Message)
func (*PodUnschedulable) XXX_Size ¶
func (m *PodUnschedulable) XXX_Size() int
func (*PodUnschedulable) XXX_Unmarshal ¶
func (m *PodUnschedulable) XXX_Unmarshal(b []byte) error
type ReprioritiseJob ¶
type ReprioritiseJob struct { Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
Set the priority of a particular job.
func (*ReprioritiseJob) Descriptor ¶
func (*ReprioritiseJob) Descriptor() ([]byte, []int)
func (*ReprioritiseJob) GetJobId ¶
func (m *ReprioritiseJob) GetJobId() string
func (*ReprioritiseJob) GetPriority ¶
func (m *ReprioritiseJob) GetPriority() uint32
func (*ReprioritiseJob) Marshal ¶
func (m *ReprioritiseJob) Marshal() (dAtA []byte, err error)
func (*ReprioritiseJob) MarshalToSizedBuffer ¶
func (m *ReprioritiseJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReprioritiseJob) ProtoMessage ¶
func (*ReprioritiseJob) ProtoMessage()
func (*ReprioritiseJob) Reset ¶
func (m *ReprioritiseJob) Reset()
func (*ReprioritiseJob) Size ¶
func (m *ReprioritiseJob) Size() (n int)
func (*ReprioritiseJob) String ¶
func (m *ReprioritiseJob) String() string
func (*ReprioritiseJob) Unmarshal ¶
func (m *ReprioritiseJob) Unmarshal(dAtA []byte) error
func (*ReprioritiseJob) XXX_DiscardUnknown ¶
func (m *ReprioritiseJob) XXX_DiscardUnknown()
func (*ReprioritiseJob) XXX_Marshal ¶
func (m *ReprioritiseJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReprioritiseJob) XXX_Merge ¶
func (m *ReprioritiseJob) XXX_Merge(src proto.Message)
func (*ReprioritiseJob) XXX_Size ¶
func (m *ReprioritiseJob) XXX_Size() int
func (*ReprioritiseJob) XXX_Unmarshal ¶
func (m *ReprioritiseJob) XXX_Unmarshal(b []byte) error
type ReprioritiseJobSet ¶
type ReprioritiseJobSet struct {
Priority uint32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
}
Set the priority of all jobs part of a job set. This sets the priority of all jobs in the job set currently in the queued state.
func (*ReprioritiseJobSet) Descriptor ¶
func (*ReprioritiseJobSet) Descriptor() ([]byte, []int)
func (*ReprioritiseJobSet) GetPriority ¶
func (m *ReprioritiseJobSet) GetPriority() uint32
func (*ReprioritiseJobSet) Marshal ¶
func (m *ReprioritiseJobSet) Marshal() (dAtA []byte, err error)
func (*ReprioritiseJobSet) MarshalTo ¶
func (m *ReprioritiseJobSet) MarshalTo(dAtA []byte) (int, error)
func (*ReprioritiseJobSet) MarshalToSizedBuffer ¶
func (m *ReprioritiseJobSet) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReprioritiseJobSet) ProtoMessage ¶
func (*ReprioritiseJobSet) ProtoMessage()
func (*ReprioritiseJobSet) Reset ¶
func (m *ReprioritiseJobSet) Reset()
func (*ReprioritiseJobSet) Size ¶
func (m *ReprioritiseJobSet) Size() (n int)
func (*ReprioritiseJobSet) String ¶
func (m *ReprioritiseJobSet) String() string
func (*ReprioritiseJobSet) Unmarshal ¶
func (m *ReprioritiseJobSet) Unmarshal(dAtA []byte) error
func (*ReprioritiseJobSet) XXX_DiscardUnknown ¶
func (m *ReprioritiseJobSet) XXX_DiscardUnknown()
func (*ReprioritiseJobSet) XXX_Marshal ¶
func (m *ReprioritiseJobSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReprioritiseJobSet) XXX_Merge ¶
func (m *ReprioritiseJobSet) XXX_Merge(src proto.Message)
func (*ReprioritiseJobSet) XXX_Size ¶
func (m *ReprioritiseJobSet) XXX_Size() int
func (*ReprioritiseJobSet) XXX_Unmarshal ¶
func (m *ReprioritiseJobSet) XXX_Unmarshal(b []byte) error
type ReprioritisedJob ¶
type ReprioritisedJob struct { Priority uint32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"` JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` }
Generated by the scheduler in response to ReprioritiseJob and ReprioritiseJobSet. One such message is generated per job that was re-prioritised and includes the new priority.
func (*ReprioritisedJob) Descriptor ¶
func (*ReprioritisedJob) Descriptor() ([]byte, []int)
func (*ReprioritisedJob) GetJobId ¶
func (m *ReprioritisedJob) GetJobId() string
func (*ReprioritisedJob) GetPriority ¶
func (m *ReprioritisedJob) GetPriority() uint32
func (*ReprioritisedJob) Marshal ¶
func (m *ReprioritisedJob) Marshal() (dAtA []byte, err error)
func (*ReprioritisedJob) MarshalToSizedBuffer ¶
func (m *ReprioritisedJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReprioritisedJob) ProtoMessage ¶
func (*ReprioritisedJob) ProtoMessage()
func (*ReprioritisedJob) Reset ¶
func (m *ReprioritisedJob) Reset()
func (*ReprioritisedJob) Size ¶
func (m *ReprioritisedJob) Size() (n int)
func (*ReprioritisedJob) String ¶
func (m *ReprioritisedJob) String() string
func (*ReprioritisedJob) Unmarshal ¶
func (m *ReprioritisedJob) Unmarshal(dAtA []byte) error
func (*ReprioritisedJob) XXX_DiscardUnknown ¶
func (m *ReprioritisedJob) XXX_DiscardUnknown()
func (*ReprioritisedJob) XXX_Marshal ¶
func (m *ReprioritisedJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReprioritisedJob) XXX_Merge ¶
func (m *ReprioritisedJob) XXX_Merge(src proto.Message)
func (*ReprioritisedJob) XXX_Size ¶
func (m *ReprioritisedJob) XXX_Size() int
func (*ReprioritisedJob) XXX_Unmarshal ¶
func (m *ReprioritisedJob) XXX_Unmarshal(b []byte) error
type ResourceUtilisation ¶
type ResourceUtilisation struct { ResourceInfo *KubernetesResourceInfo `protobuf:"bytes,3,opt,name=resource_info,json=resourceInfo,proto3" json:"resourceInfo,omitempty"` MaxResourcesForPeriod map[string]*resource.Quantity `` /* 213-byte string literal not displayed */ TotalCumulativeUsage map[string]*resource.Quantity `` /* 209-byte string literal not displayed */ JobId string `protobuf:"bytes,6,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,7,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
Resource usage of a particular k8s object created as part of a job.
func (*ResourceUtilisation) Descriptor ¶
func (*ResourceUtilisation) Descriptor() ([]byte, []int)
func (*ResourceUtilisation) GetJobId ¶
func (m *ResourceUtilisation) GetJobId() string
func (*ResourceUtilisation) GetMaxResourcesForPeriod ¶
func (m *ResourceUtilisation) GetMaxResourcesForPeriod() map[string]*resource.Quantity
func (*ResourceUtilisation) GetResourceInfo ¶
func (m *ResourceUtilisation) GetResourceInfo() *KubernetesResourceInfo
func (*ResourceUtilisation) GetRunId ¶
func (m *ResourceUtilisation) GetRunId() string
func (*ResourceUtilisation) GetTotalCumulativeUsage ¶
func (m *ResourceUtilisation) GetTotalCumulativeUsage() map[string]*resource.Quantity
func (*ResourceUtilisation) Marshal ¶
func (m *ResourceUtilisation) Marshal() (dAtA []byte, err error)
func (*ResourceUtilisation) MarshalTo ¶
func (m *ResourceUtilisation) MarshalTo(dAtA []byte) (int, error)
func (*ResourceUtilisation) MarshalToSizedBuffer ¶
func (m *ResourceUtilisation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceUtilisation) ProtoMessage ¶
func (*ResourceUtilisation) ProtoMessage()
func (*ResourceUtilisation) Reset ¶
func (m *ResourceUtilisation) Reset()
func (*ResourceUtilisation) Size ¶
func (m *ResourceUtilisation) Size() (n int)
func (*ResourceUtilisation) String ¶
func (m *ResourceUtilisation) String() string
func (*ResourceUtilisation) Unmarshal ¶
func (m *ResourceUtilisation) Unmarshal(dAtA []byte) error
func (*ResourceUtilisation) XXX_DiscardUnknown ¶
func (m *ResourceUtilisation) XXX_DiscardUnknown()
func (*ResourceUtilisation) XXX_Marshal ¶
func (m *ResourceUtilisation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceUtilisation) XXX_Merge ¶
func (m *ResourceUtilisation) XXX_Merge(src proto.Message)
func (*ResourceUtilisation) XXX_Size ¶
func (m *ResourceUtilisation) XXX_Size() int
func (*ResourceUtilisation) XXX_Unmarshal ¶
func (m *ResourceUtilisation) XXX_Unmarshal(b []byte) error
type StandaloneIngressInfo ¶
type StandaloneIngressInfo struct { // ObjectMeta associated with the ingress. ObjectMeta *ObjectMeta `protobuf:"bytes,3,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */ // The legacy message bundles info associated with the pod. NodeName string `protobuf:"bytes,5,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,6,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,7,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,8,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` JobId string `protobuf:"bytes,9,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` RunId string `protobuf:"bytes,10,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` }
For sending details associated with a created ingress. Used for compatibility with legacy messages, which send ingress info as its own message. Later, this info should be bundled with the JobRunRunning message.
func (*StandaloneIngressInfo) Descriptor ¶
func (*StandaloneIngressInfo) Descriptor() ([]byte, []int)
func (*StandaloneIngressInfo) GetIngressAddresses ¶
func (m *StandaloneIngressInfo) GetIngressAddresses() map[int32]string
func (*StandaloneIngressInfo) GetJobId ¶
func (m *StandaloneIngressInfo) GetJobId() string
func (*StandaloneIngressInfo) GetNodeName ¶
func (m *StandaloneIngressInfo) GetNodeName() string
func (*StandaloneIngressInfo) GetObjectMeta ¶
func (m *StandaloneIngressInfo) GetObjectMeta() *ObjectMeta
func (*StandaloneIngressInfo) GetPodName ¶
func (m *StandaloneIngressInfo) GetPodName() string
func (*StandaloneIngressInfo) GetPodNamespace ¶
func (m *StandaloneIngressInfo) GetPodNamespace() string
func (*StandaloneIngressInfo) GetPodNumber ¶
func (m *StandaloneIngressInfo) GetPodNumber() int32
func (*StandaloneIngressInfo) GetRunId ¶
func (m *StandaloneIngressInfo) GetRunId() string
func (*StandaloneIngressInfo) Marshal ¶
func (m *StandaloneIngressInfo) Marshal() (dAtA []byte, err error)
func (*StandaloneIngressInfo) MarshalTo ¶
func (m *StandaloneIngressInfo) MarshalTo(dAtA []byte) (int, error)
func (*StandaloneIngressInfo) MarshalToSizedBuffer ¶
func (m *StandaloneIngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StandaloneIngressInfo) ProtoMessage ¶
func (*StandaloneIngressInfo) ProtoMessage()
func (*StandaloneIngressInfo) Reset ¶
func (m *StandaloneIngressInfo) Reset()
func (*StandaloneIngressInfo) Size ¶
func (m *StandaloneIngressInfo) Size() (n int)
func (*StandaloneIngressInfo) String ¶
func (m *StandaloneIngressInfo) String() string
func (*StandaloneIngressInfo) Unmarshal ¶
func (m *StandaloneIngressInfo) Unmarshal(dAtA []byte) error
func (*StandaloneIngressInfo) XXX_DiscardUnknown ¶
func (m *StandaloneIngressInfo) XXX_DiscardUnknown()
func (*StandaloneIngressInfo) XXX_Marshal ¶
func (m *StandaloneIngressInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StandaloneIngressInfo) XXX_Merge ¶
func (m *StandaloneIngressInfo) XXX_Merge(src proto.Message)
func (*StandaloneIngressInfo) XXX_Size ¶
func (m *StandaloneIngressInfo) XXX_Size() int
func (*StandaloneIngressInfo) XXX_Unmarshal ¶
func (m *StandaloneIngressInfo) XXX_Unmarshal(b []byte) error
type SubmitJob ¶
type SubmitJob struct { // User-provided id used for server-side deduplication. // I.e., jobs submitted with the same deduplication_id as an existing job are discarded. DeduplicationId string `protobuf:"bytes,2,opt,name=deduplication_id,json=deduplicationId,proto3" json:"deduplicationId,omitempty"` // Priority of this job. Measured relative to other jobs in the same queue. Priority uint32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"` // Shared ObjectMeta for all Kubernetes objects in this job. // If provided, the namespace therein is used for all objects that do not explicitly specify another. // And the labels and annotations therein are applied to all objects part of the job. ObjectMeta *ObjectMeta `protobuf:"bytes,4,opt,name=objectMeta,proto3" json:"objectMeta,omitempty"` // Main object that determines when an application has finished. MainObject *KubernetesMainObject `protobuf:"bytes,5,opt,name=mainObject,proto3" json:"mainObject,omitempty"` // Set of additional Kubernetes objects to create as part of the job. Objects []*KubernetesObject `protobuf:"bytes,6,rep,name=objects,proto3" json:"objects,omitempty"` // Maximum lifetime of the job in seconds. Zero indicates an infinite lifetime. Lifetime uint32 `protobuf:"varint,7,opt,name=lifetime,proto3" json:"lifetime,omitempty"` // If true, the job is run at most once, i.e., at most one job run will be created for it. // If false, the job may be re-leased on failure, which may cause the job to run more than once // (e.g., if a job run succeeds but the executor fails before it can report job success). AtMostOnce bool `protobuf:"varint,8,opt,name=atMostOnce,proto3" json:"atMostOnce,omitempty"` // If true, Armada may preempt the job while running. Preemptible bool `protobuf:"varint,9,opt,name=preemptible,proto3" json:"preemptible,omitempty"` // If true, Armada may optimistically run several instances of the job concurrently // (typically on different clusters). // If false, a new job run may only be created once Armada is certain that all existing runs have finished. ConcurrencySafe bool `protobuf:"varint,10,opt,name=concurrencySafe,proto3" json:"concurrencySafe,omitempty"` // Indicates which scheduler should manage this job. // If empty, the default scheduler is used. Scheduler string `protobuf:"bytes,11,opt,name=scheduler,proto3" json:"scheduler,omitempty"` // Indicates whether job is a duplicate IsDuplicate bool `protobuf:"varint,12,opt,name=isDuplicate,proto3" json:"isDuplicate,omitempty"` // The job id JobId string `protobuf:"bytes,14,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` // Pricing Information for the job. Currently experimental ExperimentalPriceInfo *ExperimentalPriceInfo `protobuf:"bytes,15,opt,name=experimentalPriceInfo,proto3" json:"experimentalPriceInfo,omitempty"` }
A request to run an Armada job. Each job consists of a set of Kubernetes objects, one of which is the main object (typically a pod spec.) and has a priority associated with it. When the main object exits, all other objects are cleaned up. The priority, together with the queue the job is submitted to, determines the order in which jobs are run.
func (*SubmitJob) Descriptor ¶
func (*SubmitJob) GetAtMostOnce ¶
func (*SubmitJob) GetConcurrencySafe ¶
func (*SubmitJob) GetDeduplicationId ¶
func (*SubmitJob) GetExperimentalPriceInfo ¶ added in v0.15.7
func (m *SubmitJob) GetExperimentalPriceInfo() *ExperimentalPriceInfo
func (*SubmitJob) GetIsDuplicate ¶ added in v0.3.61
func (*SubmitJob) GetLifetime ¶
func (*SubmitJob) GetMainObject ¶
func (m *SubmitJob) GetMainObject() *KubernetesMainObject
func (*SubmitJob) GetObjectMeta ¶
func (m *SubmitJob) GetObjectMeta() *ObjectMeta
func (*SubmitJob) GetObjects ¶
func (m *SubmitJob) GetObjects() []*KubernetesObject
func (*SubmitJob) GetPreemptible ¶
func (*SubmitJob) GetPriority ¶
func (*SubmitJob) GetScheduler ¶
func (*SubmitJob) MarshalToSizedBuffer ¶
func (*SubmitJob) ProtoMessage ¶
func (*SubmitJob) ProtoMessage()
func (*SubmitJob) XXX_DiscardUnknown ¶
func (m *SubmitJob) XXX_DiscardUnknown()