Documentation ¶
Overview ¶
Package api is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package api is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func JobIdFromApiEvent(msg *EventMessage) string
- func JobRunStateFromApiJobState(s JobState) schedulerobjects.JobRunState
- func JobSetIdFromApiEvent(msg *EventMessage) string
- func NodeIdFromExecutorAndNodeName(executor, nodeName string) string
- func PriorityFromPodSpec(podSpec *v1.PodSpec, priorityClasses map[string]types.PriorityClass) (int32, bool)
- func RegisterEventHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterEventHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventClient) error
- func RegisterEventHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterEventHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServer) error
- func RegisterEventServer(s *grpc.Server, srv EventServer)
- func RegisterQueryApiServer(s *grpc.Server, srv QueryApiServer)
- func RegisterSubmitHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterSubmitHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubmitClient) error
- func RegisterSubmitHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterSubmitHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubmitServer) error
- func RegisterSubmitServer(s *grpc.Server, srv SubmitServer)
- func SchedulingOrderCompare(job, other *Job) int
- func SchedulingResourceRequirementsFromPodSpec(podSpec *v1.PodSpec) v1.ResourceRequirements
- func ShortStringFromEventMessages(msgs []*EventMessage) string
- func SwaggerJsonTemplate() string
- type BatchQueueCreateResponse
- func (*BatchQueueCreateResponse) Descriptor() ([]byte, []int)
- func (m *BatchQueueCreateResponse) GetFailedQueues() []*QueueCreateResponse
- func (m *BatchQueueCreateResponse) Marshal() (dAtA []byte, err error)
- func (m *BatchQueueCreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *BatchQueueCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BatchQueueCreateResponse) ProtoMessage()
- func (m *BatchQueueCreateResponse) Reset()
- func (m *BatchQueueCreateResponse) Size() (n int)
- func (this *BatchQueueCreateResponse) String() string
- func (m *BatchQueueCreateResponse) Unmarshal(dAtA []byte) error
- func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()
- func (m *BatchQueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BatchQueueCreateResponse) XXX_Merge(src proto.Message)
- func (m *BatchQueueCreateResponse) XXX_Size() int
- func (m *BatchQueueCreateResponse) XXX_Unmarshal(b []byte) error
- type BatchQueueUpdateResponse
- func (*BatchQueueUpdateResponse) Descriptor() ([]byte, []int)
- func (m *BatchQueueUpdateResponse) GetFailedQueues() []*QueueUpdateResponse
- func (m *BatchQueueUpdateResponse) Marshal() (dAtA []byte, err error)
- func (m *BatchQueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *BatchQueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BatchQueueUpdateResponse) ProtoMessage()
- func (m *BatchQueueUpdateResponse) Reset()
- func (m *BatchQueueUpdateResponse) Size() (n int)
- func (this *BatchQueueUpdateResponse) String() string
- func (m *BatchQueueUpdateResponse) Unmarshal(dAtA []byte) error
- func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()
- func (m *BatchQueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BatchQueueUpdateResponse) XXX_Merge(src proto.Message)
- func (m *BatchQueueUpdateResponse) XXX_Size() int
- func (m *BatchQueueUpdateResponse) XXX_Unmarshal(b []byte) error
- type CancellationResult
- func (*CancellationResult) Descriptor() ([]byte, []int)
- func (m *CancellationResult) GetCancelledIds() []string
- func (m *CancellationResult) Marshal() (dAtA []byte, err error)
- func (m *CancellationResult) MarshalTo(dAtA []byte) (int, error)
- func (m *CancellationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancellationResult) ProtoMessage()
- func (m *CancellationResult) Reset()
- func (m *CancellationResult) Size() (n int)
- func (this *CancellationResult) String() string
- func (m *CancellationResult) Unmarshal(dAtA []byte) error
- func (m *CancellationResult) XXX_DiscardUnknown()
- func (m *CancellationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancellationResult) XXX_Merge(src proto.Message)
- func (m *CancellationResult) XXX_Size() int
- func (m *CancellationResult) XXX_Unmarshal(b []byte) error
- type Cause
- type ContainerStatus
- func (*ContainerStatus) Descriptor() ([]byte, []int)
- func (m *ContainerStatus) GetCause() Cause
- func (m *ContainerStatus) GetExitCode() int32
- func (m *ContainerStatus) GetMessage() string
- func (m *ContainerStatus) GetName() string
- func (m *ContainerStatus) GetReason() string
- func (m *ContainerStatus) Marshal() (dAtA []byte, err error)
- func (m *ContainerStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *ContainerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContainerStatus) ProtoMessage()
- func (m *ContainerStatus) Reset()
- func (m *ContainerStatus) Size() (n int)
- func (this *ContainerStatus) String() string
- func (m *ContainerStatus) Unmarshal(dAtA []byte) error
- func (m *ContainerStatus) XXX_DiscardUnknown()
- func (m *ContainerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContainerStatus) XXX_Merge(src proto.Message)
- func (m *ContainerStatus) XXX_Size() int
- func (m *ContainerStatus) XXX_Unmarshal(b []byte) error
- type CustomSubmitClient
- type EndMarker
- func (*EndMarker) Descriptor() ([]byte, []int)
- func (m *EndMarker) Marshal() (dAtA []byte, err error)
- func (m *EndMarker) MarshalTo(dAtA []byte) (int, error)
- func (m *EndMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EndMarker) ProtoMessage()
- func (m *EndMarker) Reset()
- func (m *EndMarker) Size() (n int)
- func (this *EndMarker) String() string
- func (m *EndMarker) Unmarshal(dAtA []byte) error
- func (m *EndMarker) XXX_DiscardUnknown()
- func (m *EndMarker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EndMarker) XXX_Merge(src proto.Message)
- func (m *EndMarker) XXX_Size() int
- func (m *EndMarker) XXX_Unmarshal(b []byte) error
- type Event
- type EventClient
- type EventMessage
- func (*EventMessage) Descriptor() ([]byte, []int)
- func (m *EventMessage) GetCancelled() *JobCancelledEvent
- func (m *EventMessage) GetCancelling() *JobCancellingEvent
- func (m *EventMessage) GetDuplicateFound() *JobDuplicateFoundEvent
- func (m *EventMessage) GetEvents() isEventMessage_Events
- func (m *EventMessage) GetFailed() *JobFailedEvent
- func (m *EventMessage) GetFailedCompressed() *JobFailedEventCompressed
- func (m *EventMessage) GetIngressInfo() *JobIngressInfoEvent
- func (m *EventMessage) GetLeaseExpired() *JobLeaseExpiredEvent
- func (m *EventMessage) GetLeaseReturned() *JobLeaseReturnedEvent
- func (m *EventMessage) GetLeased() *JobLeasedEvent
- func (m *EventMessage) GetPending() *JobPendingEvent
- func (m *EventMessage) GetPreempted() *JobPreemptedEvent
- func (m *EventMessage) GetQueued() *JobQueuedEvent
- func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent
- func (m *EventMessage) GetReprioritizing() *JobReprioritizingEvent
- func (m *EventMessage) GetRunning() *JobRunningEvent
- func (m *EventMessage) GetSubmitted() *JobSubmittedEvent
- func (m *EventMessage) GetSucceeded() *JobSucceededEvent
- func (m *EventMessage) GetTerminated() *JobTerminatedEvent
- func (m *EventMessage) GetUnableToSchedule() *JobUnableToScheduleEvent
- func (m *EventMessage) GetUpdated() *JobUpdatedEvent
- func (m *EventMessage) GetUtilisation() *JobUtilisationEvent
- func (m *EventMessage) Marshal() (dAtA []byte, err error)
- func (message *EventMessage) MarshalJSON() ([]byte, error)
- func (m *EventMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *EventMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventMessage) ProtoMessage()
- func (m *EventMessage) Reset()
- func (msg *EventMessage) ShortString() string
- func (m *EventMessage) Size() (n int)
- func (this *EventMessage) String() string
- func (m *EventMessage) Unmarshal(dAtA []byte) error
- func (message *EventMessage) UnmarshalJSON(data []byte) error
- func (m *EventMessage) XXX_DiscardUnknown()
- func (m *EventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventMessage) XXX_Merge(src proto.Message)
- func (*EventMessage) XXX_OneofWrappers() []interface{}
- func (m *EventMessage) XXX_Size() int
- func (m *EventMessage) XXX_Unmarshal(b []byte) error
- type EventMessage_Cancelled
- type EventMessage_Cancelling
- type EventMessage_DuplicateFound
- type EventMessage_Failed
- type EventMessage_FailedCompressed
- type EventMessage_IngressInfo
- type EventMessage_LeaseExpired
- type EventMessage_LeaseReturned
- type EventMessage_Leased
- type EventMessage_Pending
- type EventMessage_Preempted
- type EventMessage_Queued
- type EventMessage_Reprioritized
- type EventMessage_Reprioritizing
- type EventMessage_Running
- type EventMessage_Submitted
- type EventMessage_Succeeded
- type EventMessage_Terminated
- type EventMessage_UnableToSchedule
- type EventMessage_Updated
- type EventMessage_Utilisation
- type EventServer
- type EventStreamMessage
- func (*EventStreamMessage) Descriptor() ([]byte, []int)
- func (m *EventStreamMessage) GetId() string
- func (m *EventStreamMessage) GetMessage() *EventMessage
- func (m *EventStreamMessage) Marshal() (dAtA []byte, err error)
- func (m *EventStreamMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *EventStreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventStreamMessage) ProtoMessage()
- func (m *EventStreamMessage) Reset()
- func (m *EventStreamMessage) Size() (n int)
- func (this *EventStreamMessage) String() string
- func (m *EventStreamMessage) Unmarshal(dAtA []byte) error
- func (m *EventStreamMessage) XXX_DiscardUnknown()
- func (m *EventStreamMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventStreamMessage) XXX_Merge(src proto.Message)
- func (m *EventStreamMessage) XXX_Size() int
- func (m *EventStreamMessage) XXX_Unmarshal(b []byte) error
- type Event_GetJobSetEventsClient
- type Event_GetJobSetEventsServer
- type Event_WatchClient
- type Event_WatchServer
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)
- func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
- func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error)
- func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *HealthCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HealthCheckResponse) ProtoMessage()
- func (m *HealthCheckResponse) Reset()
- func (m *HealthCheckResponse) Size() (n int)
- func (m *HealthCheckResponse) String() string
- func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error
- func (m *HealthCheckResponse) XXX_DiscardUnknown()
- func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthCheckResponse) XXX_Merge(src proto.Message)
- func (m *HealthCheckResponse) XXX_Size() int
- func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error
- type HealthCheckResponse_ServingStatus
- type IngressConfig
- func (*IngressConfig) Descriptor() ([]byte, []int)
- func (m *IngressConfig) GetAnnotations() map[string]string
- func (m *IngressConfig) GetCertName() string
- func (m *IngressConfig) GetPorts() []uint32
- func (m *IngressConfig) GetTlsEnabled() bool
- func (m *IngressConfig) GetType() IngressTypedeprecated
- func (m *IngressConfig) GetUseClusterIP() bool
- func (m *IngressConfig) Marshal() (dAtA []byte, err error)
- func (m *IngressConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *IngressConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IngressConfig) ProtoMessage()
- func (m *IngressConfig) Reset()
- func (m *IngressConfig) Size() (n int)
- func (this *IngressConfig) String() string
- func (m *IngressConfig) Unmarshal(dAtA []byte) error
- func (m *IngressConfig) XXX_DiscardUnknown()
- func (m *IngressConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IngressConfig) XXX_Merge(src proto.Message)
- func (m *IngressConfig) XXX_Size() int
- func (m *IngressConfig) XXX_Unmarshal(b []byte) error
- type IngressType
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (job *Job) GetAffinity() *v1.Affinity
- func (m *Job) GetAnnotations() map[string]string
- func (m *Job) GetClientId() string
- func (m *Job) GetCompressedQueueOwnershipUserGroups() []byte
- func (m *Job) GetCreated() time.Time
- func (m *Job) GetId() string
- func (m *Job) GetIngress() []*IngressConfig
- func (job *Job) GetJobSet() string
- func (m *Job) GetJobSetId() string
- func (m *Job) GetK8SIngress() []*v11.Ingress
- func (m *Job) GetK8SService() []*v1.Service
- func (m *Job) GetLabels() map[string]string
- func (job *Job) GetMainPodSpec() *v1.PodSpec
- func (m *Job) GetNamespace() string
- func (job *Job) GetNodeSelector() map[string]string
- func (m *Job) GetOwner() string
- func (job *Job) GetPerQueuePriority() uint32
- func (job *Job) GetPodRequirements(priorityClasses map[string]types.PriorityClass) *schedulerobjects.PodRequirements
- func (m *Job) GetPodSpec() *v1.PodSpecdeprecated
- func (m *Job) GetPodSpecs() []*v1.PodSpec
- func (m *Job) GetPriority() float64
- func (job *Job) GetPriorityClassName() string
- func (m *Job) GetQueue() string
- func (m *Job) GetQueueOwnershipUserGroups() []string
- func (m *Job) GetQueueTtlSeconds() int64
- func (m *Job) GetRequiredNodeLabels() map[string]stringdeprecated
- func (job *Job) GetResourceRequirements() v1.ResourceRequirements
- func (job *Job) GetScheduledAtPriority() (int32, bool)
- func (m *Job) GetScheduler() string
- func (job *Job) GetSchedulingKey() (schedulerobjects.SchedulingKey, bool)
- func (m *Job) GetSchedulingResourceRequirements() v1.ResourceRequirements
- func (m *Job) GetServices() []*ServiceConfig
- func (job *Job) GetSubmitTime() time.Time
- func (job *Job) GetTolerations() []v1.Toleration
- func (m *Job) Marshal() (dAtA []byte, err error)
- func (m *Job) MarshalTo(dAtA []byte) (int, error)
- func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (job *Job) SchedulingOrderCompare(other interfaces.LegacySchedulerJob) int
- func (m *Job) Size() (n int)
- func (this *Job) String() string
- func (job *Job) TotalResourceRequest() armadaresource.ComputeResources
- func (m *Job) Unmarshal(dAtA []byte) error
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type JobCancelRequest
- func (*JobCancelRequest) Descriptor() ([]byte, []int)
- func (m *JobCancelRequest) GetJobId() string
- func (m *JobCancelRequest) GetJobIds() []string
- func (m *JobCancelRequest) GetJobSetId() string
- func (m *JobCancelRequest) GetQueue() string
- func (m *JobCancelRequest) GetReason() string
- func (m *JobCancelRequest) Marshal() (dAtA []byte, err error)
- func (m *JobCancelRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobCancelRequest) ProtoMessage()
- func (m *JobCancelRequest) Reset()
- func (m *JobCancelRequest) Size() (n int)
- func (this *JobCancelRequest) String() string
- func (m *JobCancelRequest) Unmarshal(dAtA []byte) error
- func (m *JobCancelRequest) XXX_DiscardUnknown()
- func (m *JobCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobCancelRequest) XXX_Merge(src proto.Message)
- func (m *JobCancelRequest) XXX_Size() int
- func (m *JobCancelRequest) XXX_Unmarshal(b []byte) error
- type JobCancelledEvent
- func (*JobCancelledEvent) Descriptor() ([]byte, []int)
- func (m *JobCancelledEvent) GetCreated() time.Time
- func (m *JobCancelledEvent) GetJobId() string
- func (m *JobCancelledEvent) GetJobSetId() string
- func (m *JobCancelledEvent) GetQueue() string
- func (m *JobCancelledEvent) GetReason() string
- func (m *JobCancelledEvent) GetRequestor() string
- func (m *JobCancelledEvent) Marshal() (dAtA []byte, err error)
- func (m *JobCancelledEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobCancelledEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobCancelledEvent) ProtoMessage()
- func (m *JobCancelledEvent) Reset()
- func (m *JobCancelledEvent) Size() (n int)
- func (this *JobCancelledEvent) String() string
- func (m *JobCancelledEvent) Unmarshal(dAtA []byte) error
- func (m *JobCancelledEvent) XXX_DiscardUnknown()
- func (m *JobCancelledEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobCancelledEvent) XXX_Merge(src proto.Message)
- func (m *JobCancelledEvent) XXX_Size() int
- func (m *JobCancelledEvent) XXX_Unmarshal(b []byte) error
- type JobCancellingEvent
- func (*JobCancellingEvent) Descriptor() ([]byte, []int)
- func (m *JobCancellingEvent) GetCreated() time.Time
- func (m *JobCancellingEvent) GetJobId() string
- func (m *JobCancellingEvent) GetJobSetId() string
- func (m *JobCancellingEvent) GetQueue() string
- func (m *JobCancellingEvent) GetReason() string
- func (m *JobCancellingEvent) GetRequestor() string
- func (m *JobCancellingEvent) Marshal() (dAtA []byte, err error)
- func (m *JobCancellingEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobCancellingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobCancellingEvent) ProtoMessage()
- func (m *JobCancellingEvent) Reset()
- func (m *JobCancellingEvent) Size() (n int)
- func (this *JobCancellingEvent) String() string
- func (m *JobCancellingEvent) Unmarshal(dAtA []byte) error
- func (m *JobCancellingEvent) XXX_DiscardUnknown()
- func (m *JobCancellingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobCancellingEvent) XXX_Merge(src proto.Message)
- func (m *JobCancellingEvent) XXX_Size() int
- func (m *JobCancellingEvent) XXX_Unmarshal(b []byte) error
- type JobDuplicateFoundEvent
- func (*JobDuplicateFoundEvent) Descriptor() ([]byte, []int)
- func (m *JobDuplicateFoundEvent) GetCreated() time.Time
- func (m *JobDuplicateFoundEvent) GetJobId() string
- func (m *JobDuplicateFoundEvent) GetJobSetId() string
- func (m *JobDuplicateFoundEvent) GetOriginalJobId() string
- func (m *JobDuplicateFoundEvent) GetQueue() string
- func (m *JobDuplicateFoundEvent) Marshal() (dAtA []byte, err error)
- func (m *JobDuplicateFoundEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobDuplicateFoundEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobDuplicateFoundEvent) ProtoMessage()
- func (m *JobDuplicateFoundEvent) Reset()
- func (m *JobDuplicateFoundEvent) Size() (n int)
- func (this *JobDuplicateFoundEvent) String() string
- func (m *JobDuplicateFoundEvent) Unmarshal(dAtA []byte) error
- func (m *JobDuplicateFoundEvent) XXX_DiscardUnknown()
- func (m *JobDuplicateFoundEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobDuplicateFoundEvent) XXX_Merge(src proto.Message)
- func (m *JobDuplicateFoundEvent) XXX_Size() int
- func (m *JobDuplicateFoundEvent) XXX_Unmarshal(b []byte) error
- type JobFailedEvent
- func (*JobFailedEvent) Descriptor() ([]byte, []int)
- func (m *JobFailedEvent) GetCause() Cause
- func (m *JobFailedEvent) GetClusterId() string
- func (m *JobFailedEvent) GetContainerStatuses() []*ContainerStatus
- func (m *JobFailedEvent) GetCreated() time.Time
- func (m *JobFailedEvent) GetExitCodes() map[string]int32deprecated
- func (m *JobFailedEvent) GetJobId() string
- func (m *JobFailedEvent) GetJobSetId() string
- func (m *JobFailedEvent) GetKubernetesId() string
- func (m *JobFailedEvent) GetNodeName() string
- func (m *JobFailedEvent) GetPodName() string
- func (m *JobFailedEvent) GetPodNamespace() string
- func (m *JobFailedEvent) GetPodNumber() int32
- func (m *JobFailedEvent) GetQueue() string
- func (m *JobFailedEvent) GetReason() string
- func (m *JobFailedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobFailedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobFailedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobFailedEvent) ProtoMessage()
- func (m *JobFailedEvent) Reset()
- func (m *JobFailedEvent) Size() (n int)
- func (this *JobFailedEvent) String() string
- func (m *JobFailedEvent) Unmarshal(dAtA []byte) error
- func (m *JobFailedEvent) XXX_DiscardUnknown()
- func (m *JobFailedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobFailedEvent) XXX_Merge(src proto.Message)
- func (m *JobFailedEvent) XXX_Size() int
- func (m *JobFailedEvent) XXX_Unmarshal(b []byte) error
- type JobFailedEventCompressed
- func (*JobFailedEventCompressed) Descriptor() ([]byte, []int)
- func (m *JobFailedEventCompressed) GetEvent() []byte
- func (m *JobFailedEventCompressed) Marshal() (dAtA []byte, err error)
- func (m *JobFailedEventCompressed) MarshalTo(dAtA []byte) (int, error)
- func (m *JobFailedEventCompressed) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobFailedEventCompressed) ProtoMessage()
- func (m *JobFailedEventCompressed) Reset()
- func (m *JobFailedEventCompressed) Size() (n int)
- func (this *JobFailedEventCompressed) String() string
- func (m *JobFailedEventCompressed) Unmarshal(dAtA []byte) error
- func (m *JobFailedEventCompressed) XXX_DiscardUnknown()
- func (m *JobFailedEventCompressed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobFailedEventCompressed) XXX_Merge(src proto.Message)
- func (m *JobFailedEventCompressed) XXX_Size() int
- func (m *JobFailedEventCompressed) XXX_Unmarshal(b []byte) error
- type JobIngressInfoEvent
- func (*JobIngressInfoEvent) Descriptor() ([]byte, []int)
- func (m *JobIngressInfoEvent) GetClusterId() string
- func (m *JobIngressInfoEvent) GetCreated() time.Time
- func (m *JobIngressInfoEvent) GetIngressAddresses() map[int32]string
- func (m *JobIngressInfoEvent) GetJobId() string
- func (m *JobIngressInfoEvent) GetJobSetId() string
- func (m *JobIngressInfoEvent) GetKubernetesId() string
- func (m *JobIngressInfoEvent) GetNodeName() string
- func (m *JobIngressInfoEvent) GetPodName() string
- func (m *JobIngressInfoEvent) GetPodNamespace() string
- func (m *JobIngressInfoEvent) GetPodNumber() int32
- func (m *JobIngressInfoEvent) GetQueue() string
- func (m *JobIngressInfoEvent) Marshal() (dAtA []byte, err error)
- func (m *JobIngressInfoEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobIngressInfoEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobIngressInfoEvent) ProtoMessage()
- func (m *JobIngressInfoEvent) Reset()
- func (m *JobIngressInfoEvent) Size() (n int)
- func (this *JobIngressInfoEvent) String() string
- func (m *JobIngressInfoEvent) Unmarshal(dAtA []byte) error
- func (m *JobIngressInfoEvent) XXX_DiscardUnknown()
- func (m *JobIngressInfoEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobIngressInfoEvent) XXX_Merge(src proto.Message)
- func (m *JobIngressInfoEvent) XXX_Size() int
- func (m *JobIngressInfoEvent) XXX_Unmarshal(b []byte) error
- type JobLeaseExpiredEvent
- func (*JobLeaseExpiredEvent) Descriptor() ([]byte, []int)
- func (m *JobLeaseExpiredEvent) GetCreated() time.Time
- func (m *JobLeaseExpiredEvent) GetJobId() string
- func (m *JobLeaseExpiredEvent) GetJobSetId() string
- func (m *JobLeaseExpiredEvent) GetQueue() string
- func (m *JobLeaseExpiredEvent) Marshal() (dAtA []byte, err error)
- func (m *JobLeaseExpiredEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLeaseExpiredEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLeaseExpiredEvent) ProtoMessage()
- func (m *JobLeaseExpiredEvent) Reset()
- func (m *JobLeaseExpiredEvent) Size() (n int)
- func (this *JobLeaseExpiredEvent) String() string
- func (m *JobLeaseExpiredEvent) Unmarshal(dAtA []byte) error
- func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()
- func (m *JobLeaseExpiredEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLeaseExpiredEvent) XXX_Merge(src proto.Message)
- func (m *JobLeaseExpiredEvent) XXX_Size() int
- func (m *JobLeaseExpiredEvent) XXX_Unmarshal(b []byte) error
- type JobLeaseReturnedEvent
- func (*JobLeaseReturnedEvent) Descriptor() ([]byte, []int)
- func (m *JobLeaseReturnedEvent) GetClusterId() string
- func (m *JobLeaseReturnedEvent) GetCreated() time.Time
- func (m *JobLeaseReturnedEvent) GetJobId() string
- func (m *JobLeaseReturnedEvent) GetJobSetId() string
- func (m *JobLeaseReturnedEvent) GetKubernetesId() string
- func (m *JobLeaseReturnedEvent) GetPodNumber() int32
- func (m *JobLeaseReturnedEvent) GetQueue() string
- func (m *JobLeaseReturnedEvent) GetReason() string
- func (m *JobLeaseReturnedEvent) GetRunAttempted() bool
- func (m *JobLeaseReturnedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobLeaseReturnedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLeaseReturnedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLeaseReturnedEvent) ProtoMessage()
- func (m *JobLeaseReturnedEvent) Reset()
- func (m *JobLeaseReturnedEvent) Size() (n int)
- func (this *JobLeaseReturnedEvent) String() string
- func (m *JobLeaseReturnedEvent) Unmarshal(dAtA []byte) error
- func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()
- func (m *JobLeaseReturnedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLeaseReturnedEvent) XXX_Merge(src proto.Message)
- func (m *JobLeaseReturnedEvent) XXX_Size() int
- func (m *JobLeaseReturnedEvent) XXX_Unmarshal(b []byte) error
- type JobLeasedEvent
- func (*JobLeasedEvent) Descriptor() ([]byte, []int)
- func (m *JobLeasedEvent) GetClusterId() string
- func (m *JobLeasedEvent) GetCreated() time.Time
- func (m *JobLeasedEvent) GetJobId() string
- func (m *JobLeasedEvent) GetJobSetId() string
- func (m *JobLeasedEvent) GetQueue() string
- func (m *JobLeasedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobLeasedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLeasedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLeasedEvent) ProtoMessage()
- func (m *JobLeasedEvent) Reset()
- func (m *JobLeasedEvent) Size() (n int)
- func (this *JobLeasedEvent) String() string
- func (m *JobLeasedEvent) Unmarshal(dAtA []byte) error
- func (m *JobLeasedEvent) XXX_DiscardUnknown()
- func (m *JobLeasedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLeasedEvent) XXX_Merge(src proto.Message)
- func (m *JobLeasedEvent) XXX_Size() int
- func (m *JobLeasedEvent) XXX_Unmarshal(b []byte) error
- type JobPendingEvent
- func (*JobPendingEvent) Descriptor() ([]byte, []int)
- func (m *JobPendingEvent) GetClusterId() string
- func (m *JobPendingEvent) GetCreated() time.Time
- func (m *JobPendingEvent) GetJobId() string
- func (m *JobPendingEvent) GetJobSetId() string
- func (m *JobPendingEvent) GetKubernetesId() string
- func (m *JobPendingEvent) GetPodName() string
- func (m *JobPendingEvent) GetPodNamespace() string
- func (m *JobPendingEvent) GetPodNumber() int32
- func (m *JobPendingEvent) GetQueue() string
- func (m *JobPendingEvent) Marshal() (dAtA []byte, err error)
- func (m *JobPendingEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobPendingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobPendingEvent) ProtoMessage()
- func (m *JobPendingEvent) Reset()
- func (m *JobPendingEvent) Size() (n int)
- func (this *JobPendingEvent) String() string
- func (m *JobPendingEvent) Unmarshal(dAtA []byte) error
- func (m *JobPendingEvent) XXX_DiscardUnknown()
- func (m *JobPendingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobPendingEvent) XXX_Merge(src proto.Message)
- func (m *JobPendingEvent) XXX_Size() int
- func (m *JobPendingEvent) XXX_Unmarshal(b []byte) error
- type JobPreemptedEvent
- func (*JobPreemptedEvent) Descriptor() ([]byte, []int)
- func (m *JobPreemptedEvent) GetClusterId() string
- func (m *JobPreemptedEvent) GetCreated() time.Time
- func (m *JobPreemptedEvent) GetJobId() string
- func (m *JobPreemptedEvent) GetJobSetId() string
- func (m *JobPreemptedEvent) GetPreemptiveJobId() string
- func (m *JobPreemptedEvent) GetPreemptiveRunId() string
- func (m *JobPreemptedEvent) GetQueue() string
- func (m *JobPreemptedEvent) GetRunId() string
- func (m *JobPreemptedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobPreemptedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobPreemptedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobPreemptedEvent) ProtoMessage()
- func (m *JobPreemptedEvent) Reset()
- func (m *JobPreemptedEvent) Size() (n int)
- func (this *JobPreemptedEvent) String() string
- func (m *JobPreemptedEvent) Unmarshal(dAtA []byte) error
- func (m *JobPreemptedEvent) XXX_DiscardUnknown()
- func (m *JobPreemptedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobPreemptedEvent) XXX_Merge(src proto.Message)
- func (m *JobPreemptedEvent) XXX_Size() int
- func (m *JobPreemptedEvent) XXX_Unmarshal(b []byte) error
- type JobQueuedEvent
- func (*JobQueuedEvent) Descriptor() ([]byte, []int)
- func (m *JobQueuedEvent) GetCreated() time.Time
- func (m *JobQueuedEvent) GetJobId() string
- func (m *JobQueuedEvent) GetJobSetId() string
- func (m *JobQueuedEvent) GetQueue() string
- func (m *JobQueuedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobQueuedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobQueuedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobQueuedEvent) ProtoMessage()
- func (m *JobQueuedEvent) Reset()
- func (m *JobQueuedEvent) Size() (n int)
- func (this *JobQueuedEvent) String() string
- func (m *JobQueuedEvent) Unmarshal(dAtA []byte) error
- func (m *JobQueuedEvent) XXX_DiscardUnknown()
- func (m *JobQueuedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobQueuedEvent) XXX_Merge(src proto.Message)
- func (m *JobQueuedEvent) XXX_Size() int
- func (m *JobQueuedEvent) XXX_Unmarshal(b []byte) error
- type JobReprioritizeRequest
- func (*JobReprioritizeRequest) Descriptor() ([]byte, []int)
- func (m *JobReprioritizeRequest) GetJobIds() []string
- func (m *JobReprioritizeRequest) GetJobSetId() string
- func (m *JobReprioritizeRequest) GetNewPriority() float64
- func (m *JobReprioritizeRequest) GetQueue() string
- func (m *JobReprioritizeRequest) Marshal() (dAtA []byte, err error)
- func (m *JobReprioritizeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReprioritizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReprioritizeRequest) ProtoMessage()
- func (m *JobReprioritizeRequest) Reset()
- func (m *JobReprioritizeRequest) Size() (n int)
- func (this *JobReprioritizeRequest) String() string
- func (m *JobReprioritizeRequest) Unmarshal(dAtA []byte) error
- func (m *JobReprioritizeRequest) XXX_DiscardUnknown()
- func (m *JobReprioritizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReprioritizeRequest) XXX_Merge(src proto.Message)
- func (m *JobReprioritizeRequest) XXX_Size() int
- func (m *JobReprioritizeRequest) XXX_Unmarshal(b []byte) error
- type JobReprioritizeResponse
- func (*JobReprioritizeResponse) Descriptor() ([]byte, []int)
- func (m *JobReprioritizeResponse) GetReprioritizationResults() map[string]string
- func (m *JobReprioritizeResponse) Marshal() (dAtA []byte, err error)
- func (m *JobReprioritizeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReprioritizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReprioritizeResponse) ProtoMessage()
- func (m *JobReprioritizeResponse) Reset()
- func (m *JobReprioritizeResponse) Size() (n int)
- func (this *JobReprioritizeResponse) String() string
- func (m *JobReprioritizeResponse) Unmarshal(dAtA []byte) error
- func (m *JobReprioritizeResponse) XXX_DiscardUnknown()
- func (m *JobReprioritizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReprioritizeResponse) XXX_Merge(src proto.Message)
- func (m *JobReprioritizeResponse) XXX_Size() int
- func (m *JobReprioritizeResponse) XXX_Unmarshal(b []byte) error
- type JobReprioritizedEvent
- func (*JobReprioritizedEvent) Descriptor() ([]byte, []int)
- func (m *JobReprioritizedEvent) GetCreated() time.Time
- func (m *JobReprioritizedEvent) GetJobId() string
- func (m *JobReprioritizedEvent) GetJobSetId() string
- func (m *JobReprioritizedEvent) GetNewPriority() float64
- func (m *JobReprioritizedEvent) GetQueue() string
- func (m *JobReprioritizedEvent) GetRequestor() string
- func (m *JobReprioritizedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobReprioritizedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReprioritizedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReprioritizedEvent) ProtoMessage()
- func (m *JobReprioritizedEvent) Reset()
- func (m *JobReprioritizedEvent) Size() (n int)
- func (this *JobReprioritizedEvent) String() string
- func (m *JobReprioritizedEvent) Unmarshal(dAtA []byte) error
- func (m *JobReprioritizedEvent) XXX_DiscardUnknown()
- func (m *JobReprioritizedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReprioritizedEvent) XXX_Merge(src proto.Message)
- func (m *JobReprioritizedEvent) XXX_Size() int
- func (m *JobReprioritizedEvent) XXX_Unmarshal(b []byte) error
- type JobReprioritizingEvent
- func (*JobReprioritizingEvent) Descriptor() ([]byte, []int)
- func (m *JobReprioritizingEvent) GetCreated() time.Time
- func (m *JobReprioritizingEvent) GetJobId() string
- func (m *JobReprioritizingEvent) GetJobSetId() string
- func (m *JobReprioritizingEvent) GetNewPriority() float64
- func (m *JobReprioritizingEvent) GetQueue() string
- func (m *JobReprioritizingEvent) GetRequestor() string
- func (m *JobReprioritizingEvent) Marshal() (dAtA []byte, err error)
- func (m *JobReprioritizingEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReprioritizingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReprioritizingEvent) ProtoMessage()
- func (m *JobReprioritizingEvent) Reset()
- func (m *JobReprioritizingEvent) Size() (n int)
- func (this *JobReprioritizingEvent) String() string
- func (m *JobReprioritizingEvent) Unmarshal(dAtA []byte) error
- func (m *JobReprioritizingEvent) XXX_DiscardUnknown()
- func (m *JobReprioritizingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReprioritizingEvent) XXX_Merge(src proto.Message)
- func (m *JobReprioritizingEvent) XXX_Size() int
- func (m *JobReprioritizingEvent) XXX_Unmarshal(b []byte) error
- type JobRunningEvent
- func (*JobRunningEvent) Descriptor() ([]byte, []int)
- func (m *JobRunningEvent) GetClusterId() string
- func (m *JobRunningEvent) GetCreated() time.Time
- func (m *JobRunningEvent) GetJobId() string
- func (m *JobRunningEvent) GetJobSetId() string
- func (m *JobRunningEvent) GetKubernetesId() string
- func (m *JobRunningEvent) GetNodeName() string
- func (m *JobRunningEvent) GetPodName() string
- func (m *JobRunningEvent) GetPodNamespace() string
- func (m *JobRunningEvent) GetPodNumber() int32
- func (m *JobRunningEvent) GetQueue() string
- func (m *JobRunningEvent) Marshal() (dAtA []byte, err error)
- func (m *JobRunningEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunningEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunningEvent) ProtoMessage()
- func (m *JobRunningEvent) Reset()
- func (m *JobRunningEvent) Size() (n int)
- func (this *JobRunningEvent) String() string
- func (m *JobRunningEvent) Unmarshal(dAtA []byte) error
- func (m *JobRunningEvent) XXX_DiscardUnknown()
- func (m *JobRunningEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunningEvent) XXX_Merge(src proto.Message)
- func (m *JobRunningEvent) XXX_Size() int
- func (m *JobRunningEvent) XXX_Unmarshal(b []byte) error
- type JobSetCancelRequest
- func (*JobSetCancelRequest) Descriptor() ([]byte, []int)
- func (m *JobSetCancelRequest) GetFilter() *JobSetFilter
- func (m *JobSetCancelRequest) GetJobSetId() string
- func (m *JobSetCancelRequest) GetQueue() string
- func (m *JobSetCancelRequest) GetReason() string
- func (m *JobSetCancelRequest) Marshal() (dAtA []byte, err error)
- func (m *JobSetCancelRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSetCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSetCancelRequest) ProtoMessage()
- func (m *JobSetCancelRequest) Reset()
- func (m *JobSetCancelRequest) Size() (n int)
- func (this *JobSetCancelRequest) String() string
- func (m *JobSetCancelRequest) Unmarshal(dAtA []byte) error
- func (m *JobSetCancelRequest) XXX_DiscardUnknown()
- func (m *JobSetCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSetCancelRequest) XXX_Merge(src proto.Message)
- func (m *JobSetCancelRequest) XXX_Size() int
- func (m *JobSetCancelRequest) 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 (this *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 JobSetInfo
- func (*JobSetInfo) Descriptor() ([]byte, []int)
- func (m *JobSetInfo) GetLeasedJobs() int32
- func (m *JobSetInfo) GetName() string
- func (m *JobSetInfo) GetQueuedJobs() int32
- func (m *JobSetInfo) Marshal() (dAtA []byte, err error)
- func (m *JobSetInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSetInfo) ProtoMessage()
- func (m *JobSetInfo) Reset()
- func (m *JobSetInfo) Size() (n int)
- func (this *JobSetInfo) String() string
- func (m *JobSetInfo) Unmarshal(dAtA []byte) error
- func (m *JobSetInfo) XXX_DiscardUnknown()
- func (m *JobSetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSetInfo) XXX_Merge(src proto.Message)
- func (m *JobSetInfo) XXX_Size() int
- func (m *JobSetInfo) XXX_Unmarshal(b []byte) error
- type JobSetRequest
- func (*JobSetRequest) Descriptor() ([]byte, []int)
- func (m *JobSetRequest) GetErrorIfMissing() bool
- func (m *JobSetRequest) GetForceLegacy() bool
- func (m *JobSetRequest) GetForceNew() bool
- func (m *JobSetRequest) GetFromMessageId() string
- func (m *JobSetRequest) GetId() string
- func (m *JobSetRequest) GetQueue() string
- func (m *JobSetRequest) GetWatch() bool
- func (m *JobSetRequest) Marshal() (dAtA []byte, err error)
- func (m *JobSetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSetRequest) ProtoMessage()
- func (m *JobSetRequest) Reset()
- func (m *JobSetRequest) Size() (n int)
- func (this *JobSetRequest) String() string
- func (m *JobSetRequest) Unmarshal(dAtA []byte) error
- func (m *JobSetRequest) XXX_DiscardUnknown()
- func (m *JobSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSetRequest) XXX_Merge(src proto.Message)
- func (m *JobSetRequest) XXX_Size() int
- func (m *JobSetRequest) XXX_Unmarshal(b []byte) error
- type JobState
- type JobStatus
- type JobStatusRequest
- func (*JobStatusRequest) Descriptor() ([]byte, []int)
- func (m *JobStatusRequest) GetJobId() string
- func (m *JobStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *JobStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobStatusRequest) ProtoMessage()
- func (m *JobStatusRequest) Reset()
- func (m *JobStatusRequest) Size() (n int)
- func (this *JobStatusRequest) String() string
- func (m *JobStatusRequest) Unmarshal(dAtA []byte) error
- func (m *JobStatusRequest) XXX_DiscardUnknown()
- func (m *JobStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobStatusRequest) XXX_Merge(src proto.Message)
- func (m *JobStatusRequest) XXX_Size() int
- func (m *JobStatusRequest) XXX_Unmarshal(b []byte) error
- type JobStatusResponse
- func (*JobStatusResponse) Descriptor() ([]byte, []int)
- func (m *JobStatusResponse) GetJobId() string
- func (m *JobStatusResponse) GetJobStatus() JobStatus
- func (m *JobStatusResponse) Marshal() (dAtA []byte, err error)
- func (m *JobStatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobStatusResponse) ProtoMessage()
- func (m *JobStatusResponse) Reset()
- func (m *JobStatusResponse) Size() (n int)
- func (this *JobStatusResponse) String() string
- func (m *JobStatusResponse) Unmarshal(dAtA []byte) error
- func (m *JobStatusResponse) XXX_DiscardUnknown()
- func (m *JobStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobStatusResponse) XXX_Merge(src proto.Message)
- func (m *JobStatusResponse) XXX_Size() int
- func (m *JobStatusResponse) XXX_Unmarshal(b []byte) error
- type JobSubmitRequest
- func (*JobSubmitRequest) Descriptor() ([]byte, []int)
- func (m *JobSubmitRequest) GetJobRequestItems() []*JobSubmitRequestItem
- func (m *JobSubmitRequest) GetJobSetId() string
- func (m *JobSubmitRequest) GetQueue() string
- func (m *JobSubmitRequest) Marshal() (dAtA []byte, err error)
- func (m *JobSubmitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSubmitRequest) ProtoMessage()
- func (m *JobSubmitRequest) Reset()
- func (m *JobSubmitRequest) Size() (n int)
- func (this *JobSubmitRequest) String() string
- func (m *JobSubmitRequest) Unmarshal(dAtA []byte) error
- func (m *JobSubmitRequest) XXX_DiscardUnknown()
- func (m *JobSubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSubmitRequest) XXX_Merge(src proto.Message)
- func (m *JobSubmitRequest) XXX_Size() int
- func (m *JobSubmitRequest) XXX_Unmarshal(b []byte) error
- type JobSubmitRequestItem
- func (*JobSubmitRequestItem) Descriptor() ([]byte, []int)
- func (m *JobSubmitRequestItem) GetAnnotations() map[string]string
- func (m *JobSubmitRequestItem) GetClientId() string
- func (m *JobSubmitRequestItem) GetIngress() []*IngressConfig
- func (m *JobSubmitRequestItem) GetLabels() map[string]string
- func (job *JobSubmitRequestItem) GetMainPodSpec() *v1.PodSpec
- func (m *JobSubmitRequestItem) GetNamespace() string
- func (m *JobSubmitRequestItem) GetPodSpec() *v1.PodSpecdeprecated
- func (m *JobSubmitRequestItem) GetPodSpecs() []*v1.PodSpec
- func (m *JobSubmitRequestItem) GetPriority() float64
- func (m *JobSubmitRequestItem) GetQueueTtlSeconds() int64
- func (m *JobSubmitRequestItem) GetRequiredNodeLabels() map[string]stringdeprecated
- func (m *JobSubmitRequestItem) GetScheduler() string
- func (m *JobSubmitRequestItem) GetServices() []*ServiceConfig
- func (m *JobSubmitRequestItem) Marshal() (dAtA []byte, err error)
- func (m *JobSubmitRequestItem) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSubmitRequestItem) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSubmitRequestItem) ProtoMessage()
- func (m *JobSubmitRequestItem) Reset()
- func (m *JobSubmitRequestItem) Size() (n int)
- func (this *JobSubmitRequestItem) String() string
- func (m *JobSubmitRequestItem) Unmarshal(dAtA []byte) error
- func (m *JobSubmitRequestItem) XXX_DiscardUnknown()
- func (m *JobSubmitRequestItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSubmitRequestItem) XXX_Merge(src proto.Message)
- func (m *JobSubmitRequestItem) XXX_Size() int
- func (m *JobSubmitRequestItem) XXX_Unmarshal(b []byte) error
- type JobSubmitResponse
- func (*JobSubmitResponse) Descriptor() ([]byte, []int)
- func (m *JobSubmitResponse) GetJobResponseItems() []*JobSubmitResponseItem
- func (m *JobSubmitResponse) Marshal() (dAtA []byte, err error)
- func (m *JobSubmitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSubmitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSubmitResponse) ProtoMessage()
- func (m *JobSubmitResponse) Reset()
- func (m *JobSubmitResponse) Size() (n int)
- func (this *JobSubmitResponse) String() string
- func (m *JobSubmitResponse) Unmarshal(dAtA []byte) error
- func (m *JobSubmitResponse) XXX_DiscardUnknown()
- func (m *JobSubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSubmitResponse) XXX_Merge(src proto.Message)
- func (m *JobSubmitResponse) XXX_Size() int
- func (m *JobSubmitResponse) XXX_Unmarshal(b []byte) error
- type JobSubmitResponseItem
- func (*JobSubmitResponseItem) Descriptor() ([]byte, []int)
- func (m *JobSubmitResponseItem) GetError() string
- func (m *JobSubmitResponseItem) GetJobId() string
- func (m *JobSubmitResponseItem) Marshal() (dAtA []byte, err error)
- func (m *JobSubmitResponseItem) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSubmitResponseItem) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSubmitResponseItem) ProtoMessage()
- func (m *JobSubmitResponseItem) Reset()
- func (m *JobSubmitResponseItem) Size() (n int)
- func (this *JobSubmitResponseItem) String() string
- func (m *JobSubmitResponseItem) Unmarshal(dAtA []byte) error
- func (m *JobSubmitResponseItem) XXX_DiscardUnknown()
- func (m *JobSubmitResponseItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSubmitResponseItem) XXX_Merge(src proto.Message)
- func (m *JobSubmitResponseItem) XXX_Size() int
- func (m *JobSubmitResponseItem) XXX_Unmarshal(b []byte) error
- type JobSubmittedEvent
- func (*JobSubmittedEvent) Descriptor() ([]byte, []int)
- func (m *JobSubmittedEvent) GetCreated() time.Time
- func (m *JobSubmittedEvent) GetJob() Job
- func (m *JobSubmittedEvent) GetJobId() string
- func (m *JobSubmittedEvent) GetJobSetId() string
- func (m *JobSubmittedEvent) GetQueue() string
- func (m *JobSubmittedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobSubmittedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSubmittedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSubmittedEvent) ProtoMessage()
- func (m *JobSubmittedEvent) Reset()
- func (m *JobSubmittedEvent) Size() (n int)
- func (this *JobSubmittedEvent) String() string
- func (m *JobSubmittedEvent) Unmarshal(dAtA []byte) error
- func (m *JobSubmittedEvent) XXX_DiscardUnknown()
- func (m *JobSubmittedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSubmittedEvent) XXX_Merge(src proto.Message)
- func (m *JobSubmittedEvent) XXX_Size() int
- func (m *JobSubmittedEvent) XXX_Unmarshal(b []byte) error
- type JobSucceededEvent
- func (*JobSucceededEvent) Descriptor() ([]byte, []int)
- func (m *JobSucceededEvent) GetClusterId() string
- func (m *JobSucceededEvent) GetCreated() time.Time
- func (m *JobSucceededEvent) GetJobId() string
- func (m *JobSucceededEvent) GetJobSetId() string
- func (m *JobSucceededEvent) GetKubernetesId() string
- func (m *JobSucceededEvent) GetNodeName() string
- func (m *JobSucceededEvent) GetPodName() string
- func (m *JobSucceededEvent) GetPodNamespace() string
- func (m *JobSucceededEvent) GetPodNumber() int32
- func (m *JobSucceededEvent) GetQueue() string
- func (m *JobSucceededEvent) Marshal() (dAtA []byte, err error)
- func (m *JobSucceededEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSucceededEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSucceededEvent) ProtoMessage()
- func (m *JobSucceededEvent) Reset()
- func (m *JobSucceededEvent) Size() (n int)
- func (this *JobSucceededEvent) String() string
- func (m *JobSucceededEvent) Unmarshal(dAtA []byte) error
- func (m *JobSucceededEvent) XXX_DiscardUnknown()
- func (m *JobSucceededEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSucceededEvent) XXX_Merge(src proto.Message)
- func (m *JobSucceededEvent) XXX_Size() int
- func (m *JobSucceededEvent) XXX_Unmarshal(b []byte) error
- type JobTerminatedEvent
- func (*JobTerminatedEvent) Descriptor() ([]byte, []int)
- func (m *JobTerminatedEvent) GetClusterId() string
- func (m *JobTerminatedEvent) GetCreated() time.Time
- func (m *JobTerminatedEvent) GetJobId() string
- func (m *JobTerminatedEvent) GetJobSetId() string
- func (m *JobTerminatedEvent) GetKubernetesId() string
- func (m *JobTerminatedEvent) GetPodName() string
- func (m *JobTerminatedEvent) GetPodNamespace() string
- func (m *JobTerminatedEvent) GetPodNumber() int32
- func (m *JobTerminatedEvent) GetQueue() string
- func (m *JobTerminatedEvent) GetReason() string
- func (m *JobTerminatedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobTerminatedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobTerminatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobTerminatedEvent) ProtoMessage()
- func (m *JobTerminatedEvent) Reset()
- func (m *JobTerminatedEvent) Size() (n int)
- func (this *JobTerminatedEvent) String() string
- func (m *JobTerminatedEvent) Unmarshal(dAtA []byte) error
- func (m *JobTerminatedEvent) XXX_DiscardUnknown()
- func (m *JobTerminatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobTerminatedEvent) XXX_Merge(src proto.Message)
- func (m *JobTerminatedEvent) XXX_Size() int
- func (m *JobTerminatedEvent) XXX_Unmarshal(b []byte) error
- type JobUnableToScheduleEvent
- func (*JobUnableToScheduleEvent) Descriptor() ([]byte, []int)
- func (m *JobUnableToScheduleEvent) GetClusterId() string
- func (m *JobUnableToScheduleEvent) GetCreated() time.Time
- func (m *JobUnableToScheduleEvent) GetJobId() string
- func (m *JobUnableToScheduleEvent) GetJobSetId() string
- func (m *JobUnableToScheduleEvent) GetKubernetesId() string
- func (m *JobUnableToScheduleEvent) GetNodeName() string
- func (m *JobUnableToScheduleEvent) GetPodName() string
- func (m *JobUnableToScheduleEvent) GetPodNamespace() string
- func (m *JobUnableToScheduleEvent) GetPodNumber() int32
- func (m *JobUnableToScheduleEvent) GetQueue() string
- func (m *JobUnableToScheduleEvent) GetReason() string
- func (m *JobUnableToScheduleEvent) Marshal() (dAtA []byte, err error)
- func (m *JobUnableToScheduleEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobUnableToScheduleEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobUnableToScheduleEvent) ProtoMessage()
- func (m *JobUnableToScheduleEvent) Reset()
- func (m *JobUnableToScheduleEvent) Size() (n int)
- func (this *JobUnableToScheduleEvent) String() string
- func (m *JobUnableToScheduleEvent) Unmarshal(dAtA []byte) error
- func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()
- func (m *JobUnableToScheduleEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobUnableToScheduleEvent) XXX_Merge(src proto.Message)
- func (m *JobUnableToScheduleEvent) XXX_Size() int
- func (m *JobUnableToScheduleEvent) XXX_Unmarshal(b []byte) error
- type JobUpdatedEvent
- func (*JobUpdatedEvent) Descriptor() ([]byte, []int)
- func (m *JobUpdatedEvent) GetCreated() time.Time
- func (m *JobUpdatedEvent) GetJob() Job
- func (m *JobUpdatedEvent) GetJobId() string
- func (m *JobUpdatedEvent) GetJobSetId() string
- func (m *JobUpdatedEvent) GetQueue() string
- func (m *JobUpdatedEvent) GetRequestor() string
- func (m *JobUpdatedEvent) Marshal() (dAtA []byte, err error)
- func (m *JobUpdatedEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobUpdatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobUpdatedEvent) ProtoMessage()
- func (m *JobUpdatedEvent) Reset()
- func (m *JobUpdatedEvent) Size() (n int)
- func (this *JobUpdatedEvent) String() string
- func (m *JobUpdatedEvent) Unmarshal(dAtA []byte) error
- func (m *JobUpdatedEvent) XXX_DiscardUnknown()
- func (m *JobUpdatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobUpdatedEvent) XXX_Merge(src proto.Message)
- func (m *JobUpdatedEvent) XXX_Size() int
- func (m *JobUpdatedEvent) XXX_Unmarshal(b []byte) error
- type JobUtilisationEvent
- func (*JobUtilisationEvent) Descriptor() ([]byte, []int)
- func (m *JobUtilisationEvent) GetClusterId() string
- func (m *JobUtilisationEvent) GetCreated() time.Time
- func (m *JobUtilisationEvent) GetJobId() string
- func (m *JobUtilisationEvent) GetJobSetId() string
- func (m *JobUtilisationEvent) GetKubernetesId() string
- func (m *JobUtilisationEvent) GetMaxResourcesForPeriod() map[string]resource.Quantity
- func (m *JobUtilisationEvent) GetNodeName() string
- func (m *JobUtilisationEvent) GetPodName() string
- func (m *JobUtilisationEvent) GetPodNamespace() string
- func (m *JobUtilisationEvent) GetPodNumber() int32
- func (m *JobUtilisationEvent) GetQueue() string
- func (m *JobUtilisationEvent) GetTotalCumulativeUsage() map[string]resource.Quantity
- func (m *JobUtilisationEvent) Marshal() (dAtA []byte, err error)
- func (m *JobUtilisationEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobUtilisationEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobUtilisationEvent) ProtoMessage()
- func (m *JobUtilisationEvent) Reset()
- func (m *JobUtilisationEvent) Size() (n int)
- func (this *JobUtilisationEvent) String() string
- func (m *JobUtilisationEvent) Unmarshal(dAtA []byte) error
- func (m *JobUtilisationEvent) XXX_DiscardUnknown()
- func (m *JobUtilisationEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobUtilisationEvent) XXX_Merge(src proto.Message)
- func (m *JobUtilisationEvent) XXX_Size() int
- func (m *JobUtilisationEvent) XXX_Unmarshal(b []byte) error
- type KubernetesEvent
- type QueryApiClient
- type QueryApiServer
- type Queue
- func (*Queue) Descriptor() ([]byte, []int)
- func (m *Queue) GetGroupOwners() []string
- func (m *Queue) GetName() string
- func (m *Queue) GetPermissions() []*Queue_Permissions
- func (m *Queue) GetPriorityFactor() float64
- func (m *Queue) GetResourceLimits() map[string]float64
- func (m *Queue) GetUserOwners() []string
- func (m *Queue) Marshal() (dAtA []byte, err error)
- func (m *Queue) MarshalTo(dAtA []byte) (int, error)
- func (m *Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Queue) ProtoMessage()
- func (m *Queue) Reset()
- func (m *Queue) Size() (n int)
- func (this *Queue) String() string
- func (m *Queue) Unmarshal(dAtA []byte) error
- func (m *Queue) XXX_DiscardUnknown()
- func (m *Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Queue) XXX_Merge(src proto.Message)
- func (m *Queue) XXX_Size() int
- func (m *Queue) XXX_Unmarshal(b []byte) error
- type QueueCreateResponse
- func (*QueueCreateResponse) Descriptor() ([]byte, []int)
- func (m *QueueCreateResponse) GetError() string
- func (m *QueueCreateResponse) GetQueue() *Queue
- func (m *QueueCreateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueueCreateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueCreateResponse) ProtoMessage()
- func (m *QueueCreateResponse) Reset()
- func (m *QueueCreateResponse) Size() (n int)
- func (this *QueueCreateResponse) String() string
- func (m *QueueCreateResponse) Unmarshal(dAtA []byte) error
- func (m *QueueCreateResponse) XXX_DiscardUnknown()
- func (m *QueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueCreateResponse) XXX_Merge(src proto.Message)
- func (m *QueueCreateResponse) XXX_Size() int
- func (m *QueueCreateResponse) XXX_Unmarshal(b []byte) error
- type QueueDeleteRequest
- func (*QueueDeleteRequest) Descriptor() ([]byte, []int)
- func (m *QueueDeleteRequest) GetName() string
- func (m *QueueDeleteRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueDeleteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueDeleteRequest) ProtoMessage()
- func (m *QueueDeleteRequest) Reset()
- func (m *QueueDeleteRequest) Size() (n int)
- func (this *QueueDeleteRequest) String() string
- func (m *QueueDeleteRequest) Unmarshal(dAtA []byte) error
- func (m *QueueDeleteRequest) XXX_DiscardUnknown()
- func (m *QueueDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueDeleteRequest) XXX_Merge(src proto.Message)
- func (m *QueueDeleteRequest) XXX_Size() int
- func (m *QueueDeleteRequest) XXX_Unmarshal(b []byte) error
- type QueueGetRequest
- func (*QueueGetRequest) Descriptor() ([]byte, []int)
- func (m *QueueGetRequest) GetName() string
- func (m *QueueGetRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueGetRequest) ProtoMessage()
- func (m *QueueGetRequest) Reset()
- func (m *QueueGetRequest) Size() (n int)
- func (this *QueueGetRequest) String() string
- func (m *QueueGetRequest) Unmarshal(dAtA []byte) error
- func (m *QueueGetRequest) XXX_DiscardUnknown()
- func (m *QueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueGetRequest) XXX_Merge(src proto.Message)
- func (m *QueueGetRequest) XXX_Size() int
- func (m *QueueGetRequest) XXX_Unmarshal(b []byte) error
- type QueueList
- func (*QueueList) Descriptor() ([]byte, []int)
- func (m *QueueList) GetQueues() []*Queue
- func (m *QueueList) Marshal() (dAtA []byte, err error)
- func (m *QueueList) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueList) ProtoMessage()
- func (m *QueueList) Reset()
- func (m *QueueList) Size() (n int)
- func (this *QueueList) String() string
- func (m *QueueList) Unmarshal(dAtA []byte) error
- func (m *QueueList) XXX_DiscardUnknown()
- func (m *QueueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueList) XXX_Merge(src proto.Message)
- func (m *QueueList) XXX_Size() int
- func (m *QueueList) XXX_Unmarshal(b []byte) error
- type QueueUpdateResponse
- func (*QueueUpdateResponse) Descriptor() ([]byte, []int)
- func (m *QueueUpdateResponse) GetError() string
- func (m *QueueUpdateResponse) GetQueue() *Queue
- func (m *QueueUpdateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueUpdateResponse) ProtoMessage()
- func (m *QueueUpdateResponse) Reset()
- func (m *QueueUpdateResponse) Size() (n int)
- func (this *QueueUpdateResponse) String() string
- func (m *QueueUpdateResponse) Unmarshal(dAtA []byte) error
- func (m *QueueUpdateResponse) XXX_DiscardUnknown()
- func (m *QueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueUpdateResponse) XXX_Merge(src proto.Message)
- func (m *QueueUpdateResponse) XXX_Size() int
- func (m *QueueUpdateResponse) XXX_Unmarshal(b []byte) error
- type Queue_Permissions
- func (*Queue_Permissions) Descriptor() ([]byte, []int)
- func (m *Queue_Permissions) GetSubjects() []*Queue_Permissions_Subject
- func (m *Queue_Permissions) GetVerbs() []string
- func (m *Queue_Permissions) Marshal() (dAtA []byte, err error)
- func (m *Queue_Permissions) MarshalTo(dAtA []byte) (int, error)
- func (m *Queue_Permissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Queue_Permissions) ProtoMessage()
- func (m *Queue_Permissions) Reset()
- func (m *Queue_Permissions) Size() (n int)
- func (this *Queue_Permissions) String() string
- func (m *Queue_Permissions) Unmarshal(dAtA []byte) error
- func (m *Queue_Permissions) XXX_DiscardUnknown()
- func (m *Queue_Permissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Queue_Permissions) XXX_Merge(src proto.Message)
- func (m *Queue_Permissions) XXX_Size() int
- func (m *Queue_Permissions) XXX_Unmarshal(b []byte) error
- type Queue_Permissions_Subject
- func (*Queue_Permissions_Subject) Descriptor() ([]byte, []int)
- func (m *Queue_Permissions_Subject) GetKind() string
- func (m *Queue_Permissions_Subject) GetName() string
- func (m *Queue_Permissions_Subject) Marshal() (dAtA []byte, err error)
- func (m *Queue_Permissions_Subject) MarshalTo(dAtA []byte) (int, error)
- func (m *Queue_Permissions_Subject) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Queue_Permissions_Subject) ProtoMessage()
- func (m *Queue_Permissions_Subject) Reset()
- func (m *Queue_Permissions_Subject) Size() (n int)
- func (this *Queue_Permissions_Subject) String() string
- func (m *Queue_Permissions_Subject) Unmarshal(dAtA []byte) error
- func (m *Queue_Permissions_Subject) XXX_DiscardUnknown()
- func (m *Queue_Permissions_Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Queue_Permissions_Subject) XXX_Merge(src proto.Message)
- func (m *Queue_Permissions_Subject) XXX_Size() int
- func (m *Queue_Permissions_Subject) XXX_Unmarshal(b []byte) error
- type ServiceConfig
- func (*ServiceConfig) Descriptor() ([]byte, []int)
- func (m *ServiceConfig) GetPorts() []uint32
- func (m *ServiceConfig) GetType() ServiceType
- func (m *ServiceConfig) Marshal() (dAtA []byte, err error)
- func (m *ServiceConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceConfig) ProtoMessage()
- func (m *ServiceConfig) Reset()
- func (m *ServiceConfig) Size() (n int)
- func (this *ServiceConfig) String() string
- func (m *ServiceConfig) Unmarshal(dAtA []byte) error
- func (m *ServiceConfig) XXX_DiscardUnknown()
- func (m *ServiceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceConfig) XXX_Merge(src proto.Message)
- func (m *ServiceConfig) XXX_Size() int
- func (m *ServiceConfig) XXX_Unmarshal(b []byte) error
- type ServiceType
- type StreamingQueueGetRequest
- func (*StreamingQueueGetRequest) Descriptor() ([]byte, []int)
- func (m *StreamingQueueGetRequest) GetNum() uint32
- func (m *StreamingQueueGetRequest) Marshal() (dAtA []byte, err error)
- func (m *StreamingQueueGetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamingQueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamingQueueGetRequest) ProtoMessage()
- func (m *StreamingQueueGetRequest) Reset()
- func (m *StreamingQueueGetRequest) Size() (n int)
- func (this *StreamingQueueGetRequest) String() string
- func (m *StreamingQueueGetRequest) Unmarshal(dAtA []byte) error
- func (m *StreamingQueueGetRequest) XXX_DiscardUnknown()
- func (m *StreamingQueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingQueueGetRequest) XXX_Merge(src proto.Message)
- func (m *StreamingQueueGetRequest) XXX_Size() int
- func (m *StreamingQueueGetRequest) XXX_Unmarshal(b []byte) error
- type StreamingQueueMessage
- func (*StreamingQueueMessage) Descriptor() ([]byte, []int)
- func (m *StreamingQueueMessage) GetEnd() *EndMarker
- func (m *StreamingQueueMessage) GetEvent() isStreamingQueueMessage_Event
- func (m *StreamingQueueMessage) GetQueue() *Queue
- func (m *StreamingQueueMessage) Marshal() (dAtA []byte, err error)
- func (m *StreamingQueueMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamingQueueMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamingQueueMessage) ProtoMessage()
- func (m *StreamingQueueMessage) Reset()
- func (m *StreamingQueueMessage) Size() (n int)
- func (this *StreamingQueueMessage) String() string
- func (m *StreamingQueueMessage) Unmarshal(dAtA []byte) error
- func (m *StreamingQueueMessage) XXX_DiscardUnknown()
- func (m *StreamingQueueMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamingQueueMessage) XXX_Merge(src proto.Message)
- func (*StreamingQueueMessage) XXX_OneofWrappers() []interface{}
- func (m *StreamingQueueMessage) XXX_Size() int
- func (m *StreamingQueueMessage) XXX_Unmarshal(b []byte) error
- type StreamingQueueMessage_End
- type StreamingQueueMessage_Queue
- type SubmitClient
- type SubmitServer
- type Submit_GetQueuesClient
- type Submit_GetQueuesServer
- type TestSpec
- func (*TestSpec) Descriptor() ([]byte, []int)
- func (m *TestSpec) GetBatchSize() uint32
- func (m *TestSpec) GetCancel() TestSpec_Cancel
- func (m *TestSpec) GetEnvironment() string
- func (m *TestSpec) GetExpectedEvents() []*EventMessage
- func (m *TestSpec) GetGetLogs() bool
- func (m *TestSpec) GetInterval() time.Duration
- func (m *TestSpec) GetJobSetId() string
- func (m *TestSpec) GetJobs() []*JobSubmitRequestItem
- func (m *TestSpec) GetName() string
- func (m *TestSpec) GetNumBatches() uint32
- func (m *TestSpec) GetQueue() string
- func (m *TestSpec) GetRandomClientId() bool
- func (m *TestSpec) GetTarget() string
- func (m *TestSpec) GetTimeout() time.Duration
- func (m *TestSpec) Marshal() (dAtA []byte, err error)
- func (m *TestSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *TestSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TestSpec) ProtoMessage()
- func (m *TestSpec) Reset()
- func (testSpec *TestSpec) ShortString() string
- func (m *TestSpec) Size() (n int)
- func (this *TestSpec) String() string
- func (m *TestSpec) Unmarshal(dAtA []byte) error
- func (m *TestSpec) XXX_DiscardUnknown()
- func (m *TestSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestSpec) XXX_Merge(src proto.Message)
- func (m *TestSpec) XXX_Size() int
- func (m *TestSpec) XXX_Unmarshal(b []byte) error
- type TestSpec_Cancel
- type UnimplementedEventServer
- func (*UnimplementedEventServer) GetJobSetEvents(req *JobSetRequest, srv Event_GetJobSetEventsServer) error
- func (*UnimplementedEventServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)
- func (*UnimplementedEventServer) Watch(req *WatchRequest, srv Event_WatchServer) error
- type UnimplementedQueryApiServer
- type UnimplementedSubmitServer
- func (*UnimplementedSubmitServer) CancelJobSet(ctx context.Context, req *JobSetCancelRequest) (*types.Empty, error)
- func (*UnimplementedSubmitServer) CancelJobs(ctx context.Context, req *JobCancelRequest) (*CancellationResult, error)
- func (*UnimplementedSubmitServer) CreateQueue(ctx context.Context, req *Queue) (*types.Empty, error)
- func (*UnimplementedSubmitServer) CreateQueues(ctx context.Context, req *QueueList) (*BatchQueueCreateResponse, error)
- func (*UnimplementedSubmitServer) DeleteQueue(ctx context.Context, req *QueueDeleteRequest) (*types.Empty, error)
- func (*UnimplementedSubmitServer) GetQueue(ctx context.Context, req *QueueGetRequest) (*Queue, error)
- func (*UnimplementedSubmitServer) GetQueues(req *StreamingQueueGetRequest, srv Submit_GetQueuesServer) error
- func (*UnimplementedSubmitServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)
- func (*UnimplementedSubmitServer) ReprioritizeJobs(ctx context.Context, req *JobReprioritizeRequest) (*JobReprioritizeResponse, error)
- func (*UnimplementedSubmitServer) SubmitJobs(ctx context.Context, req *JobSubmitRequest) (*JobSubmitResponse, error)
- func (*UnimplementedSubmitServer) UpdateQueue(ctx context.Context, req *Queue) (*types.Empty, error)
- func (*UnimplementedSubmitServer) UpdateQueues(ctx context.Context, req *QueueList) (*BatchQueueUpdateResponse, error)
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)
- func (m *WatchRequest) GetForceLegacy() bool
- func (m *WatchRequest) GetForceNew() bool
- func (m *WatchRequest) GetFromId() string
- func (m *WatchRequest) GetJobSetId() string
- func (m *WatchRequest) GetQueue() string
- func (m *WatchRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchRequest) ProtoMessage()
- func (m *WatchRequest) Reset()
- func (m *WatchRequest) Size() (n int)
- func (this *WatchRequest) String() string
- func (m *WatchRequest) Unmarshal(dAtA []byte) error
- func (m *WatchRequest) XXX_DiscardUnknown()
- func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchRequest) XXX_Merge(src proto.Message)
- func (m *WatchRequest) XXX_Size() int
- func (m *WatchRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvent = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthHealth = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHealth = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupHealth = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQueryapi = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQueryapi = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQueryapi = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthSubmit = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSubmit = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSubmit = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTestspec = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTestspec = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTestspec = fmt.Errorf("proto: unexpected end of group") )
var Cause_name = map[int32]string{
0: "Error",
1: "Evicted",
2: "OOM",
3: "DeadlineExceeded",
}
var Cause_value = map[string]int32{
"Error": 0,
"Evicted": 1,
"OOM": 2,
"DeadlineExceeded": 3,
}
var HealthCheckResponse_ServingStatus_name = map[int32]string{
0: "UNKNOWN",
1: "SERVING",
2: "NOT_SERVING",
}
var HealthCheckResponse_ServingStatus_value = map[string]int32{
"UNKNOWN": 0,
"SERVING": 1,
"NOT_SERVING": 2,
}
var IngressType_name = map[int32]string{
0: "Ingress",
}
var IngressType_value = map[string]int32{
"Ingress": 0,
}
var JobState_name = map[int32]string{
0: "QUEUED",
1: "PENDING",
2: "RUNNING",
3: "SUCCEEDED",
4: "FAILED",
5: "UNKNOWN",
}
var JobState_value = map[string]int32{
"QUEUED": 0,
"PENDING": 1,
"RUNNING": 2,
"SUCCEEDED": 3,
"FAILED": 4,
"UNKNOWN": 5,
}
var JobStatus_name = map[int32]string{
0: "UNKNOWN",
1: "SUBMITTED",
2: "QUEUED",
3: "LEASED",
4: "PENDING",
5: "RUNNING",
6: "SUCCEEDED",
7: "FAILED",
8: "PREEMPTED",
9: "CANCELLED",
}
var JobStatus_value = map[string]int32{
"UNKNOWN": 0,
"SUBMITTED": 1,
"QUEUED": 2,
"LEASED": 3,
"PENDING": 4,
"RUNNING": 5,
"SUCCEEDED": 6,
"FAILED": 7,
"PREEMPTED": 8,
"CANCELLED": 9,
}
var ServiceType_name = map[int32]string{
0: "NodePort",
1: "Headless",
}
var ServiceType_value = map[string]int32{
"NodePort": 0,
"Headless": 1,
}
var TestSpec_Cancel_name = map[int32]string{
0: "NO",
1: "BY_ID",
2: "BY_SET",
3: "BY_IDS",
}
var TestSpec_Cancel_value = map[string]int32{
"NO": 0,
"BY_ID": 1,
"BY_SET": 2,
"BY_IDS": 3,
}
Functions ¶
func JobIdFromApiEvent ¶
func JobIdFromApiEvent(msg *EventMessage) string
func JobRunStateFromApiJobState ¶ added in v0.3.49
func JobRunStateFromApiJobState(s JobState) schedulerobjects.JobRunState
func JobSetIdFromApiEvent ¶
func JobSetIdFromApiEvent(msg *EventMessage) string
func NodeIdFromExecutorAndNodeName ¶ added in v0.3.83
func PriorityFromPodSpec ¶ added in v0.3.70
func PriorityFromPodSpec(podSpec *v1.PodSpec, priorityClasses map[string]types.PriorityClass) (int32, bool)
PriorityFromPodSpec returns the priority in a pod spec. If priority is set directly, that value is returned. Otherwise, it returns the value of the key podSpec. In both cases the value along with true boolean is returned. PriorityClassName in priorityByPriorityClassName map. If no priority is set for the pod spec, 0 along with a false boolean would be returned
func RegisterEventHandler ¶
RegisterEventHandler registers the http handlers for service Event to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterEventHandlerClient ¶
func RegisterEventHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventClient) error
RegisterEventHandlerClient registers the http handlers for service Event to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventClient" to call the correct interceptors.
func RegisterEventHandlerFromEndpoint ¶
func RegisterEventHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterEventHandlerFromEndpoint is same as RegisterEventHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterEventHandlerServer ¶
func RegisterEventHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServer) error
RegisterEventHandlerServer registers the http handlers for service Event to "mux". UnaryRPC :call EventServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEventHandlerFromEndpoint instead.
func RegisterEventServer ¶
func RegisterEventServer(s *grpc.Server, srv EventServer)
func RegisterQueryApiServer ¶ added in v0.4.20
func RegisterQueryApiServer(s *grpc.Server, srv QueryApiServer)
func RegisterSubmitHandler ¶
RegisterSubmitHandler registers the http handlers for service Submit to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterSubmitHandlerClient ¶
func RegisterSubmitHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubmitClient) error
RegisterSubmitHandlerClient registers the http handlers for service Submit to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SubmitClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SubmitClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SubmitClient" to call the correct interceptors.
func RegisterSubmitHandlerFromEndpoint ¶
func RegisterSubmitHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterSubmitHandlerFromEndpoint is same as RegisterSubmitHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterSubmitHandlerServer ¶
func RegisterSubmitHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubmitServer) error
RegisterSubmitHandlerServer registers the http handlers for service Submit to "mux". UnaryRPC :call SubmitServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSubmitHandlerFromEndpoint instead.
func RegisterSubmitServer ¶
func RegisterSubmitServer(s *grpc.Server, srv SubmitServer)
func SchedulingOrderCompare ¶ added in v0.4.0
SchedulingOrderCompare defines the order in which jobs in a queue should be scheduled (both when scheduling new jobs and when re-scheduling evicted jobs). Specifically, compare returns
- 0 if the jobs have equal job id,
- -1 if job should be scheduled before other,
- +1 if other should be scheduled before other.
func SchedulingResourceRequirementsFromPodSpec ¶ added in v0.3.70
func SchedulingResourceRequirementsFromPodSpec(podSpec *v1.PodSpec) v1.ResourceRequirements
SchedulingResourceRequirementsFromPodSpec returns resource requests and limits necessary for scheduling a pod. The requests and limits are set to:
max(
sum across all containers, max over all init containers,
)
This is because containers run in parallel, whereas initContainers run serially.
func ShortStringFromEventMessages ¶
func ShortStringFromEventMessages(msgs []*EventMessage) string
func SwaggerJsonTemplate ¶
func SwaggerJsonTemplate() string
SwaggerJsonTemplate is a generated function returning the template as a string. That string should be parsed by the functions of the golang's template package.
Types ¶
type BatchQueueCreateResponse ¶
type BatchQueueCreateResponse struct {
FailedQueues []*QueueCreateResponse `protobuf:"bytes,1,rep,name=failed_queues,json=failedQueues,proto3" json:"failedQueues,omitempty"`
}
func (*BatchQueueCreateResponse) Descriptor ¶
func (*BatchQueueCreateResponse) Descriptor() ([]byte, []int)
func (*BatchQueueCreateResponse) GetFailedQueues ¶
func (m *BatchQueueCreateResponse) GetFailedQueues() []*QueueCreateResponse
func (*BatchQueueCreateResponse) Marshal ¶
func (m *BatchQueueCreateResponse) Marshal() (dAtA []byte, err error)
func (*BatchQueueCreateResponse) MarshalTo ¶
func (m *BatchQueueCreateResponse) MarshalTo(dAtA []byte) (int, error)
func (*BatchQueueCreateResponse) MarshalToSizedBuffer ¶
func (m *BatchQueueCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BatchQueueCreateResponse) ProtoMessage ¶
func (*BatchQueueCreateResponse) ProtoMessage()
func (*BatchQueueCreateResponse) Reset ¶
func (m *BatchQueueCreateResponse) Reset()
func (*BatchQueueCreateResponse) Size ¶
func (m *BatchQueueCreateResponse) Size() (n int)
func (*BatchQueueCreateResponse) String ¶
func (this *BatchQueueCreateResponse) String() string
func (*BatchQueueCreateResponse) Unmarshal ¶
func (m *BatchQueueCreateResponse) Unmarshal(dAtA []byte) error
func (*BatchQueueCreateResponse) XXX_DiscardUnknown ¶
func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()
func (*BatchQueueCreateResponse) XXX_Marshal ¶
func (m *BatchQueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchQueueCreateResponse) XXX_Merge ¶
func (m *BatchQueueCreateResponse) XXX_Merge(src proto.Message)
func (*BatchQueueCreateResponse) XXX_Size ¶
func (m *BatchQueueCreateResponse) XXX_Size() int
func (*BatchQueueCreateResponse) XXX_Unmarshal ¶
func (m *BatchQueueCreateResponse) XXX_Unmarshal(b []byte) error
type BatchQueueUpdateResponse ¶
type BatchQueueUpdateResponse struct {
FailedQueues []*QueueUpdateResponse `protobuf:"bytes,1,rep,name=failed_queues,json=failedQueues,proto3" json:"failedQueues,omitempty"`
}
func (*BatchQueueUpdateResponse) Descriptor ¶
func (*BatchQueueUpdateResponse) Descriptor() ([]byte, []int)
func (*BatchQueueUpdateResponse) GetFailedQueues ¶
func (m *BatchQueueUpdateResponse) GetFailedQueues() []*QueueUpdateResponse
func (*BatchQueueUpdateResponse) Marshal ¶
func (m *BatchQueueUpdateResponse) Marshal() (dAtA []byte, err error)
func (*BatchQueueUpdateResponse) MarshalTo ¶
func (m *BatchQueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)
func (*BatchQueueUpdateResponse) MarshalToSizedBuffer ¶
func (m *BatchQueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BatchQueueUpdateResponse) ProtoMessage ¶
func (*BatchQueueUpdateResponse) ProtoMessage()
func (*BatchQueueUpdateResponse) Reset ¶
func (m *BatchQueueUpdateResponse) Reset()
func (*BatchQueueUpdateResponse) Size ¶
func (m *BatchQueueUpdateResponse) Size() (n int)
func (*BatchQueueUpdateResponse) String ¶
func (this *BatchQueueUpdateResponse) String() string
func (*BatchQueueUpdateResponse) Unmarshal ¶
func (m *BatchQueueUpdateResponse) Unmarshal(dAtA []byte) error
func (*BatchQueueUpdateResponse) XXX_DiscardUnknown ¶
func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()
func (*BatchQueueUpdateResponse) XXX_Marshal ¶
func (m *BatchQueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchQueueUpdateResponse) XXX_Merge ¶
func (m *BatchQueueUpdateResponse) XXX_Merge(src proto.Message)
func (*BatchQueueUpdateResponse) XXX_Size ¶
func (m *BatchQueueUpdateResponse) XXX_Size() int
func (*BatchQueueUpdateResponse) XXX_Unmarshal ¶
func (m *BatchQueueUpdateResponse) XXX_Unmarshal(b []byte) error
type CancellationResult ¶
type CancellationResult struct {
CancelledIds []string `protobuf:"bytes,1,rep,name=cancelled_ids,json=cancelledIds,proto3" json:"cancelledIds,omitempty"`
}
swagger:model
func (*CancellationResult) Descriptor ¶
func (*CancellationResult) Descriptor() ([]byte, []int)
func (*CancellationResult) GetCancelledIds ¶
func (m *CancellationResult) GetCancelledIds() []string
func (*CancellationResult) Marshal ¶
func (m *CancellationResult) Marshal() (dAtA []byte, err error)
func (*CancellationResult) MarshalTo ¶
func (m *CancellationResult) MarshalTo(dAtA []byte) (int, error)
func (*CancellationResult) MarshalToSizedBuffer ¶
func (m *CancellationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CancellationResult) ProtoMessage ¶
func (*CancellationResult) ProtoMessage()
func (*CancellationResult) Reset ¶
func (m *CancellationResult) Reset()
func (*CancellationResult) Size ¶
func (m *CancellationResult) Size() (n int)
func (*CancellationResult) String ¶
func (this *CancellationResult) String() string
func (*CancellationResult) Unmarshal ¶
func (m *CancellationResult) Unmarshal(dAtA []byte) error
func (*CancellationResult) XXX_DiscardUnknown ¶
func (m *CancellationResult) XXX_DiscardUnknown()
func (*CancellationResult) XXX_Marshal ¶
func (m *CancellationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancellationResult) XXX_Merge ¶
func (m *CancellationResult) XXX_Merge(src proto.Message)
func (*CancellationResult) XXX_Size ¶
func (m *CancellationResult) XXX_Size() int
func (*CancellationResult) XXX_Unmarshal ¶
func (m *CancellationResult) XXX_Unmarshal(b []byte) error
type ContainerStatus ¶
type ContainerStatus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ExitCode int32 `protobuf:"varint,2,opt,name=exitCode,proto3" json:"exitCode,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"` Cause Cause `protobuf:"varint,5,opt,name=cause,proto3,enum=api.Cause" json:"cause,omitempty"` }
func (*ContainerStatus) Descriptor ¶
func (*ContainerStatus) Descriptor() ([]byte, []int)
func (*ContainerStatus) GetCause ¶
func (m *ContainerStatus) GetCause() Cause
func (*ContainerStatus) GetExitCode ¶
func (m *ContainerStatus) GetExitCode() int32
func (*ContainerStatus) GetMessage ¶
func (m *ContainerStatus) GetMessage() string
func (*ContainerStatus) GetName ¶
func (m *ContainerStatus) GetName() string
func (*ContainerStatus) GetReason ¶
func (m *ContainerStatus) GetReason() string
func (*ContainerStatus) Marshal ¶
func (m *ContainerStatus) Marshal() (dAtA []byte, err error)
func (*ContainerStatus) MarshalToSizedBuffer ¶
func (m *ContainerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContainerStatus) ProtoMessage ¶
func (*ContainerStatus) ProtoMessage()
func (*ContainerStatus) Reset ¶
func (m *ContainerStatus) Reset()
func (*ContainerStatus) Size ¶
func (m *ContainerStatus) Size() (n int)
func (*ContainerStatus) String ¶
func (this *ContainerStatus) String() string
func (*ContainerStatus) Unmarshal ¶
func (m *ContainerStatus) Unmarshal(dAtA []byte) error
func (*ContainerStatus) XXX_DiscardUnknown ¶
func (m *ContainerStatus) XXX_DiscardUnknown()
func (*ContainerStatus) XXX_Marshal ¶
func (m *ContainerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContainerStatus) XXX_Merge ¶
func (m *ContainerStatus) XXX_Merge(src proto.Message)
func (*ContainerStatus) XXX_Size ¶
func (m *ContainerStatus) XXX_Size() int
func (*ContainerStatus) XXX_Unmarshal ¶
func (m *ContainerStatus) XXX_Unmarshal(b []byte) error
type CustomSubmitClient ¶ added in v0.4.8
type CustomSubmitClient struct {
Inner SubmitClient
}
func (*CustomSubmitClient) SubmitJobs ¶ added in v0.4.8
func (c *CustomSubmitClient) SubmitJobs(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)
type EndMarker ¶ added in v0.3.100
type EndMarker struct { }
Indicates the end of streams
func (*EndMarker) Descriptor ¶ added in v0.3.100
func (*EndMarker) MarshalToSizedBuffer ¶ added in v0.3.100
func (*EndMarker) ProtoMessage ¶ added in v0.3.100
func (*EndMarker) ProtoMessage()
func (*EndMarker) XXX_DiscardUnknown ¶ added in v0.3.100
func (m *EndMarker) XXX_DiscardUnknown()
func (*EndMarker) XXX_Marshal ¶ added in v0.3.100
func (*EndMarker) XXX_Unmarshal ¶ added in v0.3.100
type Event ¶
type Event interface { GetJobId() string GetJobSetId() string GetQueue() string GetCreated() time.Time }
func UnwrapEvent ¶
func UnwrapEvent(message *EventMessage) (Event, error)
type EventClient ¶
type EventClient interface { GetJobSetEvents(ctx context.Context, in *JobSetRequest, opts ...grpc.CallOption) (Event_GetJobSetEventsClient, error) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Event_WatchClient, error) Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error) }
EventClient is the client API for Event service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEventClient ¶
func NewEventClient(cc *grpc.ClientConn) EventClient
type EventMessage ¶
type EventMessage struct { // Types that are valid to be assigned to Events: // *EventMessage_Submitted // *EventMessage_Queued // *EventMessage_DuplicateFound // *EventMessage_Leased // *EventMessage_LeaseReturned // *EventMessage_LeaseExpired // *EventMessage_Pending // *EventMessage_Running // *EventMessage_UnableToSchedule // *EventMessage_Failed // *EventMessage_Succeeded // *EventMessage_Reprioritized // *EventMessage_Cancelling // *EventMessage_Cancelled // *EventMessage_Terminated // *EventMessage_Utilisation // *EventMessage_IngressInfo // *EventMessage_Reprioritizing // *EventMessage_Updated // *EventMessage_FailedCompressed // *EventMessage_Preempted Events isEventMessage_Events `protobuf_oneof:"events"` }
func Wrap ¶
func Wrap(event Event) (*EventMessage, error)
func (*EventMessage) Descriptor ¶
func (*EventMessage) Descriptor() ([]byte, []int)
func (*EventMessage) GetCancelled ¶
func (m *EventMessage) GetCancelled() *JobCancelledEvent
func (*EventMessage) GetCancelling ¶
func (m *EventMessage) GetCancelling() *JobCancellingEvent
func (*EventMessage) GetDuplicateFound ¶
func (m *EventMessage) GetDuplicateFound() *JobDuplicateFoundEvent
func (*EventMessage) GetEvents ¶
func (m *EventMessage) GetEvents() isEventMessage_Events
func (*EventMessage) GetFailed ¶
func (m *EventMessage) GetFailed() *JobFailedEvent
func (*EventMessage) GetFailedCompressed ¶
func (m *EventMessage) GetFailedCompressed() *JobFailedEventCompressed
func (*EventMessage) GetIngressInfo ¶
func (m *EventMessage) GetIngressInfo() *JobIngressInfoEvent
func (*EventMessage) GetLeaseExpired ¶
func (m *EventMessage) GetLeaseExpired() *JobLeaseExpiredEvent
func (*EventMessage) GetLeaseReturned ¶
func (m *EventMessage) GetLeaseReturned() *JobLeaseReturnedEvent
func (*EventMessage) GetLeased ¶
func (m *EventMessage) GetLeased() *JobLeasedEvent
func (*EventMessage) GetPending ¶
func (m *EventMessage) GetPending() *JobPendingEvent
func (*EventMessage) GetPreempted ¶
func (m *EventMessage) GetPreempted() *JobPreemptedEvent
func (*EventMessage) GetQueued ¶
func (m *EventMessage) GetQueued() *JobQueuedEvent
func (*EventMessage) GetReprioritized ¶
func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent
func (*EventMessage) GetReprioritizing ¶
func (m *EventMessage) GetReprioritizing() *JobReprioritizingEvent
func (*EventMessage) GetRunning ¶
func (m *EventMessage) GetRunning() *JobRunningEvent
func (*EventMessage) GetSubmitted ¶
func (m *EventMessage) GetSubmitted() *JobSubmittedEvent
func (*EventMessage) GetSucceeded ¶
func (m *EventMessage) GetSucceeded() *JobSucceededEvent
func (*EventMessage) GetTerminated ¶
func (m *EventMessage) GetTerminated() *JobTerminatedEvent
func (*EventMessage) GetUnableToSchedule ¶
func (m *EventMessage) GetUnableToSchedule() *JobUnableToScheduleEvent
func (*EventMessage) GetUpdated ¶
func (m *EventMessage) GetUpdated() *JobUpdatedEvent
func (*EventMessage) GetUtilisation ¶
func (m *EventMessage) GetUtilisation() *JobUtilisationEvent
func (*EventMessage) Marshal ¶
func (m *EventMessage) Marshal() (dAtA []byte, err error)
func (*EventMessage) MarshalJSON ¶
func (message *EventMessage) MarshalJSON() ([]byte, error)
customise oneof serialisation
func (*EventMessage) MarshalToSizedBuffer ¶
func (m *EventMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage) ProtoMessage ¶
func (*EventMessage) ProtoMessage()
func (*EventMessage) Reset ¶
func (m *EventMessage) Reset()
func (*EventMessage) ShortString ¶
func (msg *EventMessage) ShortString() string
func (*EventMessage) Size ¶
func (m *EventMessage) Size() (n int)
func (*EventMessage) String ¶
func (this *EventMessage) String() string
func (*EventMessage) Unmarshal ¶
func (m *EventMessage) Unmarshal(dAtA []byte) error
func (*EventMessage) UnmarshalJSON ¶
func (message *EventMessage) UnmarshalJSON(data []byte) error
func (*EventMessage) XXX_DiscardUnknown ¶
func (m *EventMessage) XXX_DiscardUnknown()
func (*EventMessage) XXX_Marshal ¶
func (m *EventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventMessage) XXX_Merge ¶
func (m *EventMessage) XXX_Merge(src proto.Message)
func (*EventMessage) XXX_OneofWrappers ¶
func (*EventMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*EventMessage) XXX_Size ¶
func (m *EventMessage) XXX_Size() int
func (*EventMessage) XXX_Unmarshal ¶
func (m *EventMessage) XXX_Unmarshal(b []byte) error
type EventMessage_Cancelled ¶
type EventMessage_Cancelled struct {
Cancelled *JobCancelledEvent `protobuf:"bytes,13,opt,name=cancelled,proto3,oneof" json:"cancelled,omitempty"`
}
func (*EventMessage_Cancelled) MarshalTo ¶
func (m *EventMessage_Cancelled) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Cancelled) MarshalToSizedBuffer ¶
func (m *EventMessage_Cancelled) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Cancelled) Size ¶
func (m *EventMessage_Cancelled) Size() (n int)
func (*EventMessage_Cancelled) String ¶
func (this *EventMessage_Cancelled) String() string
type EventMessage_Cancelling ¶
type EventMessage_Cancelling struct {
Cancelling *JobCancellingEvent `protobuf:"bytes,12,opt,name=cancelling,proto3,oneof" json:"cancelling,omitempty"`
}
func (*EventMessage_Cancelling) MarshalTo ¶
func (m *EventMessage_Cancelling) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Cancelling) MarshalToSizedBuffer ¶
func (m *EventMessage_Cancelling) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Cancelling) Size ¶
func (m *EventMessage_Cancelling) Size() (n int)
func (*EventMessage_Cancelling) String ¶
func (this *EventMessage_Cancelling) String() string
type EventMessage_DuplicateFound ¶
type EventMessage_DuplicateFound struct {
DuplicateFound *JobDuplicateFoundEvent `protobuf:"bytes,16,opt,name=duplicate_found,json=duplicateFound,proto3,oneof" json:"duplicateFound,omitempty"`
}
func (*EventMessage_DuplicateFound) MarshalTo ¶
func (m *EventMessage_DuplicateFound) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_DuplicateFound) MarshalToSizedBuffer ¶
func (m *EventMessage_DuplicateFound) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_DuplicateFound) Size ¶
func (m *EventMessage_DuplicateFound) Size() (n int)
func (*EventMessage_DuplicateFound) String ¶
func (this *EventMessage_DuplicateFound) String() string
type EventMessage_Failed ¶
type EventMessage_Failed struct {
Failed *JobFailedEvent `protobuf:"bytes,9,opt,name=failed,proto3,oneof" json:"failed,omitempty"`
}
func (*EventMessage_Failed) MarshalTo ¶
func (m *EventMessage_Failed) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Failed) MarshalToSizedBuffer ¶
func (m *EventMessage_Failed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Failed) Size ¶
func (m *EventMessage_Failed) Size() (n int)
func (*EventMessage_Failed) String ¶
func (this *EventMessage_Failed) String() string
type EventMessage_FailedCompressed ¶
type EventMessage_FailedCompressed struct {
FailedCompressed *JobFailedEventCompressed `protobuf:"bytes,20,opt,name=failedCompressed,proto3,oneof" json:"failedCompressed,omitempty"`
}
func (*EventMessage_FailedCompressed) MarshalTo ¶
func (m *EventMessage_FailedCompressed) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_FailedCompressed) MarshalToSizedBuffer ¶
func (m *EventMessage_FailedCompressed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_FailedCompressed) Size ¶
func (m *EventMessage_FailedCompressed) Size() (n int)
func (*EventMessage_FailedCompressed) String ¶
func (this *EventMessage_FailedCompressed) String() string
type EventMessage_IngressInfo ¶
type EventMessage_IngressInfo struct {
IngressInfo *JobIngressInfoEvent `protobuf:"bytes,17,opt,name=ingress_info,json=ingressInfo,proto3,oneof" json:"ingressInfo,omitempty"`
}
func (*EventMessage_IngressInfo) MarshalTo ¶
func (m *EventMessage_IngressInfo) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_IngressInfo) MarshalToSizedBuffer ¶
func (m *EventMessage_IngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_IngressInfo) Size ¶
func (m *EventMessage_IngressInfo) Size() (n int)
func (*EventMessage_IngressInfo) String ¶
func (this *EventMessage_IngressInfo) String() string
type EventMessage_LeaseExpired ¶
type EventMessage_LeaseExpired struct {
LeaseExpired *JobLeaseExpiredEvent `protobuf:"bytes,5,opt,name=lease_expired,json=leaseExpired,proto3,oneof" json:"leaseExpired,omitempty"`
}
func (*EventMessage_LeaseExpired) MarshalTo ¶
func (m *EventMessage_LeaseExpired) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_LeaseExpired) MarshalToSizedBuffer ¶
func (m *EventMessage_LeaseExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_LeaseExpired) Size ¶
func (m *EventMessage_LeaseExpired) Size() (n int)
func (*EventMessage_LeaseExpired) String ¶
func (this *EventMessage_LeaseExpired) String() string
type EventMessage_LeaseReturned ¶
type EventMessage_LeaseReturned struct {
LeaseReturned *JobLeaseReturnedEvent `protobuf:"bytes,4,opt,name=lease_returned,json=leaseReturned,proto3,oneof" json:"leaseReturned,omitempty"`
}
func (*EventMessage_LeaseReturned) MarshalTo ¶
func (m *EventMessage_LeaseReturned) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_LeaseReturned) MarshalToSizedBuffer ¶
func (m *EventMessage_LeaseReturned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_LeaseReturned) Size ¶
func (m *EventMessage_LeaseReturned) Size() (n int)
func (*EventMessage_LeaseReturned) String ¶
func (this *EventMessage_LeaseReturned) String() string
type EventMessage_Leased ¶
type EventMessage_Leased struct {
Leased *JobLeasedEvent `protobuf:"bytes,3,opt,name=leased,proto3,oneof" json:"leased,omitempty"`
}
func (*EventMessage_Leased) MarshalTo ¶
func (m *EventMessage_Leased) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Leased) MarshalToSizedBuffer ¶
func (m *EventMessage_Leased) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Leased) Size ¶
func (m *EventMessage_Leased) Size() (n int)
func (*EventMessage_Leased) String ¶
func (this *EventMessage_Leased) String() string
type EventMessage_Pending ¶
type EventMessage_Pending struct {
Pending *JobPendingEvent `protobuf:"bytes,6,opt,name=pending,proto3,oneof" json:"pending,omitempty"`
}
func (*EventMessage_Pending) MarshalTo ¶
func (m *EventMessage_Pending) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Pending) MarshalToSizedBuffer ¶
func (m *EventMessage_Pending) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Pending) Size ¶
func (m *EventMessage_Pending) Size() (n int)
func (*EventMessage_Pending) String ¶
func (this *EventMessage_Pending) String() string
type EventMessage_Preempted ¶
type EventMessage_Preempted struct {
Preempted *JobPreemptedEvent `protobuf:"bytes,21,opt,name=preempted,proto3,oneof" json:"preempted,omitempty"`
}
func (*EventMessage_Preempted) MarshalTo ¶
func (m *EventMessage_Preempted) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Preempted) MarshalToSizedBuffer ¶
func (m *EventMessage_Preempted) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Preempted) Size ¶
func (m *EventMessage_Preempted) Size() (n int)
func (*EventMessage_Preempted) String ¶
func (this *EventMessage_Preempted) String() string
type EventMessage_Queued ¶
type EventMessage_Queued struct {
Queued *JobQueuedEvent `protobuf:"bytes,2,opt,name=queued,proto3,oneof" json:"queued,omitempty"`
}
func (*EventMessage_Queued) MarshalTo ¶
func (m *EventMessage_Queued) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Queued) MarshalToSizedBuffer ¶
func (m *EventMessage_Queued) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Queued) Size ¶
func (m *EventMessage_Queued) Size() (n int)
func (*EventMessage_Queued) String ¶
func (this *EventMessage_Queued) String() string
type EventMessage_Reprioritized ¶
type EventMessage_Reprioritized struct {
Reprioritized *JobReprioritizedEvent `protobuf:"bytes,11,opt,name=reprioritized,proto3,oneof" json:"reprioritized,omitempty"`
}
func (*EventMessage_Reprioritized) MarshalTo ¶
func (m *EventMessage_Reprioritized) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Reprioritized) MarshalToSizedBuffer ¶
func (m *EventMessage_Reprioritized) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Reprioritized) Size ¶
func (m *EventMessage_Reprioritized) Size() (n int)
func (*EventMessage_Reprioritized) String ¶
func (this *EventMessage_Reprioritized) String() string
type EventMessage_Reprioritizing ¶
type EventMessage_Reprioritizing struct {
Reprioritizing *JobReprioritizingEvent `protobuf:"bytes,18,opt,name=reprioritizing,proto3,oneof" json:"reprioritizing,omitempty"`
}
func (*EventMessage_Reprioritizing) MarshalTo ¶
func (m *EventMessage_Reprioritizing) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Reprioritizing) MarshalToSizedBuffer ¶
func (m *EventMessage_Reprioritizing) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Reprioritizing) Size ¶
func (m *EventMessage_Reprioritizing) Size() (n int)
func (*EventMessage_Reprioritizing) String ¶
func (this *EventMessage_Reprioritizing) String() string
type EventMessage_Running ¶
type EventMessage_Running struct {
Running *JobRunningEvent `protobuf:"bytes,7,opt,name=running,proto3,oneof" json:"running,omitempty"`
}
func (*EventMessage_Running) MarshalTo ¶
func (m *EventMessage_Running) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Running) MarshalToSizedBuffer ¶
func (m *EventMessage_Running) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Running) Size ¶
func (m *EventMessage_Running) Size() (n int)
func (*EventMessage_Running) String ¶
func (this *EventMessage_Running) String() string
type EventMessage_Submitted ¶
type EventMessage_Submitted struct {
Submitted *JobSubmittedEvent `protobuf:"bytes,1,opt,name=submitted,proto3,oneof" json:"submitted,omitempty"`
}
func (*EventMessage_Submitted) MarshalTo ¶
func (m *EventMessage_Submitted) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Submitted) MarshalToSizedBuffer ¶
func (m *EventMessage_Submitted) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Submitted) Size ¶
func (m *EventMessage_Submitted) Size() (n int)
func (*EventMessage_Submitted) String ¶
func (this *EventMessage_Submitted) String() string
type EventMessage_Succeeded ¶
type EventMessage_Succeeded struct {
Succeeded *JobSucceededEvent `protobuf:"bytes,10,opt,name=succeeded,proto3,oneof" json:"succeeded,omitempty"`
}
func (*EventMessage_Succeeded) MarshalTo ¶
func (m *EventMessage_Succeeded) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Succeeded) MarshalToSizedBuffer ¶
func (m *EventMessage_Succeeded) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Succeeded) Size ¶
func (m *EventMessage_Succeeded) Size() (n int)
func (*EventMessage_Succeeded) String ¶
func (this *EventMessage_Succeeded) String() string
type EventMessage_Terminated ¶
type EventMessage_Terminated struct {
Terminated *JobTerminatedEvent `protobuf:"bytes,14,opt,name=terminated,proto3,oneof" json:"terminated,omitempty"`
}
func (*EventMessage_Terminated) MarshalTo ¶
func (m *EventMessage_Terminated) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Terminated) MarshalToSizedBuffer ¶
func (m *EventMessage_Terminated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Terminated) Size ¶
func (m *EventMessage_Terminated) Size() (n int)
func (*EventMessage_Terminated) String ¶
func (this *EventMessage_Terminated) String() string
type EventMessage_UnableToSchedule ¶
type EventMessage_UnableToSchedule struct {
UnableToSchedule *JobUnableToScheduleEvent `protobuf:"bytes,8,opt,name=unable_to_schedule,json=unableToSchedule,proto3,oneof" json:"unableToSchedule,omitempty"`
}
func (*EventMessage_UnableToSchedule) MarshalTo ¶
func (m *EventMessage_UnableToSchedule) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_UnableToSchedule) MarshalToSizedBuffer ¶
func (m *EventMessage_UnableToSchedule) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_UnableToSchedule) Size ¶
func (m *EventMessage_UnableToSchedule) Size() (n int)
func (*EventMessage_UnableToSchedule) String ¶
func (this *EventMessage_UnableToSchedule) String() string
type EventMessage_Updated ¶
type EventMessage_Updated struct {
Updated *JobUpdatedEvent `protobuf:"bytes,19,opt,name=updated,proto3,oneof" json:"updated,omitempty"`
}
func (*EventMessage_Updated) MarshalTo ¶
func (m *EventMessage_Updated) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Updated) MarshalToSizedBuffer ¶
func (m *EventMessage_Updated) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Updated) Size ¶
func (m *EventMessage_Updated) Size() (n int)
func (*EventMessage_Updated) String ¶
func (this *EventMessage_Updated) String() string
type EventMessage_Utilisation ¶
type EventMessage_Utilisation struct {
Utilisation *JobUtilisationEvent `protobuf:"bytes,15,opt,name=utilisation,proto3,oneof" json:"utilisation,omitempty"`
}
func (*EventMessage_Utilisation) MarshalTo ¶
func (m *EventMessage_Utilisation) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Utilisation) MarshalToSizedBuffer ¶
func (m *EventMessage_Utilisation) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Utilisation) Size ¶
func (m *EventMessage_Utilisation) Size() (n int)
func (*EventMessage_Utilisation) String ¶
func (this *EventMessage_Utilisation) String() string
type EventServer ¶
type EventServer interface { GetJobSetEvents(*JobSetRequest, Event_GetJobSetEventsServer) error Watch(*WatchRequest, Event_WatchServer) error Health(context.Context, *types.Empty) (*HealthCheckResponse, error) }
EventServer is the server API for Event service.
type EventStreamMessage ¶
type EventStreamMessage struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Message *EventMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` }
swagger:model
func (*EventStreamMessage) Descriptor ¶
func (*EventStreamMessage) Descriptor() ([]byte, []int)
func (*EventStreamMessage) GetId ¶
func (m *EventStreamMessage) GetId() string
func (*EventStreamMessage) GetMessage ¶
func (m *EventStreamMessage) GetMessage() *EventMessage
func (*EventStreamMessage) Marshal ¶
func (m *EventStreamMessage) Marshal() (dAtA []byte, err error)
func (*EventStreamMessage) MarshalTo ¶
func (m *EventStreamMessage) MarshalTo(dAtA []byte) (int, error)
func (*EventStreamMessage) MarshalToSizedBuffer ¶
func (m *EventStreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventStreamMessage) ProtoMessage ¶
func (*EventStreamMessage) ProtoMessage()
func (*EventStreamMessage) Reset ¶
func (m *EventStreamMessage) Reset()
func (*EventStreamMessage) Size ¶
func (m *EventStreamMessage) Size() (n int)
func (*EventStreamMessage) String ¶
func (this *EventStreamMessage) String() string
func (*EventStreamMessage) Unmarshal ¶
func (m *EventStreamMessage) Unmarshal(dAtA []byte) error
func (*EventStreamMessage) XXX_DiscardUnknown ¶
func (m *EventStreamMessage) XXX_DiscardUnknown()
func (*EventStreamMessage) XXX_Marshal ¶
func (m *EventStreamMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventStreamMessage) XXX_Merge ¶
func (m *EventStreamMessage) XXX_Merge(src proto.Message)
func (*EventStreamMessage) XXX_Size ¶
func (m *EventStreamMessage) XXX_Size() int
func (*EventStreamMessage) XXX_Unmarshal ¶
func (m *EventStreamMessage) XXX_Unmarshal(b []byte) error
type Event_GetJobSetEventsClient ¶
type Event_GetJobSetEventsClient interface { Recv() (*EventStreamMessage, error) grpc.ClientStream }
type Event_GetJobSetEventsServer ¶
type Event_GetJobSetEventsServer interface { Send(*EventStreamMessage) error grpc.ServerStream }
type Event_WatchClient ¶
type Event_WatchClient interface { Recv() (*EventStreamMessage, error) grpc.ClientStream }
type Event_WatchServer ¶
type Event_WatchServer interface { Send(*EventStreamMessage) error grpc.ServerStream }
type HealthCheckResponse ¶
type HealthCheckResponse struct {
Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=api.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
}
func (*HealthCheckResponse) Descriptor ¶
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
func (*HealthCheckResponse) GetStatus ¶
func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
func (*HealthCheckResponse) Marshal ¶
func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error)
func (*HealthCheckResponse) MarshalTo ¶
func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error)
func (*HealthCheckResponse) MarshalToSizedBuffer ¶
func (m *HealthCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) Reset ¶
func (m *HealthCheckResponse) Reset()
func (*HealthCheckResponse) Size ¶
func (m *HealthCheckResponse) Size() (n int)
func (*HealthCheckResponse) String ¶
func (m *HealthCheckResponse) String() string
func (*HealthCheckResponse) Unmarshal ¶
func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error
func (*HealthCheckResponse) XXX_DiscardUnknown ¶
func (m *HealthCheckResponse) XXX_DiscardUnknown()
func (*HealthCheckResponse) XXX_Marshal ¶
func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthCheckResponse) XXX_Merge ¶
func (m *HealthCheckResponse) XXX_Merge(src proto.Message)
func (*HealthCheckResponse) XXX_Size ¶
func (m *HealthCheckResponse) XXX_Size() int
func (*HealthCheckResponse) XXX_Unmarshal ¶
func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error
type HealthCheckResponse_ServingStatus ¶
type HealthCheckResponse_ServingStatus int32
const ( HealthCheckResponse_UNKNOWN HealthCheckResponse_ServingStatus = 0 HealthCheckResponse_SERVING HealthCheckResponse_ServingStatus = 1 HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2 )
func (HealthCheckResponse_ServingStatus) EnumDescriptor ¶
func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)
func (HealthCheckResponse_ServingStatus) String ¶
func (x HealthCheckResponse_ServingStatus) String() string
type IngressConfig ¶
type IngressConfig struct { Type IngressType `protobuf:"varint,1,opt,name=type,proto3,enum=api.IngressType" json:"type,omitempty"` // Deprecated: Do not use. Ports []uint32 `protobuf:"varint,2,rep,packed,name=ports,proto3" json:"ports,omitempty"` Annotations map[string]string `` /* 163-byte string literal not displayed */ TlsEnabled bool `protobuf:"varint,4,opt,name=tls_enabled,json=tlsEnabled,proto3" json:"tlsEnabled,omitempty"` CertName string `protobuf:"bytes,5,opt,name=cert_name,json=certName,proto3" json:"certName,omitempty"` UseClusterIP bool `protobuf:"varint,6,opt,name=use_clusterIP,json=useClusterIP,proto3" json:"useClusterIP,omitempty"` }
func (*IngressConfig) Descriptor ¶
func (*IngressConfig) Descriptor() ([]byte, []int)
func (*IngressConfig) GetAnnotations ¶
func (m *IngressConfig) GetAnnotations() map[string]string
func (*IngressConfig) GetCertName ¶
func (m *IngressConfig) GetCertName() string
func (*IngressConfig) GetPorts ¶
func (m *IngressConfig) GetPorts() []uint32
func (*IngressConfig) GetTlsEnabled ¶
func (m *IngressConfig) GetTlsEnabled() bool
func (*IngressConfig) GetType
deprecated
func (m *IngressConfig) GetType() IngressType
Deprecated: Do not use.
func (*IngressConfig) GetUseClusterIP ¶
func (m *IngressConfig) GetUseClusterIP() bool
func (*IngressConfig) Marshal ¶
func (m *IngressConfig) Marshal() (dAtA []byte, err error)
func (*IngressConfig) MarshalToSizedBuffer ¶
func (m *IngressConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IngressConfig) ProtoMessage ¶
func (*IngressConfig) ProtoMessage()
func (*IngressConfig) Reset ¶
func (m *IngressConfig) Reset()
func (*IngressConfig) Size ¶
func (m *IngressConfig) Size() (n int)
func (*IngressConfig) String ¶
func (this *IngressConfig) String() string
func (*IngressConfig) Unmarshal ¶
func (m *IngressConfig) Unmarshal(dAtA []byte) error
func (*IngressConfig) XXX_DiscardUnknown ¶
func (m *IngressConfig) XXX_DiscardUnknown()
func (*IngressConfig) XXX_Marshal ¶
func (m *IngressConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IngressConfig) XXX_Merge ¶
func (m *IngressConfig) XXX_Merge(src proto.Message)
func (*IngressConfig) XXX_Size ¶
func (m *IngressConfig) XXX_Size() int
func (*IngressConfig) XXX_Unmarshal ¶
func (m *IngressConfig) XXX_Unmarshal(b []byte) error
type IngressType ¶
type IngressType int32
Ingress type is being kept here to maintain backwards compatibility for a while.
const (
IngressType_Ingress IngressType = 0
)
func (IngressType) EnumDescriptor ¶
func (IngressType) EnumDescriptor() ([]byte, []int)
func (IngressType) String ¶
func (x IngressType) String() string
func (*IngressType) UnmarshalJSON ¶
func (x *IngressType) UnmarshalJSON(data []byte) error
type Job ¶
type Job struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ClientId string `protobuf:"bytes,13,opt,name=client_id,json=clientId,proto3" json:"clientId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 164-byte string literal not displayed */ RequiredNodeLabels map[string]string `` // Deprecated: Do not use. /* 204-byte string literal not displayed */ Owner string `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"` QueueOwnershipUserGroups []string `` /* 135-byte string literal not displayed */ CompressedQueueOwnershipUserGroups []byte `` /* 166-byte string literal not displayed */ Priority float64 `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"` PodSpec *v1.PodSpec `protobuf:"bytes,5,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"` // Deprecated: Do not use. PodSpecs []*v1.PodSpec `protobuf:"bytes,12,rep,name=pod_specs,json=podSpecs,proto3" json:"podSpecs,omitempty"` // Resource requests and limits necessary for scheduling the main pod of this job. // The requests and limits herein are set to: // // max( // // sum across all containers, // max over all init containers, // // ) // // This is because containers run in parallel, whereas initContainers run serially. // This field is populated automatically at submission. // Submitting a job with this field already populated results in an error. SchedulingResourceRequirements v1.ResourceRequirements `` /* 142-byte string literal not displayed */ Created time.Time `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"` // Services can be provided either as Armada-specific config objects or as proper k8s objects. // These options are exclusive, i.e., if either ingress or services is provided, // then neither of k8s_ingress or k8s_service can be provided, and vice versa. Ingress []*IngressConfig `protobuf:"bytes,14,rep,name=ingress,proto3" json:"ingress,omitempty"` Services []*ServiceConfig `protobuf:"bytes,16,rep,name=services,proto3" json:"services,omitempty"` K8SIngress []*v11.Ingress `protobuf:"bytes,17,rep,name=k8s_ingress,json=k8sIngress,proto3" json:"k8sIngress,omitempty"` K8SService []*v1.Service `protobuf:"bytes,18,rep,name=k8s_service,json=k8sService,proto3" json:"k8sService,omitempty"` // Indicates which scheduler should manage this job. // If empty, the default scheduler is used. Scheduler string `protobuf:"bytes,20,opt,name=scheduler,proto3" json:"scheduler,omitempty"` // Queuing TTL for this job in seconds. If this job queues for more than this duration it will be cancelled. Zero indicates an infinite lifetime. QueueTtlSeconds int64 `protobuf:"varint,22,opt,name=queue_ttl_seconds,json=queueTtlSeconds,proto3" json:"queueTtlSeconds,omitempty"` }
func (*Job) Descriptor ¶
func (*Job) GetAffinity ¶ added in v0.3.71
func (*Job) GetAnnotations ¶
func (*Job) GetClientId ¶
func (*Job) GetCompressedQueueOwnershipUserGroups ¶
func (*Job) GetCreated ¶
func (*Job) GetIngress ¶
func (m *Job) GetIngress() []*IngressConfig
func (*Job) GetJobSetId ¶
func (*Job) GetK8SIngress ¶
func (*Job) GetK8SService ¶
func (*Job) GetMainPodSpec ¶ added in v0.3.47
func (*Job) GetNamespace ¶
func (*Job) GetNodeSelector ¶ added in v0.3.71
func (*Job) GetPerQueuePriority ¶ added in v0.3.77
func (*Job) GetPodRequirements ¶ added in v0.3.78
func (job *Job) GetPodRequirements(priorityClasses map[string]types.PriorityClass) *schedulerobjects.PodRequirements
func (*Job) GetPodSpec
deprecated
func (*Job) GetPodSpecs ¶
func (*Job) GetPriority ¶
func (*Job) GetPriorityClassName ¶ added in v0.3.70
func (*Job) GetQueueOwnershipUserGroups ¶
func (*Job) GetQueueTtlSeconds ¶ added in v0.3.95
func (*Job) GetRequiredNodeLabels
deprecated
func (*Job) GetResourceRequirements ¶ added in v0.3.71
func (job *Job) GetResourceRequirements() v1.ResourceRequirements
func (*Job) GetScheduledAtPriority ¶ added in v0.4.8
func (*Job) GetScheduler ¶
func (*Job) GetSchedulingKey ¶ added in v0.3.100
func (job *Job) GetSchedulingKey() (schedulerobjects.SchedulingKey, bool)
GetSchedulingKey returns the scheduling key associated with a job. The second return value is always false since scheduling keys are not pre-computed for these jobs.
func (*Job) GetSchedulingResourceRequirements ¶ added in v0.3.70
func (m *Job) GetSchedulingResourceRequirements() v1.ResourceRequirements
func (*Job) GetServices ¶
func (m *Job) GetServices() []*ServiceConfig
func (*Job) GetSubmitTime ¶ added in v0.3.77
func (*Job) GetTolerations ¶ added in v0.3.71
func (job *Job) GetTolerations() []v1.Toleration
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) SchedulingOrderCompare ¶ added in v0.4.0
func (job *Job) SchedulingOrderCompare(other interfaces.LegacySchedulerJob) int
SchedulingOrderCompare defines the order in which jobs in a particular queue should be scheduled,
func (*Job) TotalResourceRequest ¶ added in v0.3.47
func (job *Job) TotalResourceRequest() armadaresource.ComputeResources
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type JobCancelRequest ¶
type JobCancelRequest struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` JobIds []string `protobuf:"bytes,4,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"` Reason string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"` }
swagger:model
func (*JobCancelRequest) Descriptor ¶
func (*JobCancelRequest) Descriptor() ([]byte, []int)
func (*JobCancelRequest) GetJobId ¶
func (m *JobCancelRequest) GetJobId() string
func (*JobCancelRequest) GetJobIds ¶
func (m *JobCancelRequest) GetJobIds() []string
func (*JobCancelRequest) GetJobSetId ¶
func (m *JobCancelRequest) GetJobSetId() string
func (*JobCancelRequest) GetQueue ¶
func (m *JobCancelRequest) GetQueue() string
func (*JobCancelRequest) GetReason ¶ added in v0.3.68
func (m *JobCancelRequest) GetReason() string
func (*JobCancelRequest) Marshal ¶
func (m *JobCancelRequest) Marshal() (dAtA []byte, err error)
func (*JobCancelRequest) MarshalToSizedBuffer ¶
func (m *JobCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobCancelRequest) ProtoMessage ¶
func (*JobCancelRequest) ProtoMessage()
func (*JobCancelRequest) Reset ¶
func (m *JobCancelRequest) Reset()
func (*JobCancelRequest) Size ¶
func (m *JobCancelRequest) Size() (n int)
func (*JobCancelRequest) String ¶
func (this *JobCancelRequest) String() string
func (*JobCancelRequest) Unmarshal ¶
func (m *JobCancelRequest) Unmarshal(dAtA []byte) error
func (*JobCancelRequest) XXX_DiscardUnknown ¶
func (m *JobCancelRequest) XXX_DiscardUnknown()
func (*JobCancelRequest) XXX_Marshal ¶
func (m *JobCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobCancelRequest) XXX_Merge ¶
func (m *JobCancelRequest) XXX_Merge(src proto.Message)
func (*JobCancelRequest) XXX_Size ¶
func (m *JobCancelRequest) XXX_Size() int
func (*JobCancelRequest) XXX_Unmarshal ¶
func (m *JobCancelRequest) XXX_Unmarshal(b []byte) error
type JobCancelledEvent ¶
type JobCancelledEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` Requestor string `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"` Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` }
func (*JobCancelledEvent) Descriptor ¶
func (*JobCancelledEvent) Descriptor() ([]byte, []int)
func (*JobCancelledEvent) GetCreated ¶
func (m *JobCancelledEvent) GetCreated() time.Time
func (*JobCancelledEvent) GetJobId ¶
func (m *JobCancelledEvent) GetJobId() string
func (*JobCancelledEvent) GetJobSetId ¶
func (m *JobCancelledEvent) GetJobSetId() string
func (*JobCancelledEvent) GetQueue ¶
func (m *JobCancelledEvent) GetQueue() string
func (*JobCancelledEvent) GetReason ¶ added in v0.3.68
func (m *JobCancelledEvent) GetReason() string
func (*JobCancelledEvent) GetRequestor ¶
func (m *JobCancelledEvent) GetRequestor() string
func (*JobCancelledEvent) Marshal ¶
func (m *JobCancelledEvent) Marshal() (dAtA []byte, err error)
func (*JobCancelledEvent) MarshalTo ¶
func (m *JobCancelledEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobCancelledEvent) MarshalToSizedBuffer ¶
func (m *JobCancelledEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobCancelledEvent) ProtoMessage ¶
func (*JobCancelledEvent) ProtoMessage()
func (*JobCancelledEvent) Reset ¶
func (m *JobCancelledEvent) Reset()
func (*JobCancelledEvent) Size ¶
func (m *JobCancelledEvent) Size() (n int)
func (*JobCancelledEvent) String ¶
func (this *JobCancelledEvent) String() string
func (*JobCancelledEvent) Unmarshal ¶
func (m *JobCancelledEvent) Unmarshal(dAtA []byte) error
func (*JobCancelledEvent) XXX_DiscardUnknown ¶
func (m *JobCancelledEvent) XXX_DiscardUnknown()
func (*JobCancelledEvent) XXX_Marshal ¶
func (m *JobCancelledEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobCancelledEvent) XXX_Merge ¶
func (m *JobCancelledEvent) XXX_Merge(src proto.Message)
func (*JobCancelledEvent) XXX_Size ¶
func (m *JobCancelledEvent) XXX_Size() int
func (*JobCancelledEvent) XXX_Unmarshal ¶
func (m *JobCancelledEvent) XXX_Unmarshal(b []byte) error
type JobCancellingEvent ¶
type JobCancellingEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` Requestor string `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"` Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` }
func (*JobCancellingEvent) Descriptor ¶
func (*JobCancellingEvent) Descriptor() ([]byte, []int)
func (*JobCancellingEvent) GetCreated ¶
func (m *JobCancellingEvent) GetCreated() time.Time
func (*JobCancellingEvent) GetJobId ¶
func (m *JobCancellingEvent) GetJobId() string
func (*JobCancellingEvent) GetJobSetId ¶
func (m *JobCancellingEvent) GetJobSetId() string
func (*JobCancellingEvent) GetQueue ¶
func (m *JobCancellingEvent) GetQueue() string
func (*JobCancellingEvent) GetReason ¶ added in v0.3.68
func (m *JobCancellingEvent) GetReason() string
func (*JobCancellingEvent) GetRequestor ¶
func (m *JobCancellingEvent) GetRequestor() string
func (*JobCancellingEvent) Marshal ¶
func (m *JobCancellingEvent) Marshal() (dAtA []byte, err error)
func (*JobCancellingEvent) MarshalTo ¶
func (m *JobCancellingEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobCancellingEvent) MarshalToSizedBuffer ¶
func (m *JobCancellingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobCancellingEvent) ProtoMessage ¶
func (*JobCancellingEvent) ProtoMessage()
func (*JobCancellingEvent) Reset ¶
func (m *JobCancellingEvent) Reset()
func (*JobCancellingEvent) Size ¶
func (m *JobCancellingEvent) Size() (n int)
func (*JobCancellingEvent) String ¶
func (this *JobCancellingEvent) String() string
func (*JobCancellingEvent) Unmarshal ¶
func (m *JobCancellingEvent) Unmarshal(dAtA []byte) error
func (*JobCancellingEvent) XXX_DiscardUnknown ¶
func (m *JobCancellingEvent) XXX_DiscardUnknown()
func (*JobCancellingEvent) XXX_Marshal ¶
func (m *JobCancellingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobCancellingEvent) XXX_Merge ¶
func (m *JobCancellingEvent) XXX_Merge(src proto.Message)
func (*JobCancellingEvent) XXX_Size ¶
func (m *JobCancellingEvent) XXX_Size() int
func (*JobCancellingEvent) XXX_Unmarshal ¶
func (m *JobCancellingEvent) XXX_Unmarshal(b []byte) error
type JobDuplicateFoundEvent ¶
type JobDuplicateFoundEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` OriginalJobId string `protobuf:"bytes,5,opt,name=original_job_id,json=originalJobId,proto3" json:"originalJobId,omitempty"` }
func (*JobDuplicateFoundEvent) Descriptor ¶
func (*JobDuplicateFoundEvent) Descriptor() ([]byte, []int)
func (*JobDuplicateFoundEvent) GetCreated ¶
func (m *JobDuplicateFoundEvent) GetCreated() time.Time
func (*JobDuplicateFoundEvent) GetJobId ¶
func (m *JobDuplicateFoundEvent) GetJobId() string
func (*JobDuplicateFoundEvent) GetJobSetId ¶
func (m *JobDuplicateFoundEvent) GetJobSetId() string
func (*JobDuplicateFoundEvent) GetOriginalJobId ¶
func (m *JobDuplicateFoundEvent) GetOriginalJobId() string
func (*JobDuplicateFoundEvent) GetQueue ¶
func (m *JobDuplicateFoundEvent) GetQueue() string
func (*JobDuplicateFoundEvent) Marshal ¶
func (m *JobDuplicateFoundEvent) Marshal() (dAtA []byte, err error)
func (*JobDuplicateFoundEvent) MarshalTo ¶
func (m *JobDuplicateFoundEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobDuplicateFoundEvent) MarshalToSizedBuffer ¶
func (m *JobDuplicateFoundEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobDuplicateFoundEvent) ProtoMessage ¶
func (*JobDuplicateFoundEvent) ProtoMessage()
func (*JobDuplicateFoundEvent) Reset ¶
func (m *JobDuplicateFoundEvent) Reset()
func (*JobDuplicateFoundEvent) Size ¶
func (m *JobDuplicateFoundEvent) Size() (n int)
func (*JobDuplicateFoundEvent) String ¶
func (this *JobDuplicateFoundEvent) String() string
func (*JobDuplicateFoundEvent) Unmarshal ¶
func (m *JobDuplicateFoundEvent) Unmarshal(dAtA []byte) error
func (*JobDuplicateFoundEvent) XXX_DiscardUnknown ¶
func (m *JobDuplicateFoundEvent) XXX_DiscardUnknown()
func (*JobDuplicateFoundEvent) XXX_Marshal ¶
func (m *JobDuplicateFoundEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobDuplicateFoundEvent) XXX_Merge ¶
func (m *JobDuplicateFoundEvent) XXX_Merge(src proto.Message)
func (*JobDuplicateFoundEvent) XXX_Size ¶
func (m *JobDuplicateFoundEvent) XXX_Size() int
func (*JobDuplicateFoundEvent) XXX_Unmarshal ¶
func (m *JobDuplicateFoundEvent) XXX_Unmarshal(b []byte) error
type JobFailedEvent ¶
type JobFailedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` ExitCodes map[string]int32 `` // Deprecated: Do not use. /* 176-byte string literal not displayed */ KubernetesId string `protobuf:"bytes,8,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` NodeName string `protobuf:"bytes,9,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,10,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,13,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,14,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` ContainerStatuses []*ContainerStatus `protobuf:"bytes,11,rep,name=container_statuses,json=containerStatuses,proto3" json:"containerStatuses,omitempty"` Cause Cause `protobuf:"varint,12,opt,name=cause,proto3,enum=api.Cause" json:"cause,omitempty"` }
func (*JobFailedEvent) Descriptor ¶
func (*JobFailedEvent) Descriptor() ([]byte, []int)
func (*JobFailedEvent) GetCause ¶
func (m *JobFailedEvent) GetCause() Cause
func (*JobFailedEvent) GetClusterId ¶
func (m *JobFailedEvent) GetClusterId() string
func (*JobFailedEvent) GetContainerStatuses ¶
func (m *JobFailedEvent) GetContainerStatuses() []*ContainerStatus
func (*JobFailedEvent) GetCreated ¶
func (m *JobFailedEvent) GetCreated() time.Time
func (*JobFailedEvent) GetExitCodes
deprecated
func (m *JobFailedEvent) GetExitCodes() map[string]int32
Deprecated: Do not use.
func (*JobFailedEvent) GetJobId ¶
func (m *JobFailedEvent) GetJobId() string
func (*JobFailedEvent) GetJobSetId ¶
func (m *JobFailedEvent) GetJobSetId() string
func (*JobFailedEvent) GetKubernetesId ¶
func (m *JobFailedEvent) GetKubernetesId() string
func (*JobFailedEvent) GetNodeName ¶
func (m *JobFailedEvent) GetNodeName() string
func (*JobFailedEvent) GetPodName ¶
func (m *JobFailedEvent) GetPodName() string
func (*JobFailedEvent) GetPodNamespace ¶
func (m *JobFailedEvent) GetPodNamespace() string
func (*JobFailedEvent) GetPodNumber ¶
func (m *JobFailedEvent) GetPodNumber() int32
func (*JobFailedEvent) GetQueue ¶
func (m *JobFailedEvent) GetQueue() string
func (*JobFailedEvent) GetReason ¶
func (m *JobFailedEvent) GetReason() string
func (*JobFailedEvent) Marshal ¶
func (m *JobFailedEvent) Marshal() (dAtA []byte, err error)
func (*JobFailedEvent) MarshalToSizedBuffer ¶
func (m *JobFailedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobFailedEvent) ProtoMessage ¶
func (*JobFailedEvent) ProtoMessage()
func (*JobFailedEvent) Reset ¶
func (m *JobFailedEvent) Reset()
func (*JobFailedEvent) Size ¶
func (m *JobFailedEvent) Size() (n int)
func (*JobFailedEvent) String ¶
func (this *JobFailedEvent) String() string
func (*JobFailedEvent) Unmarshal ¶
func (m *JobFailedEvent) Unmarshal(dAtA []byte) error
func (*JobFailedEvent) XXX_DiscardUnknown ¶
func (m *JobFailedEvent) XXX_DiscardUnknown()
func (*JobFailedEvent) XXX_Marshal ¶
func (m *JobFailedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobFailedEvent) XXX_Merge ¶
func (m *JobFailedEvent) XXX_Merge(src proto.Message)
func (*JobFailedEvent) XXX_Size ¶
func (m *JobFailedEvent) XXX_Size() int
func (*JobFailedEvent) XXX_Unmarshal ¶
func (m *JobFailedEvent) XXX_Unmarshal(b []byte) error
type JobFailedEventCompressed ¶
type JobFailedEventCompressed struct {
Event []byte `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
}
Only used internally by Armada
func (*JobFailedEventCompressed) Descriptor ¶
func (*JobFailedEventCompressed) Descriptor() ([]byte, []int)
func (*JobFailedEventCompressed) GetEvent ¶
func (m *JobFailedEventCompressed) GetEvent() []byte
func (*JobFailedEventCompressed) Marshal ¶
func (m *JobFailedEventCompressed) Marshal() (dAtA []byte, err error)
func (*JobFailedEventCompressed) MarshalTo ¶
func (m *JobFailedEventCompressed) MarshalTo(dAtA []byte) (int, error)
func (*JobFailedEventCompressed) MarshalToSizedBuffer ¶
func (m *JobFailedEventCompressed) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobFailedEventCompressed) ProtoMessage ¶
func (*JobFailedEventCompressed) ProtoMessage()
func (*JobFailedEventCompressed) Reset ¶
func (m *JobFailedEventCompressed) Reset()
func (*JobFailedEventCompressed) Size ¶
func (m *JobFailedEventCompressed) Size() (n int)
func (*JobFailedEventCompressed) String ¶
func (this *JobFailedEventCompressed) String() string
func (*JobFailedEventCompressed) Unmarshal ¶
func (m *JobFailedEventCompressed) Unmarshal(dAtA []byte) error
func (*JobFailedEventCompressed) XXX_DiscardUnknown ¶
func (m *JobFailedEventCompressed) XXX_DiscardUnknown()
func (*JobFailedEventCompressed) XXX_Marshal ¶
func (m *JobFailedEventCompressed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobFailedEventCompressed) XXX_Merge ¶
func (m *JobFailedEventCompressed) XXX_Merge(src proto.Message)
func (*JobFailedEventCompressed) XXX_Size ¶
func (m *JobFailedEventCompressed) XXX_Size() int
func (*JobFailedEventCompressed) XXX_Unmarshal ¶
func (m *JobFailedEventCompressed) XXX_Unmarshal(b []byte) error
type JobIngressInfoEvent ¶
type JobIngressInfoEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` NodeName string `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */ }
func (*JobIngressInfoEvent) Descriptor ¶
func (*JobIngressInfoEvent) Descriptor() ([]byte, []int)
func (*JobIngressInfoEvent) GetClusterId ¶
func (m *JobIngressInfoEvent) GetClusterId() string
func (*JobIngressInfoEvent) GetCreated ¶
func (m *JobIngressInfoEvent) GetCreated() time.Time
func (*JobIngressInfoEvent) GetIngressAddresses ¶
func (m *JobIngressInfoEvent) GetIngressAddresses() map[int32]string
func (*JobIngressInfoEvent) GetJobId ¶
func (m *JobIngressInfoEvent) GetJobId() string
func (*JobIngressInfoEvent) GetJobSetId ¶
func (m *JobIngressInfoEvent) GetJobSetId() string
func (*JobIngressInfoEvent) GetKubernetesId ¶
func (m *JobIngressInfoEvent) GetKubernetesId() string
func (*JobIngressInfoEvent) GetNodeName ¶
func (m *JobIngressInfoEvent) GetNodeName() string
func (*JobIngressInfoEvent) GetPodName ¶
func (m *JobIngressInfoEvent) GetPodName() string
func (*JobIngressInfoEvent) GetPodNamespace ¶
func (m *JobIngressInfoEvent) GetPodNamespace() string
func (*JobIngressInfoEvent) GetPodNumber ¶
func (m *JobIngressInfoEvent) GetPodNumber() int32
func (*JobIngressInfoEvent) GetQueue ¶
func (m *JobIngressInfoEvent) GetQueue() string
func (*JobIngressInfoEvent) Marshal ¶
func (m *JobIngressInfoEvent) Marshal() (dAtA []byte, err error)
func (*JobIngressInfoEvent) MarshalTo ¶
func (m *JobIngressInfoEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobIngressInfoEvent) MarshalToSizedBuffer ¶
func (m *JobIngressInfoEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobIngressInfoEvent) ProtoMessage ¶
func (*JobIngressInfoEvent) ProtoMessage()
func (*JobIngressInfoEvent) Reset ¶
func (m *JobIngressInfoEvent) Reset()
func (*JobIngressInfoEvent) Size ¶
func (m *JobIngressInfoEvent) Size() (n int)
func (*JobIngressInfoEvent) String ¶
func (this *JobIngressInfoEvent) String() string
func (*JobIngressInfoEvent) Unmarshal ¶
func (m *JobIngressInfoEvent) Unmarshal(dAtA []byte) error
func (*JobIngressInfoEvent) XXX_DiscardUnknown ¶
func (m *JobIngressInfoEvent) XXX_DiscardUnknown()
func (*JobIngressInfoEvent) XXX_Marshal ¶
func (m *JobIngressInfoEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobIngressInfoEvent) XXX_Merge ¶
func (m *JobIngressInfoEvent) XXX_Merge(src proto.Message)
func (*JobIngressInfoEvent) XXX_Size ¶
func (m *JobIngressInfoEvent) XXX_Size() int
func (*JobIngressInfoEvent) XXX_Unmarshal ¶
func (m *JobIngressInfoEvent) XXX_Unmarshal(b []byte) error
type JobLeaseExpiredEvent ¶
type JobLeaseExpiredEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` }
func (*JobLeaseExpiredEvent) Descriptor ¶
func (*JobLeaseExpiredEvent) Descriptor() ([]byte, []int)
func (*JobLeaseExpiredEvent) GetCreated ¶
func (m *JobLeaseExpiredEvent) GetCreated() time.Time
func (*JobLeaseExpiredEvent) GetJobId ¶
func (m *JobLeaseExpiredEvent) GetJobId() string
func (*JobLeaseExpiredEvent) GetJobSetId ¶
func (m *JobLeaseExpiredEvent) GetJobSetId() string
func (*JobLeaseExpiredEvent) GetQueue ¶
func (m *JobLeaseExpiredEvent) GetQueue() string
func (*JobLeaseExpiredEvent) Marshal ¶
func (m *JobLeaseExpiredEvent) Marshal() (dAtA []byte, err error)
func (*JobLeaseExpiredEvent) MarshalTo ¶
func (m *JobLeaseExpiredEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobLeaseExpiredEvent) MarshalToSizedBuffer ¶
func (m *JobLeaseExpiredEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobLeaseExpiredEvent) ProtoMessage ¶
func (*JobLeaseExpiredEvent) ProtoMessage()
func (*JobLeaseExpiredEvent) Reset ¶
func (m *JobLeaseExpiredEvent) Reset()
func (*JobLeaseExpiredEvent) Size ¶
func (m *JobLeaseExpiredEvent) Size() (n int)
func (*JobLeaseExpiredEvent) String ¶
func (this *JobLeaseExpiredEvent) String() string
func (*JobLeaseExpiredEvent) Unmarshal ¶
func (m *JobLeaseExpiredEvent) Unmarshal(dAtA []byte) error
func (*JobLeaseExpiredEvent) XXX_DiscardUnknown ¶
func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()
func (*JobLeaseExpiredEvent) XXX_Marshal ¶
func (m *JobLeaseExpiredEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobLeaseExpiredEvent) XXX_Merge ¶
func (m *JobLeaseExpiredEvent) XXX_Merge(src proto.Message)
func (*JobLeaseExpiredEvent) XXX_Size ¶
func (m *JobLeaseExpiredEvent) XXX_Size() int
func (*JobLeaseExpiredEvent) XXX_Unmarshal ¶
func (m *JobLeaseExpiredEvent) XXX_Unmarshal(b []byte) error
type JobLeaseReturnedEvent ¶
type JobLeaseReturnedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` KubernetesId string `protobuf:"bytes,7,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` PodNumber int32 `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` RunAttempted bool `protobuf:"varint,9,opt,name=run_attempted,json=runAttempted,proto3" json:"runAttempted,omitempty"` }
func (*JobLeaseReturnedEvent) Descriptor ¶
func (*JobLeaseReturnedEvent) Descriptor() ([]byte, []int)
func (*JobLeaseReturnedEvent) GetClusterId ¶
func (m *JobLeaseReturnedEvent) GetClusterId() string
func (*JobLeaseReturnedEvent) GetCreated ¶
func (m *JobLeaseReturnedEvent) GetCreated() time.Time
func (*JobLeaseReturnedEvent) GetJobId ¶
func (m *JobLeaseReturnedEvent) GetJobId() string
func (*JobLeaseReturnedEvent) GetJobSetId ¶
func (m *JobLeaseReturnedEvent) GetJobSetId() string
func (*JobLeaseReturnedEvent) GetKubernetesId ¶
func (m *JobLeaseReturnedEvent) GetKubernetesId() string
func (*JobLeaseReturnedEvent) GetPodNumber ¶
func (m *JobLeaseReturnedEvent) GetPodNumber() int32
func (*JobLeaseReturnedEvent) GetQueue ¶
func (m *JobLeaseReturnedEvent) GetQueue() string
func (*JobLeaseReturnedEvent) GetReason ¶
func (m *JobLeaseReturnedEvent) GetReason() string
func (*JobLeaseReturnedEvent) GetRunAttempted ¶ added in v0.3.48
func (m *JobLeaseReturnedEvent) GetRunAttempted() bool
func (*JobLeaseReturnedEvent) Marshal ¶
func (m *JobLeaseReturnedEvent) Marshal() (dAtA []byte, err error)
func (*JobLeaseReturnedEvent) MarshalTo ¶
func (m *JobLeaseReturnedEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobLeaseReturnedEvent) MarshalToSizedBuffer ¶
func (m *JobLeaseReturnedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobLeaseReturnedEvent) ProtoMessage ¶
func (*JobLeaseReturnedEvent) ProtoMessage()
func (*JobLeaseReturnedEvent) Reset ¶
func (m *JobLeaseReturnedEvent) Reset()
func (*JobLeaseReturnedEvent) Size ¶
func (m *JobLeaseReturnedEvent) Size() (n int)
func (*JobLeaseReturnedEvent) String ¶
func (this *JobLeaseReturnedEvent) String() string
func (*JobLeaseReturnedEvent) Unmarshal ¶
func (m *JobLeaseReturnedEvent) Unmarshal(dAtA []byte) error
func (*JobLeaseReturnedEvent) XXX_DiscardUnknown ¶
func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()
func (*JobLeaseReturnedEvent) XXX_Marshal ¶
func (m *JobLeaseReturnedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobLeaseReturnedEvent) XXX_Merge ¶
func (m *JobLeaseReturnedEvent) XXX_Merge(src proto.Message)
func (*JobLeaseReturnedEvent) XXX_Size ¶
func (m *JobLeaseReturnedEvent) XXX_Size() int
func (*JobLeaseReturnedEvent) XXX_Unmarshal ¶
func (m *JobLeaseReturnedEvent) XXX_Unmarshal(b []byte) error
type JobLeasedEvent ¶
type JobLeasedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` }
func (*JobLeasedEvent) Descriptor ¶
func (*JobLeasedEvent) Descriptor() ([]byte, []int)
func (*JobLeasedEvent) GetClusterId ¶
func (m *JobLeasedEvent) GetClusterId() string
func (*JobLeasedEvent) GetCreated ¶
func (m *JobLeasedEvent) GetCreated() time.Time
func (*JobLeasedEvent) GetJobId ¶
func (m *JobLeasedEvent) GetJobId() string
func (*JobLeasedEvent) GetJobSetId ¶
func (m *JobLeasedEvent) GetJobSetId() string
func (*JobLeasedEvent) GetQueue ¶
func (m *JobLeasedEvent) GetQueue() string
func (*JobLeasedEvent) Marshal ¶
func (m *JobLeasedEvent) Marshal() (dAtA []byte, err error)
func (*JobLeasedEvent) MarshalToSizedBuffer ¶
func (m *JobLeasedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobLeasedEvent) ProtoMessage ¶
func (*JobLeasedEvent) ProtoMessage()
func (*JobLeasedEvent) Reset ¶
func (m *JobLeasedEvent) Reset()
func (*JobLeasedEvent) Size ¶
func (m *JobLeasedEvent) Size() (n int)
func (*JobLeasedEvent) String ¶
func (this *JobLeasedEvent) String() string
func (*JobLeasedEvent) Unmarshal ¶
func (m *JobLeasedEvent) Unmarshal(dAtA []byte) error
func (*JobLeasedEvent) XXX_DiscardUnknown ¶
func (m *JobLeasedEvent) XXX_DiscardUnknown()
func (*JobLeasedEvent) XXX_Marshal ¶
func (m *JobLeasedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobLeasedEvent) XXX_Merge ¶
func (m *JobLeasedEvent) XXX_Merge(src proto.Message)
func (*JobLeasedEvent) XXX_Size ¶
func (m *JobLeasedEvent) XXX_Size() int
func (*JobLeasedEvent) XXX_Unmarshal ¶
func (m *JobLeasedEvent) XXX_Unmarshal(b []byte) error
type JobPendingEvent ¶
type JobPendingEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` PodNumber int32 `protobuf:"varint,7,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,8,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,9,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` }
func (*JobPendingEvent) Descriptor ¶
func (*JobPendingEvent) Descriptor() ([]byte, []int)
func (*JobPendingEvent) GetClusterId ¶
func (m *JobPendingEvent) GetClusterId() string
func (*JobPendingEvent) GetCreated ¶
func (m *JobPendingEvent) GetCreated() time.Time
func (*JobPendingEvent) GetJobId ¶
func (m *JobPendingEvent) GetJobId() string
func (*JobPendingEvent) GetJobSetId ¶
func (m *JobPendingEvent) GetJobSetId() string
func (*JobPendingEvent) GetKubernetesId ¶
func (m *JobPendingEvent) GetKubernetesId() string
func (*JobPendingEvent) GetPodName ¶
func (m *JobPendingEvent) GetPodName() string
func (*JobPendingEvent) GetPodNamespace ¶
func (m *JobPendingEvent) GetPodNamespace() string
func (*JobPendingEvent) GetPodNumber ¶
func (m *JobPendingEvent) GetPodNumber() int32
func (*JobPendingEvent) GetQueue ¶
func (m *JobPendingEvent) GetQueue() string
func (*JobPendingEvent) Marshal ¶
func (m *JobPendingEvent) Marshal() (dAtA []byte, err error)
func (*JobPendingEvent) MarshalToSizedBuffer ¶
func (m *JobPendingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobPendingEvent) ProtoMessage ¶
func (*JobPendingEvent) ProtoMessage()
func (*JobPendingEvent) Reset ¶
func (m *JobPendingEvent) Reset()
func (*JobPendingEvent) Size ¶
func (m *JobPendingEvent) Size() (n int)
func (*JobPendingEvent) String ¶
func (this *JobPendingEvent) String() string
func (*JobPendingEvent) Unmarshal ¶
func (m *JobPendingEvent) Unmarshal(dAtA []byte) error
func (*JobPendingEvent) XXX_DiscardUnknown ¶
func (m *JobPendingEvent) XXX_DiscardUnknown()
func (*JobPendingEvent) XXX_Marshal ¶
func (m *JobPendingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobPendingEvent) XXX_Merge ¶
func (m *JobPendingEvent) XXX_Merge(src proto.Message)
func (*JobPendingEvent) XXX_Size ¶
func (m *JobPendingEvent) XXX_Size() int
func (*JobPendingEvent) XXX_Unmarshal ¶
func (m *JobPendingEvent) XXX_Unmarshal(b []byte) error
type JobPreemptedEvent ¶
type JobPreemptedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` RunId string `protobuf:"bytes,6,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` PreemptiveJobId string `protobuf:"bytes,7,opt,name=preemptive_job_id,json=preemptiveJobId,proto3" json:"preemptiveJobId,omitempty"` PreemptiveRunId string `protobuf:"bytes,8,opt,name=preemptive_run_id,json=preemptiveRunId,proto3" json:"preemptiveRunId,omitempty"` }
func (*JobPreemptedEvent) Descriptor ¶
func (*JobPreemptedEvent) Descriptor() ([]byte, []int)
func (*JobPreemptedEvent) GetClusterId ¶
func (m *JobPreemptedEvent) GetClusterId() string
func (*JobPreemptedEvent) GetCreated ¶
func (m *JobPreemptedEvent) GetCreated() time.Time
func (*JobPreemptedEvent) GetJobId ¶
func (m *JobPreemptedEvent) GetJobId() string
func (*JobPreemptedEvent) GetJobSetId ¶
func (m *JobPreemptedEvent) GetJobSetId() string
func (*JobPreemptedEvent) GetPreemptiveJobId ¶
func (m *JobPreemptedEvent) GetPreemptiveJobId() string
func (*JobPreemptedEvent) GetPreemptiveRunId ¶
func (m *JobPreemptedEvent) GetPreemptiveRunId() string
func (*JobPreemptedEvent) GetQueue ¶
func (m *JobPreemptedEvent) GetQueue() string
func (*JobPreemptedEvent) GetRunId ¶
func (m *JobPreemptedEvent) GetRunId() string
func (*JobPreemptedEvent) Marshal ¶
func (m *JobPreemptedEvent) Marshal() (dAtA []byte, err error)
func (*JobPreemptedEvent) MarshalTo ¶
func (m *JobPreemptedEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobPreemptedEvent) MarshalToSizedBuffer ¶
func (m *JobPreemptedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobPreemptedEvent) ProtoMessage ¶
func (*JobPreemptedEvent) ProtoMessage()
func (*JobPreemptedEvent) Reset ¶
func (m *JobPreemptedEvent) Reset()
func (*JobPreemptedEvent) Size ¶
func (m *JobPreemptedEvent) Size() (n int)
func (*JobPreemptedEvent) String ¶
func (this *JobPreemptedEvent) String() string
func (*JobPreemptedEvent) Unmarshal ¶
func (m *JobPreemptedEvent) Unmarshal(dAtA []byte) error
func (*JobPreemptedEvent) XXX_DiscardUnknown ¶
func (m *JobPreemptedEvent) XXX_DiscardUnknown()
func (*JobPreemptedEvent) XXX_Marshal ¶
func (m *JobPreemptedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobPreemptedEvent) XXX_Merge ¶
func (m *JobPreemptedEvent) XXX_Merge(src proto.Message)
func (*JobPreemptedEvent) XXX_Size ¶
func (m *JobPreemptedEvent) XXX_Size() int
func (*JobPreemptedEvent) XXX_Unmarshal ¶
func (m *JobPreemptedEvent) XXX_Unmarshal(b []byte) error
type JobQueuedEvent ¶
type JobQueuedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` }
func (*JobQueuedEvent) Descriptor ¶
func (*JobQueuedEvent) Descriptor() ([]byte, []int)
func (*JobQueuedEvent) GetCreated ¶
func (m *JobQueuedEvent) GetCreated() time.Time
func (*JobQueuedEvent) GetJobId ¶
func (m *JobQueuedEvent) GetJobId() string
func (*JobQueuedEvent) GetJobSetId ¶
func (m *JobQueuedEvent) GetJobSetId() string
func (*JobQueuedEvent) GetQueue ¶
func (m *JobQueuedEvent) GetQueue() string
func (*JobQueuedEvent) Marshal ¶
func (m *JobQueuedEvent) Marshal() (dAtA []byte, err error)
func (*JobQueuedEvent) MarshalToSizedBuffer ¶
func (m *JobQueuedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobQueuedEvent) ProtoMessage ¶
func (*JobQueuedEvent) ProtoMessage()
func (*JobQueuedEvent) Reset ¶
func (m *JobQueuedEvent) Reset()
func (*JobQueuedEvent) Size ¶
func (m *JobQueuedEvent) Size() (n int)
func (*JobQueuedEvent) String ¶
func (this *JobQueuedEvent) String() string
func (*JobQueuedEvent) Unmarshal ¶
func (m *JobQueuedEvent) Unmarshal(dAtA []byte) error
func (*JobQueuedEvent) XXX_DiscardUnknown ¶
func (m *JobQueuedEvent) XXX_DiscardUnknown()
func (*JobQueuedEvent) XXX_Marshal ¶
func (m *JobQueuedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobQueuedEvent) XXX_Merge ¶
func (m *JobQueuedEvent) XXX_Merge(src proto.Message)
func (*JobQueuedEvent) XXX_Size ¶
func (m *JobQueuedEvent) XXX_Size() int
func (*JobQueuedEvent) XXX_Unmarshal ¶
func (m *JobQueuedEvent) XXX_Unmarshal(b []byte) error
type JobReprioritizeRequest ¶
type JobReprioritizeRequest struct { JobIds []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` NewPriority float64 `protobuf:"fixed64,4,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"` }
swagger:model
func (*JobReprioritizeRequest) Descriptor ¶
func (*JobReprioritizeRequest) Descriptor() ([]byte, []int)
func (*JobReprioritizeRequest) GetJobIds ¶
func (m *JobReprioritizeRequest) GetJobIds() []string
func (*JobReprioritizeRequest) GetJobSetId ¶
func (m *JobReprioritizeRequest) GetJobSetId() string
func (*JobReprioritizeRequest) GetNewPriority ¶
func (m *JobReprioritizeRequest) GetNewPriority() float64
func (*JobReprioritizeRequest) GetQueue ¶
func (m *JobReprioritizeRequest) GetQueue() string
func (*JobReprioritizeRequest) Marshal ¶
func (m *JobReprioritizeRequest) Marshal() (dAtA []byte, err error)
func (*JobReprioritizeRequest) MarshalTo ¶
func (m *JobReprioritizeRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobReprioritizeRequest) MarshalToSizedBuffer ¶
func (m *JobReprioritizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobReprioritizeRequest) ProtoMessage ¶
func (*JobReprioritizeRequest) ProtoMessage()
func (*JobReprioritizeRequest) Reset ¶
func (m *JobReprioritizeRequest) Reset()
func (*JobReprioritizeRequest) Size ¶
func (m *JobReprioritizeRequest) Size() (n int)
func (*JobReprioritizeRequest) String ¶
func (this *JobReprioritizeRequest) String() string
func (*JobReprioritizeRequest) Unmarshal ¶
func (m *JobReprioritizeRequest) Unmarshal(dAtA []byte) error
func (*JobReprioritizeRequest) XXX_DiscardUnknown ¶
func (m *JobReprioritizeRequest) XXX_DiscardUnknown()
func (*JobReprioritizeRequest) XXX_Marshal ¶
func (m *JobReprioritizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobReprioritizeRequest) XXX_Merge ¶
func (m *JobReprioritizeRequest) XXX_Merge(src proto.Message)
func (*JobReprioritizeRequest) XXX_Size ¶
func (m *JobReprioritizeRequest) XXX_Size() int
func (*JobReprioritizeRequest) XXX_Unmarshal ¶
func (m *JobReprioritizeRequest) XXX_Unmarshal(b []byte) error
type JobReprioritizeResponse ¶
type JobReprioritizeResponse struct {
ReprioritizationResults map[string]string `` /* 217-byte string literal not displayed */
}
swagger:model
func (*JobReprioritizeResponse) Descriptor ¶
func (*JobReprioritizeResponse) Descriptor() ([]byte, []int)
func (*JobReprioritizeResponse) GetReprioritizationResults ¶
func (m *JobReprioritizeResponse) GetReprioritizationResults() map[string]string
func (*JobReprioritizeResponse) Marshal ¶
func (m *JobReprioritizeResponse) Marshal() (dAtA []byte, err error)
func (*JobReprioritizeResponse) MarshalTo ¶
func (m *JobReprioritizeResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobReprioritizeResponse) MarshalToSizedBuffer ¶
func (m *JobReprioritizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobReprioritizeResponse) ProtoMessage ¶
func (*JobReprioritizeResponse) ProtoMessage()
func (*JobReprioritizeResponse) Reset ¶
func (m *JobReprioritizeResponse) Reset()
func (*JobReprioritizeResponse) Size ¶
func (m *JobReprioritizeResponse) Size() (n int)
func (*JobReprioritizeResponse) String ¶
func (this *JobReprioritizeResponse) String() string
func (*JobReprioritizeResponse) Unmarshal ¶
func (m *JobReprioritizeResponse) Unmarshal(dAtA []byte) error
func (*JobReprioritizeResponse) XXX_DiscardUnknown ¶
func (m *JobReprioritizeResponse) XXX_DiscardUnknown()
func (*JobReprioritizeResponse) XXX_Marshal ¶
func (m *JobReprioritizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobReprioritizeResponse) XXX_Merge ¶
func (m *JobReprioritizeResponse) XXX_Merge(src proto.Message)
func (*JobReprioritizeResponse) XXX_Size ¶
func (m *JobReprioritizeResponse) XXX_Size() int
func (*JobReprioritizeResponse) XXX_Unmarshal ¶
func (m *JobReprioritizeResponse) XXX_Unmarshal(b []byte) error
type JobReprioritizedEvent ¶
type JobReprioritizedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` NewPriority float64 `protobuf:"fixed64,5,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"` Requestor string `protobuf:"bytes,6,opt,name=requestor,proto3" json:"requestor,omitempty"` }
func (*JobReprioritizedEvent) Descriptor ¶
func (*JobReprioritizedEvent) Descriptor() ([]byte, []int)
func (*JobReprioritizedEvent) GetCreated ¶
func (m *JobReprioritizedEvent) GetCreated() time.Time
func (*JobReprioritizedEvent) GetJobId ¶
func (m *JobReprioritizedEvent) GetJobId() string
func (*JobReprioritizedEvent) GetJobSetId ¶
func (m *JobReprioritizedEvent) GetJobSetId() string
func (*JobReprioritizedEvent) GetNewPriority ¶
func (m *JobReprioritizedEvent) GetNewPriority() float64
func (*JobReprioritizedEvent) GetQueue ¶
func (m *JobReprioritizedEvent) GetQueue() string
func (*JobReprioritizedEvent) GetRequestor ¶
func (m *JobReprioritizedEvent) GetRequestor() string
func (*JobReprioritizedEvent) Marshal ¶
func (m *JobReprioritizedEvent) Marshal() (dAtA []byte, err error)
func (*JobReprioritizedEvent) MarshalTo ¶
func (m *JobReprioritizedEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobReprioritizedEvent) MarshalToSizedBuffer ¶
func (m *JobReprioritizedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobReprioritizedEvent) ProtoMessage ¶
func (*JobReprioritizedEvent) ProtoMessage()
func (*JobReprioritizedEvent) Reset ¶
func (m *JobReprioritizedEvent) Reset()
func (*JobReprioritizedEvent) Size ¶
func (m *JobReprioritizedEvent) Size() (n int)
func (*JobReprioritizedEvent) String ¶
func (this *JobReprioritizedEvent) String() string
func (*JobReprioritizedEvent) Unmarshal ¶
func (m *JobReprioritizedEvent) Unmarshal(dAtA []byte) error
func (*JobReprioritizedEvent) XXX_DiscardUnknown ¶
func (m *JobReprioritizedEvent) XXX_DiscardUnknown()
func (*JobReprioritizedEvent) XXX_Marshal ¶
func (m *JobReprioritizedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobReprioritizedEvent) XXX_Merge ¶
func (m *JobReprioritizedEvent) XXX_Merge(src proto.Message)
func (*JobReprioritizedEvent) XXX_Size ¶
func (m *JobReprioritizedEvent) XXX_Size() int
func (*JobReprioritizedEvent) XXX_Unmarshal ¶
func (m *JobReprioritizedEvent) XXX_Unmarshal(b []byte) error
type JobReprioritizingEvent ¶
type JobReprioritizingEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` NewPriority float64 `protobuf:"fixed64,5,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"` Requestor string `protobuf:"bytes,6,opt,name=requestor,proto3" json:"requestor,omitempty"` }
func (*JobReprioritizingEvent) Descriptor ¶
func (*JobReprioritizingEvent) Descriptor() ([]byte, []int)
func (*JobReprioritizingEvent) GetCreated ¶
func (m *JobReprioritizingEvent) GetCreated() time.Time
func (*JobReprioritizingEvent) GetJobId ¶
func (m *JobReprioritizingEvent) GetJobId() string
func (*JobReprioritizingEvent) GetJobSetId ¶
func (m *JobReprioritizingEvent) GetJobSetId() string
func (*JobReprioritizingEvent) GetNewPriority ¶
func (m *JobReprioritizingEvent) GetNewPriority() float64
func (*JobReprioritizingEvent) GetQueue ¶
func (m *JobReprioritizingEvent) GetQueue() string
func (*JobReprioritizingEvent) GetRequestor ¶
func (m *JobReprioritizingEvent) GetRequestor() string
func (*JobReprioritizingEvent) Marshal ¶
func (m *JobReprioritizingEvent) Marshal() (dAtA []byte, err error)
func (*JobReprioritizingEvent) MarshalTo ¶
func (m *JobReprioritizingEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobReprioritizingEvent) MarshalToSizedBuffer ¶
func (m *JobReprioritizingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobReprioritizingEvent) ProtoMessage ¶
func (*JobReprioritizingEvent) ProtoMessage()
func (*JobReprioritizingEvent) Reset ¶
func (m *JobReprioritizingEvent) Reset()
func (*JobReprioritizingEvent) Size ¶
func (m *JobReprioritizingEvent) Size() (n int)
func (*JobReprioritizingEvent) String ¶
func (this *JobReprioritizingEvent) String() string
func (*JobReprioritizingEvent) Unmarshal ¶
func (m *JobReprioritizingEvent) Unmarshal(dAtA []byte) error
func (*JobReprioritizingEvent) XXX_DiscardUnknown ¶
func (m *JobReprioritizingEvent) XXX_DiscardUnknown()
func (*JobReprioritizingEvent) XXX_Marshal ¶
func (m *JobReprioritizingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobReprioritizingEvent) XXX_Merge ¶
func (m *JobReprioritizingEvent) XXX_Merge(src proto.Message)
func (*JobReprioritizingEvent) XXX_Size ¶
func (m *JobReprioritizingEvent) XXX_Size() int
func (*JobReprioritizingEvent) XXX_Unmarshal ¶
func (m *JobReprioritizingEvent) XXX_Unmarshal(b []byte) error
type JobRunningEvent ¶
type JobRunningEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` NodeName string `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` }
func (*JobRunningEvent) Descriptor ¶
func (*JobRunningEvent) Descriptor() ([]byte, []int)
func (*JobRunningEvent) GetClusterId ¶
func (m *JobRunningEvent) GetClusterId() string
func (*JobRunningEvent) GetCreated ¶
func (m *JobRunningEvent) GetCreated() time.Time
func (*JobRunningEvent) GetJobId ¶
func (m *JobRunningEvent) GetJobId() string
func (*JobRunningEvent) GetJobSetId ¶
func (m *JobRunningEvent) GetJobSetId() string
func (*JobRunningEvent) GetKubernetesId ¶
func (m *JobRunningEvent) GetKubernetesId() string
func (*JobRunningEvent) GetNodeName ¶
func (m *JobRunningEvent) GetNodeName() string
func (*JobRunningEvent) GetPodName ¶
func (m *JobRunningEvent) GetPodName() string
func (*JobRunningEvent) GetPodNamespace ¶
func (m *JobRunningEvent) GetPodNamespace() string
func (*JobRunningEvent) GetPodNumber ¶
func (m *JobRunningEvent) GetPodNumber() int32
func (*JobRunningEvent) GetQueue ¶
func (m *JobRunningEvent) GetQueue() string
func (*JobRunningEvent) Marshal ¶
func (m *JobRunningEvent) Marshal() (dAtA []byte, err error)
func (*JobRunningEvent) MarshalToSizedBuffer ¶
func (m *JobRunningEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunningEvent) ProtoMessage ¶
func (*JobRunningEvent) ProtoMessage()
func (*JobRunningEvent) Reset ¶
func (m *JobRunningEvent) Reset()
func (*JobRunningEvent) Size ¶
func (m *JobRunningEvent) Size() (n int)
func (*JobRunningEvent) String ¶
func (this *JobRunningEvent) String() string
func (*JobRunningEvent) Unmarshal ¶
func (m *JobRunningEvent) Unmarshal(dAtA []byte) error
func (*JobRunningEvent) XXX_DiscardUnknown ¶
func (m *JobRunningEvent) XXX_DiscardUnknown()
func (*JobRunningEvent) XXX_Marshal ¶
func (m *JobRunningEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunningEvent) XXX_Merge ¶
func (m *JobRunningEvent) XXX_Merge(src proto.Message)
func (*JobRunningEvent) XXX_Size ¶
func (m *JobRunningEvent) XXX_Size() int
func (*JobRunningEvent) XXX_Unmarshal ¶
func (m *JobRunningEvent) XXX_Unmarshal(b []byte) error
type JobSetCancelRequest ¶
type JobSetCancelRequest struct { JobSetId string `protobuf:"bytes,1,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` Filter *JobSetFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"` }
swagger:model
func (*JobSetCancelRequest) Descriptor ¶
func (*JobSetCancelRequest) Descriptor() ([]byte, []int)
func (*JobSetCancelRequest) GetFilter ¶
func (m *JobSetCancelRequest) GetFilter() *JobSetFilter
func (*JobSetCancelRequest) GetJobSetId ¶
func (m *JobSetCancelRequest) GetJobSetId() string
func (*JobSetCancelRequest) GetQueue ¶
func (m *JobSetCancelRequest) GetQueue() string
func (*JobSetCancelRequest) GetReason ¶ added in v0.3.68
func (m *JobSetCancelRequest) GetReason() string
func (*JobSetCancelRequest) Marshal ¶
func (m *JobSetCancelRequest) Marshal() (dAtA []byte, err error)
func (*JobSetCancelRequest) MarshalTo ¶
func (m *JobSetCancelRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobSetCancelRequest) MarshalToSizedBuffer ¶
func (m *JobSetCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSetCancelRequest) ProtoMessage ¶
func (*JobSetCancelRequest) ProtoMessage()
func (*JobSetCancelRequest) Reset ¶
func (m *JobSetCancelRequest) Reset()
func (*JobSetCancelRequest) Size ¶
func (m *JobSetCancelRequest) Size() (n int)
func (*JobSetCancelRequest) String ¶
func (this *JobSetCancelRequest) String() string
func (*JobSetCancelRequest) Unmarshal ¶
func (m *JobSetCancelRequest) Unmarshal(dAtA []byte) error
func (*JobSetCancelRequest) XXX_DiscardUnknown ¶
func (m *JobSetCancelRequest) XXX_DiscardUnknown()
func (*JobSetCancelRequest) XXX_Marshal ¶
func (m *JobSetCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSetCancelRequest) XXX_Merge ¶
func (m *JobSetCancelRequest) XXX_Merge(src proto.Message)
func (*JobSetCancelRequest) XXX_Size ¶
func (m *JobSetCancelRequest) XXX_Size() int
func (*JobSetCancelRequest) XXX_Unmarshal ¶
func (m *JobSetCancelRequest) XXX_Unmarshal(b []byte) error
type JobSetFilter ¶
type JobSetFilter struct {
States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=api.JobState" json:"states,omitempty"`
}
swagger:model
func (*JobSetFilter) Descriptor ¶
func (*JobSetFilter) Descriptor() ([]byte, []int)
func (*JobSetFilter) GetStates ¶
func (m *JobSetFilter) GetStates() []JobState
func (*JobSetFilter) Marshal ¶
func (m *JobSetFilter) Marshal() (dAtA []byte, err error)
func (*JobSetFilter) MarshalToSizedBuffer ¶
func (m *JobSetFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSetFilter) ProtoMessage ¶
func (*JobSetFilter) ProtoMessage()
func (*JobSetFilter) Reset ¶
func (m *JobSetFilter) Reset()
func (*JobSetFilter) Size ¶
func (m *JobSetFilter) Size() (n int)
func (*JobSetFilter) String ¶
func (this *JobSetFilter) String() string
func (*JobSetFilter) Unmarshal ¶
func (m *JobSetFilter) Unmarshal(dAtA []byte) error
func (*JobSetFilter) XXX_DiscardUnknown ¶
func (m *JobSetFilter) XXX_DiscardUnknown()
func (*JobSetFilter) XXX_Marshal ¶
func (m *JobSetFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSetFilter) XXX_Merge ¶
func (m *JobSetFilter) XXX_Merge(src proto.Message)
func (*JobSetFilter) XXX_Size ¶
func (m *JobSetFilter) XXX_Size() int
func (*JobSetFilter) XXX_Unmarshal ¶
func (m *JobSetFilter) XXX_Unmarshal(b []byte) error
type JobSetInfo ¶
type JobSetInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` QueuedJobs int32 `protobuf:"varint,2,opt,name=queued_jobs,json=queuedJobs,proto3" json:"queuedJobs,omitempty"` LeasedJobs int32 `protobuf:"varint,3,opt,name=leased_jobs,json=leasedJobs,proto3" json:"leasedJobs,omitempty"` }
func (*JobSetInfo) Descriptor ¶
func (*JobSetInfo) Descriptor() ([]byte, []int)
func (*JobSetInfo) GetLeasedJobs ¶
func (m *JobSetInfo) GetLeasedJobs() int32
func (*JobSetInfo) GetName ¶
func (m *JobSetInfo) GetName() string
func (*JobSetInfo) GetQueuedJobs ¶
func (m *JobSetInfo) GetQueuedJobs() int32
func (*JobSetInfo) Marshal ¶
func (m *JobSetInfo) Marshal() (dAtA []byte, err error)
func (*JobSetInfo) MarshalToSizedBuffer ¶
func (m *JobSetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSetInfo) ProtoMessage ¶
func (*JobSetInfo) ProtoMessage()
func (*JobSetInfo) Reset ¶
func (m *JobSetInfo) Reset()
func (*JobSetInfo) Size ¶
func (m *JobSetInfo) Size() (n int)
func (*JobSetInfo) String ¶
func (this *JobSetInfo) String() string
func (*JobSetInfo) Unmarshal ¶
func (m *JobSetInfo) Unmarshal(dAtA []byte) error
func (*JobSetInfo) XXX_DiscardUnknown ¶
func (m *JobSetInfo) XXX_DiscardUnknown()
func (*JobSetInfo) XXX_Marshal ¶
func (m *JobSetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSetInfo) XXX_Merge ¶
func (m *JobSetInfo) XXX_Merge(src proto.Message)
func (*JobSetInfo) XXX_Size ¶
func (m *JobSetInfo) XXX_Size() int
func (*JobSetInfo) XXX_Unmarshal ¶
func (m *JobSetInfo) XXX_Unmarshal(b []byte) error
type JobSetRequest ¶
type JobSetRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Watch bool `protobuf:"varint,2,opt,name=watch,proto3" json:"watch,omitempty"` FromMessageId string `protobuf:"bytes,3,opt,name=from_message_id,json=fromMessageId,proto3" json:"fromMessageId,omitempty"` Queue string `protobuf:"bytes,4,opt,name=queue,proto3" json:"queue,omitempty"` ErrorIfMissing bool `protobuf:"varint,5,opt,name=errorIfMissing,proto3" json:"errorIfMissing,omitempty"` ForceLegacy bool `protobuf:"varint,6,opt,name=force_legacy,json=forceLegacy,proto3" json:"forceLegacy,omitempty"` ForceNew bool `protobuf:"varint,7,opt,name=force_new,json=forceNew,proto3" json:"forceNew,omitempty"` }
swagger:model
func (*JobSetRequest) Descriptor ¶
func (*JobSetRequest) Descriptor() ([]byte, []int)
func (*JobSetRequest) GetErrorIfMissing ¶
func (m *JobSetRequest) GetErrorIfMissing() bool
func (*JobSetRequest) GetForceLegacy ¶
func (m *JobSetRequest) GetForceLegacy() bool
func (*JobSetRequest) GetForceNew ¶
func (m *JobSetRequest) GetForceNew() bool
func (*JobSetRequest) GetFromMessageId ¶
func (m *JobSetRequest) GetFromMessageId() string
func (*JobSetRequest) GetId ¶
func (m *JobSetRequest) GetId() string
func (*JobSetRequest) GetQueue ¶
func (m *JobSetRequest) GetQueue() string
func (*JobSetRequest) GetWatch ¶
func (m *JobSetRequest) GetWatch() bool
func (*JobSetRequest) Marshal ¶
func (m *JobSetRequest) Marshal() (dAtA []byte, err error)
func (*JobSetRequest) MarshalToSizedBuffer ¶
func (m *JobSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSetRequest) ProtoMessage ¶
func (*JobSetRequest) ProtoMessage()
func (*JobSetRequest) Reset ¶
func (m *JobSetRequest) Reset()
func (*JobSetRequest) Size ¶
func (m *JobSetRequest) Size() (n int)
func (*JobSetRequest) String ¶
func (this *JobSetRequest) String() string
func (*JobSetRequest) Unmarshal ¶
func (m *JobSetRequest) Unmarshal(dAtA []byte) error
func (*JobSetRequest) XXX_DiscardUnknown ¶
func (m *JobSetRequest) XXX_DiscardUnknown()
func (*JobSetRequest) XXX_Marshal ¶
func (m *JobSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSetRequest) XXX_Merge ¶
func (m *JobSetRequest) XXX_Merge(src proto.Message)
func (*JobSetRequest) XXX_Size ¶
func (m *JobSetRequest) XXX_Size() int
func (*JobSetRequest) XXX_Unmarshal ¶
func (m *JobSetRequest) XXX_Unmarshal(b []byte) error
type JobState ¶
type JobState int32
swagger:model
func (JobState) EnumDescriptor ¶
func (JobState) IsTerminal ¶ added in v0.3.50
IsTerminal returns true if the JobState s corresponds to a state that indicates the job has been terminated.
func (*JobState) UnmarshalJSON ¶
type JobStatus ¶ added in v0.4.20
type JobStatus int32
const ( JobStatus_UNKNOWN JobStatus = 0 JobStatus_SUBMITTED JobStatus = 1 JobStatus_QUEUED JobStatus = 2 JobStatus_LEASED JobStatus = 3 JobStatus_PENDING JobStatus = 4 JobStatus_RUNNING JobStatus = 5 JobStatus_SUCCEEDED JobStatus = 6 JobStatus_FAILED JobStatus = 7 JobStatus_PREEMPTED JobStatus = 8 JobStatus_CANCELLED JobStatus = 9 )
func (JobStatus) EnumDescriptor ¶ added in v0.4.20
type JobStatusRequest ¶ added in v0.4.20
type JobStatusRequest struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}
func (*JobStatusRequest) Descriptor ¶ added in v0.4.20
func (*JobStatusRequest) Descriptor() ([]byte, []int)
func (*JobStatusRequest) GetJobId ¶ added in v0.4.20
func (m *JobStatusRequest) GetJobId() string
func (*JobStatusRequest) Marshal ¶ added in v0.4.20
func (m *JobStatusRequest) Marshal() (dAtA []byte, err error)
func (*JobStatusRequest) MarshalTo ¶ added in v0.4.20
func (m *JobStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobStatusRequest) MarshalToSizedBuffer ¶ added in v0.4.20
func (m *JobStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobStatusRequest) ProtoMessage ¶ added in v0.4.20
func (*JobStatusRequest) ProtoMessage()
func (*JobStatusRequest) Reset ¶ added in v0.4.20
func (m *JobStatusRequest) Reset()
func (*JobStatusRequest) Size ¶ added in v0.4.20
func (m *JobStatusRequest) Size() (n int)
func (*JobStatusRequest) String ¶ added in v0.4.20
func (this *JobStatusRequest) String() string
func (*JobStatusRequest) Unmarshal ¶ added in v0.4.20
func (m *JobStatusRequest) Unmarshal(dAtA []byte) error
func (*JobStatusRequest) XXX_DiscardUnknown ¶ added in v0.4.20
func (m *JobStatusRequest) XXX_DiscardUnknown()
func (*JobStatusRequest) XXX_Marshal ¶ added in v0.4.20
func (m *JobStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobStatusRequest) XXX_Merge ¶ added in v0.4.20
func (m *JobStatusRequest) XXX_Merge(src proto.Message)
func (*JobStatusRequest) XXX_Size ¶ added in v0.4.20
func (m *JobStatusRequest) XXX_Size() int
func (*JobStatusRequest) XXX_Unmarshal ¶ added in v0.4.20
func (m *JobStatusRequest) XXX_Unmarshal(b []byte) error
type JobStatusResponse ¶ added in v0.4.20
type JobStatusResponse struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobStatus JobStatus `protobuf:"varint,2,opt,name=job_status,json=jobStatus,proto3,enum=queryapi.JobStatus" json:"jobStatus,omitempty"` }
func (*JobStatusResponse) Descriptor ¶ added in v0.4.20
func (*JobStatusResponse) Descriptor() ([]byte, []int)
func (*JobStatusResponse) GetJobId ¶ added in v0.4.20
func (m *JobStatusResponse) GetJobId() string
func (*JobStatusResponse) GetJobStatus ¶ added in v0.4.20
func (m *JobStatusResponse) GetJobStatus() JobStatus
func (*JobStatusResponse) Marshal ¶ added in v0.4.20
func (m *JobStatusResponse) Marshal() (dAtA []byte, err error)
func (*JobStatusResponse) MarshalTo ¶ added in v0.4.20
func (m *JobStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobStatusResponse) MarshalToSizedBuffer ¶ added in v0.4.20
func (m *JobStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobStatusResponse) ProtoMessage ¶ added in v0.4.20
func (*JobStatusResponse) ProtoMessage()
func (*JobStatusResponse) Reset ¶ added in v0.4.20
func (m *JobStatusResponse) Reset()
func (*JobStatusResponse) Size ¶ added in v0.4.20
func (m *JobStatusResponse) Size() (n int)
func (*JobStatusResponse) String ¶ added in v0.4.20
func (this *JobStatusResponse) String() string
func (*JobStatusResponse) Unmarshal ¶ added in v0.4.20
func (m *JobStatusResponse) Unmarshal(dAtA []byte) error
func (*JobStatusResponse) XXX_DiscardUnknown ¶ added in v0.4.20
func (m *JobStatusResponse) XXX_DiscardUnknown()
func (*JobStatusResponse) XXX_Marshal ¶ added in v0.4.20
func (m *JobStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobStatusResponse) XXX_Merge ¶ added in v0.4.20
func (m *JobStatusResponse) XXX_Merge(src proto.Message)
func (*JobStatusResponse) XXX_Size ¶ added in v0.4.20
func (m *JobStatusResponse) XXX_Size() int
func (*JobStatusResponse) XXX_Unmarshal ¶ added in v0.4.20
func (m *JobStatusResponse) XXX_Unmarshal(b []byte) error
type JobSubmitRequest ¶
type JobSubmitRequest struct { Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` JobRequestItems []*JobSubmitRequestItem `protobuf:"bytes,3,rep,name=job_request_items,json=jobRequestItems,proto3" json:"jobRequestItems,omitempty"` }
swagger:model
func (*JobSubmitRequest) Descriptor ¶
func (*JobSubmitRequest) Descriptor() ([]byte, []int)
func (*JobSubmitRequest) GetJobRequestItems ¶
func (m *JobSubmitRequest) GetJobRequestItems() []*JobSubmitRequestItem
func (*JobSubmitRequest) GetJobSetId ¶
func (m *JobSubmitRequest) GetJobSetId() string
func (*JobSubmitRequest) GetQueue ¶
func (m *JobSubmitRequest) GetQueue() string
func (*JobSubmitRequest) Marshal ¶
func (m *JobSubmitRequest) Marshal() (dAtA []byte, err error)
func (*JobSubmitRequest) MarshalToSizedBuffer ¶
func (m *JobSubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSubmitRequest) ProtoMessage ¶
func (*JobSubmitRequest) ProtoMessage()
func (*JobSubmitRequest) Reset ¶
func (m *JobSubmitRequest) Reset()
func (*JobSubmitRequest) Size ¶
func (m *JobSubmitRequest) Size() (n int)
func (*JobSubmitRequest) String ¶
func (this *JobSubmitRequest) String() string
func (*JobSubmitRequest) Unmarshal ¶
func (m *JobSubmitRequest) Unmarshal(dAtA []byte) error
func (*JobSubmitRequest) XXX_DiscardUnknown ¶
func (m *JobSubmitRequest) XXX_DiscardUnknown()
func (*JobSubmitRequest) XXX_Marshal ¶
func (m *JobSubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSubmitRequest) XXX_Merge ¶
func (m *JobSubmitRequest) XXX_Merge(src proto.Message)
func (*JobSubmitRequest) XXX_Size ¶
func (m *JobSubmitRequest) XXX_Size() int
func (*JobSubmitRequest) XXX_Unmarshal ¶
func (m *JobSubmitRequest) XXX_Unmarshal(b []byte) error
type JobSubmitRequestItem ¶
type JobSubmitRequestItem struct { Priority float64 `protobuf:"fixed64,1,opt,name=priority,proto3" json:"priority,omitempty"` Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` ClientId string `protobuf:"bytes,8,opt,name=client_id,json=clientId,proto3" json:"clientId,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Annotations map[string]string `` /* 163-byte string literal not displayed */ RequiredNodeLabels map[string]string `` // Deprecated: Do not use. /* 203-byte string literal not displayed */ PodSpec *v1.PodSpec `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"` // Deprecated: Do not use. PodSpecs []*v1.PodSpec `protobuf:"bytes,7,rep,name=pod_specs,json=podSpecs,proto3" json:"podSpecs,omitempty"` Ingress []*IngressConfig `protobuf:"bytes,9,rep,name=ingress,proto3" json:"ingress,omitempty"` Services []*ServiceConfig `protobuf:"bytes,10,rep,name=services,proto3" json:"services,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"` // Queuing TTL for this job in seconds. If this job queues for more than this duration it will be cancelled. Zero indicates an infinite lifetime. QueueTtlSeconds int64 `protobuf:"varint,12,opt,name=queue_ttl_seconds,json=queueTtlSeconds,proto3" json:"queueTtlSeconds,omitempty"` }
func (*JobSubmitRequestItem) Descriptor ¶
func (*JobSubmitRequestItem) Descriptor() ([]byte, []int)
func (*JobSubmitRequestItem) GetAnnotations ¶
func (m *JobSubmitRequestItem) GetAnnotations() map[string]string
func (*JobSubmitRequestItem) GetClientId ¶
func (m *JobSubmitRequestItem) GetClientId() string
func (*JobSubmitRequestItem) GetIngress ¶
func (m *JobSubmitRequestItem) GetIngress() []*IngressConfig
func (*JobSubmitRequestItem) GetLabels ¶
func (m *JobSubmitRequestItem) GetLabels() map[string]string
func (*JobSubmitRequestItem) GetMainPodSpec ¶ added in v0.3.70
func (job *JobSubmitRequestItem) GetMainPodSpec() *v1.PodSpec
func (*JobSubmitRequestItem) GetNamespace ¶
func (m *JobSubmitRequestItem) GetNamespace() string
func (*JobSubmitRequestItem) GetPodSpec
deprecated
func (m *JobSubmitRequestItem) GetPodSpec() *v1.PodSpec
Deprecated: Do not use.
func (*JobSubmitRequestItem) GetPodSpecs ¶
func (m *JobSubmitRequestItem) GetPodSpecs() []*v1.PodSpec
func (*JobSubmitRequestItem) GetPriority ¶
func (m *JobSubmitRequestItem) GetPriority() float64
func (*JobSubmitRequestItem) GetQueueTtlSeconds ¶ added in v0.3.95
func (m *JobSubmitRequestItem) GetQueueTtlSeconds() int64
func (*JobSubmitRequestItem) GetRequiredNodeLabels
deprecated
func (m *JobSubmitRequestItem) GetRequiredNodeLabels() map[string]string
Deprecated: Do not use.
func (*JobSubmitRequestItem) GetScheduler ¶
func (m *JobSubmitRequestItem) GetScheduler() string
func (*JobSubmitRequestItem) GetServices ¶
func (m *JobSubmitRequestItem) GetServices() []*ServiceConfig
func (*JobSubmitRequestItem) Marshal ¶
func (m *JobSubmitRequestItem) Marshal() (dAtA []byte, err error)
func (*JobSubmitRequestItem) MarshalTo ¶
func (m *JobSubmitRequestItem) MarshalTo(dAtA []byte) (int, error)
func (*JobSubmitRequestItem) MarshalToSizedBuffer ¶
func (m *JobSubmitRequestItem) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSubmitRequestItem) ProtoMessage ¶
func (*JobSubmitRequestItem) ProtoMessage()
func (*JobSubmitRequestItem) Reset ¶
func (m *JobSubmitRequestItem) Reset()
func (*JobSubmitRequestItem) Size ¶
func (m *JobSubmitRequestItem) Size() (n int)
func (*JobSubmitRequestItem) String ¶
func (this *JobSubmitRequestItem) String() string
func (*JobSubmitRequestItem) Unmarshal ¶
func (m *JobSubmitRequestItem) Unmarshal(dAtA []byte) error
func (*JobSubmitRequestItem) XXX_DiscardUnknown ¶
func (m *JobSubmitRequestItem) XXX_DiscardUnknown()
func (*JobSubmitRequestItem) XXX_Marshal ¶
func (m *JobSubmitRequestItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSubmitRequestItem) XXX_Merge ¶
func (m *JobSubmitRequestItem) XXX_Merge(src proto.Message)
func (*JobSubmitRequestItem) XXX_Size ¶
func (m *JobSubmitRequestItem) XXX_Size() int
func (*JobSubmitRequestItem) XXX_Unmarshal ¶
func (m *JobSubmitRequestItem) XXX_Unmarshal(b []byte) error
type JobSubmitResponse ¶
type JobSubmitResponse struct {
JobResponseItems []*JobSubmitResponseItem `protobuf:"bytes,1,rep,name=job_response_items,json=jobResponseItems,proto3" json:"jobResponseItems,omitempty"`
}
swagger:model
func (*JobSubmitResponse) Descriptor ¶
func (*JobSubmitResponse) Descriptor() ([]byte, []int)
func (*JobSubmitResponse) GetJobResponseItems ¶
func (m *JobSubmitResponse) GetJobResponseItems() []*JobSubmitResponseItem
func (*JobSubmitResponse) Marshal ¶
func (m *JobSubmitResponse) Marshal() (dAtA []byte, err error)
func (*JobSubmitResponse) MarshalTo ¶
func (m *JobSubmitResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobSubmitResponse) MarshalToSizedBuffer ¶
func (m *JobSubmitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSubmitResponse) ProtoMessage ¶
func (*JobSubmitResponse) ProtoMessage()
func (*JobSubmitResponse) Reset ¶
func (m *JobSubmitResponse) Reset()
func (*JobSubmitResponse) Size ¶
func (m *JobSubmitResponse) Size() (n int)
func (*JobSubmitResponse) String ¶
func (this *JobSubmitResponse) String() string
func (*JobSubmitResponse) Unmarshal ¶
func (m *JobSubmitResponse) Unmarshal(dAtA []byte) error
func (*JobSubmitResponse) XXX_DiscardUnknown ¶
func (m *JobSubmitResponse) XXX_DiscardUnknown()
func (*JobSubmitResponse) XXX_Marshal ¶
func (m *JobSubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSubmitResponse) XXX_Merge ¶
func (m *JobSubmitResponse) XXX_Merge(src proto.Message)
func (*JobSubmitResponse) XXX_Size ¶
func (m *JobSubmitResponse) XXX_Size() int
func (*JobSubmitResponse) XXX_Unmarshal ¶
func (m *JobSubmitResponse) XXX_Unmarshal(b []byte) error
type JobSubmitResponseItem ¶
type JobSubmitResponseItem struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
func (*JobSubmitResponseItem) Descriptor ¶
func (*JobSubmitResponseItem) Descriptor() ([]byte, []int)
func (*JobSubmitResponseItem) GetError ¶
func (m *JobSubmitResponseItem) GetError() string
func (*JobSubmitResponseItem) GetJobId ¶
func (m *JobSubmitResponseItem) GetJobId() string
func (*JobSubmitResponseItem) Marshal ¶
func (m *JobSubmitResponseItem) Marshal() (dAtA []byte, err error)
func (*JobSubmitResponseItem) MarshalTo ¶
func (m *JobSubmitResponseItem) MarshalTo(dAtA []byte) (int, error)
func (*JobSubmitResponseItem) MarshalToSizedBuffer ¶
func (m *JobSubmitResponseItem) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSubmitResponseItem) ProtoMessage ¶
func (*JobSubmitResponseItem) ProtoMessage()
func (*JobSubmitResponseItem) Reset ¶
func (m *JobSubmitResponseItem) Reset()
func (*JobSubmitResponseItem) Size ¶
func (m *JobSubmitResponseItem) Size() (n int)
func (*JobSubmitResponseItem) String ¶
func (this *JobSubmitResponseItem) String() string
func (*JobSubmitResponseItem) Unmarshal ¶
func (m *JobSubmitResponseItem) Unmarshal(dAtA []byte) error
func (*JobSubmitResponseItem) XXX_DiscardUnknown ¶
func (m *JobSubmitResponseItem) XXX_DiscardUnknown()
func (*JobSubmitResponseItem) XXX_Marshal ¶
func (m *JobSubmitResponseItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSubmitResponseItem) XXX_Merge ¶
func (m *JobSubmitResponseItem) XXX_Merge(src proto.Message)
func (*JobSubmitResponseItem) XXX_Size ¶
func (m *JobSubmitResponseItem) XXX_Size() int
func (*JobSubmitResponseItem) XXX_Unmarshal ¶
func (m *JobSubmitResponseItem) XXX_Unmarshal(b []byte) error
type JobSubmittedEvent ¶
type JobSubmittedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` Job Job `protobuf:"bytes,5,opt,name=job,proto3" json:"job"` }
func (*JobSubmittedEvent) Descriptor ¶
func (*JobSubmittedEvent) Descriptor() ([]byte, []int)
func (*JobSubmittedEvent) GetCreated ¶
func (m *JobSubmittedEvent) GetCreated() time.Time
func (*JobSubmittedEvent) GetJob ¶
func (m *JobSubmittedEvent) GetJob() Job
func (*JobSubmittedEvent) GetJobId ¶
func (m *JobSubmittedEvent) GetJobId() string
func (*JobSubmittedEvent) GetJobSetId ¶
func (m *JobSubmittedEvent) GetJobSetId() string
func (*JobSubmittedEvent) GetQueue ¶
func (m *JobSubmittedEvent) GetQueue() string
func (*JobSubmittedEvent) Marshal ¶
func (m *JobSubmittedEvent) Marshal() (dAtA []byte, err error)
func (*JobSubmittedEvent) MarshalTo ¶
func (m *JobSubmittedEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobSubmittedEvent) MarshalToSizedBuffer ¶
func (m *JobSubmittedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSubmittedEvent) ProtoMessage ¶
func (*JobSubmittedEvent) ProtoMessage()
func (*JobSubmittedEvent) Reset ¶
func (m *JobSubmittedEvent) Reset()
func (*JobSubmittedEvent) Size ¶
func (m *JobSubmittedEvent) Size() (n int)
func (*JobSubmittedEvent) String ¶
func (this *JobSubmittedEvent) String() string
func (*JobSubmittedEvent) Unmarshal ¶
func (m *JobSubmittedEvent) Unmarshal(dAtA []byte) error
func (*JobSubmittedEvent) XXX_DiscardUnknown ¶
func (m *JobSubmittedEvent) XXX_DiscardUnknown()
func (*JobSubmittedEvent) XXX_Marshal ¶
func (m *JobSubmittedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSubmittedEvent) XXX_Merge ¶
func (m *JobSubmittedEvent) XXX_Merge(src proto.Message)
func (*JobSubmittedEvent) XXX_Size ¶
func (m *JobSubmittedEvent) XXX_Size() int
func (*JobSubmittedEvent) XXX_Unmarshal ¶
func (m *JobSubmittedEvent) XXX_Unmarshal(b []byte) error
type JobSucceededEvent ¶
type JobSucceededEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` NodeName string `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` }
func (*JobSucceededEvent) Descriptor ¶
func (*JobSucceededEvent) Descriptor() ([]byte, []int)
func (*JobSucceededEvent) GetClusterId ¶
func (m *JobSucceededEvent) GetClusterId() string
func (*JobSucceededEvent) GetCreated ¶
func (m *JobSucceededEvent) GetCreated() time.Time
func (*JobSucceededEvent) GetJobId ¶
func (m *JobSucceededEvent) GetJobId() string
func (*JobSucceededEvent) GetJobSetId ¶
func (m *JobSucceededEvent) GetJobSetId() string
func (*JobSucceededEvent) GetKubernetesId ¶
func (m *JobSucceededEvent) GetKubernetesId() string
func (*JobSucceededEvent) GetNodeName ¶
func (m *JobSucceededEvent) GetNodeName() string
func (*JobSucceededEvent) GetPodName ¶
func (m *JobSucceededEvent) GetPodName() string
func (*JobSucceededEvent) GetPodNamespace ¶
func (m *JobSucceededEvent) GetPodNamespace() string
func (*JobSucceededEvent) GetPodNumber ¶
func (m *JobSucceededEvent) GetPodNumber() int32
func (*JobSucceededEvent) GetQueue ¶
func (m *JobSucceededEvent) GetQueue() string
func (*JobSucceededEvent) Marshal ¶
func (m *JobSucceededEvent) Marshal() (dAtA []byte, err error)
func (*JobSucceededEvent) MarshalTo ¶
func (m *JobSucceededEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobSucceededEvent) MarshalToSizedBuffer ¶
func (m *JobSucceededEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSucceededEvent) ProtoMessage ¶
func (*JobSucceededEvent) ProtoMessage()
func (*JobSucceededEvent) Reset ¶
func (m *JobSucceededEvent) Reset()
func (*JobSucceededEvent) Size ¶
func (m *JobSucceededEvent) Size() (n int)
func (*JobSucceededEvent) String ¶
func (this *JobSucceededEvent) String() string
func (*JobSucceededEvent) Unmarshal ¶
func (m *JobSucceededEvent) Unmarshal(dAtA []byte) error
func (*JobSucceededEvent) XXX_DiscardUnknown ¶
func (m *JobSucceededEvent) XXX_DiscardUnknown()
func (*JobSucceededEvent) XXX_Marshal ¶
func (m *JobSucceededEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSucceededEvent) XXX_Merge ¶
func (m *JobSucceededEvent) XXX_Merge(src proto.Message)
func (*JobSucceededEvent) XXX_Size ¶
func (m *JobSucceededEvent) XXX_Size() int
func (*JobSucceededEvent) XXX_Unmarshal ¶
func (m *JobSucceededEvent) XXX_Unmarshal(b []byte) error
type JobTerminatedEvent ¶
type JobTerminatedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` PodNumber int32 `protobuf:"varint,7,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` Reason string `protobuf:"bytes,8,opt,name=reason,proto3" json:"reason,omitempty"` }
func (*JobTerminatedEvent) Descriptor ¶
func (*JobTerminatedEvent) Descriptor() ([]byte, []int)
func (*JobTerminatedEvent) GetClusterId ¶
func (m *JobTerminatedEvent) GetClusterId() string
func (*JobTerminatedEvent) GetCreated ¶
func (m *JobTerminatedEvent) GetCreated() time.Time
func (*JobTerminatedEvent) GetJobId ¶
func (m *JobTerminatedEvent) GetJobId() string
func (*JobTerminatedEvent) GetJobSetId ¶
func (m *JobTerminatedEvent) GetJobSetId() string
func (*JobTerminatedEvent) GetKubernetesId ¶
func (m *JobTerminatedEvent) GetKubernetesId() string
func (*JobTerminatedEvent) GetPodName ¶
func (m *JobTerminatedEvent) GetPodName() string
func (*JobTerminatedEvent) GetPodNamespace ¶
func (m *JobTerminatedEvent) GetPodNamespace() string
func (*JobTerminatedEvent) GetPodNumber ¶
func (m *JobTerminatedEvent) GetPodNumber() int32
func (*JobTerminatedEvent) GetQueue ¶
func (m *JobTerminatedEvent) GetQueue() string
func (*JobTerminatedEvent) GetReason ¶
func (m *JobTerminatedEvent) GetReason() string
func (*JobTerminatedEvent) Marshal ¶
func (m *JobTerminatedEvent) Marshal() (dAtA []byte, err error)
func (*JobTerminatedEvent) MarshalTo ¶
func (m *JobTerminatedEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobTerminatedEvent) MarshalToSizedBuffer ¶
func (m *JobTerminatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobTerminatedEvent) ProtoMessage ¶
func (*JobTerminatedEvent) ProtoMessage()
func (*JobTerminatedEvent) Reset ¶
func (m *JobTerminatedEvent) Reset()
func (*JobTerminatedEvent) Size ¶
func (m *JobTerminatedEvent) Size() (n int)
func (*JobTerminatedEvent) String ¶
func (this *JobTerminatedEvent) String() string
func (*JobTerminatedEvent) Unmarshal ¶
func (m *JobTerminatedEvent) Unmarshal(dAtA []byte) error
func (*JobTerminatedEvent) XXX_DiscardUnknown ¶
func (m *JobTerminatedEvent) XXX_DiscardUnknown()
func (*JobTerminatedEvent) XXX_Marshal ¶
func (m *JobTerminatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobTerminatedEvent) XXX_Merge ¶
func (m *JobTerminatedEvent) XXX_Merge(src proto.Message)
func (*JobTerminatedEvent) XXX_Size ¶
func (m *JobTerminatedEvent) XXX_Size() int
func (*JobTerminatedEvent) XXX_Unmarshal ¶
func (m *JobTerminatedEvent) XXX_Unmarshal(b []byte) error
type JobUnableToScheduleEvent ¶
type JobUnableToScheduleEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` KubernetesId string `protobuf:"bytes,7,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` NodeName string `protobuf:"bytes,8,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,9,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` }
func (*JobUnableToScheduleEvent) Descriptor ¶
func (*JobUnableToScheduleEvent) Descriptor() ([]byte, []int)
func (*JobUnableToScheduleEvent) GetClusterId ¶
func (m *JobUnableToScheduleEvent) GetClusterId() string
func (*JobUnableToScheduleEvent) GetCreated ¶
func (m *JobUnableToScheduleEvent) GetCreated() time.Time
func (*JobUnableToScheduleEvent) GetJobId ¶
func (m *JobUnableToScheduleEvent) GetJobId() string
func (*JobUnableToScheduleEvent) GetJobSetId ¶
func (m *JobUnableToScheduleEvent) GetJobSetId() string
func (*JobUnableToScheduleEvent) GetKubernetesId ¶
func (m *JobUnableToScheduleEvent) GetKubernetesId() string
func (*JobUnableToScheduleEvent) GetNodeName ¶
func (m *JobUnableToScheduleEvent) GetNodeName() string
func (*JobUnableToScheduleEvent) GetPodName ¶
func (m *JobUnableToScheduleEvent) GetPodName() string
func (*JobUnableToScheduleEvent) GetPodNamespace ¶
func (m *JobUnableToScheduleEvent) GetPodNamespace() string
func (*JobUnableToScheduleEvent) GetPodNumber ¶
func (m *JobUnableToScheduleEvent) GetPodNumber() int32
func (*JobUnableToScheduleEvent) GetQueue ¶
func (m *JobUnableToScheduleEvent) GetQueue() string
func (*JobUnableToScheduleEvent) GetReason ¶
func (m *JobUnableToScheduleEvent) GetReason() string
func (*JobUnableToScheduleEvent) Marshal ¶
func (m *JobUnableToScheduleEvent) Marshal() (dAtA []byte, err error)
func (*JobUnableToScheduleEvent) MarshalTo ¶
func (m *JobUnableToScheduleEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobUnableToScheduleEvent) MarshalToSizedBuffer ¶
func (m *JobUnableToScheduleEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobUnableToScheduleEvent) ProtoMessage ¶
func (*JobUnableToScheduleEvent) ProtoMessage()
func (*JobUnableToScheduleEvent) Reset ¶
func (m *JobUnableToScheduleEvent) Reset()
func (*JobUnableToScheduleEvent) Size ¶
func (m *JobUnableToScheduleEvent) Size() (n int)
func (*JobUnableToScheduleEvent) String ¶
func (this *JobUnableToScheduleEvent) String() string
func (*JobUnableToScheduleEvent) Unmarshal ¶
func (m *JobUnableToScheduleEvent) Unmarshal(dAtA []byte) error
func (*JobUnableToScheduleEvent) XXX_DiscardUnknown ¶
func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()
func (*JobUnableToScheduleEvent) XXX_Marshal ¶
func (m *JobUnableToScheduleEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobUnableToScheduleEvent) XXX_Merge ¶
func (m *JobUnableToScheduleEvent) XXX_Merge(src proto.Message)
func (*JobUnableToScheduleEvent) XXX_Size ¶
func (m *JobUnableToScheduleEvent) XXX_Size() int
func (*JobUnableToScheduleEvent) XXX_Unmarshal ¶
func (m *JobUnableToScheduleEvent) XXX_Unmarshal(b []byte) error
type JobUpdatedEvent ¶
type JobUpdatedEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` Requestor string `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"` Job Job `protobuf:"bytes,6,opt,name=job,proto3" json:"job"` }
func (*JobUpdatedEvent) Descriptor ¶
func (*JobUpdatedEvent) Descriptor() ([]byte, []int)
func (*JobUpdatedEvent) GetCreated ¶
func (m *JobUpdatedEvent) GetCreated() time.Time
func (*JobUpdatedEvent) GetJob ¶
func (m *JobUpdatedEvent) GetJob() Job
func (*JobUpdatedEvent) GetJobId ¶
func (m *JobUpdatedEvent) GetJobId() string
func (*JobUpdatedEvent) GetJobSetId ¶
func (m *JobUpdatedEvent) GetJobSetId() string
func (*JobUpdatedEvent) GetQueue ¶
func (m *JobUpdatedEvent) GetQueue() string
func (*JobUpdatedEvent) GetRequestor ¶
func (m *JobUpdatedEvent) GetRequestor() string
func (*JobUpdatedEvent) Marshal ¶
func (m *JobUpdatedEvent) Marshal() (dAtA []byte, err error)
func (*JobUpdatedEvent) MarshalToSizedBuffer ¶
func (m *JobUpdatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobUpdatedEvent) ProtoMessage ¶
func (*JobUpdatedEvent) ProtoMessage()
func (*JobUpdatedEvent) Reset ¶
func (m *JobUpdatedEvent) Reset()
func (*JobUpdatedEvent) Size ¶
func (m *JobUpdatedEvent) Size() (n int)
func (*JobUpdatedEvent) String ¶
func (this *JobUpdatedEvent) String() string
func (*JobUpdatedEvent) Unmarshal ¶
func (m *JobUpdatedEvent) Unmarshal(dAtA []byte) error
func (*JobUpdatedEvent) XXX_DiscardUnknown ¶
func (m *JobUpdatedEvent) XXX_DiscardUnknown()
func (*JobUpdatedEvent) XXX_Marshal ¶
func (m *JobUpdatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobUpdatedEvent) XXX_Merge ¶
func (m *JobUpdatedEvent) XXX_Merge(src proto.Message)
func (*JobUpdatedEvent) XXX_Size ¶
func (m *JobUpdatedEvent) XXX_Size() int
func (*JobUpdatedEvent) XXX_Unmarshal ¶
func (m *JobUpdatedEvent) XXX_Unmarshal(b []byte) error
type JobUtilisationEvent ¶
type JobUtilisationEvent struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` Created time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"` ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"` KubernetesId string `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"` MaxResourcesForPeriod map[string]resource.Quantity `` /* 173-byte string literal not displayed */ NodeName string `protobuf:"bytes,8,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"` PodNumber int32 `protobuf:"varint,9,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"` PodName string `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"` PodNamespace string `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"` TotalCumulativeUsage map[string]resource.Quantity `` /* 200-byte string literal not displayed */ }
func (*JobUtilisationEvent) Descriptor ¶
func (*JobUtilisationEvent) Descriptor() ([]byte, []int)
func (*JobUtilisationEvent) GetClusterId ¶
func (m *JobUtilisationEvent) GetClusterId() string
func (*JobUtilisationEvent) GetCreated ¶
func (m *JobUtilisationEvent) GetCreated() time.Time
func (*JobUtilisationEvent) GetJobId ¶
func (m *JobUtilisationEvent) GetJobId() string
func (*JobUtilisationEvent) GetJobSetId ¶
func (m *JobUtilisationEvent) GetJobSetId() string
func (*JobUtilisationEvent) GetKubernetesId ¶
func (m *JobUtilisationEvent) GetKubernetesId() string
func (*JobUtilisationEvent) GetMaxResourcesForPeriod ¶
func (m *JobUtilisationEvent) GetMaxResourcesForPeriod() map[string]resource.Quantity
func (*JobUtilisationEvent) GetNodeName ¶
func (m *JobUtilisationEvent) GetNodeName() string
func (*JobUtilisationEvent) GetPodName ¶
func (m *JobUtilisationEvent) GetPodName() string
func (*JobUtilisationEvent) GetPodNamespace ¶
func (m *JobUtilisationEvent) GetPodNamespace() string
func (*JobUtilisationEvent) GetPodNumber ¶
func (m *JobUtilisationEvent) GetPodNumber() int32
func (*JobUtilisationEvent) GetQueue ¶
func (m *JobUtilisationEvent) GetQueue() string
func (*JobUtilisationEvent) GetTotalCumulativeUsage ¶
func (m *JobUtilisationEvent) GetTotalCumulativeUsage() map[string]resource.Quantity
func (*JobUtilisationEvent) Marshal ¶
func (m *JobUtilisationEvent) Marshal() (dAtA []byte, err error)
func (*JobUtilisationEvent) MarshalTo ¶
func (m *JobUtilisationEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobUtilisationEvent) MarshalToSizedBuffer ¶
func (m *JobUtilisationEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobUtilisationEvent) ProtoMessage ¶
func (*JobUtilisationEvent) ProtoMessage()
func (*JobUtilisationEvent) Reset ¶
func (m *JobUtilisationEvent) Reset()
func (*JobUtilisationEvent) Size ¶
func (m *JobUtilisationEvent) Size() (n int)
func (*JobUtilisationEvent) String ¶
func (this *JobUtilisationEvent) String() string
func (*JobUtilisationEvent) Unmarshal ¶
func (m *JobUtilisationEvent) Unmarshal(dAtA []byte) error
func (*JobUtilisationEvent) XXX_DiscardUnknown ¶
func (m *JobUtilisationEvent) XXX_DiscardUnknown()
func (*JobUtilisationEvent) XXX_Marshal ¶
func (m *JobUtilisationEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobUtilisationEvent) XXX_Merge ¶
func (m *JobUtilisationEvent) XXX_Merge(src proto.Message)
func (*JobUtilisationEvent) XXX_Size ¶
func (m *JobUtilisationEvent) XXX_Size() int
func (*JobUtilisationEvent) XXX_Unmarshal ¶
func (m *JobUtilisationEvent) XXX_Unmarshal(b []byte) error
type KubernetesEvent ¶
type QueryApiClient ¶ added in v0.4.20
type QueryApiClient interface {
GetJobStatus(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
}
QueryApiClient is the client API for QueryApi service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryApiClient ¶ added in v0.4.20
func NewQueryApiClient(cc *grpc.ClientConn) QueryApiClient
type QueryApiServer ¶ added in v0.4.20
type QueryApiServer interface {
GetJobStatus(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
}
QueryApiServer is the server API for QueryApi service.
type Queue ¶
type Queue struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` PriorityFactor float64 `protobuf:"fixed64,2,opt,name=priority_factor,json=priorityFactor,proto3" json:"priorityFactor,omitempty"` UserOwners []string `protobuf:"bytes,3,rep,name=user_owners,json=userOwners,proto3" json:"userOwners,omitempty"` GroupOwners []string `protobuf:"bytes,4,rep,name=group_owners,json=groupOwners,proto3" json:"groupOwners,omitempty"` ResourceLimits map[string]float64 `` /* 192-byte string literal not displayed */ Permissions []*Queue_Permissions `protobuf:"bytes,6,rep,name=permissions,proto3" json:"permissions,omitempty"` }
swagger:model
func (*Queue) Descriptor ¶
func (*Queue) GetGroupOwners ¶
func (*Queue) GetPermissions ¶
func (m *Queue) GetPermissions() []*Queue_Permissions
func (*Queue) GetPriorityFactor ¶
func (*Queue) GetResourceLimits ¶
func (*Queue) GetUserOwners ¶
func (*Queue) ProtoMessage ¶
func (*Queue) ProtoMessage()
func (*Queue) XXX_DiscardUnknown ¶
func (m *Queue) XXX_DiscardUnknown()
func (*Queue) XXX_Marshal ¶
func (*Queue) XXX_Unmarshal ¶
type QueueCreateResponse ¶
type QueueCreateResponse struct { Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
func (*QueueCreateResponse) Descriptor ¶
func (*QueueCreateResponse) Descriptor() ([]byte, []int)
func (*QueueCreateResponse) GetError ¶
func (m *QueueCreateResponse) GetError() string
func (*QueueCreateResponse) GetQueue ¶
func (m *QueueCreateResponse) GetQueue() *Queue
func (*QueueCreateResponse) Marshal ¶
func (m *QueueCreateResponse) Marshal() (dAtA []byte, err error)
func (*QueueCreateResponse) MarshalTo ¶
func (m *QueueCreateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueueCreateResponse) MarshalToSizedBuffer ¶
func (m *QueueCreateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueCreateResponse) ProtoMessage ¶
func (*QueueCreateResponse) ProtoMessage()
func (*QueueCreateResponse) Reset ¶
func (m *QueueCreateResponse) Reset()
func (*QueueCreateResponse) Size ¶
func (m *QueueCreateResponse) Size() (n int)
func (*QueueCreateResponse) String ¶
func (this *QueueCreateResponse) String() string
func (*QueueCreateResponse) Unmarshal ¶
func (m *QueueCreateResponse) Unmarshal(dAtA []byte) error
func (*QueueCreateResponse) XXX_DiscardUnknown ¶
func (m *QueueCreateResponse) XXX_DiscardUnknown()
func (*QueueCreateResponse) XXX_Marshal ¶
func (m *QueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueCreateResponse) XXX_Merge ¶
func (m *QueueCreateResponse) XXX_Merge(src proto.Message)
func (*QueueCreateResponse) XXX_Size ¶
func (m *QueueCreateResponse) XXX_Size() int
func (*QueueCreateResponse) XXX_Unmarshal ¶
func (m *QueueCreateResponse) XXX_Unmarshal(b []byte) error
type QueueDeleteRequest ¶
type QueueDeleteRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*QueueDeleteRequest) Descriptor ¶
func (*QueueDeleteRequest) Descriptor() ([]byte, []int)
func (*QueueDeleteRequest) GetName ¶
func (m *QueueDeleteRequest) GetName() string
func (*QueueDeleteRequest) Marshal ¶
func (m *QueueDeleteRequest) Marshal() (dAtA []byte, err error)
func (*QueueDeleteRequest) MarshalTo ¶
func (m *QueueDeleteRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueueDeleteRequest) MarshalToSizedBuffer ¶
func (m *QueueDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueDeleteRequest) ProtoMessage ¶
func (*QueueDeleteRequest) ProtoMessage()
func (*QueueDeleteRequest) Reset ¶
func (m *QueueDeleteRequest) Reset()
func (*QueueDeleteRequest) Size ¶
func (m *QueueDeleteRequest) Size() (n int)
func (*QueueDeleteRequest) String ¶
func (this *QueueDeleteRequest) String() string
func (*QueueDeleteRequest) Unmarshal ¶
func (m *QueueDeleteRequest) Unmarshal(dAtA []byte) error
func (*QueueDeleteRequest) XXX_DiscardUnknown ¶
func (m *QueueDeleteRequest) XXX_DiscardUnknown()
func (*QueueDeleteRequest) XXX_Marshal ¶
func (m *QueueDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueDeleteRequest) XXX_Merge ¶
func (m *QueueDeleteRequest) XXX_Merge(src proto.Message)
func (*QueueDeleteRequest) XXX_Size ¶
func (m *QueueDeleteRequest) XXX_Size() int
func (*QueueDeleteRequest) XXX_Unmarshal ¶
func (m *QueueDeleteRequest) XXX_Unmarshal(b []byte) error
type QueueGetRequest ¶
type QueueGetRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*QueueGetRequest) Descriptor ¶
func (*QueueGetRequest) Descriptor() ([]byte, []int)
func (*QueueGetRequest) GetName ¶
func (m *QueueGetRequest) GetName() string
func (*QueueGetRequest) Marshal ¶
func (m *QueueGetRequest) Marshal() (dAtA []byte, err error)
func (*QueueGetRequest) MarshalToSizedBuffer ¶
func (m *QueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueGetRequest) ProtoMessage ¶
func (*QueueGetRequest) ProtoMessage()
func (*QueueGetRequest) Reset ¶
func (m *QueueGetRequest) Reset()
func (*QueueGetRequest) Size ¶
func (m *QueueGetRequest) Size() (n int)
func (*QueueGetRequest) String ¶
func (this *QueueGetRequest) String() string
func (*QueueGetRequest) Unmarshal ¶
func (m *QueueGetRequest) Unmarshal(dAtA []byte) error
func (*QueueGetRequest) XXX_DiscardUnknown ¶
func (m *QueueGetRequest) XXX_DiscardUnknown()
func (*QueueGetRequest) XXX_Marshal ¶
func (m *QueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueGetRequest) XXX_Merge ¶
func (m *QueueGetRequest) XXX_Merge(src proto.Message)
func (*QueueGetRequest) XXX_Size ¶
func (m *QueueGetRequest) XXX_Size() int
func (*QueueGetRequest) XXX_Unmarshal ¶
func (m *QueueGetRequest) XXX_Unmarshal(b []byte) error
type QueueList ¶
type QueueList struct {
Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
}
swagger:model
func (*QueueList) Descriptor ¶
func (*QueueList) MarshalToSizedBuffer ¶
func (*QueueList) ProtoMessage ¶
func (*QueueList) ProtoMessage()
func (*QueueList) XXX_DiscardUnknown ¶
func (m *QueueList) XXX_DiscardUnknown()
func (*QueueList) XXX_Marshal ¶
func (*QueueList) XXX_Unmarshal ¶
type QueueUpdateResponse ¶
type QueueUpdateResponse struct { Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
func (*QueueUpdateResponse) Descriptor ¶
func (*QueueUpdateResponse) Descriptor() ([]byte, []int)
func (*QueueUpdateResponse) GetError ¶
func (m *QueueUpdateResponse) GetError() string
func (*QueueUpdateResponse) GetQueue ¶
func (m *QueueUpdateResponse) GetQueue() *Queue
func (*QueueUpdateResponse) Marshal ¶
func (m *QueueUpdateResponse) Marshal() (dAtA []byte, err error)
func (*QueueUpdateResponse) MarshalTo ¶
func (m *QueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueueUpdateResponse) MarshalToSizedBuffer ¶
func (m *QueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueUpdateResponse) ProtoMessage ¶
func (*QueueUpdateResponse) ProtoMessage()
func (*QueueUpdateResponse) Reset ¶
func (m *QueueUpdateResponse) Reset()
func (*QueueUpdateResponse) Size ¶
func (m *QueueUpdateResponse) Size() (n int)
func (*QueueUpdateResponse) String ¶
func (this *QueueUpdateResponse) String() string
func (*QueueUpdateResponse) Unmarshal ¶
func (m *QueueUpdateResponse) Unmarshal(dAtA []byte) error
func (*QueueUpdateResponse) XXX_DiscardUnknown ¶
func (m *QueueUpdateResponse) XXX_DiscardUnknown()
func (*QueueUpdateResponse) XXX_Marshal ¶
func (m *QueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueUpdateResponse) XXX_Merge ¶
func (m *QueueUpdateResponse) XXX_Merge(src proto.Message)
func (*QueueUpdateResponse) XXX_Size ¶
func (m *QueueUpdateResponse) XXX_Size() int
func (*QueueUpdateResponse) XXX_Unmarshal ¶
func (m *QueueUpdateResponse) XXX_Unmarshal(b []byte) error
type Queue_Permissions ¶
type Queue_Permissions struct { Subjects []*Queue_Permissions_Subject `protobuf:"bytes,1,rep,name=subjects,proto3" json:"subjects,omitempty"` Verbs []string `protobuf:"bytes,2,rep,name=verbs,proto3" json:"verbs,omitempty"` }
func (*Queue_Permissions) Descriptor ¶
func (*Queue_Permissions) Descriptor() ([]byte, []int)
func (*Queue_Permissions) GetSubjects ¶
func (m *Queue_Permissions) GetSubjects() []*Queue_Permissions_Subject
func (*Queue_Permissions) GetVerbs ¶
func (m *Queue_Permissions) GetVerbs() []string
func (*Queue_Permissions) Marshal ¶
func (m *Queue_Permissions) Marshal() (dAtA []byte, err error)
func (*Queue_Permissions) MarshalTo ¶
func (m *Queue_Permissions) MarshalTo(dAtA []byte) (int, error)
func (*Queue_Permissions) MarshalToSizedBuffer ¶
func (m *Queue_Permissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Queue_Permissions) ProtoMessage ¶
func (*Queue_Permissions) ProtoMessage()
func (*Queue_Permissions) Reset ¶
func (m *Queue_Permissions) Reset()
func (*Queue_Permissions) Size ¶
func (m *Queue_Permissions) Size() (n int)
func (*Queue_Permissions) String ¶
func (this *Queue_Permissions) String() string
func (*Queue_Permissions) Unmarshal ¶
func (m *Queue_Permissions) Unmarshal(dAtA []byte) error
func (*Queue_Permissions) XXX_DiscardUnknown ¶
func (m *Queue_Permissions) XXX_DiscardUnknown()
func (*Queue_Permissions) XXX_Marshal ¶
func (m *Queue_Permissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Queue_Permissions) XXX_Merge ¶
func (m *Queue_Permissions) XXX_Merge(src proto.Message)
func (*Queue_Permissions) XXX_Size ¶
func (m *Queue_Permissions) XXX_Size() int
func (*Queue_Permissions) XXX_Unmarshal ¶
func (m *Queue_Permissions) XXX_Unmarshal(b []byte) error
type Queue_Permissions_Subject ¶
type Queue_Permissions_Subject struct { Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` }
func (*Queue_Permissions_Subject) Descriptor ¶
func (*Queue_Permissions_Subject) Descriptor() ([]byte, []int)
func (*Queue_Permissions_Subject) GetKind ¶
func (m *Queue_Permissions_Subject) GetKind() string
func (*Queue_Permissions_Subject) GetName ¶
func (m *Queue_Permissions_Subject) GetName() string
func (*Queue_Permissions_Subject) Marshal ¶
func (m *Queue_Permissions_Subject) Marshal() (dAtA []byte, err error)
func (*Queue_Permissions_Subject) MarshalTo ¶
func (m *Queue_Permissions_Subject) MarshalTo(dAtA []byte) (int, error)
func (*Queue_Permissions_Subject) MarshalToSizedBuffer ¶
func (m *Queue_Permissions_Subject) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Queue_Permissions_Subject) ProtoMessage ¶
func (*Queue_Permissions_Subject) ProtoMessage()
func (*Queue_Permissions_Subject) Reset ¶
func (m *Queue_Permissions_Subject) Reset()
func (*Queue_Permissions_Subject) Size ¶
func (m *Queue_Permissions_Subject) Size() (n int)
func (*Queue_Permissions_Subject) String ¶
func (this *Queue_Permissions_Subject) String() string
func (*Queue_Permissions_Subject) Unmarshal ¶
func (m *Queue_Permissions_Subject) Unmarshal(dAtA []byte) error
func (*Queue_Permissions_Subject) XXX_DiscardUnknown ¶
func (m *Queue_Permissions_Subject) XXX_DiscardUnknown()
func (*Queue_Permissions_Subject) XXX_Marshal ¶
func (m *Queue_Permissions_Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Queue_Permissions_Subject) XXX_Merge ¶
func (m *Queue_Permissions_Subject) XXX_Merge(src proto.Message)
func (*Queue_Permissions_Subject) XXX_Size ¶
func (m *Queue_Permissions_Subject) XXX_Size() int
func (*Queue_Permissions_Subject) XXX_Unmarshal ¶
func (m *Queue_Permissions_Subject) XXX_Unmarshal(b []byte) error
type ServiceConfig ¶
type ServiceConfig struct { Type ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=api.ServiceType" json:"type,omitempty"` Ports []uint32 `protobuf:"varint,2,rep,packed,name=ports,proto3" json:"ports,omitempty"` }
func (*ServiceConfig) Descriptor ¶
func (*ServiceConfig) Descriptor() ([]byte, []int)
func (*ServiceConfig) GetPorts ¶
func (m *ServiceConfig) GetPorts() []uint32
func (*ServiceConfig) GetType ¶
func (m *ServiceConfig) GetType() ServiceType
func (*ServiceConfig) Marshal ¶
func (m *ServiceConfig) Marshal() (dAtA []byte, err error)
func (*ServiceConfig) MarshalToSizedBuffer ¶
func (m *ServiceConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ServiceConfig) ProtoMessage ¶
func (*ServiceConfig) ProtoMessage()
func (*ServiceConfig) Reset ¶
func (m *ServiceConfig) Reset()
func (*ServiceConfig) Size ¶
func (m *ServiceConfig) Size() (n int)
func (*ServiceConfig) String ¶
func (this *ServiceConfig) String() string
func (*ServiceConfig) Unmarshal ¶
func (m *ServiceConfig) Unmarshal(dAtA []byte) error
func (*ServiceConfig) XXX_DiscardUnknown ¶
func (m *ServiceConfig) XXX_DiscardUnknown()
func (*ServiceConfig) XXX_Marshal ¶
func (m *ServiceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceConfig) XXX_Merge ¶
func (m *ServiceConfig) XXX_Merge(src proto.Message)
func (*ServiceConfig) XXX_Size ¶
func (m *ServiceConfig) XXX_Size() int
func (*ServiceConfig) XXX_Unmarshal ¶
func (m *ServiceConfig) XXX_Unmarshal(b []byte) error
type ServiceType ¶
type ServiceType int32
const ( ServiceType_NodePort ServiceType = 0 ServiceType_Headless ServiceType = 1 )
func (ServiceType) EnumDescriptor ¶
func (ServiceType) EnumDescriptor() ([]byte, []int)
func (ServiceType) String ¶
func (x ServiceType) String() string
func (*ServiceType) UnmarshalJSON ¶
func (x *ServiceType) UnmarshalJSON(data []byte) error
type StreamingQueueGetRequest ¶ added in v0.3.100
type StreamingQueueGetRequest struct {
Num uint32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
}
func (*StreamingQueueGetRequest) Descriptor ¶ added in v0.3.100
func (*StreamingQueueGetRequest) Descriptor() ([]byte, []int)
func (*StreamingQueueGetRequest) GetNum ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) GetNum() uint32
func (*StreamingQueueGetRequest) Marshal ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) Marshal() (dAtA []byte, err error)
func (*StreamingQueueGetRequest) MarshalTo ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) MarshalTo(dAtA []byte) (int, error)
func (*StreamingQueueGetRequest) MarshalToSizedBuffer ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamingQueueGetRequest) ProtoMessage ¶ added in v0.3.100
func (*StreamingQueueGetRequest) ProtoMessage()
func (*StreamingQueueGetRequest) Reset ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) Reset()
func (*StreamingQueueGetRequest) Size ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) Size() (n int)
func (*StreamingQueueGetRequest) String ¶ added in v0.3.100
func (this *StreamingQueueGetRequest) String() string
func (*StreamingQueueGetRequest) Unmarshal ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) Unmarshal(dAtA []byte) error
func (*StreamingQueueGetRequest) XXX_DiscardUnknown ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) XXX_DiscardUnknown()
func (*StreamingQueueGetRequest) XXX_Marshal ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingQueueGetRequest) XXX_Merge ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) XXX_Merge(src proto.Message)
func (*StreamingQueueGetRequest) XXX_Size ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) XXX_Size() int
func (*StreamingQueueGetRequest) XXX_Unmarshal ¶ added in v0.3.100
func (m *StreamingQueueGetRequest) XXX_Unmarshal(b []byte) error
type StreamingQueueMessage ¶ added in v0.3.100
type StreamingQueueMessage struct { // Types that are valid to be assigned to Event: // *StreamingQueueMessage_Queue // *StreamingQueueMessage_End Event isStreamingQueueMessage_Event `protobuf_oneof:"event"` }
func (*StreamingQueueMessage) Descriptor ¶ added in v0.3.100
func (*StreamingQueueMessage) Descriptor() ([]byte, []int)
func (*StreamingQueueMessage) GetEnd ¶ added in v0.3.100
func (m *StreamingQueueMessage) GetEnd() *EndMarker
func (*StreamingQueueMessage) GetEvent ¶ added in v0.3.100
func (m *StreamingQueueMessage) GetEvent() isStreamingQueueMessage_Event
func (*StreamingQueueMessage) GetQueue ¶ added in v0.3.100
func (m *StreamingQueueMessage) GetQueue() *Queue
func (*StreamingQueueMessage) Marshal ¶ added in v0.3.100
func (m *StreamingQueueMessage) Marshal() (dAtA []byte, err error)
func (*StreamingQueueMessage) MarshalTo ¶ added in v0.3.100
func (m *StreamingQueueMessage) MarshalTo(dAtA []byte) (int, error)
func (*StreamingQueueMessage) MarshalToSizedBuffer ¶ added in v0.3.100
func (m *StreamingQueueMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamingQueueMessage) ProtoMessage ¶ added in v0.3.100
func (*StreamingQueueMessage) ProtoMessage()
func (*StreamingQueueMessage) Reset ¶ added in v0.3.100
func (m *StreamingQueueMessage) Reset()
func (*StreamingQueueMessage) Size ¶ added in v0.3.100
func (m *StreamingQueueMessage) Size() (n int)
func (*StreamingQueueMessage) String ¶ added in v0.3.100
func (this *StreamingQueueMessage) String() string
func (*StreamingQueueMessage) Unmarshal ¶ added in v0.3.100
func (m *StreamingQueueMessage) Unmarshal(dAtA []byte) error
func (*StreamingQueueMessage) XXX_DiscardUnknown ¶ added in v0.3.100
func (m *StreamingQueueMessage) XXX_DiscardUnknown()
func (*StreamingQueueMessage) XXX_Marshal ¶ added in v0.3.100
func (m *StreamingQueueMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamingQueueMessage) XXX_Merge ¶ added in v0.3.100
func (m *StreamingQueueMessage) XXX_Merge(src proto.Message)
func (*StreamingQueueMessage) XXX_OneofWrappers ¶ added in v0.3.100
func (*StreamingQueueMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*StreamingQueueMessage) XXX_Size ¶ added in v0.3.100
func (m *StreamingQueueMessage) XXX_Size() int
func (*StreamingQueueMessage) XXX_Unmarshal ¶ added in v0.3.100
func (m *StreamingQueueMessage) XXX_Unmarshal(b []byte) error
type StreamingQueueMessage_End ¶ added in v0.3.100
type StreamingQueueMessage_End struct {
End *EndMarker `protobuf:"bytes,2,opt,name=end,proto3,oneof" json:"end,omitempty"`
}
func (*StreamingQueueMessage_End) MarshalTo ¶ added in v0.3.100
func (m *StreamingQueueMessage_End) MarshalTo(dAtA []byte) (int, error)
func (*StreamingQueueMessage_End) MarshalToSizedBuffer ¶ added in v0.3.100
func (m *StreamingQueueMessage_End) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamingQueueMessage_End) Size ¶ added in v0.3.100
func (m *StreamingQueueMessage_End) Size() (n int)
func (*StreamingQueueMessage_End) String ¶ added in v0.3.100
func (this *StreamingQueueMessage_End) String() string
type StreamingQueueMessage_Queue ¶ added in v0.3.100
type StreamingQueueMessage_Queue struct {
Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3,oneof" json:"queue,omitempty"`
}
func (*StreamingQueueMessage_Queue) MarshalTo ¶ added in v0.3.100
func (m *StreamingQueueMessage_Queue) MarshalTo(dAtA []byte) (int, error)
func (*StreamingQueueMessage_Queue) MarshalToSizedBuffer ¶ added in v0.3.100
func (m *StreamingQueueMessage_Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamingQueueMessage_Queue) Size ¶ added in v0.3.100
func (m *StreamingQueueMessage_Queue) Size() (n int)
func (*StreamingQueueMessage_Queue) String ¶ added in v0.3.100
func (this *StreamingQueueMessage_Queue) String() string
type SubmitClient ¶
type SubmitClient interface { SubmitJobs(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error) CancelJobs(ctx context.Context, in *JobCancelRequest, opts ...grpc.CallOption) (*CancellationResult, error) CancelJobSet(ctx context.Context, in *JobSetCancelRequest, opts ...grpc.CallOption) (*types.Empty, error) ReprioritizeJobs(ctx context.Context, in *JobReprioritizeRequest, opts ...grpc.CallOption) (*JobReprioritizeResponse, error) CreateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error) CreateQueues(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueCreateResponse, error) UpdateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error) UpdateQueues(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueUpdateResponse, error) DeleteQueue(ctx context.Context, in *QueueDeleteRequest, opts ...grpc.CallOption) (*types.Empty, error) GetQueue(ctx context.Context, in *QueueGetRequest, opts ...grpc.CallOption) (*Queue, error) GetQueues(ctx context.Context, in *StreamingQueueGetRequest, opts ...grpc.CallOption) (Submit_GetQueuesClient, error) Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error) }
SubmitClient is the client API for Submit service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSubmitClient ¶
func NewSubmitClient(cc *grpc.ClientConn) SubmitClient
type SubmitServer ¶
type SubmitServer interface { SubmitJobs(context.Context, *JobSubmitRequest) (*JobSubmitResponse, error) CancelJobs(context.Context, *JobCancelRequest) (*CancellationResult, error) CancelJobSet(context.Context, *JobSetCancelRequest) (*types.Empty, error) ReprioritizeJobs(context.Context, *JobReprioritizeRequest) (*JobReprioritizeResponse, error) CreateQueue(context.Context, *Queue) (*types.Empty, error) CreateQueues(context.Context, *QueueList) (*BatchQueueCreateResponse, error) UpdateQueue(context.Context, *Queue) (*types.Empty, error) UpdateQueues(context.Context, *QueueList) (*BatchQueueUpdateResponse, error) DeleteQueue(context.Context, *QueueDeleteRequest) (*types.Empty, error) GetQueue(context.Context, *QueueGetRequest) (*Queue, error) GetQueues(*StreamingQueueGetRequest, Submit_GetQueuesServer) error Health(context.Context, *types.Empty) (*HealthCheckResponse, error) }
SubmitServer is the server API for Submit service.
type Submit_GetQueuesClient ¶ added in v0.3.100
type Submit_GetQueuesClient interface { Recv() (*StreamingQueueMessage, error) grpc.ClientStream }
type Submit_GetQueuesServer ¶ added in v0.3.100
type Submit_GetQueuesServer interface { Send(*StreamingQueueMessage) error grpc.ServerStream }
type TestSpec ¶
type TestSpec struct { // Jobs to submit. // The n jobs herein are copied BatchSize times to produce n*BatchSize jobs. // A batch of n*BatchSize such jobs are submitted in each API call. // NumBatches such batches are submitted in total. Jobs []*JobSubmitRequestItem `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` // Events expected in response to submitting each job. ExpectedEvents []*EventMessage `protobuf:"bytes,2,rep,name=expected_events,json=expectedEvents,proto3" json:"expectedEvents,omitempty"` // Queue to submit jobs to. Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"` // Job set to submit jobs to. JobSetId string `protobuf:"bytes,4,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` // Number of batches of jobs to submit. // If 0, will submit forever. NumBatches uint32 `protobuf:"varint,5,opt,name=num_batches,json=numBatches,proto3" json:"numBatches,omitempty"` // Number of copies of the provided jobs to submit per batch. BatchSize uint32 `protobuf:"varint,6,opt,name=batch_size,json=batchSize,proto3" json:"batchSize,omitempty"` // Time between batches. // If 0, jobs are submitted as quickly as possible. Interval time.Duration `protobuf:"bytes,7,opt,name=interval,proto3,stdduration" json:"interval"` // Number of seconds to wait for jobs to finish. Timeout time.Duration `protobuf:"bytes,8,opt,name=timeout,proto3,stdduration" json:"timeout"` Cancel TestSpec_Cancel `protobuf:"varint,9,opt,name=cancel,proto3,enum=api.TestSpec_Cancel" json:"cancel,omitempty"` // Test name. Defaults to the filename if not provided. Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"` // Randomize clientId if not provided RandomClientId bool `protobuf:"varint,11,opt,name=random_client_id,json=randomClientId,proto3" json:"randomClientId,omitempty"` // Toggle should testsuite scrape Armada Job (pod) logs GetLogs bool `protobuf:"varint,12,opt,name=get_logs,json=getLogs,proto3" json:"getLogs,omitempty"` // Value of the environment label set on exported Prometheus metrics. Environment string `protobuf:"bytes,13,opt,name=environment,proto3" json:"environment,omitempty"` // Value of the target label set on exported Prometheus metrics. Target string `protobuf:"bytes,14,opt,name=target,proto3" json:"target,omitempty"` }
Defines a test case for the Armada test suite. Defined as a proto message to enable unmarshalling oneof fields.
func (*TestSpec) Descriptor ¶
func (*TestSpec) GetBatchSize ¶
func (*TestSpec) GetCancel ¶
func (m *TestSpec) GetCancel() TestSpec_Cancel
func (*TestSpec) GetEnvironment ¶ added in v0.3.94
func (*TestSpec) GetExpectedEvents ¶
func (m *TestSpec) GetExpectedEvents() []*EventMessage
func (*TestSpec) GetGetLogs ¶
func (*TestSpec) GetInterval ¶
func (*TestSpec) GetJobSetId ¶
func (*TestSpec) GetJobs ¶
func (m *TestSpec) GetJobs() []*JobSubmitRequestItem
func (*TestSpec) GetNumBatches ¶
func (*TestSpec) GetRandomClientId ¶
func (*TestSpec) GetTimeout ¶
func (*TestSpec) MarshalToSizedBuffer ¶
func (*TestSpec) ProtoMessage ¶
func (*TestSpec) ProtoMessage()
func (*TestSpec) ShortString ¶
func (*TestSpec) XXX_DiscardUnknown ¶
func (m *TestSpec) XXX_DiscardUnknown()
func (*TestSpec) XXX_Marshal ¶
func (*TestSpec) XXX_Unmarshal ¶
type TestSpec_Cancel ¶
type TestSpec_Cancel int32
If the jobs in this spec. should be cancelled.
const ( TestSpec_NO TestSpec_Cancel = 0 TestSpec_BY_ID TestSpec_Cancel = 1 TestSpec_BY_SET TestSpec_Cancel = 2 TestSpec_BY_IDS TestSpec_Cancel = 3 )
func (TestSpec_Cancel) EnumDescriptor ¶
func (TestSpec_Cancel) EnumDescriptor() ([]byte, []int)
func (TestSpec_Cancel) String ¶
func (x TestSpec_Cancel) String() string
type UnimplementedEventServer ¶
type UnimplementedEventServer struct { }
UnimplementedEventServer can be embedded to have forward compatible implementations.
func (*UnimplementedEventServer) GetJobSetEvents ¶
func (*UnimplementedEventServer) GetJobSetEvents(req *JobSetRequest, srv Event_GetJobSetEventsServer) error
func (*UnimplementedEventServer) Health ¶
func (*UnimplementedEventServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)
func (*UnimplementedEventServer) Watch ¶
func (*UnimplementedEventServer) Watch(req *WatchRequest, srv Event_WatchServer) error
type UnimplementedQueryApiServer ¶ added in v0.4.20
type UnimplementedQueryApiServer struct { }
UnimplementedQueryApiServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryApiServer) GetJobStatus ¶ added in v0.4.20
func (*UnimplementedQueryApiServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)
type UnimplementedSubmitServer ¶
type UnimplementedSubmitServer struct { }
UnimplementedSubmitServer can be embedded to have forward compatible implementations.
func (*UnimplementedSubmitServer) CancelJobSet ¶
func (*UnimplementedSubmitServer) CancelJobSet(ctx context.Context, req *JobSetCancelRequest) (*types.Empty, error)
func (*UnimplementedSubmitServer) CancelJobs ¶
func (*UnimplementedSubmitServer) CancelJobs(ctx context.Context, req *JobCancelRequest) (*CancellationResult, error)
func (*UnimplementedSubmitServer) CreateQueue ¶
func (*UnimplementedSubmitServer) CreateQueues ¶
func (*UnimplementedSubmitServer) CreateQueues(ctx context.Context, req *QueueList) (*BatchQueueCreateResponse, error)
func (*UnimplementedSubmitServer) DeleteQueue ¶
func (*UnimplementedSubmitServer) DeleteQueue(ctx context.Context, req *QueueDeleteRequest) (*types.Empty, error)
func (*UnimplementedSubmitServer) GetQueue ¶
func (*UnimplementedSubmitServer) GetQueue(ctx context.Context, req *QueueGetRequest) (*Queue, error)
func (*UnimplementedSubmitServer) GetQueues ¶ added in v0.3.100
func (*UnimplementedSubmitServer) GetQueues(req *StreamingQueueGetRequest, srv Submit_GetQueuesServer) error
func (*UnimplementedSubmitServer) Health ¶
func (*UnimplementedSubmitServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)
func (*UnimplementedSubmitServer) ReprioritizeJobs ¶
func (*UnimplementedSubmitServer) ReprioritizeJobs(ctx context.Context, req *JobReprioritizeRequest) (*JobReprioritizeResponse, error)
func (*UnimplementedSubmitServer) SubmitJobs ¶
func (*UnimplementedSubmitServer) SubmitJobs(ctx context.Context, req *JobSubmitRequest) (*JobSubmitResponse, error)
func (*UnimplementedSubmitServer) UpdateQueue ¶
func (*UnimplementedSubmitServer) UpdateQueues ¶
func (*UnimplementedSubmitServer) UpdateQueues(ctx context.Context, req *QueueList) (*BatchQueueUpdateResponse, error)
type WatchRequest ¶
type WatchRequest struct { Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"` JobSetId string `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"` FromId string `protobuf:"bytes,3,opt,name=from_id,json=fromId,proto3" json:"fromId,omitempty"` ForceLegacy bool `protobuf:"varint,4,opt,name=force_legacy,json=forceLegacy,proto3" json:"forceLegacy,omitempty"` ForceNew bool `protobuf:"varint,5,opt,name=force_new,json=forceNew,proto3" json:"forceNew,omitempty"` }
func (*WatchRequest) Descriptor ¶
func (*WatchRequest) Descriptor() ([]byte, []int)
func (*WatchRequest) GetForceLegacy ¶
func (m *WatchRequest) GetForceLegacy() bool
func (*WatchRequest) GetForceNew ¶
func (m *WatchRequest) GetForceNew() bool
func (*WatchRequest) GetFromId ¶
func (m *WatchRequest) GetFromId() string
func (*WatchRequest) GetJobSetId ¶
func (m *WatchRequest) GetJobSetId() string
func (*WatchRequest) GetQueue ¶
func (m *WatchRequest) GetQueue() string
func (*WatchRequest) Marshal ¶
func (m *WatchRequest) Marshal() (dAtA []byte, err error)
func (*WatchRequest) MarshalToSizedBuffer ¶
func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) Reset ¶
func (m *WatchRequest) Reset()
func (*WatchRequest) Size ¶
func (m *WatchRequest) Size() (n int)
func (*WatchRequest) String ¶
func (this *WatchRequest) String() string
func (*WatchRequest) Unmarshal ¶
func (m *WatchRequest) Unmarshal(dAtA []byte) error
func (*WatchRequest) XXX_DiscardUnknown ¶
func (m *WatchRequest) XXX_DiscardUnknown()
func (*WatchRequest) XXX_Marshal ¶
func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchRequest) XXX_Merge ¶
func (m *WatchRequest) XXX_Merge(src proto.Message)
func (*WatchRequest) XXX_Size ¶
func (m *WatchRequest) XXX_Size() int
func (*WatchRequest) XXX_Unmarshal ¶
func (m *WatchRequest) XXX_Unmarshal(b []byte) error
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package binoculars is a reverse proxy.
|
Package binoculars is a reverse proxy. |