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.
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 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 RegisterJobsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterJobsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobsClient) error
- func RegisterJobsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterJobsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobsServer) error
- func RegisterJobsServer(s *grpc.Server, srv JobsServer)
- func RegisterQueueServiceServer(s *grpc.Server, srv QueueServiceServer)
- 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 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 (m *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 (m *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 (m *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 (m *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 (m *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) GetEvents() isEventMessage_Events
- func (m *EventMessage) GetFailed() *JobFailedEvent
- 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) GetPreempting() *JobPreemptingEvent
- 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) 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 (m *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_Failed
- type EventMessage_IngressInfo
- type EventMessage_LeaseExpired
- type EventMessage_LeaseReturned
- type EventMessage_Leased
- type EventMessage_Pending
- type EventMessage_Preempted
- type EventMessage_Preempting
- 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_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 (m *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 (m *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 (m *Job) GetAnnotations() map[string]string
- func (m *Job) GetClientId() string
- func (m *Job) GetCompressedQueueOwnershipUserGroups() []byte
- func (m *Job) GetCreated() *types.Timestamp
- func (m *Job) GetId() string
- func (m *Job) GetIngress() []*IngressConfig
- 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 (m *Job) GetOwner() string
- func (m *Job) GetPodSpec() *v1.PodSpecdeprecated
- func (m *Job) GetPodSpecs() []*v1.PodSpec
- func (m *Job) GetPriority() float64
- func (m *Job) GetQueue() string
- func (m *Job) GetQueueOwnershipUserGroups() []string
- func (m *Job) GetQueueTtlSeconds() int64
- func (m *Job) GetRequiredNodeLabels() map[string]stringdeprecated
- func (m *Job) GetScheduler() string
- func (m *Job) GetSchedulingResourceRequirements() *v1.ResourceRequirements
- func (m *Job) GetServices() []*ServiceConfig
- 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 (m *Job) Size() (n int)
- func (m *Job) String() string
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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 JobDetails
- func (*JobDetails) Descriptor() ([]byte, []int)
- func (m *JobDetails) GetCancelReason() string
- func (m *JobDetails) GetCancelTs() *types.Timestamp
- func (m *JobDetails) GetJobId() string
- func (m *JobDetails) GetJobRuns() []*JobRunDetails
- func (m *JobDetails) GetJobSpec() *Job
- func (m *JobDetails) GetJobset() string
- func (m *JobDetails) GetLastTransitionTs() *types.Timestamp
- func (m *JobDetails) GetLatestRunId() string
- func (m *JobDetails) GetNamespace() string
- func (m *JobDetails) GetQueue() string
- func (m *JobDetails) GetState() JobState
- func (m *JobDetails) GetSubmittedTs() *types.Timestamp
- func (m *JobDetails) Marshal() (dAtA []byte, err error)
- func (m *JobDetails) MarshalTo(dAtA []byte) (int, error)
- func (m *JobDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobDetails) ProtoMessage()
- func (m *JobDetails) Reset()
- func (m *JobDetails) Size() (n int)
- func (m *JobDetails) String() string
- func (m *JobDetails) Unmarshal(dAtA []byte) error
- func (m *JobDetails) XXX_DiscardUnknown()
- func (m *JobDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobDetails) XXX_Merge(src proto.Message)
- func (m *JobDetails) XXX_Size() int
- func (m *JobDetails) XXX_Unmarshal(b []byte) error
- type JobDetailsRequest
- func (*JobDetailsRequest) Descriptor() ([]byte, []int)
- func (m *JobDetailsRequest) GetExpandJobRun() bool
- func (m *JobDetailsRequest) GetExpandJobSpec() bool
- func (m *JobDetailsRequest) GetJobIds() []string
- func (m *JobDetailsRequest) Marshal() (dAtA []byte, err error)
- func (m *JobDetailsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobDetailsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobDetailsRequest) ProtoMessage()
- func (m *JobDetailsRequest) Reset()
- func (m *JobDetailsRequest) Size() (n int)
- func (m *JobDetailsRequest) String() string
- func (m *JobDetailsRequest) Unmarshal(dAtA []byte) error
- func (m *JobDetailsRequest) XXX_DiscardUnknown()
- func (m *JobDetailsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobDetailsRequest) XXX_Merge(src proto.Message)
- func (m *JobDetailsRequest) XXX_Size() int
- func (m *JobDetailsRequest) XXX_Unmarshal(b []byte) error
- type JobDetailsResponse
- func (*JobDetailsResponse) Descriptor() ([]byte, []int)
- func (m *JobDetailsResponse) GetJobDetails() map[string]*JobDetails
- func (m *JobDetailsResponse) Marshal() (dAtA []byte, err error)
- func (m *JobDetailsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobDetailsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobDetailsResponse) ProtoMessage()
- func (m *JobDetailsResponse) Reset()
- func (m *JobDetailsResponse) Size() (n int)
- func (m *JobDetailsResponse) String() string
- func (m *JobDetailsResponse) Unmarshal(dAtA []byte) error
- func (m *JobDetailsResponse) XXX_DiscardUnknown()
- func (m *JobDetailsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobDetailsResponse) XXX_Merge(src proto.Message)
- func (m *JobDetailsResponse) XXX_Size() int
- func (m *JobDetailsResponse) 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() *types.Timestamp
- 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 (m *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 JobIngressInfoEvent
- func (*JobIngressInfoEvent) Descriptor() ([]byte, []int)
- func (m *JobIngressInfoEvent) GetClusterId() string
- func (m *JobIngressInfoEvent) GetCreated() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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 JobPreemptRequest
- func (*JobPreemptRequest) Descriptor() ([]byte, []int)
- func (m *JobPreemptRequest) GetJobIds() []string
- func (m *JobPreemptRequest) GetJobSetId() string
- func (m *JobPreemptRequest) GetQueue() string
- func (m *JobPreemptRequest) Marshal() (dAtA []byte, err error)
- func (m *JobPreemptRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobPreemptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobPreemptRequest) ProtoMessage()
- func (m *JobPreemptRequest) Reset()
- func (m *JobPreemptRequest) Size() (n int)
- func (m *JobPreemptRequest) String() string
- func (m *JobPreemptRequest) Unmarshal(dAtA []byte) error
- func (m *JobPreemptRequest) XXX_DiscardUnknown()
- func (m *JobPreemptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobPreemptRequest) XXX_Merge(src proto.Message)
- func (m *JobPreemptRequest) XXX_Size() int
- func (m *JobPreemptRequest) XXX_Unmarshal(b []byte) error
- type JobPreemptedEvent
- func (*JobPreemptedEvent) Descriptor() ([]byte, []int)
- func (m *JobPreemptedEvent) GetClusterId() string
- func (m *JobPreemptedEvent) GetCreated() *types.Timestamp
- 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 (m *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 JobPreemptingEvent
- func (*JobPreemptingEvent) Descriptor() ([]byte, []int)
- func (m *JobPreemptingEvent) GetCreated() *types.Timestamp
- func (m *JobPreemptingEvent) GetJobId() string
- func (m *JobPreemptingEvent) GetJobSetId() string
- func (m *JobPreemptingEvent) GetQueue() string
- func (m *JobPreemptingEvent) GetRequestor() string
- func (m *JobPreemptingEvent) Marshal() (dAtA []byte, err error)
- func (m *JobPreemptingEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *JobPreemptingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobPreemptingEvent) ProtoMessage()
- func (m *JobPreemptingEvent) Reset()
- func (m *JobPreemptingEvent) Size() (n int)
- func (m *JobPreemptingEvent) String() string
- func (m *JobPreemptingEvent) Unmarshal(dAtA []byte) error
- func (m *JobPreemptingEvent) XXX_DiscardUnknown()
- func (m *JobPreemptingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobPreemptingEvent) XXX_Merge(src proto.Message)
- func (m *JobPreemptingEvent) XXX_Size() int
- func (m *JobPreemptingEvent) XXX_Unmarshal(b []byte) error
- type JobQueuedEvent
- func (*JobQueuedEvent) Descriptor() ([]byte, []int)
- func (m *JobQueuedEvent) GetCreated() *types.Timestamp
- 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 (m *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 (m *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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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 JobRunDetails
- func (*JobRunDetails) Descriptor() ([]byte, []int)
- func (m *JobRunDetails) GetCluster() string
- func (m *JobRunDetails) GetFinishedTs() *types.Timestamp
- func (m *JobRunDetails) GetJobId() string
- func (m *JobRunDetails) GetLeasedTs() *types.Timestamp
- func (m *JobRunDetails) GetNode() string
- func (m *JobRunDetails) GetPendingTs() *types.Timestamp
- func (m *JobRunDetails) GetRunId() string
- func (m *JobRunDetails) GetStartedTs() *types.Timestamp
- func (m *JobRunDetails) GetState() JobRunState
- func (m *JobRunDetails) Marshal() (dAtA []byte, err error)
- func (m *JobRunDetails) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunDetails) ProtoMessage()
- func (m *JobRunDetails) Reset()
- func (m *JobRunDetails) Size() (n int)
- func (m *JobRunDetails) String() string
- func (m *JobRunDetails) Unmarshal(dAtA []byte) error
- func (m *JobRunDetails) XXX_DiscardUnknown()
- func (m *JobRunDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunDetails) XXX_Merge(src proto.Message)
- func (m *JobRunDetails) XXX_Size() int
- func (m *JobRunDetails) XXX_Unmarshal(b []byte) error
- type JobRunDetailsRequest
- func (*JobRunDetailsRequest) Descriptor() ([]byte, []int)
- func (m *JobRunDetailsRequest) GetRunIds() []string
- func (m *JobRunDetailsRequest) Marshal() (dAtA []byte, err error)
- func (m *JobRunDetailsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunDetailsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunDetailsRequest) ProtoMessage()
- func (m *JobRunDetailsRequest) Reset()
- func (m *JobRunDetailsRequest) Size() (n int)
- func (m *JobRunDetailsRequest) String() string
- func (m *JobRunDetailsRequest) Unmarshal(dAtA []byte) error
- func (m *JobRunDetailsRequest) XXX_DiscardUnknown()
- func (m *JobRunDetailsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunDetailsRequest) XXX_Merge(src proto.Message)
- func (m *JobRunDetailsRequest) XXX_Size() int
- func (m *JobRunDetailsRequest) XXX_Unmarshal(b []byte) error
- type JobRunDetailsResponse
- func (*JobRunDetailsResponse) Descriptor() ([]byte, []int)
- func (m *JobRunDetailsResponse) GetJobRunDetails() map[string]*JobRunDetails
- func (m *JobRunDetailsResponse) Marshal() (dAtA []byte, err error)
- func (m *JobRunDetailsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRunDetailsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRunDetailsResponse) ProtoMessage()
- func (m *JobRunDetailsResponse) Reset()
- func (m *JobRunDetailsResponse) Size() (n int)
- func (m *JobRunDetailsResponse) String() string
- func (m *JobRunDetailsResponse) Unmarshal(dAtA []byte) error
- func (m *JobRunDetailsResponse) XXX_DiscardUnknown()
- func (m *JobRunDetailsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRunDetailsResponse) XXX_Merge(src proto.Message)
- func (m *JobRunDetailsResponse) XXX_Size() int
- func (m *JobRunDetailsResponse) XXX_Unmarshal(b []byte) error
- type JobRunState
- type JobRunningEvent
- func (*JobRunningEvent) Descriptor() ([]byte, []int)
- func (m *JobRunningEvent) GetClusterId() string
- func (m *JobRunningEvent) GetCreated() *types.Timestamp
- 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 (m *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 (m *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 (m *JobSetFilter) String() string
- func (m *JobSetFilter) Unmarshal(dAtA []byte) error
- func (m *JobSetFilter) XXX_DiscardUnknown()
- func (m *JobSetFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSetFilter) XXX_Merge(src proto.Message)
- func (m *JobSetFilter) XXX_Size() int
- func (m *JobSetFilter) XXX_Unmarshal(b []byte) error
- type 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 (m *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) 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 (m *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 JobStatusRequest
- func (*JobStatusRequest) Descriptor() ([]byte, []int)
- func (m *JobStatusRequest) GetJobIds() []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 (m *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) GetJobStates() map[string]JobState
- 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 (m *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 (m *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) 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 (m *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 (m *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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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() *types.Timestamp
- 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 (m *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 JobUtilisationEvent
- func (*JobUtilisationEvent) Descriptor() ([]byte, []int)
- func (m *JobUtilisationEvent) GetClusterId() string
- func (m *JobUtilisationEvent) GetCreated() *types.Timestamp
- 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 (m *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 JobsClient
- type JobsServer
- type KubernetesEvent
- type PriorityClassPoolResourceLimits
- func (*PriorityClassPoolResourceLimits) Descriptor() ([]byte, []int)
- func (m *PriorityClassPoolResourceLimits) GetMaximumResourceFraction() map[string]float64
- func (m *PriorityClassPoolResourceLimits) Marshal() (dAtA []byte, err error)
- func (m *PriorityClassPoolResourceLimits) MarshalTo(dAtA []byte) (int, error)
- func (m *PriorityClassPoolResourceLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PriorityClassPoolResourceLimits) ProtoMessage()
- func (m *PriorityClassPoolResourceLimits) Reset()
- func (m *PriorityClassPoolResourceLimits) Size() (n int)
- func (m *PriorityClassPoolResourceLimits) String() string
- func (m *PriorityClassPoolResourceLimits) Unmarshal(dAtA []byte) error
- func (m *PriorityClassPoolResourceLimits) XXX_DiscardUnknown()
- func (m *PriorityClassPoolResourceLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PriorityClassPoolResourceLimits) XXX_Merge(src proto.Message)
- func (m *PriorityClassPoolResourceLimits) XXX_Size() int
- func (m *PriorityClassPoolResourceLimits) XXX_Unmarshal(b []byte) error
- type PriorityClassResourceLimits
- func (*PriorityClassResourceLimits) Descriptor() ([]byte, []int)
- func (m *PriorityClassResourceLimits) GetMaximumResourceFraction() map[string]float64
- func (m *PriorityClassResourceLimits) GetMaximumResourceFractionByPool() map[string]*PriorityClassPoolResourceLimits
- func (m *PriorityClassResourceLimits) Marshal() (dAtA []byte, err error)
- func (m *PriorityClassResourceLimits) MarshalTo(dAtA []byte) (int, error)
- func (m *PriorityClassResourceLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PriorityClassResourceLimits) ProtoMessage()
- func (m *PriorityClassResourceLimits) Reset()
- func (m *PriorityClassResourceLimits) Size() (n int)
- func (m *PriorityClassResourceLimits) String() string
- func (m *PriorityClassResourceLimits) Unmarshal(dAtA []byte) error
- func (m *PriorityClassResourceLimits) XXX_DiscardUnknown()
- func (m *PriorityClassResourceLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PriorityClassResourceLimits) XXX_Merge(src proto.Message)
- func (m *PriorityClassResourceLimits) XXX_Size() int
- func (m *PriorityClassResourceLimits) XXX_Unmarshal(b []byte) error
- type Queue
- func (*Queue) Descriptor() ([]byte, []int)
- func (m *Queue) GetCordoned() bool
- func (m *Queue) GetGroupOwners() []string
- func (m *Queue) GetLabels() []string
- func (m *Queue) GetName() string
- func (m *Queue) GetPermissions() []*Queue_Permissions
- func (m *Queue) GetPriorityFactor() float64
- func (m *Queue) GetResourceLimits() map[string]float64deprecated
- func (m *Queue) GetResourceLimitsByPriorityClassName() map[string]*PriorityClassResourceLimits
- 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 (m *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 QueueCordonRequest
- func (*QueueCordonRequest) Descriptor() ([]byte, []int)
- func (m *QueueCordonRequest) GetName() string
- func (m *QueueCordonRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueCordonRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueCordonRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueCordonRequest) ProtoMessage()
- func (m *QueueCordonRequest) Reset()
- func (m *QueueCordonRequest) Size() (n int)
- func (m *QueueCordonRequest) String() string
- func (m *QueueCordonRequest) Unmarshal(dAtA []byte) error
- func (m *QueueCordonRequest) XXX_DiscardUnknown()
- func (m *QueueCordonRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueCordonRequest) XXX_Merge(src proto.Message)
- func (m *QueueCordonRequest) XXX_Size() int
- func (m *QueueCordonRequest) 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 (m *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 (m *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 (m *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 (m *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 QueueServiceClient
- type QueueServiceServer
- type QueueService_GetQueuesClient
- type QueueService_GetQueuesServer
- type QueueUncordonRequest
- func (*QueueUncordonRequest) Descriptor() ([]byte, []int)
- func (m *QueueUncordonRequest) GetName() string
- func (m *QueueUncordonRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueUncordonRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueUncordonRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueUncordonRequest) ProtoMessage()
- func (m *QueueUncordonRequest) Reset()
- func (m *QueueUncordonRequest) Size() (n int)
- func (m *QueueUncordonRequest) String() string
- func (m *QueueUncordonRequest) Unmarshal(dAtA []byte) error
- func (m *QueueUncordonRequest) XXX_DiscardUnknown()
- func (m *QueueUncordonRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueUncordonRequest) XXX_Merge(src proto.Message)
- func (m *QueueUncordonRequest) XXX_Size() int
- func (m *QueueUncordonRequest) 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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() *types.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() *types.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 (m *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 UnimplementedJobsServer
- func (*UnimplementedJobsServer) GetJobDetails(ctx context.Context, req *JobDetailsRequest) (*JobDetailsResponse, error)
- func (*UnimplementedJobsServer) GetJobRunDetails(ctx context.Context, req *JobRunDetailsRequest) (*JobRunDetailsResponse, error)
- func (*UnimplementedJobsServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)
- type UnimplementedQueueServiceServer
- func (*UnimplementedQueueServiceServer) CordonQueue(ctx context.Context, req *QueueCordonRequest) (*types.Empty, error)
- func (*UnimplementedQueueServiceServer) CreateQueue(ctx context.Context, req *Queue) (*types.Empty, error)
- func (*UnimplementedQueueServiceServer) CreateQueues(ctx context.Context, req *QueueList) (*BatchQueueCreateResponse, error)
- func (*UnimplementedQueueServiceServer) DeleteQueue(ctx context.Context, req *QueueDeleteRequest) (*types.Empty, error)
- func (*UnimplementedQueueServiceServer) GetQueue(ctx context.Context, req *QueueGetRequest) (*Queue, error)
- func (*UnimplementedQueueServiceServer) GetQueues(req *StreamingQueueGetRequest, srv QueueService_GetQueuesServer) error
- func (*UnimplementedQueueServiceServer) UncordonQueue(ctx context.Context, req *QueueUncordonRequest) (*types.Empty, error)
- func (*UnimplementedQueueServiceServer) UpdateQueue(ctx context.Context, req *Queue) (*types.Empty, error)
- func (*UnimplementedQueueServiceServer) UpdateQueues(ctx context.Context, req *QueueList) (*BatchQueueUpdateResponse, error)
- 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) PreemptJobs(ctx context.Context, req *JobPreemptRequest) (*types.Empty, 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) 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 (m *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 ( ErrInvalidLengthJob = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowJob = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupJob = 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",
4: "Rejected",
}
var Cause_value = map[string]int32{
"Error": 0,
"Evicted": 1,
"OOM": 2,
"DeadlineExceeded": 3,
"Rejected": 4,
}
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 JobRunState_name = map[int32]string{
0: "RUN_STATE_UNKNOWN",
1: "RUN_STATE_LEASED",
2: "RUN_STATE_PENDING",
3: "RUN_STATE_RUNNING",
4: "RUN_STATE_SUCCEEDED",
5: "RUN_STATE_FAILED",
6: "RUN_STATE_PREEMPTED",
7: "RUN_STATE_CANCELLED",
8: "RUN_STATE_LEASE_EXPIRED",
9: "RUNS_STATE_LEASE_RETURNED",
}
var JobRunState_value = map[string]int32{
"RUN_STATE_UNKNOWN": 0,
"RUN_STATE_LEASED": 1,
"RUN_STATE_PENDING": 2,
"RUN_STATE_RUNNING": 3,
"RUN_STATE_SUCCEEDED": 4,
"RUN_STATE_FAILED": 5,
"RUN_STATE_PREEMPTED": 6,
"RUN_STATE_CANCELLED": 7,
"RUN_STATE_LEASE_EXPIRED": 8,
"RUNS_STATE_LEASE_RETURNED": 9,
}
var JobState_name = map[int32]string{
0: "QUEUED",
1: "PENDING",
2: "RUNNING",
3: "SUCCEEDED",
4: "FAILED",
5: "UNKNOWN",
6: "SUBMITTED",
7: "LEASED",
8: "PREEMPTED",
9: "CANCELLED",
10: "REJECTED",
}
var JobState_value = map[string]int32{
"QUEUED": 0,
"PENDING": 1,
"RUNNING": 2,
"SUCCEEDED": 3,
"FAILED": 4,
"UNKNOWN": 5,
"SUBMITTED": 6,
"LEASED": 7,
"PREEMPTED": 8,
"CANCELLED": 9,
"REJECTED": 10,
}
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 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 RegisterJobsHandler ¶ added in v0.4.40
RegisterJobsHandler registers the http handlers for service Jobs to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterJobsHandlerClient ¶ added in v0.4.40
RegisterJobsHandlerClient registers the http handlers for service Jobs to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobsClient" to call the correct interceptors.
func RegisterJobsHandlerFromEndpoint ¶ added in v0.4.40
func RegisterJobsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterJobsHandlerFromEndpoint is same as RegisterJobsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterJobsHandlerServer ¶ added in v0.4.40
RegisterJobsHandlerServer registers the http handlers for service Jobs to "mux". UnaryRPC :call JobsServer 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 RegisterJobsHandlerFromEndpoint instead.
func RegisterJobsServer ¶ added in v0.4.24
func RegisterJobsServer(s *grpc.Server, srv JobsServer)
func RegisterQueueServiceServer ¶ added in v0.7.0
func RegisterQueueServiceServer(s *grpc.Server, srv QueueServiceServer)
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 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 (m *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 (m *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 (m *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 (m *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() *types.Timestamp }
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_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_Preempted // *EventMessage_Preempting Events isEventMessage_Events `protobuf_oneof:"events"` }
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) GetEvents ¶
func (m *EventMessage) GetEvents() isEventMessage_Events
func (*EventMessage) GetFailed ¶
func (m *EventMessage) GetFailed() *JobFailedEvent
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) GetPreempting ¶ added in v0.4.41
func (m *EventMessage) GetPreempting() *JobPreemptingEvent
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) 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 (m *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)
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)
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)
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)
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)
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)
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)
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)
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)
type EventMessage_Preempting ¶ added in v0.4.41
type EventMessage_Preempting struct {
Preempting *JobPreemptingEvent `protobuf:"bytes,22,opt,name=preempting,proto3,oneof" json:"preempting,omitempty"`
}
func (*EventMessage_Preempting) MarshalTo ¶ added in v0.4.41
func (m *EventMessage_Preempting) MarshalTo(dAtA []byte) (int, error)
func (*EventMessage_Preempting) MarshalToSizedBuffer ¶ added in v0.4.41
func (m *EventMessage_Preempting) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventMessage_Preempting) Size ¶ added in v0.4.41
func (m *EventMessage_Preempting) Size() (n int)
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)
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)
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)
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)
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)
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)
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)
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)
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)
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 (m *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 (m *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 `` /* 152-byte string literal not displayed */ Created *types.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"` // 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) 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) GetPodSpec
deprecated
func (*Job) GetPodSpecs ¶
func (*Job) GetPriority ¶
func (*Job) GetQueueOwnershipUserGroups ¶
func (*Job) GetQueueTtlSeconds ¶ added in v0.3.95
func (*Job) GetRequiredNodeLabels
deprecated
func (*Job) GetScheduler ¶
func (*Job) GetSchedulingResourceRequirements ¶ added in v0.3.70
func (m *Job) GetSchedulingResourceRequirements() *v1.ResourceRequirements
func (*Job) GetServices ¶
func (m *Job) GetServices() []*ServiceConfig
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 JobDetails ¶ added in v0.4.24
type JobDetails struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` Jobset string `protobuf:"bytes,3,opt,name=jobset,proto3" json:"jobset,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` State JobState `protobuf:"varint,5,opt,name=state,proto3,enum=api.JobState" json:"state,omitempty"` SubmittedTs *types.Timestamp `protobuf:"bytes,6,opt,name=submitted_ts,json=submittedTs,proto3" json:"submittedTs,omitempty"` CancelTs *types.Timestamp `protobuf:"bytes,7,opt,name=cancel_ts,json=cancelTs,proto3" json:"cancelTs,omitempty"` CancelReason string `protobuf:"bytes,8,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancelReason,omitempty"` LastTransitionTs *types.Timestamp `protobuf:"bytes,9,opt,name=last_transition_ts,json=lastTransitionTs,proto3" json:"lastTransitionTs,omitempty"` LatestRunId string `protobuf:"bytes,10,opt,name=latest_run_id,json=latestRunId,proto3" json:"latestRunId,omitempty"` JobSpec *Job `protobuf:"bytes,11,opt,name=job_spec,json=jobSpec,proto3" json:"jobSpec,omitempty"` JobRuns []*JobRunDetails `protobuf:"bytes,12,rep,name=job_runs,json=jobRuns,proto3" json:"jobRuns,omitempty"` }
func (*JobDetails) Descriptor ¶ added in v0.4.24
func (*JobDetails) Descriptor() ([]byte, []int)
func (*JobDetails) GetCancelReason ¶ added in v0.4.24
func (m *JobDetails) GetCancelReason() string
func (*JobDetails) GetCancelTs ¶ added in v0.4.24
func (m *JobDetails) GetCancelTs() *types.Timestamp
func (*JobDetails) GetJobId ¶ added in v0.4.24
func (m *JobDetails) GetJobId() string
func (*JobDetails) GetJobRuns ¶ added in v0.4.24
func (m *JobDetails) GetJobRuns() []*JobRunDetails
func (*JobDetails) GetJobSpec ¶ added in v0.4.24
func (m *JobDetails) GetJobSpec() *Job
func (*JobDetails) GetJobset ¶ added in v0.4.24
func (m *JobDetails) GetJobset() string
func (*JobDetails) GetLastTransitionTs ¶ added in v0.4.24
func (m *JobDetails) GetLastTransitionTs() *types.Timestamp
func (*JobDetails) GetLatestRunId ¶ added in v0.4.24
func (m *JobDetails) GetLatestRunId() string
func (*JobDetails) GetNamespace ¶ added in v0.4.24
func (m *JobDetails) GetNamespace() string
func (*JobDetails) GetQueue ¶ added in v0.4.24
func (m *JobDetails) GetQueue() string
func (*JobDetails) GetState ¶ added in v0.4.24
func (m *JobDetails) GetState() JobState
func (*JobDetails) GetSubmittedTs ¶ added in v0.4.24
func (m *JobDetails) GetSubmittedTs() *types.Timestamp
func (*JobDetails) Marshal ¶ added in v0.4.24
func (m *JobDetails) Marshal() (dAtA []byte, err error)
func (*JobDetails) MarshalTo ¶ added in v0.4.24
func (m *JobDetails) MarshalTo(dAtA []byte) (int, error)
func (*JobDetails) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobDetails) ProtoMessage ¶ added in v0.4.24
func (*JobDetails) ProtoMessage()
func (*JobDetails) Reset ¶ added in v0.4.24
func (m *JobDetails) Reset()
func (*JobDetails) Size ¶ added in v0.4.24
func (m *JobDetails) Size() (n int)
func (*JobDetails) String ¶ added in v0.4.24
func (m *JobDetails) String() string
func (*JobDetails) Unmarshal ¶ added in v0.4.24
func (m *JobDetails) Unmarshal(dAtA []byte) error
func (*JobDetails) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobDetails) XXX_DiscardUnknown()
func (*JobDetails) XXX_Marshal ¶ added in v0.4.24
func (m *JobDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobDetails) XXX_Merge ¶ added in v0.4.24
func (m *JobDetails) XXX_Merge(src proto.Message)
func (*JobDetails) XXX_Size ¶ added in v0.4.24
func (m *JobDetails) XXX_Size() int
func (*JobDetails) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobDetails) XXX_Unmarshal(b []byte) error
type JobDetailsRequest ¶ added in v0.4.24
type JobDetailsRequest struct { JobIds []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"` ExpandJobSpec bool `protobuf:"varint,2,opt,name=expand_job_spec,json=expandJobSpec,proto3" json:"expandJobSpec,omitempty"` ExpandJobRun bool `protobuf:"varint,3,opt,name=expand_job_run,json=expandJobRun,proto3" json:"expandJobRun,omitempty"` }
func (*JobDetailsRequest) Descriptor ¶ added in v0.4.24
func (*JobDetailsRequest) Descriptor() ([]byte, []int)
func (*JobDetailsRequest) GetExpandJobRun ¶ added in v0.4.24
func (m *JobDetailsRequest) GetExpandJobRun() bool
func (*JobDetailsRequest) GetExpandJobSpec ¶ added in v0.4.24
func (m *JobDetailsRequest) GetExpandJobSpec() bool
func (*JobDetailsRequest) GetJobIds ¶ added in v0.4.24
func (m *JobDetailsRequest) GetJobIds() []string
func (*JobDetailsRequest) Marshal ¶ added in v0.4.24
func (m *JobDetailsRequest) Marshal() (dAtA []byte, err error)
func (*JobDetailsRequest) MarshalTo ¶ added in v0.4.24
func (m *JobDetailsRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobDetailsRequest) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobDetailsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobDetailsRequest) ProtoMessage ¶ added in v0.4.24
func (*JobDetailsRequest) ProtoMessage()
func (*JobDetailsRequest) Reset ¶ added in v0.4.24
func (m *JobDetailsRequest) Reset()
func (*JobDetailsRequest) Size ¶ added in v0.4.24
func (m *JobDetailsRequest) Size() (n int)
func (*JobDetailsRequest) String ¶ added in v0.4.24
func (m *JobDetailsRequest) String() string
func (*JobDetailsRequest) Unmarshal ¶ added in v0.4.24
func (m *JobDetailsRequest) Unmarshal(dAtA []byte) error
func (*JobDetailsRequest) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobDetailsRequest) XXX_DiscardUnknown()
func (*JobDetailsRequest) XXX_Marshal ¶ added in v0.4.24
func (m *JobDetailsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobDetailsRequest) XXX_Merge ¶ added in v0.4.24
func (m *JobDetailsRequest) XXX_Merge(src proto.Message)
func (*JobDetailsRequest) XXX_Size ¶ added in v0.4.24
func (m *JobDetailsRequest) XXX_Size() int
func (*JobDetailsRequest) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobDetailsRequest) XXX_Unmarshal(b []byte) error
type JobDetailsResponse ¶ added in v0.4.24
type JobDetailsResponse struct {
JobDetails map[string]*JobDetails `` /* 178-byte string literal not displayed */
}
func (*JobDetailsResponse) Descriptor ¶ added in v0.4.24
func (*JobDetailsResponse) Descriptor() ([]byte, []int)
func (*JobDetailsResponse) GetJobDetails ¶ added in v0.4.24
func (m *JobDetailsResponse) GetJobDetails() map[string]*JobDetails
func (*JobDetailsResponse) Marshal ¶ added in v0.4.24
func (m *JobDetailsResponse) Marshal() (dAtA []byte, err error)
func (*JobDetailsResponse) MarshalTo ¶ added in v0.4.24
func (m *JobDetailsResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobDetailsResponse) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobDetailsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobDetailsResponse) ProtoMessage ¶ added in v0.4.24
func (*JobDetailsResponse) ProtoMessage()
func (*JobDetailsResponse) Reset ¶ added in v0.4.24
func (m *JobDetailsResponse) Reset()
func (*JobDetailsResponse) Size ¶ added in v0.4.24
func (m *JobDetailsResponse) Size() (n int)
func (*JobDetailsResponse) String ¶ added in v0.4.24
func (m *JobDetailsResponse) String() string
func (*JobDetailsResponse) Unmarshal ¶ added in v0.4.24
func (m *JobDetailsResponse) Unmarshal(dAtA []byte) error
func (*JobDetailsResponse) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobDetailsResponse) XXX_DiscardUnknown()
func (*JobDetailsResponse) XXX_Marshal ¶ added in v0.4.24
func (m *JobDetailsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobDetailsResponse) XXX_Merge ¶ added in v0.4.24
func (m *JobDetailsResponse) XXX_Merge(src proto.Message)
func (*JobDetailsResponse) XXX_Size ¶ added in v0.4.24
func (m *JobDetailsResponse) XXX_Size() int
func (*JobDetailsResponse) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobDetailsResponse) 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` }
func (*JobLeaseExpiredEvent) Descriptor ¶
func (*JobLeaseExpiredEvent) Descriptor() ([]byte, []int)
func (*JobLeaseExpiredEvent) GetCreated ¶
func (m *JobLeaseExpiredEvent) GetCreated() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 JobPreemptRequest ¶ added in v0.4.41
type JobPreemptRequest 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"` JobIds []string `protobuf:"bytes,3,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"` }
swagger:model
func (*JobPreemptRequest) Descriptor ¶ added in v0.4.41
func (*JobPreemptRequest) Descriptor() ([]byte, []int)
func (*JobPreemptRequest) GetJobIds ¶ added in v0.4.41
func (m *JobPreemptRequest) GetJobIds() []string
func (*JobPreemptRequest) GetJobSetId ¶ added in v0.4.41
func (m *JobPreemptRequest) GetJobSetId() string
func (*JobPreemptRequest) GetQueue ¶ added in v0.4.41
func (m *JobPreemptRequest) GetQueue() string
func (*JobPreemptRequest) Marshal ¶ added in v0.4.41
func (m *JobPreemptRequest) Marshal() (dAtA []byte, err error)
func (*JobPreemptRequest) MarshalTo ¶ added in v0.4.41
func (m *JobPreemptRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobPreemptRequest) MarshalToSizedBuffer ¶ added in v0.4.41
func (m *JobPreemptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobPreemptRequest) ProtoMessage ¶ added in v0.4.41
func (*JobPreemptRequest) ProtoMessage()
func (*JobPreemptRequest) Reset ¶ added in v0.4.41
func (m *JobPreemptRequest) Reset()
func (*JobPreemptRequest) Size ¶ added in v0.4.41
func (m *JobPreemptRequest) Size() (n int)
func (*JobPreemptRequest) String ¶ added in v0.4.41
func (m *JobPreemptRequest) String() string
func (*JobPreemptRequest) Unmarshal ¶ added in v0.4.41
func (m *JobPreemptRequest) Unmarshal(dAtA []byte) error
func (*JobPreemptRequest) XXX_DiscardUnknown ¶ added in v0.4.41
func (m *JobPreemptRequest) XXX_DiscardUnknown()
func (*JobPreemptRequest) XXX_Marshal ¶ added in v0.4.41
func (m *JobPreemptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobPreemptRequest) XXX_Merge ¶ added in v0.4.41
func (m *JobPreemptRequest) XXX_Merge(src proto.Message)
func (*JobPreemptRequest) XXX_Size ¶ added in v0.4.41
func (m *JobPreemptRequest) XXX_Size() int
func (*JobPreemptRequest) XXX_Unmarshal ¶ added in v0.4.41
func (m *JobPreemptRequest) 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 JobPreemptingEvent ¶ added in v0.4.41
type JobPreemptingEvent 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` Requestor string `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"` }
func (*JobPreemptingEvent) Descriptor ¶ added in v0.4.41
func (*JobPreemptingEvent) Descriptor() ([]byte, []int)
func (*JobPreemptingEvent) GetCreated ¶ added in v0.4.41
func (m *JobPreemptingEvent) GetCreated() *types.Timestamp
func (*JobPreemptingEvent) GetJobId ¶ added in v0.4.41
func (m *JobPreemptingEvent) GetJobId() string
func (*JobPreemptingEvent) GetJobSetId ¶ added in v0.4.41
func (m *JobPreemptingEvent) GetJobSetId() string
func (*JobPreemptingEvent) GetQueue ¶ added in v0.4.41
func (m *JobPreemptingEvent) GetQueue() string
func (*JobPreemptingEvent) GetRequestor ¶ added in v0.4.41
func (m *JobPreemptingEvent) GetRequestor() string
func (*JobPreemptingEvent) Marshal ¶ added in v0.4.41
func (m *JobPreemptingEvent) Marshal() (dAtA []byte, err error)
func (*JobPreemptingEvent) MarshalTo ¶ added in v0.4.41
func (m *JobPreemptingEvent) MarshalTo(dAtA []byte) (int, error)
func (*JobPreemptingEvent) MarshalToSizedBuffer ¶ added in v0.4.41
func (m *JobPreemptingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobPreemptingEvent) ProtoMessage ¶ added in v0.4.41
func (*JobPreemptingEvent) ProtoMessage()
func (*JobPreemptingEvent) Reset ¶ added in v0.4.41
func (m *JobPreemptingEvent) Reset()
func (*JobPreemptingEvent) Size ¶ added in v0.4.41
func (m *JobPreemptingEvent) Size() (n int)
func (*JobPreemptingEvent) String ¶ added in v0.4.41
func (m *JobPreemptingEvent) String() string
func (*JobPreemptingEvent) Unmarshal ¶ added in v0.4.41
func (m *JobPreemptingEvent) Unmarshal(dAtA []byte) error
func (*JobPreemptingEvent) XXX_DiscardUnknown ¶ added in v0.4.41
func (m *JobPreemptingEvent) XXX_DiscardUnknown()
func (*JobPreemptingEvent) XXX_Marshal ¶ added in v0.4.41
func (m *JobPreemptingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobPreemptingEvent) XXX_Merge ¶ added in v0.4.41
func (m *JobPreemptingEvent) XXX_Merge(src proto.Message)
func (*JobPreemptingEvent) XXX_Size ¶ added in v0.4.41
func (m *JobPreemptingEvent) XXX_Size() int
func (*JobPreemptingEvent) XXX_Unmarshal ¶ added in v0.4.41
func (m *JobPreemptingEvent) 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` }
func (*JobQueuedEvent) Descriptor ¶
func (*JobQueuedEvent) Descriptor() ([]byte, []int)
func (*JobQueuedEvent) GetCreated ¶
func (m *JobQueuedEvent) GetCreated() *types.Timestamp
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 (m *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 (m *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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 JobRunDetails ¶ added in v0.4.24
type JobRunDetails struct { RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"` JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"` State JobRunState `protobuf:"varint,3,opt,name=state,proto3,enum=api.JobRunState" json:"state,omitempty"` Cluster string `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"` Node string `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"` LeasedTs *types.Timestamp `protobuf:"bytes,7,opt,name=leased_ts,json=leasedTs,proto3" json:"leasedTs,omitempty"` PendingTs *types.Timestamp `protobuf:"bytes,8,opt,name=pending_ts,json=pendingTs,proto3" json:"pendingTs,omitempty"` StartedTs *types.Timestamp `protobuf:"bytes,9,opt,name=started_ts,json=startedTs,proto3" json:"startedTs,omitempty"` FinishedTs *types.Timestamp `protobuf:"bytes,10,opt,name=finished_ts,json=finishedTs,proto3" json:"finishedTs,omitempty"` }
func (*JobRunDetails) Descriptor ¶ added in v0.4.24
func (*JobRunDetails) Descriptor() ([]byte, []int)
func (*JobRunDetails) GetCluster ¶ added in v0.4.24
func (m *JobRunDetails) GetCluster() string
func (*JobRunDetails) GetFinishedTs ¶ added in v0.4.24
func (m *JobRunDetails) GetFinishedTs() *types.Timestamp
func (*JobRunDetails) GetJobId ¶ added in v0.4.24
func (m *JobRunDetails) GetJobId() string
func (*JobRunDetails) GetLeasedTs ¶ added in v0.4.24
func (m *JobRunDetails) GetLeasedTs() *types.Timestamp
func (*JobRunDetails) GetNode ¶ added in v0.4.24
func (m *JobRunDetails) GetNode() string
func (*JobRunDetails) GetPendingTs ¶ added in v0.4.24
func (m *JobRunDetails) GetPendingTs() *types.Timestamp
func (*JobRunDetails) GetRunId ¶ added in v0.4.24
func (m *JobRunDetails) GetRunId() string
func (*JobRunDetails) GetStartedTs ¶ added in v0.4.24
func (m *JobRunDetails) GetStartedTs() *types.Timestamp
func (*JobRunDetails) GetState ¶ added in v0.4.24
func (m *JobRunDetails) GetState() JobRunState
func (*JobRunDetails) Marshal ¶ added in v0.4.24
func (m *JobRunDetails) Marshal() (dAtA []byte, err error)
func (*JobRunDetails) MarshalTo ¶ added in v0.4.24
func (m *JobRunDetails) MarshalTo(dAtA []byte) (int, error)
func (*JobRunDetails) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobRunDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunDetails) ProtoMessage ¶ added in v0.4.24
func (*JobRunDetails) ProtoMessage()
func (*JobRunDetails) Reset ¶ added in v0.4.24
func (m *JobRunDetails) Reset()
func (*JobRunDetails) Size ¶ added in v0.4.24
func (m *JobRunDetails) Size() (n int)
func (*JobRunDetails) String ¶ added in v0.4.24
func (m *JobRunDetails) String() string
func (*JobRunDetails) Unmarshal ¶ added in v0.4.24
func (m *JobRunDetails) Unmarshal(dAtA []byte) error
func (*JobRunDetails) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobRunDetails) XXX_DiscardUnknown()
func (*JobRunDetails) XXX_Marshal ¶ added in v0.4.24
func (m *JobRunDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunDetails) XXX_Merge ¶ added in v0.4.24
func (m *JobRunDetails) XXX_Merge(src proto.Message)
func (*JobRunDetails) XXX_Size ¶ added in v0.4.24
func (m *JobRunDetails) XXX_Size() int
func (*JobRunDetails) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobRunDetails) XXX_Unmarshal(b []byte) error
type JobRunDetailsRequest ¶ added in v0.4.24
type JobRunDetailsRequest struct {
RunIds []string `protobuf:"bytes,1,rep,name=run_ids,json=runIds,proto3" json:"runIds,omitempty"`
}
func (*JobRunDetailsRequest) Descriptor ¶ added in v0.4.24
func (*JobRunDetailsRequest) Descriptor() ([]byte, []int)
func (*JobRunDetailsRequest) GetRunIds ¶ added in v0.4.24
func (m *JobRunDetailsRequest) GetRunIds() []string
func (*JobRunDetailsRequest) Marshal ¶ added in v0.4.24
func (m *JobRunDetailsRequest) Marshal() (dAtA []byte, err error)
func (*JobRunDetailsRequest) MarshalTo ¶ added in v0.4.24
func (m *JobRunDetailsRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobRunDetailsRequest) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobRunDetailsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunDetailsRequest) ProtoMessage ¶ added in v0.4.24
func (*JobRunDetailsRequest) ProtoMessage()
func (*JobRunDetailsRequest) Reset ¶ added in v0.4.24
func (m *JobRunDetailsRequest) Reset()
func (*JobRunDetailsRequest) Size ¶ added in v0.4.24
func (m *JobRunDetailsRequest) Size() (n int)
func (*JobRunDetailsRequest) String ¶ added in v0.4.24
func (m *JobRunDetailsRequest) String() string
func (*JobRunDetailsRequest) Unmarshal ¶ added in v0.4.24
func (m *JobRunDetailsRequest) Unmarshal(dAtA []byte) error
func (*JobRunDetailsRequest) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobRunDetailsRequest) XXX_DiscardUnknown()
func (*JobRunDetailsRequest) XXX_Marshal ¶ added in v0.4.24
func (m *JobRunDetailsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunDetailsRequest) XXX_Merge ¶ added in v0.4.24
func (m *JobRunDetailsRequest) XXX_Merge(src proto.Message)
func (*JobRunDetailsRequest) XXX_Size ¶ added in v0.4.24
func (m *JobRunDetailsRequest) XXX_Size() int
func (*JobRunDetailsRequest) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobRunDetailsRequest) XXX_Unmarshal(b []byte) error
type JobRunDetailsResponse ¶ added in v0.4.24
type JobRunDetailsResponse struct {
JobRunDetails map[string]*JobRunDetails `` /* 188-byte string literal not displayed */
}
func (*JobRunDetailsResponse) Descriptor ¶ added in v0.4.24
func (*JobRunDetailsResponse) Descriptor() ([]byte, []int)
func (*JobRunDetailsResponse) GetJobRunDetails ¶ added in v0.4.24
func (m *JobRunDetailsResponse) GetJobRunDetails() map[string]*JobRunDetails
func (*JobRunDetailsResponse) Marshal ¶ added in v0.4.24
func (m *JobRunDetailsResponse) Marshal() (dAtA []byte, err error)
func (*JobRunDetailsResponse) MarshalTo ¶ added in v0.4.24
func (m *JobRunDetailsResponse) MarshalTo(dAtA []byte) (int, error)
func (*JobRunDetailsResponse) MarshalToSizedBuffer ¶ added in v0.4.24
func (m *JobRunDetailsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRunDetailsResponse) ProtoMessage ¶ added in v0.4.24
func (*JobRunDetailsResponse) ProtoMessage()
func (*JobRunDetailsResponse) Reset ¶ added in v0.4.24
func (m *JobRunDetailsResponse) Reset()
func (*JobRunDetailsResponse) Size ¶ added in v0.4.24
func (m *JobRunDetailsResponse) Size() (n int)
func (*JobRunDetailsResponse) String ¶ added in v0.4.24
func (m *JobRunDetailsResponse) String() string
func (*JobRunDetailsResponse) Unmarshal ¶ added in v0.4.24
func (m *JobRunDetailsResponse) Unmarshal(dAtA []byte) error
func (*JobRunDetailsResponse) XXX_DiscardUnknown ¶ added in v0.4.24
func (m *JobRunDetailsResponse) XXX_DiscardUnknown()
func (*JobRunDetailsResponse) XXX_Marshal ¶ added in v0.4.24
func (m *JobRunDetailsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRunDetailsResponse) XXX_Merge ¶ added in v0.4.24
func (m *JobRunDetailsResponse) XXX_Merge(src proto.Message)
func (*JobRunDetailsResponse) XXX_Size ¶ added in v0.4.24
func (m *JobRunDetailsResponse) XXX_Size() int
func (*JobRunDetailsResponse) XXX_Unmarshal ¶ added in v0.4.24
func (m *JobRunDetailsResponse) XXX_Unmarshal(b []byte) error
type JobRunState ¶ added in v0.4.24
type JobRunState int32
const ( JobRunState_RUN_STATE_UNKNOWN JobRunState = 0 JobRunState_RUN_STATE_LEASED JobRunState = 1 JobRunState_RUN_STATE_PENDING JobRunState = 2 JobRunState_RUN_STATE_RUNNING JobRunState = 3 JobRunState_RUN_STATE_SUCCEEDED JobRunState = 4 JobRunState_RUN_STATE_FAILED JobRunState = 5 JobRunState_RUN_STATE_PREEMPTED JobRunState = 6 JobRunState_RUN_STATE_CANCELLED JobRunState = 7 JobRunState_RUN_STATE_LEASE_EXPIRED JobRunState = 8 JobRunState_RUNS_STATE_LEASE_RETURNED JobRunState = 9 )
func (JobRunState) EnumDescriptor ¶ added in v0.4.24
func (JobRunState) EnumDescriptor() ([]byte, []int)
func (JobRunState) String ¶ added in v0.4.24
func (x JobRunState) String() string
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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 (m *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 (m *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 (m *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"` }
swagger:model
func (*JobSetRequest) Descriptor ¶
func (*JobSetRequest) Descriptor() ([]byte, []int)
func (*JobSetRequest) GetErrorIfMissing ¶
func (m *JobSetRequest) GetErrorIfMissing() 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 (m *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
const ( JobState_QUEUED JobState = 0 JobState_PENDING JobState = 1 JobState_RUNNING JobState = 2 JobState_SUCCEEDED JobState = 3 JobState_FAILED JobState = 4 JobState_UNKNOWN JobState = 5 JobState_SUBMITTED JobState = 6 JobState_LEASED JobState = 7 JobState_PREEMPTED JobState = 8 JobState_CANCELLED JobState = 9 JobState_REJECTED JobState = 10 )
func (JobState) EnumDescriptor ¶
func (*JobState) UnmarshalJSON ¶
type JobStatusRequest ¶ added in v0.4.20
type JobStatusRequest struct {
JobIds []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"`
}
func (*JobStatusRequest) Descriptor ¶ added in v0.4.20
func (*JobStatusRequest) Descriptor() ([]byte, []int)
func (*JobStatusRequest) GetJobIds ¶ added in v0.4.24
func (m *JobStatusRequest) GetJobIds() []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 (m *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 {
JobStates map[string]JobState `` /* 194-byte string literal not displayed */
}
func (*JobStatusResponse) Descriptor ¶ added in v0.4.20
func (*JobStatusResponse) Descriptor() ([]byte, []int)
func (*JobStatusResponse) GetJobStates ¶ added in v0.4.24
func (m *JobStatusResponse) GetJobStates() map[string]JobState
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 (m *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 (m *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"` }
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) 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 (m *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 (m *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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` Job *Job `protobuf:"bytes,5,opt,name=job,proto3" json:"job,omitempty"` }
func (*JobSubmittedEvent) Descriptor ¶
func (*JobSubmittedEvent) Descriptor() ([]byte, []int)
func (*JobSubmittedEvent) GetCreated ¶
func (m *JobSubmittedEvent) GetCreated() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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() *types.Timestamp
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 (m *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 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 *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"` 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 `` /* 183-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 `` /* 210-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() *types.Timestamp
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 (m *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 JobsClient ¶ added in v0.4.24
type JobsClient interface { GetJobStatus(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error) GetJobDetails(ctx context.Context, in *JobDetailsRequest, opts ...grpc.CallOption) (*JobDetailsResponse, error) GetJobRunDetails(ctx context.Context, in *JobRunDetailsRequest, opts ...grpc.CallOption) (*JobRunDetailsResponse, error) }
JobsClient is the client API for Jobs service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobsClient ¶ added in v0.4.24
func NewJobsClient(cc *grpc.ClientConn) JobsClient
type JobsServer ¶ added in v0.4.24
type JobsServer interface { GetJobStatus(context.Context, *JobStatusRequest) (*JobStatusResponse, error) GetJobDetails(context.Context, *JobDetailsRequest) (*JobDetailsResponse, error) GetJobRunDetails(context.Context, *JobRunDetailsRequest) (*JobRunDetailsResponse, error) }
JobsServer is the server API for Jobs service.
type KubernetesEvent ¶
type PriorityClassPoolResourceLimits ¶ added in v0.4.29
type PriorityClassPoolResourceLimits struct {
MaximumResourceFraction map[string]float64 `` /* 220-byte string literal not displayed */
}
func (*PriorityClassPoolResourceLimits) Descriptor ¶ added in v0.4.29
func (*PriorityClassPoolResourceLimits) Descriptor() ([]byte, []int)
func (*PriorityClassPoolResourceLimits) GetMaximumResourceFraction ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) GetMaximumResourceFraction() map[string]float64
func (*PriorityClassPoolResourceLimits) Marshal ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) Marshal() (dAtA []byte, err error)
func (*PriorityClassPoolResourceLimits) MarshalTo ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) MarshalTo(dAtA []byte) (int, error)
func (*PriorityClassPoolResourceLimits) MarshalToSizedBuffer ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PriorityClassPoolResourceLimits) ProtoMessage ¶ added in v0.4.29
func (*PriorityClassPoolResourceLimits) ProtoMessage()
func (*PriorityClassPoolResourceLimits) Reset ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) Reset()
func (*PriorityClassPoolResourceLimits) Size ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) Size() (n int)
func (*PriorityClassPoolResourceLimits) String ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) String() string
func (*PriorityClassPoolResourceLimits) Unmarshal ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) Unmarshal(dAtA []byte) error
func (*PriorityClassPoolResourceLimits) XXX_DiscardUnknown ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) XXX_DiscardUnknown()
func (*PriorityClassPoolResourceLimits) XXX_Marshal ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PriorityClassPoolResourceLimits) XXX_Merge ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) XXX_Merge(src proto.Message)
func (*PriorityClassPoolResourceLimits) XXX_Size ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) XXX_Size() int
func (*PriorityClassPoolResourceLimits) XXX_Unmarshal ¶ added in v0.4.29
func (m *PriorityClassPoolResourceLimits) XXX_Unmarshal(b []byte) error
type PriorityClassResourceLimits ¶ added in v0.4.29
type PriorityClassResourceLimits struct { // Limits resources assigned to jobs of this priority class. // Specifically, jobs of this priority class are only scheduled if doing so does not exceed this limit. MaximumResourceFraction map[string]float64 `` /* 220-byte string literal not displayed */ // Per-pool override of maximum_resource_fraction. // If missing for a particular pool, maximum_resource_fraction is used instead for that pool. MaximumResourceFractionByPool map[string]*PriorityClassPoolResourceLimits `` /* 238-byte string literal not displayed */ }
func (*PriorityClassResourceLimits) Descriptor ¶ added in v0.4.29
func (*PriorityClassResourceLimits) Descriptor() ([]byte, []int)
func (*PriorityClassResourceLimits) GetMaximumResourceFraction ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) GetMaximumResourceFraction() map[string]float64
func (*PriorityClassResourceLimits) GetMaximumResourceFractionByPool ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) GetMaximumResourceFractionByPool() map[string]*PriorityClassPoolResourceLimits
func (*PriorityClassResourceLimits) Marshal ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) Marshal() (dAtA []byte, err error)
func (*PriorityClassResourceLimits) MarshalTo ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) MarshalTo(dAtA []byte) (int, error)
func (*PriorityClassResourceLimits) MarshalToSizedBuffer ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PriorityClassResourceLimits) ProtoMessage ¶ added in v0.4.29
func (*PriorityClassResourceLimits) ProtoMessage()
func (*PriorityClassResourceLimits) Reset ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) Reset()
func (*PriorityClassResourceLimits) Size ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) Size() (n int)
func (*PriorityClassResourceLimits) String ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) String() string
func (*PriorityClassResourceLimits) Unmarshal ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) Unmarshal(dAtA []byte) error
func (*PriorityClassResourceLimits) XXX_DiscardUnknown ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) XXX_DiscardUnknown()
func (*PriorityClassResourceLimits) XXX_Marshal ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PriorityClassResourceLimits) XXX_Merge ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) XXX_Merge(src proto.Message)
func (*PriorityClassResourceLimits) XXX_Size ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) XXX_Size() int
func (*PriorityClassResourceLimits) XXX_Unmarshal ¶ added in v0.4.29
func (m *PriorityClassResourceLimits) XXX_Unmarshal(b []byte) error
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"` // These are ignored and should be removed ResourceLimits map[string]float64 `` // Deprecated: Do not use. /* 192-byte string literal not displayed */ // Map from priority class name to resource limit overrides for this queue and priority class. // If provided for a priority class, global limits for that priority class do not apply to this queue. ResourceLimitsByPriorityClassName map[string]*PriorityClassResourceLimits `` /* 251-byte string literal not displayed */ Permissions []*Queue_Permissions `protobuf:"bytes,6,rep,name=permissions,proto3" json:"permissions,omitempty"` // Determines whether scheduling is enabled for this queue. Cordoned bool `protobuf:"varint,8,opt,name=cordoned,proto3" json:"cordoned,omitempty"` // A list of Kubernetes-like key-value labels, e.g. armadaproject.io/priority=critical Labels []string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty"` }
swagger:model
func (*Queue) Descriptor ¶
func (*Queue) GetCordoned ¶ added in v0.9.8
func (*Queue) GetGroupOwners ¶
func (*Queue) GetPermissions ¶
func (m *Queue) GetPermissions() []*Queue_Permissions
func (*Queue) GetPriorityFactor ¶
func (*Queue) GetResourceLimits
deprecated
func (*Queue) GetResourceLimitsByPriorityClassName ¶ added in v0.4.29
func (m *Queue) GetResourceLimitsByPriorityClassName() map[string]*PriorityClassResourceLimits
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 QueueCordonRequest ¶ added in v0.9.8
type QueueCordonRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*QueueCordonRequest) Descriptor ¶ added in v0.9.8
func (*QueueCordonRequest) Descriptor() ([]byte, []int)
func (*QueueCordonRequest) GetName ¶ added in v0.9.8
func (m *QueueCordonRequest) GetName() string
func (*QueueCordonRequest) Marshal ¶ added in v0.9.8
func (m *QueueCordonRequest) Marshal() (dAtA []byte, err error)
func (*QueueCordonRequest) MarshalTo ¶ added in v0.9.8
func (m *QueueCordonRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueueCordonRequest) MarshalToSizedBuffer ¶ added in v0.9.8
func (m *QueueCordonRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueCordonRequest) ProtoMessage ¶ added in v0.9.8
func (*QueueCordonRequest) ProtoMessage()
func (*QueueCordonRequest) Reset ¶ added in v0.9.8
func (m *QueueCordonRequest) Reset()
func (*QueueCordonRequest) Size ¶ added in v0.9.8
func (m *QueueCordonRequest) Size() (n int)
func (*QueueCordonRequest) String ¶ added in v0.9.8
func (m *QueueCordonRequest) String() string
func (*QueueCordonRequest) Unmarshal ¶ added in v0.9.8
func (m *QueueCordonRequest) Unmarshal(dAtA []byte) error
func (*QueueCordonRequest) XXX_DiscardUnknown ¶ added in v0.9.8
func (m *QueueCordonRequest) XXX_DiscardUnknown()
func (*QueueCordonRequest) XXX_Marshal ¶ added in v0.9.8
func (m *QueueCordonRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueCordonRequest) XXX_Merge ¶ added in v0.9.8
func (m *QueueCordonRequest) XXX_Merge(src proto.Message)
func (*QueueCordonRequest) XXX_Size ¶ added in v0.9.8
func (m *QueueCordonRequest) XXX_Size() int
func (*QueueCordonRequest) XXX_Unmarshal ¶ added in v0.9.8
func (m *QueueCordonRequest) XXX_Unmarshal(b []byte) error
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 (m *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 (m *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 (m *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 QueueServiceClient ¶ added in v0.7.0
type QueueServiceClient interface { 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) (QueueService_GetQueuesClient, error) CordonQueue(ctx context.Context, in *QueueCordonRequest, opts ...grpc.CallOption) (*types.Empty, error) UncordonQueue(ctx context.Context, in *QueueUncordonRequest, opts ...grpc.CallOption) (*types.Empty, error) }
QueueServiceClient is the client API for QueueService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueueServiceClient ¶ added in v0.7.0
func NewQueueServiceClient(cc *grpc.ClientConn) QueueServiceClient
type QueueServiceServer ¶ added in v0.7.0
type QueueServiceServer interface { 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, QueueService_GetQueuesServer) error CordonQueue(context.Context, *QueueCordonRequest) (*types.Empty, error) UncordonQueue(context.Context, *QueueUncordonRequest) (*types.Empty, error) }
QueueServiceServer is the server API for QueueService service.
type QueueService_GetQueuesClient ¶ added in v0.7.0
type QueueService_GetQueuesClient interface { Recv() (*StreamingQueueMessage, error) grpc.ClientStream }
type QueueService_GetQueuesServer ¶ added in v0.7.0
type QueueService_GetQueuesServer interface { Send(*StreamingQueueMessage) error grpc.ServerStream }
type QueueUncordonRequest ¶ added in v0.9.8
type QueueUncordonRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*QueueUncordonRequest) Descriptor ¶ added in v0.9.8
func (*QueueUncordonRequest) Descriptor() ([]byte, []int)
func (*QueueUncordonRequest) GetName ¶ added in v0.9.8
func (m *QueueUncordonRequest) GetName() string
func (*QueueUncordonRequest) Marshal ¶ added in v0.9.8
func (m *QueueUncordonRequest) Marshal() (dAtA []byte, err error)
func (*QueueUncordonRequest) MarshalTo ¶ added in v0.9.8
func (m *QueueUncordonRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueueUncordonRequest) MarshalToSizedBuffer ¶ added in v0.9.8
func (m *QueueUncordonRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueUncordonRequest) ProtoMessage ¶ added in v0.9.8
func (*QueueUncordonRequest) ProtoMessage()
func (*QueueUncordonRequest) Reset ¶ added in v0.9.8
func (m *QueueUncordonRequest) Reset()
func (*QueueUncordonRequest) Size ¶ added in v0.9.8
func (m *QueueUncordonRequest) Size() (n int)
func (*QueueUncordonRequest) String ¶ added in v0.9.8
func (m *QueueUncordonRequest) String() string
func (*QueueUncordonRequest) Unmarshal ¶ added in v0.9.8
func (m *QueueUncordonRequest) Unmarshal(dAtA []byte) error
func (*QueueUncordonRequest) XXX_DiscardUnknown ¶ added in v0.9.8
func (m *QueueUncordonRequest) XXX_DiscardUnknown()
func (*QueueUncordonRequest) XXX_Marshal ¶ added in v0.9.8
func (m *QueueUncordonRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueUncordonRequest) XXX_Merge ¶ added in v0.9.8
func (m *QueueUncordonRequest) XXX_Merge(src proto.Message)
func (*QueueUncordonRequest) XXX_Size ¶ added in v0.9.8
func (m *QueueUncordonRequest) XXX_Size() int
func (*QueueUncordonRequest) XXX_Unmarshal ¶ added in v0.9.8
func (m *QueueUncordonRequest) XXX_Unmarshal(b []byte) error
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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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)
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)
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) PreemptJobs(ctx context.Context, in *JobPreemptRequest, opts ...grpc.CallOption) (*types.Empty, 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) PreemptJobs(context.Context, *JobPreemptRequest) (*types.Empty, 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 *types.Duration `protobuf:"bytes,7,opt,name=interval,proto3" json:"interval,omitempty"` // Number of seconds to wait for jobs to finish. Timeout *types.Duration `protobuf:"bytes,8,opt,name=timeout,proto3" json:"timeout,omitempty"` 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 UnimplementedJobsServer ¶ added in v0.4.24
type UnimplementedJobsServer struct { }
UnimplementedJobsServer can be embedded to have forward compatible implementations.
func (*UnimplementedJobsServer) GetJobDetails ¶ added in v0.4.24
func (*UnimplementedJobsServer) GetJobDetails(ctx context.Context, req *JobDetailsRequest) (*JobDetailsResponse, error)
func (*UnimplementedJobsServer) GetJobRunDetails ¶ added in v0.4.24
func (*UnimplementedJobsServer) GetJobRunDetails(ctx context.Context, req *JobRunDetailsRequest) (*JobRunDetailsResponse, error)
func (*UnimplementedJobsServer) GetJobStatus ¶ added in v0.4.24
func (*UnimplementedJobsServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)
type UnimplementedQueueServiceServer ¶ added in v0.7.0
type UnimplementedQueueServiceServer struct { }
UnimplementedQueueServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueueServiceServer) CordonQueue ¶ added in v0.9.8
func (*UnimplementedQueueServiceServer) CordonQueue(ctx context.Context, req *QueueCordonRequest) (*types.Empty, error)
func (*UnimplementedQueueServiceServer) CreateQueue ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) CreateQueues ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) CreateQueues(ctx context.Context, req *QueueList) (*BatchQueueCreateResponse, error)
func (*UnimplementedQueueServiceServer) DeleteQueue ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) DeleteQueue(ctx context.Context, req *QueueDeleteRequest) (*types.Empty, error)
func (*UnimplementedQueueServiceServer) GetQueue ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) GetQueue(ctx context.Context, req *QueueGetRequest) (*Queue, error)
func (*UnimplementedQueueServiceServer) GetQueues ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) GetQueues(req *StreamingQueueGetRequest, srv QueueService_GetQueuesServer) error
func (*UnimplementedQueueServiceServer) UncordonQueue ¶ added in v0.9.8
func (*UnimplementedQueueServiceServer) UncordonQueue(ctx context.Context, req *QueueUncordonRequest) (*types.Empty, error)
func (*UnimplementedQueueServiceServer) UpdateQueue ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) UpdateQueues ¶ added in v0.7.0
func (*UnimplementedQueueServiceServer) UpdateQueues(ctx context.Context, req *QueueList) (*BatchQueueUpdateResponse, 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) PreemptJobs ¶ added in v0.4.41
func (*UnimplementedSubmitServer) PreemptJobs(ctx context.Context, req *JobPreemptRequest) (*types.Empty, 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"` }
func (*WatchRequest) Descriptor ¶
func (*WatchRequest) Descriptor() ([]byte, []int)
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 (m *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. |