api

package
v0.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2024 License: Apache-2.0 Imports: 31 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthHealth        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHealth          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHealth = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthJob        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowJob          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupJob = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSubmit        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubmit          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubmit = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTestspec        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTestspec          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTestspec = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Cause_name = map[int32]string{
	0: "Error",
	1: "Evicted",
	2: "OOM",
	3: "DeadlineExceeded",
	4: "Rejected",
}
View Source 
var Cause_value = map[string]int32{
	"Error":            0,
	"Evicted":          1,
	"OOM":              2,
	"DeadlineExceeded": 3,
	"Rejected":         4,
}
View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var IngressType_name = map[int32]string{
	0: "Ingress",
}
View Source 
var IngressType_value = map[string]int32{
	"Ingress": 0,
}
View Source 
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",
}
View Source 
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,
}
View Source 
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",
}
View Source 
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,
}
View Source 
var ServiceType_name = map[int32]string{
	0: "NodePort",
	1: "Headless",
}
View Source 
var ServiceType_value = map[string]int32{
	"NodePort": 0,
	"Headless": 1,
}
View Source 
var TestSpec_Cancel_name = map[int32]string{
	0: "NO",
	1: "BY_ID",
	2: "BY_SET",
	3: "BY_IDS",
}
View Source 
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 NodeIdFromExecutorAndNodeName(executor, nodeName string) string

func RegisterEventHandler 

func RegisterEventHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 

func RegisterJobsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 

func RegisterJobsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobsClient) error

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 

func RegisterJobsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobsServer) error

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 

func RegisterSubmitHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 (this *BatchQueueCreateResponse) String() string

func (*BatchQueueCreateResponse) Unmarshal 

func (m *BatchQueueCreateResponse) Unmarshal(dAtA []byte) error

func (*BatchQueueCreateResponse) XXX_DiscardUnknown 

func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()

func (*BatchQueueCreateResponse) XXX_Marshal 

func (m *BatchQueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchQueueCreateResponse) XXX_Merge 

func (m *BatchQueueCreateResponse) XXX_Merge(src proto.Message)

func (*BatchQueueCreateResponse) XXX_Size 

func (m *BatchQueueCreateResponse) XXX_Size() int

func (*BatchQueueCreateResponse) XXX_Unmarshal 

func (m *BatchQueueCreateResponse) XXX_Unmarshal(b []byte) error

type BatchQueueUpdateResponse 

type BatchQueueUpdateResponse struct {
	FailedQueues []*QueueUpdateResponse `protobuf:"bytes,1,rep,name=failed_queues,json=failedQueues,proto3" json:"failedQueues,omitempty"`
}

func (*BatchQueueUpdateResponse) Descriptor 

func (*BatchQueueUpdateResponse) Descriptor() ([]byte, []int)

func (*BatchQueueUpdateResponse) GetFailedQueues 

func (m *BatchQueueUpdateResponse) GetFailedQueues() []*QueueUpdateResponse

func (*BatchQueueUpdateResponse) Marshal 

func (m *BatchQueueUpdateResponse) Marshal() (dAtA []byte, err error)

func (*BatchQueueUpdateResponse) MarshalTo 

func (m *BatchQueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchQueueUpdateResponse) MarshalToSizedBuffer 

func (m *BatchQueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchQueueUpdateResponse) ProtoMessage 

func (*BatchQueueUpdateResponse) ProtoMessage()

func (*BatchQueueUpdateResponse) Reset 

func (m *BatchQueueUpdateResponse) Reset()

func (*BatchQueueUpdateResponse) Size 

func (m *BatchQueueUpdateResponse) Size() (n int)

func (*BatchQueueUpdateResponse) String 

func (this *BatchQueueUpdateResponse) String() string

func (*BatchQueueUpdateResponse) Unmarshal 

func (m *BatchQueueUpdateResponse) Unmarshal(dAtA []byte) error

func (*BatchQueueUpdateResponse) XXX_DiscardUnknown 

func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()

func (*BatchQueueUpdateResponse) XXX_Marshal 

func (m *BatchQueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchQueueUpdateResponse) XXX_Merge 

func (m *BatchQueueUpdateResponse) XXX_Merge(src proto.Message)

func (*BatchQueueUpdateResponse) XXX_Size 

func (m *BatchQueueUpdateResponse) XXX_Size() int

func (*BatchQueueUpdateResponse) XXX_Unmarshal 

func (m *BatchQueueUpdateResponse) XXX_Unmarshal(b []byte) error

type CancellationResult 

type CancellationResult struct {
	CancelledIds []string `protobuf:"bytes,1,rep,name=cancelled_ids,json=cancelledIds,proto3" json:"cancelledIds,omitempty"`
}

swagger:model

func (*CancellationResult) Descriptor 

func (*CancellationResult) Descriptor() ([]byte, []int)

func (*CancellationResult) GetCancelledIds 

func (m *CancellationResult) GetCancelledIds() []string

func (*CancellationResult) Marshal 

func (m *CancellationResult) Marshal() (dAtA []byte, err error)

func (*CancellationResult) MarshalTo 

func (m *CancellationResult) MarshalTo(dAtA []byte) (int, error)

func (*CancellationResult) MarshalToSizedBuffer 

func (m *CancellationResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CancellationResult) ProtoMessage 

func (*CancellationResult) ProtoMessage()

func (*CancellationResult) Reset 

func (m *CancellationResult) Reset()

func (*CancellationResult) Size 

func (m *CancellationResult) Size() (n int)

func (*CancellationResult) String 

func (this *CancellationResult) String() string

func (*CancellationResult) Unmarshal 

func (m *CancellationResult) Unmarshal(dAtA []byte) error

func (*CancellationResult) XXX_DiscardUnknown 

func (m *CancellationResult) XXX_DiscardUnknown()

func (*CancellationResult) XXX_Marshal 

func (m *CancellationResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancellationResult) XXX_Merge 

func (m *CancellationResult) XXX_Merge(src proto.Message)

func (*CancellationResult) XXX_Size 

func (m *CancellationResult) XXX_Size() int

func (*CancellationResult) XXX_Unmarshal 

func (m *CancellationResult) XXX_Unmarshal(b []byte) error

type Cause 

type Cause int32
const (
	Cause_Error            Cause = 0
	Cause_Evicted          Cause = 1
	Cause_OOM              Cause = 2
	Cause_DeadlineExceeded Cause = 3
	Cause_Rejected         Cause = 4
)

func (Cause) EnumDescriptor 

func (Cause) EnumDescriptor() ([]byte, []int)

func (Cause) String 

func (x Cause) String() string

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) MarshalTo 

func (m *ContainerStatus) MarshalTo(dAtA []byte) (int, error)

func (*ContainerStatus) MarshalToSizedBuffer 

func (m *ContainerStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size 

func (m *ContainerStatus) Size() (n int)

func (*ContainerStatus) String 

func (this *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal 

func (m *ContainerStatus) Unmarshal(dAtA []byte) error

func (*ContainerStatus) XXX_DiscardUnknown 

func (m *ContainerStatus) XXX_DiscardUnknown()

func (*ContainerStatus) XXX_Marshal 

func (m *ContainerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerStatus) XXX_Merge 

func (m *ContainerStatus) XXX_Merge(src proto.Message)

func (*ContainerStatus) XXX_Size 

func (m *ContainerStatus) XXX_Size() int

func (*ContainerStatus) XXX_Unmarshal 

func (m *ContainerStatus) XXX_Unmarshal(b []byte) error

type CustomSubmitClient added in v0.4.8 

type CustomSubmitClient struct {
	Inner SubmitClient
}

func (*CustomSubmitClient) SubmitJobs added in v0.4.8 

func (c *CustomSubmitClient) SubmitJobs(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)

type EndMarker added in v0.3.100 

type EndMarker struct {
}

Indicates the end of streams

func (*EndMarker) Descriptor added in v0.3.100 

func (*EndMarker) Descriptor() ([]byte, []int)

func (*EndMarker) Marshal added in v0.3.100 

func (m *EndMarker) Marshal() (dAtA []byte, err error)

func (*EndMarker) MarshalTo added in v0.3.100 

func (m *EndMarker) MarshalTo(dAtA []byte) (int, error)

func (*EndMarker) MarshalToSizedBuffer added in v0.3.100 

func (m *EndMarker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndMarker) ProtoMessage added in v0.3.100 

func (*EndMarker) ProtoMessage()

func (*EndMarker) Reset added in v0.3.100 

func (m *EndMarker) Reset()

func (*EndMarker) Size added in v0.3.100 

func (m *EndMarker) Size() (n int)

func (*EndMarker) String added in v0.3.100 

func (this *EndMarker) String() string

func (*EndMarker) Unmarshal added in v0.3.100 

func (m *EndMarker) Unmarshal(dAtA []byte) error

func (*EndMarker) XXX_DiscardUnknown added in v0.3.100 

func (m *EndMarker) XXX_DiscardUnknown()

func (*EndMarker) XXX_Marshal added in v0.3.100 

func (m *EndMarker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndMarker) XXX_Merge added in v0.3.100 

func (m *EndMarker) XXX_Merge(src proto.Message)

func (*EndMarker) XXX_Size added in v0.3.100 

func (m *EndMarker) XXX_Size() int

func (*EndMarker) XXX_Unmarshal added in v0.3.100 

func (m *EndMarker) XXX_Unmarshal(b []byte) error

type Event 

type Event interface {
	GetJobId() string
	GetJobSetId() string
	GetQueue() string
	GetCreated() time.Time
}

func UnwrapEvent 

func UnwrapEvent(message *EventMessage) (Event, error)

type EventClient 

type EventClient interface {
	GetJobSetEvents(ctx context.Context, in *JobSetRequest, opts ...grpc.CallOption) (Event_GetJobSetEventsClient, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Event_WatchClient, error)
	Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

EventClient is the client API for Event service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventClient 

func NewEventClient(cc *grpc.ClientConn) EventClient

type EventMessage 

type EventMessage struct {
	// Types that are valid to be assigned to Events:
	//	*EventMessage_Submitted
	//	*EventMessage_Queued
	//	*EventMessage_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) MarshalTo 

func (m *EventMessage) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage) MarshalToSizedBuffer 

func (m *EventMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) Reset 

func (m *EventMessage) Reset()

func (*EventMessage) ShortString 

func (msg *EventMessage) ShortString() string

func (*EventMessage) Size 

func (m *EventMessage) Size() (n int)

func (*EventMessage) String 

func (this *EventMessage) String() string

func (*EventMessage) Unmarshal 

func (m *EventMessage) Unmarshal(dAtA []byte) error

func (*EventMessage) UnmarshalJSON 

func (message *EventMessage) UnmarshalJSON(data []byte) error

func (*EventMessage) XXX_DiscardUnknown 

func (m *EventMessage) XXX_DiscardUnknown()

func (*EventMessage) XXX_Marshal 

func (m *EventMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventMessage) XXX_Merge 

func (m *EventMessage) XXX_Merge(src proto.Message)

func (*EventMessage) XXX_OneofWrappers 

func (*EventMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EventMessage) XXX_Size 

func (m *EventMessage) XXX_Size() int

func (*EventMessage) XXX_Unmarshal 

func (m *EventMessage) XXX_Unmarshal(b []byte) error

type EventMessage_Cancelled 

type EventMessage_Cancelled struct {
	Cancelled *JobCancelledEvent `protobuf:"bytes,13,opt,name=cancelled,proto3,oneof" json:"cancelled,omitempty"`
}

func (*EventMessage_Cancelled) MarshalTo 

func (m *EventMessage_Cancelled) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Cancelled) MarshalToSizedBuffer 

func (m *EventMessage_Cancelled) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Cancelled) Size 

func (m *EventMessage_Cancelled) Size() (n int)

func (*EventMessage_Cancelled) String 

func (this *EventMessage_Cancelled) String() string

type EventMessage_Cancelling 

type EventMessage_Cancelling struct {
	Cancelling *JobCancellingEvent `protobuf:"bytes,12,opt,name=cancelling,proto3,oneof" json:"cancelling,omitempty"`
}

func (*EventMessage_Cancelling) MarshalTo 

func (m *EventMessage_Cancelling) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Cancelling) MarshalToSizedBuffer 

func (m *EventMessage_Cancelling) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Cancelling) Size 

func (m *EventMessage_Cancelling) Size() (n int)

func (*EventMessage_Cancelling) String 

func (this *EventMessage_Cancelling) String() string

type EventMessage_Failed 

type EventMessage_Failed struct {
	Failed *JobFailedEvent `protobuf:"bytes,9,opt,name=failed,proto3,oneof" json:"failed,omitempty"`
}

func (*EventMessage_Failed) MarshalTo 

func (m *EventMessage_Failed) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Failed) MarshalToSizedBuffer 

func (m *EventMessage_Failed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Failed) Size 

func (m *EventMessage_Failed) Size() (n int)

func (*EventMessage_Failed) String 

func (this *EventMessage_Failed) String() string

type EventMessage_IngressInfo 

type EventMessage_IngressInfo struct {
	IngressInfo *JobIngressInfoEvent `protobuf:"bytes,17,opt,name=ingress_info,json=ingressInfo,proto3,oneof" json:"ingressInfo,omitempty"`
}

func (*EventMessage_IngressInfo) MarshalTo 

func (m *EventMessage_IngressInfo) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_IngressInfo) MarshalToSizedBuffer 

func (m *EventMessage_IngressInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_IngressInfo) Size 

func (m *EventMessage_IngressInfo) Size() (n int)

func (*EventMessage_IngressInfo) String 

func (this *EventMessage_IngressInfo) String() string

type EventMessage_LeaseExpired 

type EventMessage_LeaseExpired struct {
	LeaseExpired *JobLeaseExpiredEvent `protobuf:"bytes,5,opt,name=lease_expired,json=leaseExpired,proto3,oneof" json:"leaseExpired,omitempty"`
}

func (*EventMessage_LeaseExpired) MarshalTo 

func (m *EventMessage_LeaseExpired) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_LeaseExpired) MarshalToSizedBuffer 

func (m *EventMessage_LeaseExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_LeaseExpired) Size 

func (m *EventMessage_LeaseExpired) Size() (n int)

func (*EventMessage_LeaseExpired) String 

func (this *EventMessage_LeaseExpired) String() string

type EventMessage_LeaseReturned 

type EventMessage_LeaseReturned struct {
	LeaseReturned *JobLeaseReturnedEvent `protobuf:"bytes,4,opt,name=lease_returned,json=leaseReturned,proto3,oneof" json:"leaseReturned,omitempty"`
}

func (*EventMessage_LeaseReturned) MarshalTo 

func (m *EventMessage_LeaseReturned) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_LeaseReturned) MarshalToSizedBuffer 

func (m *EventMessage_LeaseReturned) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_LeaseReturned) Size 

func (m *EventMessage_LeaseReturned) Size() (n int)

func (*EventMessage_LeaseReturned) String 

func (this *EventMessage_LeaseReturned) String() string

type EventMessage_Leased 

type EventMessage_Leased struct {
	Leased *JobLeasedEvent `protobuf:"bytes,3,opt,name=leased,proto3,oneof" json:"leased,omitempty"`
}

func (*EventMessage_Leased) MarshalTo 

func (m *EventMessage_Leased) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Leased) MarshalToSizedBuffer 

func (m *EventMessage_Leased) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Leased) Size 

func (m *EventMessage_Leased) Size() (n int)

func (*EventMessage_Leased) String 

func (this *EventMessage_Leased) String() string

type EventMessage_Pending 

type EventMessage_Pending struct {
	Pending *JobPendingEvent `protobuf:"bytes,6,opt,name=pending,proto3,oneof" json:"pending,omitempty"`
}

func (*EventMessage_Pending) MarshalTo 

func (m *EventMessage_Pending) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Pending) MarshalToSizedBuffer 

func (m *EventMessage_Pending) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Pending) Size 

func (m *EventMessage_Pending) Size() (n int)

func (*EventMessage_Pending) String 

func (this *EventMessage_Pending) String() string

type EventMessage_Preempted 

type EventMessage_Preempted struct {
	Preempted *JobPreemptedEvent `protobuf:"bytes,21,opt,name=preempted,proto3,oneof" json:"preempted,omitempty"`
}

func (*EventMessage_Preempted) MarshalTo 

func (m *EventMessage_Preempted) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Preempted) MarshalToSizedBuffer 

func (m *EventMessage_Preempted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Preempted) Size 

func (m *EventMessage_Preempted) Size() (n int)

func (*EventMessage_Preempted) String 

func (this *EventMessage_Preempted) String() string

type EventMessage_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)

func (*EventMessage_Preempting) String added in v0.4.41 

func (this *EventMessage_Preempting) String() string

type EventMessage_Queued 

type EventMessage_Queued struct {
	Queued *JobQueuedEvent `protobuf:"bytes,2,opt,name=queued,proto3,oneof" json:"queued,omitempty"`
}

func (*EventMessage_Queued) MarshalTo 

func (m *EventMessage_Queued) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Queued) MarshalToSizedBuffer 

func (m *EventMessage_Queued) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Queued) Size 

func (m *EventMessage_Queued) Size() (n int)

func (*EventMessage_Queued) String 

func (this *EventMessage_Queued) String() string

type EventMessage_Reprioritized 

type EventMessage_Reprioritized struct {
	Reprioritized *JobReprioritizedEvent `protobuf:"bytes,11,opt,name=reprioritized,proto3,oneof" json:"reprioritized,omitempty"`
}

func (*EventMessage_Reprioritized) MarshalTo 

func (m *EventMessage_Reprioritized) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Reprioritized) MarshalToSizedBuffer 

func (m *EventMessage_Reprioritized) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Reprioritized) Size 

func (m *EventMessage_Reprioritized) Size() (n int)

func (*EventMessage_Reprioritized) String 

func (this *EventMessage_Reprioritized) String() string

type EventMessage_Reprioritizing 

type EventMessage_Reprioritizing struct {
	Reprioritizing *JobReprioritizingEvent `protobuf:"bytes,18,opt,name=reprioritizing,proto3,oneof" json:"reprioritizing,omitempty"`
}

func (*EventMessage_Reprioritizing) MarshalTo 

func (m *EventMessage_Reprioritizing) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Reprioritizing) MarshalToSizedBuffer 

func (m *EventMessage_Reprioritizing) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Reprioritizing) Size 

func (m *EventMessage_Reprioritizing) Size() (n int)

func (*EventMessage_Reprioritizing) String 

func (this *EventMessage_Reprioritizing) String() string

type EventMessage_Running 

type EventMessage_Running struct {
	Running *JobRunningEvent `protobuf:"bytes,7,opt,name=running,proto3,oneof" json:"running,omitempty"`
}

func (*EventMessage_Running) MarshalTo 

func (m *EventMessage_Running) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Running) MarshalToSizedBuffer 

func (m *EventMessage_Running) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Running) Size 

func (m *EventMessage_Running) Size() (n int)

func (*EventMessage_Running) String 

func (this *EventMessage_Running) String() string

type EventMessage_Submitted 

type EventMessage_Submitted struct {
	Submitted *JobSubmittedEvent `protobuf:"bytes,1,opt,name=submitted,proto3,oneof" json:"submitted,omitempty"`
}

func (*EventMessage_Submitted) MarshalTo 

func (m *EventMessage_Submitted) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Submitted) MarshalToSizedBuffer 

func (m *EventMessage_Submitted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Submitted) Size 

func (m *EventMessage_Submitted) Size() (n int)

func (*EventMessage_Submitted) String 

func (this *EventMessage_Submitted) String() string

type EventMessage_Succeeded 

type EventMessage_Succeeded struct {
	Succeeded *JobSucceededEvent `protobuf:"bytes,10,opt,name=succeeded,proto3,oneof" json:"succeeded,omitempty"`
}

func (*EventMessage_Succeeded) MarshalTo 

func (m *EventMessage_Succeeded) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Succeeded) MarshalToSizedBuffer 

func (m *EventMessage_Succeeded) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Succeeded) Size 

func (m *EventMessage_Succeeded) Size() (n int)

func (*EventMessage_Succeeded) String 

func (this *EventMessage_Succeeded) String() string

type EventMessage_Terminated 

type EventMessage_Terminated struct {
	Terminated *JobTerminatedEvent `protobuf:"bytes,14,opt,name=terminated,proto3,oneof" json:"terminated,omitempty"`
}

func (*EventMessage_Terminated) MarshalTo 

func (m *EventMessage_Terminated) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Terminated) MarshalToSizedBuffer 

func (m *EventMessage_Terminated) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Terminated) Size 

func (m *EventMessage_Terminated) Size() (n int)

func (*EventMessage_Terminated) String 

func (this *EventMessage_Terminated) String() string

type EventMessage_UnableToSchedule 

type EventMessage_UnableToSchedule struct {
	UnableToSchedule *JobUnableToScheduleEvent `protobuf:"bytes,8,opt,name=unable_to_schedule,json=unableToSchedule,proto3,oneof" json:"unableToSchedule,omitempty"`
}

func (*EventMessage_UnableToSchedule) MarshalTo 

func (m *EventMessage_UnableToSchedule) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_UnableToSchedule) MarshalToSizedBuffer 

func (m *EventMessage_UnableToSchedule) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_UnableToSchedule) Size 

func (m *EventMessage_UnableToSchedule) Size() (n int)

func (*EventMessage_UnableToSchedule) String 

func (this *EventMessage_UnableToSchedule) String() string

type EventMessage_Utilisation 

type EventMessage_Utilisation struct {
	Utilisation *JobUtilisationEvent `protobuf:"bytes,15,opt,name=utilisation,proto3,oneof" json:"utilisation,omitempty"`
}

func (*EventMessage_Utilisation) MarshalTo 

func (m *EventMessage_Utilisation) MarshalTo(dAtA []byte) (int, error)

func (*EventMessage_Utilisation) MarshalToSizedBuffer 

func (m *EventMessage_Utilisation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventMessage_Utilisation) Size 

func (m *EventMessage_Utilisation) Size() (n int)

func (*EventMessage_Utilisation) String 

func (this *EventMessage_Utilisation) String() string

type EventServer 

type EventServer interface {
	GetJobSetEvents(*JobSetRequest, Event_GetJobSetEventsServer) error
	Watch(*WatchRequest, Event_WatchServer) error
	Health(context.Context, *types.Empty) (*HealthCheckResponse, error)
}

EventServer is the server API for Event service.

type EventStreamMessage 

type EventStreamMessage struct {
	Id      string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Message *EventMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

swagger:model

func (*EventStreamMessage) Descriptor 

func (*EventStreamMessage) Descriptor() ([]byte, []int)

func (*EventStreamMessage) GetId 

func (m *EventStreamMessage) GetId() string

func (*EventStreamMessage) GetMessage 

func (m *EventStreamMessage) GetMessage() *EventMessage

func (*EventStreamMessage) Marshal 

func (m *EventStreamMessage) Marshal() (dAtA []byte, err error)

func (*EventStreamMessage) MarshalTo 

func (m *EventStreamMessage) MarshalTo(dAtA []byte) (int, error)

func (*EventStreamMessage) MarshalToSizedBuffer 

func (m *EventStreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventStreamMessage) ProtoMessage 

func (*EventStreamMessage) ProtoMessage()

func (*EventStreamMessage) Reset 

func (m *EventStreamMessage) Reset()

func (*EventStreamMessage) Size 

func (m *EventStreamMessage) Size() (n int)

func (*EventStreamMessage) String 

func (this *EventStreamMessage) String() string

func (*EventStreamMessage) Unmarshal 

func (m *EventStreamMessage) Unmarshal(dAtA []byte) error

func (*EventStreamMessage) XXX_DiscardUnknown 

func (m *EventStreamMessage) XXX_DiscardUnknown()

func (*EventStreamMessage) XXX_Marshal 

func (m *EventStreamMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventStreamMessage) XXX_Merge 

func (m *EventStreamMessage) XXX_Merge(src proto.Message)

func (*EventStreamMessage) XXX_Size 

func (m *EventStreamMessage) XXX_Size() int

func (*EventStreamMessage) XXX_Unmarshal 

func (m *EventStreamMessage) XXX_Unmarshal(b []byte) error

type Event_GetJobSetEventsClient 

type Event_GetJobSetEventsClient interface {
	Recv() (*EventStreamMessage, error)
	grpc.ClientStream
}

type Event_GetJobSetEventsServer 

type Event_GetJobSetEventsServer interface {
	Send(*EventStreamMessage) error
	grpc.ServerStream
}

type Event_WatchClient 

type Event_WatchClient interface {
	Recv() (*EventStreamMessage, error)
	grpc.ClientStream
}

type Event_WatchServer 

type Event_WatchServer interface {
	Send(*EventStreamMessage) error
	grpc.ServerStream
}

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=api.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
}

func (*HealthCheckResponse) Descriptor 

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) Marshal 

func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error)

func (*HealthCheckResponse) MarshalTo 

func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheckResponse) MarshalToSizedBuffer 

func (m *HealthCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size 

func (m *HealthCheckResponse) Size() (n int)

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal 

func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResponse) XXX_Merge 

func (m *HealthCheckResponse) XXX_Merge(src proto.Message)

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type IngressConfig 

type IngressConfig struct {
	Type         IngressType       `protobuf:"varint,1,opt,name=type,proto3,enum=api.IngressType" json:"type,omitempty"` // Deprecated: Do not use.
	Ports        []uint32          `protobuf:"varint,2,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	Annotations  map[string]string `` /* 163-byte string literal not displayed */
	TlsEnabled   bool              `protobuf:"varint,4,opt,name=tls_enabled,json=tlsEnabled,proto3" json:"tlsEnabled,omitempty"`
	CertName     string            `protobuf:"bytes,5,opt,name=cert_name,json=certName,proto3" json:"certName,omitempty"`
	UseClusterIP bool              `protobuf:"varint,6,opt,name=use_clusterIP,json=useClusterIP,proto3" json:"useClusterIP,omitempty"`
}

func (*IngressConfig) Descriptor 

func (*IngressConfig) Descriptor() ([]byte, []int)

func (*IngressConfig) GetAnnotations 

func (m *IngressConfig) GetAnnotations() map[string]string

func (*IngressConfig) GetCertName 

func (m *IngressConfig) GetCertName() string

func (*IngressConfig) GetPorts 

func (m *IngressConfig) GetPorts() []uint32

func (*IngressConfig) GetTlsEnabled 

func (m *IngressConfig) GetTlsEnabled() bool

func (*IngressConfig) GetType deprecated 

func (m *IngressConfig) GetType() IngressType

Deprecated: Do not use.

func (*IngressConfig) GetUseClusterIP 

func (m *IngressConfig) GetUseClusterIP() bool

func (*IngressConfig) Marshal 

func (m *IngressConfig) Marshal() (dAtA []byte, err error)

func (*IngressConfig) MarshalTo 

func (m *IngressConfig) MarshalTo(dAtA []byte) (int, error)

func (*IngressConfig) MarshalToSizedBuffer 

func (m *IngressConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IngressConfig) ProtoMessage 

func (*IngressConfig) ProtoMessage()

func (*IngressConfig) Reset 

func (m *IngressConfig) Reset()

func (*IngressConfig) Size 

func (m *IngressConfig) Size() (n int)

func (*IngressConfig) String 

func (this *IngressConfig) String() string

func (*IngressConfig) Unmarshal 

func (m *IngressConfig) Unmarshal(dAtA []byte) error

func (*IngressConfig) XXX_DiscardUnknown 

func (m *IngressConfig) XXX_DiscardUnknown()

func (*IngressConfig) XXX_Marshal 

func (m *IngressConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IngressConfig) XXX_Merge 

func (m *IngressConfig) XXX_Merge(src proto.Message)

func (*IngressConfig) XXX_Size 

func (m *IngressConfig) XXX_Size() int

func (*IngressConfig) XXX_Unmarshal 

func (m *IngressConfig) XXX_Unmarshal(b []byte) error

type IngressType 

type IngressType int32

Ingress type is being kept here to maintain backwards compatibility for a while. 

const (
	IngressType_Ingress IngressType = 0
)

func (IngressType) EnumDescriptor 

func (IngressType) EnumDescriptor() ([]byte, []int)

func (IngressType) String 

func (x IngressType) String() string

func (*IngressType) UnmarshalJSON 

func (x *IngressType) UnmarshalJSON(data []byte) error

type Job 

type Job struct {
	Id                 string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClientId           string            `protobuf:"bytes,13,opt,name=client_id,json=clientId,proto3" json:"clientId,omitempty"`
	JobSetId           string            `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue              string            `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Namespace          string            `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels             map[string]string `` /* 153-byte string literal not displayed */
	Annotations        map[string]string `` /* 164-byte string literal not displayed */
	RequiredNodeLabels map[string]string `` // Deprecated: Do not use.
	/* 204-byte string literal not displayed */
	Owner                              string        `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"`
	QueueOwnershipUserGroups           []string      `` /* 135-byte string literal not displayed */
	CompressedQueueOwnershipUserGroups []byte        `` /* 166-byte string literal not displayed */
	Priority                           float64       `protobuf:"fixed64,4,opt,name=priority,proto3" json:"priority,omitempty"`
	PodSpec                            *v1.PodSpec   `protobuf:"bytes,5,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"` // Deprecated: Do not use.
	PodSpecs                           []*v1.PodSpec `protobuf:"bytes,12,rep,name=pod_specs,json=podSpecs,proto3" json:"podSpecs,omitempty"`
	// Resource requests and limits necessary for scheduling the main pod of this job.
	// The requests and limits herein are set to:
	//
	// max(
	//
	//	sum across all containers,
	//	max over all init containers,
	//
	// )
	//
	// This is because containers run in parallel, whereas initContainers run serially.
	// This field is populated automatically at submission.
	// Submitting a job with this field already populated results in an error.
	SchedulingResourceRequirements v1.ResourceRequirements `` /* 142-byte string literal not displayed */
	Created                        time.Time               `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created"`
	// Services can be provided either as Armada-specific config objects or as proper k8s objects.
	// These options are exclusive, i.e., if either ingress or services is provided,
	// then neither of k8s_ingress or k8s_service can be provided, and vice versa.
	Ingress    []*IngressConfig `protobuf:"bytes,14,rep,name=ingress,proto3" json:"ingress,omitempty"`
	Services   []*ServiceConfig `protobuf:"bytes,16,rep,name=services,proto3" json:"services,omitempty"`
	K8SIngress []*v11.Ingress   `protobuf:"bytes,17,rep,name=k8s_ingress,json=k8sIngress,proto3" json:"k8sIngress,omitempty"`
	K8SService []*v1.Service    `protobuf:"bytes,18,rep,name=k8s_service,json=k8sService,proto3" json:"k8sService,omitempty"`
	// Indicates which scheduler should manage this job.
	// If empty, the default scheduler is used.
	Scheduler string `protobuf:"bytes,20,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Queuing TTL for this job in seconds. If this job queues for more than this duration it will be cancelled. Zero indicates an infinite lifetime.
	QueueTtlSeconds int64 `protobuf:"varint,22,opt,name=queue_ttl_seconds,json=queueTtlSeconds,proto3" json:"queueTtlSeconds,omitempty"`
}

func (*Job) Descriptor 

func (*Job) Descriptor() ([]byte, []int)

func (*Job) GetAnnotations 

func (m *Job) GetAnnotations() map[string]string

func (*Job) GetClientId 

func (m *Job) GetClientId() string

func (*Job) GetCompressedQueueOwnershipUserGroups 

func (m *Job) GetCompressedQueueOwnershipUserGroups() []byte

func (*Job) GetCreated 

func (m *Job) GetCreated() time.Time

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetIngress 

func (m *Job) GetIngress() []*IngressConfig

func (*Job) GetJobSetId 

func (m *Job) GetJobSetId() string

func (*Job) GetK8SIngress 

func (m *Job) GetK8SIngress() []*v11.Ingress

func (*Job) GetK8SService 

func (m *Job) GetK8SService() []*v1.Service

func (*Job) GetLabels 

func (m *Job) GetLabels() map[string]string

func (*Job) GetMainPodSpec added in v0.3.47 

func (job *Job) GetMainPodSpec() *v1.PodSpec

func (*Job) GetNamespace 

func (m *Job) GetNamespace() string

func (*Job) GetOwner 

func (m *Job) GetOwner() string

func (*Job) GetPodSpec deprecated 

func (m *Job) GetPodSpec() *v1.PodSpec

Deprecated: Do not use.

func (*Job) GetPodSpecs 

func (m *Job) GetPodSpecs() []*v1.PodSpec

func (*Job) GetPriority 

func (m *Job) GetPriority() float64

func (*Job) GetQueue 

func (m *Job) GetQueue() string

func (*Job) GetQueueOwnershipUserGroups 

func (m *Job) GetQueueOwnershipUserGroups() []string

func (*Job) GetQueueTtlSeconds added in v0.3.95 

func (m *Job) GetQueueTtlSeconds() int64

func (*Job) GetRequiredNodeLabels deprecated 

func (m *Job) GetRequiredNodeLabels() map[string]string

Deprecated: Do not use.

func (*Job) GetScheduler 

func (m *Job) GetScheduler() string

func (*Job) GetSchedulingResourceRequirements added in v0.3.70 

func (m *Job) GetSchedulingResourceRequirements() v1.ResourceRequirements

func (*Job) GetServices 

func (m *Job) GetServices() []*ServiceConfig

func (*Job) Marshal 

func (m *Job) Marshal() (dAtA []byte, err error)

func (*Job) MarshalTo 

func (m *Job) MarshalTo(dAtA []byte) (int, error)

func (*Job) MarshalToSizedBuffer 

func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (this *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (m *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *JobCancelRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobCancelRequest) MarshalToSizedBuffer 

func (m *JobCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobCancelRequest) ProtoMessage 

func (*JobCancelRequest) ProtoMessage()

func (*JobCancelRequest) Reset 

func (m *JobCancelRequest) Reset()

func (*JobCancelRequest) Size 

func (m *JobCancelRequest) Size() (n int)

func (*JobCancelRequest) String 

func (this *JobCancelRequest) String() string

func (*JobCancelRequest) Unmarshal 

func (m *JobCancelRequest) Unmarshal(dAtA []byte) error

func (*JobCancelRequest) XXX_DiscardUnknown 

func (m *JobCancelRequest) XXX_DiscardUnknown()

func (*JobCancelRequest) XXX_Marshal 

func (m *JobCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobCancelRequest) XXX_Merge 

func (m *JobCancelRequest) XXX_Merge(src proto.Message)

func (*JobCancelRequest) XXX_Size 

func (m *JobCancelRequest) XXX_Size() int

func (*JobCancelRequest) XXX_Unmarshal 

func (m *JobCancelRequest) XXX_Unmarshal(b []byte) error

type JobCancelledEvent 

type JobCancelledEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	Requestor string    `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"`
	Reason    string    `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*JobCancelledEvent) Descriptor 

func (*JobCancelledEvent) Descriptor() ([]byte, []int)

func (*JobCancelledEvent) GetCreated 

func (m *JobCancelledEvent) GetCreated() time.Time

func (*JobCancelledEvent) GetJobId 

func (m *JobCancelledEvent) GetJobId() string

func (*JobCancelledEvent) GetJobSetId 

func (m *JobCancelledEvent) GetJobSetId() string

func (*JobCancelledEvent) GetQueue 

func (m *JobCancelledEvent) GetQueue() string

func (*JobCancelledEvent) GetReason added in v0.3.68 

func (m *JobCancelledEvent) GetReason() string

func (*JobCancelledEvent) GetRequestor 

func (m *JobCancelledEvent) GetRequestor() string

func (*JobCancelledEvent) Marshal 

func (m *JobCancelledEvent) Marshal() (dAtA []byte, err error)

func (*JobCancelledEvent) MarshalTo 

func (m *JobCancelledEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobCancelledEvent) MarshalToSizedBuffer 

func (m *JobCancelledEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobCancelledEvent) ProtoMessage 

func (*JobCancelledEvent) ProtoMessage()

func (*JobCancelledEvent) Reset 

func (m *JobCancelledEvent) Reset()

func (*JobCancelledEvent) Size 

func (m *JobCancelledEvent) Size() (n int)

func (*JobCancelledEvent) String 

func (this *JobCancelledEvent) String() string

func (*JobCancelledEvent) Unmarshal 

func (m *JobCancelledEvent) Unmarshal(dAtA []byte) error

func (*JobCancelledEvent) XXX_DiscardUnknown 

func (m *JobCancelledEvent) XXX_DiscardUnknown()

func (*JobCancelledEvent) XXX_Marshal 

func (m *JobCancelledEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobCancelledEvent) XXX_Merge 

func (m *JobCancelledEvent) XXX_Merge(src proto.Message)

func (*JobCancelledEvent) XXX_Size 

func (m *JobCancelledEvent) XXX_Size() int

func (*JobCancelledEvent) XXX_Unmarshal 

func (m *JobCancelledEvent) XXX_Unmarshal(b []byte) error

type JobCancellingEvent 

type JobCancellingEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	Requestor string    `protobuf:"bytes,5,opt,name=requestor,proto3" json:"requestor,omitempty"`
	Reason    string    `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*JobCancellingEvent) Descriptor 

func (*JobCancellingEvent) Descriptor() ([]byte, []int)

func (*JobCancellingEvent) GetCreated 

func (m *JobCancellingEvent) GetCreated() time.Time

func (*JobCancellingEvent) GetJobId 

func (m *JobCancellingEvent) GetJobId() string

func (*JobCancellingEvent) GetJobSetId 

func (m *JobCancellingEvent) GetJobSetId() string

func (*JobCancellingEvent) GetQueue 

func (m *JobCancellingEvent) GetQueue() string

func (*JobCancellingEvent) GetReason added in v0.3.68 

func (m *JobCancellingEvent) GetReason() string

func (*JobCancellingEvent) GetRequestor 

func (m *JobCancellingEvent) GetRequestor() string

func (*JobCancellingEvent) Marshal 

func (m *JobCancellingEvent) Marshal() (dAtA []byte, err error)

func (*JobCancellingEvent) MarshalTo 

func (m *JobCancellingEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobCancellingEvent) MarshalToSizedBuffer 

func (m *JobCancellingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobCancellingEvent) ProtoMessage 

func (*JobCancellingEvent) ProtoMessage()

func (*JobCancellingEvent) Reset 

func (m *JobCancellingEvent) Reset()

func (*JobCancellingEvent) Size 

func (m *JobCancellingEvent) Size() (n int)

func (*JobCancellingEvent) String 

func (this *JobCancellingEvent) String() string

func (*JobCancellingEvent) Unmarshal 

func (m *JobCancellingEvent) Unmarshal(dAtA []byte) error

func (*JobCancellingEvent) XXX_DiscardUnknown 

func (m *JobCancellingEvent) XXX_DiscardUnknown()

func (*JobCancellingEvent) XXX_Marshal 

func (m *JobCancellingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobCancellingEvent) XXX_Merge 

func (m *JobCancellingEvent) XXX_Merge(src proto.Message)

func (*JobCancellingEvent) XXX_Size 

func (m *JobCancellingEvent) XXX_Size() int

func (*JobCancellingEvent) XXX_Unmarshal 

func (m *JobCancellingEvent) XXX_Unmarshal(b []byte) error

type 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      *time.Time       `protobuf:"bytes,6,opt,name=submitted_ts,json=submittedTs,proto3,stdtime" json:"submittedTs,omitempty"`
	CancelTs         *time.Time       `protobuf:"bytes,7,opt,name=cancel_ts,json=cancelTs,proto3,stdtime" json:"cancelTs,omitempty"`
	CancelReason     string           `protobuf:"bytes,8,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancelReason,omitempty"`
	LastTransitionTs *time.Time       `protobuf:"bytes,9,opt,name=last_transition_ts,json=lastTransitionTs,proto3,stdtime" 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() *time.Time

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() *time.Time

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() *time.Time

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 (this *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 (this *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 (this *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   time.Time        `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId string           `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Reason    string           `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	ExitCodes map[string]int32 `` // Deprecated: Do not use.
	/* 176-byte string literal not displayed */
	KubernetesId      string             `protobuf:"bytes,8,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName          string             `protobuf:"bytes,9,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber         int32              `protobuf:"varint,10,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName           string             `protobuf:"bytes,13,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace      string             `protobuf:"bytes,14,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
	ContainerStatuses []*ContainerStatus `protobuf:"bytes,11,rep,name=container_statuses,json=containerStatuses,proto3" json:"containerStatuses,omitempty"`
	Cause             Cause              `protobuf:"varint,12,opt,name=cause,proto3,enum=api.Cause" json:"cause,omitempty"`
}

func (*JobFailedEvent) Descriptor 

func (*JobFailedEvent) Descriptor() ([]byte, []int)

func (*JobFailedEvent) GetCause 

func (m *JobFailedEvent) GetCause() Cause

func (*JobFailedEvent) GetClusterId 

func (m *JobFailedEvent) GetClusterId() string

func (*JobFailedEvent) GetContainerStatuses 

func (m *JobFailedEvent) GetContainerStatuses() []*ContainerStatus

func (*JobFailedEvent) GetCreated 

func (m *JobFailedEvent) GetCreated() time.Time

func (*JobFailedEvent) GetExitCodes deprecated 

func (m *JobFailedEvent) GetExitCodes() map[string]int32

Deprecated: Do not use.

func (*JobFailedEvent) GetJobId 

func (m *JobFailedEvent) GetJobId() string

func (*JobFailedEvent) GetJobSetId 

func (m *JobFailedEvent) GetJobSetId() string

func (*JobFailedEvent) GetKubernetesId 

func (m *JobFailedEvent) GetKubernetesId() string

func (*JobFailedEvent) GetNodeName 

func (m *JobFailedEvent) GetNodeName() string

func (*JobFailedEvent) GetPodName 

func (m *JobFailedEvent) GetPodName() string

func (*JobFailedEvent) GetPodNamespace 

func (m *JobFailedEvent) GetPodNamespace() string

func (*JobFailedEvent) GetPodNumber 

func (m *JobFailedEvent) GetPodNumber() int32

func (*JobFailedEvent) GetQueue 

func (m *JobFailedEvent) GetQueue() string

func (*JobFailedEvent) GetReason 

func (m *JobFailedEvent) GetReason() string

func (*JobFailedEvent) Marshal 

func (m *JobFailedEvent) Marshal() (dAtA []byte, err error)

func (*JobFailedEvent) MarshalTo 

func (m *JobFailedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobFailedEvent) MarshalToSizedBuffer 

func (m *JobFailedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobFailedEvent) ProtoMessage 

func (*JobFailedEvent) ProtoMessage()

func (*JobFailedEvent) Reset 

func (m *JobFailedEvent) Reset()

func (*JobFailedEvent) Size 

func (m *JobFailedEvent) Size() (n int)

func (*JobFailedEvent) String 

func (this *JobFailedEvent) String() string

func (*JobFailedEvent) Unmarshal 

func (m *JobFailedEvent) Unmarshal(dAtA []byte) error

func (*JobFailedEvent) XXX_DiscardUnknown 

func (m *JobFailedEvent) XXX_DiscardUnknown()

func (*JobFailedEvent) XXX_Marshal 

func (m *JobFailedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobFailedEvent) XXX_Merge 

func (m *JobFailedEvent) XXX_Merge(src proto.Message)

func (*JobFailedEvent) XXX_Size 

func (m *JobFailedEvent) XXX_Size() int

func (*JobFailedEvent) XXX_Unmarshal 

func (m *JobFailedEvent) XXX_Unmarshal(b []byte) error

type JobIngressInfoEvent 

type JobIngressInfoEvent struct {
	JobId            string           `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId         string           `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue            string           `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created          time.Time        `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId        string           `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId     string           `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName         string           `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber        int32            `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName          string           `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace     string           `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
	IngressAddresses map[int32]string `` /* 197-byte string literal not displayed */
}

func (*JobIngressInfoEvent) Descriptor 

func (*JobIngressInfoEvent) Descriptor() ([]byte, []int)

func (*JobIngressInfoEvent) GetClusterId 

func (m *JobIngressInfoEvent) GetClusterId() string

func (*JobIngressInfoEvent) GetCreated 

func (m *JobIngressInfoEvent) GetCreated() time.Time

func (*JobIngressInfoEvent) GetIngressAddresses 

func (m *JobIngressInfoEvent) GetIngressAddresses() map[int32]string

func (*JobIngressInfoEvent) GetJobId 

func (m *JobIngressInfoEvent) GetJobId() string

func (*JobIngressInfoEvent) GetJobSetId 

func (m *JobIngressInfoEvent) GetJobSetId() string

func (*JobIngressInfoEvent) GetKubernetesId 

func (m *JobIngressInfoEvent) GetKubernetesId() string

func (*JobIngressInfoEvent) GetNodeName 

func (m *JobIngressInfoEvent) GetNodeName() string

func (*JobIngressInfoEvent) GetPodName 

func (m *JobIngressInfoEvent) GetPodName() string

func (*JobIngressInfoEvent) GetPodNamespace 

func (m *JobIngressInfoEvent) GetPodNamespace() string

func (*JobIngressInfoEvent) GetPodNumber 

func (m *JobIngressInfoEvent) GetPodNumber() int32

func (*JobIngressInfoEvent) GetQueue 

func (m *JobIngressInfoEvent) GetQueue() string

func (*JobIngressInfoEvent) Marshal 

func (m *JobIngressInfoEvent) Marshal() (dAtA []byte, err error)

func (*JobIngressInfoEvent) MarshalTo 

func (m *JobIngressInfoEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobIngressInfoEvent) MarshalToSizedBuffer 

func (m *JobIngressInfoEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobIngressInfoEvent) ProtoMessage 

func (*JobIngressInfoEvent) ProtoMessage()

func (*JobIngressInfoEvent) Reset 

func (m *JobIngressInfoEvent) Reset()

func (*JobIngressInfoEvent) Size 

func (m *JobIngressInfoEvent) Size() (n int)

func (*JobIngressInfoEvent) String 

func (this *JobIngressInfoEvent) String() string

func (*JobIngressInfoEvent) Unmarshal 

func (m *JobIngressInfoEvent) Unmarshal(dAtA []byte) error

func (*JobIngressInfoEvent) XXX_DiscardUnknown 

func (m *JobIngressInfoEvent) XXX_DiscardUnknown()

func (*JobIngressInfoEvent) XXX_Marshal 

func (m *JobIngressInfoEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobIngressInfoEvent) XXX_Merge 

func (m *JobIngressInfoEvent) XXX_Merge(src proto.Message)

func (*JobIngressInfoEvent) XXX_Size 

func (m *JobIngressInfoEvent) XXX_Size() int

func (*JobIngressInfoEvent) XXX_Unmarshal 

func (m *JobIngressInfoEvent) XXX_Unmarshal(b []byte) error

type JobLeaseExpiredEvent 

type JobLeaseExpiredEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
}

func (*JobLeaseExpiredEvent) Descriptor 

func (*JobLeaseExpiredEvent) Descriptor() ([]byte, []int)

func (*JobLeaseExpiredEvent) GetCreated 

func (m *JobLeaseExpiredEvent) GetCreated() time.Time

func (*JobLeaseExpiredEvent) GetJobId 

func (m *JobLeaseExpiredEvent) GetJobId() string

func (*JobLeaseExpiredEvent) GetJobSetId 

func (m *JobLeaseExpiredEvent) GetJobSetId() string

func (*JobLeaseExpiredEvent) GetQueue 

func (m *JobLeaseExpiredEvent) GetQueue() string

func (*JobLeaseExpiredEvent) Marshal 

func (m *JobLeaseExpiredEvent) Marshal() (dAtA []byte, err error)

func (*JobLeaseExpiredEvent) MarshalTo 

func (m *JobLeaseExpiredEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobLeaseExpiredEvent) MarshalToSizedBuffer 

func (m *JobLeaseExpiredEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobLeaseExpiredEvent) ProtoMessage 

func (*JobLeaseExpiredEvent) ProtoMessage()

func (*JobLeaseExpiredEvent) Reset 

func (m *JobLeaseExpiredEvent) Reset()

func (*JobLeaseExpiredEvent) Size 

func (m *JobLeaseExpiredEvent) Size() (n int)

func (*JobLeaseExpiredEvent) String 

func (this *JobLeaseExpiredEvent) String() string

func (*JobLeaseExpiredEvent) Unmarshal 

func (m *JobLeaseExpiredEvent) Unmarshal(dAtA []byte) error

func (*JobLeaseExpiredEvent) XXX_DiscardUnknown 

func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()

func (*JobLeaseExpiredEvent) XXX_Marshal 

func (m *JobLeaseExpiredEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobLeaseExpiredEvent) XXX_Merge 

func (m *JobLeaseExpiredEvent) XXX_Merge(src proto.Message)

func (*JobLeaseExpiredEvent) XXX_Size 

func (m *JobLeaseExpiredEvent) XXX_Size() int

func (*JobLeaseExpiredEvent) XXX_Unmarshal 

func (m *JobLeaseExpiredEvent) XXX_Unmarshal(b []byte) error

type JobLeaseReturnedEvent 

type JobLeaseReturnedEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Reason       string    `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	KubernetesId string    `protobuf:"bytes,7,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	PodNumber    int32     `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	RunAttempted bool      `protobuf:"varint,9,opt,name=run_attempted,json=runAttempted,proto3" json:"runAttempted,omitempty"`
}

func (*JobLeaseReturnedEvent) Descriptor 

func (*JobLeaseReturnedEvent) Descriptor() ([]byte, []int)

func (*JobLeaseReturnedEvent) GetClusterId 

func (m *JobLeaseReturnedEvent) GetClusterId() string

func (*JobLeaseReturnedEvent) GetCreated 

func (m *JobLeaseReturnedEvent) GetCreated() time.Time

func (*JobLeaseReturnedEvent) GetJobId 

func (m *JobLeaseReturnedEvent) GetJobId() string

func (*JobLeaseReturnedEvent) GetJobSetId 

func (m *JobLeaseReturnedEvent) GetJobSetId() string

func (*JobLeaseReturnedEvent) GetKubernetesId 

func (m *JobLeaseReturnedEvent) GetKubernetesId() string

func (*JobLeaseReturnedEvent) GetPodNumber 

func (m *JobLeaseReturnedEvent) GetPodNumber() int32

func (*JobLeaseReturnedEvent) GetQueue 

func (m *JobLeaseReturnedEvent) GetQueue() string

func (*JobLeaseReturnedEvent) GetReason 

func (m *JobLeaseReturnedEvent) GetReason() string

func (*JobLeaseReturnedEvent) GetRunAttempted added in v0.3.48 

func (m *JobLeaseReturnedEvent) GetRunAttempted() bool

func (*JobLeaseReturnedEvent) Marshal 

func (m *JobLeaseReturnedEvent) Marshal() (dAtA []byte, err error)

func (*JobLeaseReturnedEvent) MarshalTo 

func (m *JobLeaseReturnedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobLeaseReturnedEvent) MarshalToSizedBuffer 

func (m *JobLeaseReturnedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobLeaseReturnedEvent) ProtoMessage 

func (*JobLeaseReturnedEvent) ProtoMessage()

func (*JobLeaseReturnedEvent) Reset 

func (m *JobLeaseReturnedEvent) Reset()

func (*JobLeaseReturnedEvent) Size 

func (m *JobLeaseReturnedEvent) Size() (n int)

func (*JobLeaseReturnedEvent) String 

func (this *JobLeaseReturnedEvent) String() string

func (*JobLeaseReturnedEvent) Unmarshal 

func (m *JobLeaseReturnedEvent) Unmarshal(dAtA []byte) error

func (*JobLeaseReturnedEvent) XXX_DiscardUnknown 

func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()

func (*JobLeaseReturnedEvent) XXX_Marshal 

func (m *JobLeaseReturnedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobLeaseReturnedEvent) XXX_Merge 

func (m *JobLeaseReturnedEvent) XXX_Merge(src proto.Message)

func (*JobLeaseReturnedEvent) XXX_Size 

func (m *JobLeaseReturnedEvent) XXX_Size() int

func (*JobLeaseReturnedEvent) XXX_Unmarshal 

func (m *JobLeaseReturnedEvent) XXX_Unmarshal(b []byte) error

type JobLeasedEvent 

type JobLeasedEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
}

func (*JobLeasedEvent) Descriptor 

func (*JobLeasedEvent) Descriptor() ([]byte, []int)

func (*JobLeasedEvent) GetClusterId 

func (m *JobLeasedEvent) GetClusterId() string

func (*JobLeasedEvent) GetCreated 

func (m *JobLeasedEvent) GetCreated() time.Time

func (*JobLeasedEvent) GetJobId 

func (m *JobLeasedEvent) GetJobId() string

func (*JobLeasedEvent) GetJobSetId 

func (m *JobLeasedEvent) GetJobSetId() string

func (*JobLeasedEvent) GetQueue 

func (m *JobLeasedEvent) GetQueue() string

func (*JobLeasedEvent) Marshal 

func (m *JobLeasedEvent) Marshal() (dAtA []byte, err error)

func (*JobLeasedEvent) MarshalTo 

func (m *JobLeasedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobLeasedEvent) MarshalToSizedBuffer 

func (m *JobLeasedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobLeasedEvent) ProtoMessage 

func (*JobLeasedEvent) ProtoMessage()

func (*JobLeasedEvent) Reset 

func (m *JobLeasedEvent) Reset()

func (*JobLeasedEvent) Size 

func (m *JobLeasedEvent) Size() (n int)

func (*JobLeasedEvent) String 

func (this *JobLeasedEvent) String() string

func (*JobLeasedEvent) Unmarshal 

func (m *JobLeasedEvent) Unmarshal(dAtA []byte) error

func (*JobLeasedEvent) XXX_DiscardUnknown 

func (m *JobLeasedEvent) XXX_DiscardUnknown()

func (*JobLeasedEvent) XXX_Marshal 

func (m *JobLeasedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobLeasedEvent) XXX_Merge 

func (m *JobLeasedEvent) XXX_Merge(src proto.Message)

func (*JobLeasedEvent) XXX_Size 

func (m *JobLeasedEvent) XXX_Size() int

func (*JobLeasedEvent) XXX_Unmarshal 

func (m *JobLeasedEvent) XXX_Unmarshal(b []byte) error

type JobPendingEvent 

type JobPendingEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	PodNumber    int32     `protobuf:"varint,7,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string    `protobuf:"bytes,8,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string    `protobuf:"bytes,9,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
}

func (*JobPendingEvent) Descriptor 

func (*JobPendingEvent) Descriptor() ([]byte, []int)

func (*JobPendingEvent) GetClusterId 

func (m *JobPendingEvent) GetClusterId() string

func (*JobPendingEvent) GetCreated 

func (m *JobPendingEvent) GetCreated() time.Time

func (*JobPendingEvent) GetJobId 

func (m *JobPendingEvent) GetJobId() string

func (*JobPendingEvent) GetJobSetId 

func (m *JobPendingEvent) GetJobSetId() string

func (*JobPendingEvent) GetKubernetesId 

func (m *JobPendingEvent) GetKubernetesId() string

func (*JobPendingEvent) GetPodName 

func (m *JobPendingEvent) GetPodName() string

func (*JobPendingEvent) GetPodNamespace 

func (m *JobPendingEvent) GetPodNamespace() string

func (*JobPendingEvent) GetPodNumber 

func (m *JobPendingEvent) GetPodNumber() int32

func (*JobPendingEvent) GetQueue 

func (m *JobPendingEvent) GetQueue() string

func (*JobPendingEvent) Marshal 

func (m *JobPendingEvent) Marshal() (dAtA []byte, err error)

func (*JobPendingEvent) MarshalTo 

func (m *JobPendingEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobPendingEvent) MarshalToSizedBuffer 

func (m *JobPendingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobPendingEvent) ProtoMessage 

func (*JobPendingEvent) ProtoMessage()

func (*JobPendingEvent) Reset 

func (m *JobPendingEvent) Reset()

func (*JobPendingEvent) Size 

func (m *JobPendingEvent) Size() (n int)

func (*JobPendingEvent) String 

func (this *JobPendingEvent) String() string

func (*JobPendingEvent) Unmarshal 

func (m *JobPendingEvent) Unmarshal(dAtA []byte) error

func (*JobPendingEvent) XXX_DiscardUnknown 

func (m *JobPendingEvent) XXX_DiscardUnknown()

func (*JobPendingEvent) XXX_Marshal 

func (m *JobPendingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobPendingEvent) XXX_Merge 

func (m *JobPendingEvent) XXX_Merge(src proto.Message)

func (*JobPendingEvent) XXX_Size 

func (m *JobPendingEvent) XXX_Size() int

func (*JobPendingEvent) XXX_Unmarshal 

func (m *JobPendingEvent) XXX_Unmarshal(b []byte) error

type 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 (this *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         time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId       string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	RunId           string    `protobuf:"bytes,6,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	PreemptiveJobId string    `protobuf:"bytes,7,opt,name=preemptive_job_id,json=preemptiveJobId,proto3" json:"preemptiveJobId,omitempty"`
	PreemptiveRunId string    `protobuf:"bytes,8,opt,name=preemptive_run_id,json=preemptiveRunId,proto3" json:"preemptiveRunId,omitempty"`
}

func (*JobPreemptedEvent) Descriptor 

func (*JobPreemptedEvent) Descriptor() ([]byte, []int)

func (*JobPreemptedEvent) GetClusterId 

func (m *JobPreemptedEvent) GetClusterId() string

func (*JobPreemptedEvent) GetCreated 

func (m *JobPreemptedEvent) GetCreated() time.Time

func (*JobPreemptedEvent) GetJobId 

func (m *JobPreemptedEvent) GetJobId() string

func (*JobPreemptedEvent) GetJobSetId 

func (m *JobPreemptedEvent) GetJobSetId() string

func (*JobPreemptedEvent) GetPreemptiveJobId 

func (m *JobPreemptedEvent) GetPreemptiveJobId() string

func (*JobPreemptedEvent) GetPreemptiveRunId 

func (m *JobPreemptedEvent) GetPreemptiveRunId() string

func (*JobPreemptedEvent) GetQueue 

func (m *JobPreemptedEvent) GetQueue() string

func (*JobPreemptedEvent) GetRunId 

func (m *JobPreemptedEvent) GetRunId() string

func (*JobPreemptedEvent) Marshal 

func (m *JobPreemptedEvent) Marshal() (dAtA []byte, err error)

func (*JobPreemptedEvent) MarshalTo 

func (m *JobPreemptedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobPreemptedEvent) MarshalToSizedBuffer 

func (m *JobPreemptedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobPreemptedEvent) ProtoMessage 

func (*JobPreemptedEvent) ProtoMessage()

func (*JobPreemptedEvent) Reset 

func (m *JobPreemptedEvent) Reset()

func (*JobPreemptedEvent) Size 

func (m *JobPreemptedEvent) Size() (n int)

func (*JobPreemptedEvent) String 

func (this *JobPreemptedEvent) String() string

func (*JobPreemptedEvent) Unmarshal 

func (m *JobPreemptedEvent) Unmarshal(dAtA []byte) error

func (*JobPreemptedEvent) XXX_DiscardUnknown 

func (m *JobPreemptedEvent) XXX_DiscardUnknown()

func (*JobPreemptedEvent) XXX_Marshal 

func (m *JobPreemptedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobPreemptedEvent) XXX_Merge 

func (m *JobPreemptedEvent) XXX_Merge(src proto.Message)

func (*JobPreemptedEvent) XXX_Size 

func (m *JobPreemptedEvent) XXX_Size() int

func (*JobPreemptedEvent) XXX_Unmarshal 

func (m *JobPreemptedEvent) XXX_Unmarshal(b []byte) error

type 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   time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	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() time.Time

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 (this *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  time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
}

func (*JobQueuedEvent) Descriptor 

func (*JobQueuedEvent) Descriptor() ([]byte, []int)

func (*JobQueuedEvent) GetCreated 

func (m *JobQueuedEvent) GetCreated() time.Time

func (*JobQueuedEvent) GetJobId 

func (m *JobQueuedEvent) GetJobId() string

func (*JobQueuedEvent) GetJobSetId 

func (m *JobQueuedEvent) GetJobSetId() string

func (*JobQueuedEvent) GetQueue 

func (m *JobQueuedEvent) GetQueue() string

func (*JobQueuedEvent) Marshal 

func (m *JobQueuedEvent) Marshal() (dAtA []byte, err error)

func (*JobQueuedEvent) MarshalTo 

func (m *JobQueuedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobQueuedEvent) MarshalToSizedBuffer 

func (m *JobQueuedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobQueuedEvent) ProtoMessage 

func (*JobQueuedEvent) ProtoMessage()

func (*JobQueuedEvent) Reset 

func (m *JobQueuedEvent) Reset()

func (*JobQueuedEvent) Size 

func (m *JobQueuedEvent) Size() (n int)

func (*JobQueuedEvent) String 

func (this *JobQueuedEvent) String() string

func (*JobQueuedEvent) Unmarshal 

func (m *JobQueuedEvent) Unmarshal(dAtA []byte) error

func (*JobQueuedEvent) XXX_DiscardUnknown 

func (m *JobQueuedEvent) XXX_DiscardUnknown()

func (*JobQueuedEvent) XXX_Marshal 

func (m *JobQueuedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobQueuedEvent) XXX_Merge 

func (m *JobQueuedEvent) XXX_Merge(src proto.Message)

func (*JobQueuedEvent) XXX_Size 

func (m *JobQueuedEvent) XXX_Size() int

func (*JobQueuedEvent) XXX_Unmarshal 

func (m *JobQueuedEvent) XXX_Unmarshal(b []byte) error

type JobReprioritizeRequest 

type JobReprioritizeRequest struct {
	JobIds      []string `protobuf:"bytes,1,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"`
	JobSetId    string   `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue       string   `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	NewPriority float64  `protobuf:"fixed64,4,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"`
}

swagger:model

func (*JobReprioritizeRequest) Descriptor 

func (*JobReprioritizeRequest) Descriptor() ([]byte, []int)

func (*JobReprioritizeRequest) GetJobIds 

func (m *JobReprioritizeRequest) GetJobIds() []string

func (*JobReprioritizeRequest) GetJobSetId 

func (m *JobReprioritizeRequest) GetJobSetId() string

func (*JobReprioritizeRequest) GetNewPriority 

func (m *JobReprioritizeRequest) GetNewPriority() float64

func (*JobReprioritizeRequest) GetQueue 

func (m *JobReprioritizeRequest) GetQueue() string

func (*JobReprioritizeRequest) Marshal 

func (m *JobReprioritizeRequest) Marshal() (dAtA []byte, err error)

func (*JobReprioritizeRequest) MarshalTo 

func (m *JobReprioritizeRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobReprioritizeRequest) MarshalToSizedBuffer 

func (m *JobReprioritizeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReprioritizeRequest) ProtoMessage 

func (*JobReprioritizeRequest) ProtoMessage()

func (*JobReprioritizeRequest) Reset 

func (m *JobReprioritizeRequest) Reset()

func (*JobReprioritizeRequest) Size 

func (m *JobReprioritizeRequest) Size() (n int)

func (*JobReprioritizeRequest) String 

func (this *JobReprioritizeRequest) String() string

func (*JobReprioritizeRequest) Unmarshal 

func (m *JobReprioritizeRequest) Unmarshal(dAtA []byte) error

func (*JobReprioritizeRequest) XXX_DiscardUnknown 

func (m *JobReprioritizeRequest) XXX_DiscardUnknown()

func (*JobReprioritizeRequest) XXX_Marshal 

func (m *JobReprioritizeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReprioritizeRequest) XXX_Merge 

func (m *JobReprioritizeRequest) XXX_Merge(src proto.Message)

func (*JobReprioritizeRequest) XXX_Size 

func (m *JobReprioritizeRequest) XXX_Size() int

func (*JobReprioritizeRequest) XXX_Unmarshal 

func (m *JobReprioritizeRequest) XXX_Unmarshal(b []byte) error

type JobReprioritizeResponse 

type JobReprioritizeResponse struct {
	ReprioritizationResults map[string]string `` /* 217-byte string literal not displayed */
}

swagger:model

func (*JobReprioritizeResponse) Descriptor 

func (*JobReprioritizeResponse) Descriptor() ([]byte, []int)

func (*JobReprioritizeResponse) GetReprioritizationResults 

func (m *JobReprioritizeResponse) GetReprioritizationResults() map[string]string

func (*JobReprioritizeResponse) Marshal 

func (m *JobReprioritizeResponse) Marshal() (dAtA []byte, err error)

func (*JobReprioritizeResponse) MarshalTo 

func (m *JobReprioritizeResponse) MarshalTo(dAtA []byte) (int, error)

func (*JobReprioritizeResponse) MarshalToSizedBuffer 

func (m *JobReprioritizeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReprioritizeResponse) ProtoMessage 

func (*JobReprioritizeResponse) ProtoMessage()

func (*JobReprioritizeResponse) Reset 

func (m *JobReprioritizeResponse) Reset()

func (*JobReprioritizeResponse) Size 

func (m *JobReprioritizeResponse) Size() (n int)

func (*JobReprioritizeResponse) String 

func (this *JobReprioritizeResponse) String() string

func (*JobReprioritizeResponse) Unmarshal 

func (m *JobReprioritizeResponse) Unmarshal(dAtA []byte) error

func (*JobReprioritizeResponse) XXX_DiscardUnknown 

func (m *JobReprioritizeResponse) XXX_DiscardUnknown()

func (*JobReprioritizeResponse) XXX_Marshal 

func (m *JobReprioritizeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReprioritizeResponse) XXX_Merge 

func (m *JobReprioritizeResponse) XXX_Merge(src proto.Message)

func (*JobReprioritizeResponse) XXX_Size 

func (m *JobReprioritizeResponse) XXX_Size() int

func (*JobReprioritizeResponse) XXX_Unmarshal 

func (m *JobReprioritizeResponse) XXX_Unmarshal(b []byte) error

type JobReprioritizedEvent 

type JobReprioritizedEvent struct {
	JobId       string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId    string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue       string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created     time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	NewPriority float64   `protobuf:"fixed64,5,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"`
	Requestor   string    `protobuf:"bytes,6,opt,name=requestor,proto3" json:"requestor,omitempty"`
}

func (*JobReprioritizedEvent) Descriptor 

func (*JobReprioritizedEvent) Descriptor() ([]byte, []int)

func (*JobReprioritizedEvent) GetCreated 

func (m *JobReprioritizedEvent) GetCreated() time.Time

func (*JobReprioritizedEvent) GetJobId 

func (m *JobReprioritizedEvent) GetJobId() string

func (*JobReprioritizedEvent) GetJobSetId 

func (m *JobReprioritizedEvent) GetJobSetId() string

func (*JobReprioritizedEvent) GetNewPriority 

func (m *JobReprioritizedEvent) GetNewPriority() float64

func (*JobReprioritizedEvent) GetQueue 

func (m *JobReprioritizedEvent) GetQueue() string

func (*JobReprioritizedEvent) GetRequestor 

func (m *JobReprioritizedEvent) GetRequestor() string

func (*JobReprioritizedEvent) Marshal 

func (m *JobReprioritizedEvent) Marshal() (dAtA []byte, err error)

func (*JobReprioritizedEvent) MarshalTo 

func (m *JobReprioritizedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobReprioritizedEvent) MarshalToSizedBuffer 

func (m *JobReprioritizedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReprioritizedEvent) ProtoMessage 

func (*JobReprioritizedEvent) ProtoMessage()

func (*JobReprioritizedEvent) Reset 

func (m *JobReprioritizedEvent) Reset()

func (*JobReprioritizedEvent) Size 

func (m *JobReprioritizedEvent) Size() (n int)

func (*JobReprioritizedEvent) String 

func (this *JobReprioritizedEvent) String() string

func (*JobReprioritizedEvent) Unmarshal 

func (m *JobReprioritizedEvent) Unmarshal(dAtA []byte) error

func (*JobReprioritizedEvent) XXX_DiscardUnknown 

func (m *JobReprioritizedEvent) XXX_DiscardUnknown()

func (*JobReprioritizedEvent) XXX_Marshal 

func (m *JobReprioritizedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReprioritizedEvent) XXX_Merge 

func (m *JobReprioritizedEvent) XXX_Merge(src proto.Message)

func (*JobReprioritizedEvent) XXX_Size 

func (m *JobReprioritizedEvent) XXX_Size() int

func (*JobReprioritizedEvent) XXX_Unmarshal 

func (m *JobReprioritizedEvent) XXX_Unmarshal(b []byte) error

type JobReprioritizingEvent 

type JobReprioritizingEvent struct {
	JobId       string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId    string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue       string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created     time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	NewPriority float64   `protobuf:"fixed64,5,opt,name=new_priority,json=newPriority,proto3" json:"newPriority,omitempty"`
	Requestor   string    `protobuf:"bytes,6,opt,name=requestor,proto3" json:"requestor,omitempty"`
}

func (*JobReprioritizingEvent) Descriptor 

func (*JobReprioritizingEvent) Descriptor() ([]byte, []int)

func (*JobReprioritizingEvent) GetCreated 

func (m *JobReprioritizingEvent) GetCreated() time.Time

func (*JobReprioritizingEvent) GetJobId 

func (m *JobReprioritizingEvent) GetJobId() string

func (*JobReprioritizingEvent) GetJobSetId 

func (m *JobReprioritizingEvent) GetJobSetId() string

func (*JobReprioritizingEvent) GetNewPriority 

func (m *JobReprioritizingEvent) GetNewPriority() float64

func (*JobReprioritizingEvent) GetQueue 

func (m *JobReprioritizingEvent) GetQueue() string

func (*JobReprioritizingEvent) GetRequestor 

func (m *JobReprioritizingEvent) GetRequestor() string

func (*JobReprioritizingEvent) Marshal 

func (m *JobReprioritizingEvent) Marshal() (dAtA []byte, err error)

func (*JobReprioritizingEvent) MarshalTo 

func (m *JobReprioritizingEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobReprioritizingEvent) MarshalToSizedBuffer 

func (m *JobReprioritizingEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobReprioritizingEvent) ProtoMessage 

func (*JobReprioritizingEvent) ProtoMessage()

func (*JobReprioritizingEvent) Reset 

func (m *JobReprioritizingEvent) Reset()

func (*JobReprioritizingEvent) Size 

func (m *JobReprioritizingEvent) Size() (n int)

func (*JobReprioritizingEvent) String 

func (this *JobReprioritizingEvent) String() string

func (*JobReprioritizingEvent) Unmarshal 

func (m *JobReprioritizingEvent) Unmarshal(dAtA []byte) error

func (*JobReprioritizingEvent) XXX_DiscardUnknown 

func (m *JobReprioritizingEvent) XXX_DiscardUnknown()

func (*JobReprioritizingEvent) XXX_Marshal 

func (m *JobReprioritizingEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobReprioritizingEvent) XXX_Merge 

func (m *JobReprioritizingEvent) XXX_Merge(src proto.Message)

func (*JobReprioritizingEvent) XXX_Size 

func (m *JobReprioritizingEvent) XXX_Size() int

func (*JobReprioritizingEvent) XXX_Unmarshal 

func (m *JobReprioritizingEvent) XXX_Unmarshal(b []byte) error

type 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   *time.Time  `protobuf:"bytes,7,opt,name=leased_ts,json=leasedTs,proto3,stdtime" json:"leasedTs,omitempty"`
	PendingTs  *time.Time  `protobuf:"bytes,8,opt,name=pending_ts,json=pendingTs,proto3,stdtime" json:"pendingTs,omitempty"`
	StartedTs  *time.Time  `protobuf:"bytes,9,opt,name=started_ts,json=startedTs,proto3,stdtime" json:"startedTs,omitempty"`
	FinishedTs *time.Time  `protobuf:"bytes,10,opt,name=finished_ts,json=finishedTs,proto3,stdtime" 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() *time.Time

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() *time.Time

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() *time.Time

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() *time.Time

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 (this *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 (this *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 (this *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      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber    int32     `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string    `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string    `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
}

func (*JobRunningEvent) Descriptor 

func (*JobRunningEvent) Descriptor() ([]byte, []int)

func (*JobRunningEvent) GetClusterId 

func (m *JobRunningEvent) GetClusterId() string

func (*JobRunningEvent) GetCreated 

func (m *JobRunningEvent) GetCreated() time.Time

func (*JobRunningEvent) GetJobId 

func (m *JobRunningEvent) GetJobId() string

func (*JobRunningEvent) GetJobSetId 

func (m *JobRunningEvent) GetJobSetId() string

func (*JobRunningEvent) GetKubernetesId 

func (m *JobRunningEvent) GetKubernetesId() string

func (*JobRunningEvent) GetNodeName 

func (m *JobRunningEvent) GetNodeName() string

func (*JobRunningEvent) GetPodName 

func (m *JobRunningEvent) GetPodName() string

func (*JobRunningEvent) GetPodNamespace 

func (m *JobRunningEvent) GetPodNamespace() string

func (*JobRunningEvent) GetPodNumber 

func (m *JobRunningEvent) GetPodNumber() int32

func (*JobRunningEvent) GetQueue 

func (m *JobRunningEvent) GetQueue() string

func (*JobRunningEvent) Marshal 

func (m *JobRunningEvent) Marshal() (dAtA []byte, err error)

func (*JobRunningEvent) MarshalTo 

func (m *JobRunningEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobRunningEvent) MarshalToSizedBuffer 

func (m *JobRunningEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobRunningEvent) ProtoMessage 

func (*JobRunningEvent) ProtoMessage()

func (*JobRunningEvent) Reset 

func (m *JobRunningEvent) Reset()

func (*JobRunningEvent) Size 

func (m *JobRunningEvent) Size() (n int)

func (*JobRunningEvent) String 

func (this *JobRunningEvent) String() string

func (*JobRunningEvent) Unmarshal 

func (m *JobRunningEvent) Unmarshal(dAtA []byte) error

func (*JobRunningEvent) XXX_DiscardUnknown 

func (m *JobRunningEvent) XXX_DiscardUnknown()

func (*JobRunningEvent) XXX_Marshal 

func (m *JobRunningEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobRunningEvent) XXX_Merge 

func (m *JobRunningEvent) XXX_Merge(src proto.Message)

func (*JobRunningEvent) XXX_Size 

func (m *JobRunningEvent) XXX_Size() int

func (*JobRunningEvent) XXX_Unmarshal 

func (m *JobRunningEvent) XXX_Unmarshal(b []byte) error

type JobSetCancelRequest 

type JobSetCancelRequest struct {
	JobSetId string        `protobuf:"bytes,1,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue    string        `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	Filter   *JobSetFilter `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	Reason   string        `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
}

swagger:model

func (*JobSetCancelRequest) Descriptor 

func (*JobSetCancelRequest) Descriptor() ([]byte, []int)

func (*JobSetCancelRequest) GetFilter 

func (m *JobSetCancelRequest) GetFilter() *JobSetFilter

func (*JobSetCancelRequest) GetJobSetId 

func (m *JobSetCancelRequest) GetJobSetId() string

func (*JobSetCancelRequest) GetQueue 

func (m *JobSetCancelRequest) GetQueue() string

func (*JobSetCancelRequest) GetReason added in v0.3.68 

func (m *JobSetCancelRequest) GetReason() string

func (*JobSetCancelRequest) Marshal 

func (m *JobSetCancelRequest) Marshal() (dAtA []byte, err error)

func (*JobSetCancelRequest) MarshalTo 

func (m *JobSetCancelRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobSetCancelRequest) MarshalToSizedBuffer 

func (m *JobSetCancelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetCancelRequest) ProtoMessage 

func (*JobSetCancelRequest) ProtoMessage()

func (*JobSetCancelRequest) Reset 

func (m *JobSetCancelRequest) Reset()

func (*JobSetCancelRequest) Size 

func (m *JobSetCancelRequest) Size() (n int)

func (*JobSetCancelRequest) String 

func (this *JobSetCancelRequest) String() string

func (*JobSetCancelRequest) Unmarshal 

func (m *JobSetCancelRequest) Unmarshal(dAtA []byte) error

func (*JobSetCancelRequest) XXX_DiscardUnknown 

func (m *JobSetCancelRequest) XXX_DiscardUnknown()

func (*JobSetCancelRequest) XXX_Marshal 

func (m *JobSetCancelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSetCancelRequest) XXX_Merge 

func (m *JobSetCancelRequest) XXX_Merge(src proto.Message)

func (*JobSetCancelRequest) XXX_Size 

func (m *JobSetCancelRequest) XXX_Size() int

func (*JobSetCancelRequest) XXX_Unmarshal 

func (m *JobSetCancelRequest) XXX_Unmarshal(b []byte) error

type JobSetFilter 

type JobSetFilter struct {
	States []JobState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=api.JobState" json:"states,omitempty"`
}

swagger:model

func (*JobSetFilter) Descriptor 

func (*JobSetFilter) Descriptor() ([]byte, []int)

func (*JobSetFilter) GetStates 

func (m *JobSetFilter) GetStates() []JobState

func (*JobSetFilter) Marshal 

func (m *JobSetFilter) Marshal() (dAtA []byte, err error)

func (*JobSetFilter) MarshalTo 

func (m *JobSetFilter) MarshalTo(dAtA []byte) (int, error)

func (*JobSetFilter) MarshalToSizedBuffer 

func (m *JobSetFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetFilter) ProtoMessage 

func (*JobSetFilter) ProtoMessage()

func (*JobSetFilter) Reset 

func (m *JobSetFilter) Reset()

func (*JobSetFilter) Size 

func (m *JobSetFilter) Size() (n int)

func (*JobSetFilter) String 

func (this *JobSetFilter) String() string

func (*JobSetFilter) Unmarshal 

func (m *JobSetFilter) Unmarshal(dAtA []byte) error

func (*JobSetFilter) XXX_DiscardUnknown 

func (m *JobSetFilter) XXX_DiscardUnknown()

func (*JobSetFilter) XXX_Marshal 

func (m *JobSetFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSetFilter) XXX_Merge 

func (m *JobSetFilter) XXX_Merge(src proto.Message)

func (*JobSetFilter) XXX_Size 

func (m *JobSetFilter) XXX_Size() int

func (*JobSetFilter) XXX_Unmarshal 

func (m *JobSetFilter) XXX_Unmarshal(b []byte) error

type JobSetInfo 

type JobSetInfo struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	QueuedJobs int32  `protobuf:"varint,2,opt,name=queued_jobs,json=queuedJobs,proto3" json:"queuedJobs,omitempty"`
	LeasedJobs int32  `protobuf:"varint,3,opt,name=leased_jobs,json=leasedJobs,proto3" json:"leasedJobs,omitempty"`
}

func (*JobSetInfo) Descriptor 

func (*JobSetInfo) Descriptor() ([]byte, []int)

func (*JobSetInfo) GetLeasedJobs 

func (m *JobSetInfo) GetLeasedJobs() int32

func (*JobSetInfo) GetName 

func (m *JobSetInfo) GetName() string

func (*JobSetInfo) GetQueuedJobs 

func (m *JobSetInfo) GetQueuedJobs() int32

func (*JobSetInfo) Marshal 

func (m *JobSetInfo) Marshal() (dAtA []byte, err error)

func (*JobSetInfo) MarshalTo 

func (m *JobSetInfo) MarshalTo(dAtA []byte) (int, error)

func (*JobSetInfo) MarshalToSizedBuffer 

func (m *JobSetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetInfo) ProtoMessage 

func (*JobSetInfo) ProtoMessage()

func (*JobSetInfo) Reset 

func (m *JobSetInfo) Reset()

func (*JobSetInfo) Size 

func (m *JobSetInfo) Size() (n int)

func (*JobSetInfo) String 

func (this *JobSetInfo) String() string

func (*JobSetInfo) Unmarshal 

func (m *JobSetInfo) Unmarshal(dAtA []byte) error

func (*JobSetInfo) XXX_DiscardUnknown 

func (m *JobSetInfo) XXX_DiscardUnknown()

func (*JobSetInfo) XXX_Marshal 

func (m *JobSetInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSetInfo) XXX_Merge 

func (m *JobSetInfo) XXX_Merge(src proto.Message)

func (*JobSetInfo) XXX_Size 

func (m *JobSetInfo) XXX_Size() int

func (*JobSetInfo) XXX_Unmarshal 

func (m *JobSetInfo) XXX_Unmarshal(b []byte) error

type JobSetRequest 

type JobSetRequest struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Watch          bool   `protobuf:"varint,2,opt,name=watch,proto3" json:"watch,omitempty"`
	FromMessageId  string `protobuf:"bytes,3,opt,name=from_message_id,json=fromMessageId,proto3" json:"fromMessageId,omitempty"`
	Queue          string `protobuf:"bytes,4,opt,name=queue,proto3" json:"queue,omitempty"`
	ErrorIfMissing bool   `protobuf:"varint,5,opt,name=errorIfMissing,proto3" json:"errorIfMissing,omitempty"`
}

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) MarshalTo 

func (m *JobSetRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobSetRequest) MarshalToSizedBuffer 

func (m *JobSetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetRequest) ProtoMessage 

func (*JobSetRequest) ProtoMessage()

func (*JobSetRequest) Reset 

func (m *JobSetRequest) Reset()

func (*JobSetRequest) Size 

func (m *JobSetRequest) Size() (n int)

func (*JobSetRequest) String 

func (this *JobSetRequest) String() string

func (*JobSetRequest) Unmarshal 

func (m *JobSetRequest) Unmarshal(dAtA []byte) error

func (*JobSetRequest) XXX_DiscardUnknown 

func (m *JobSetRequest) XXX_DiscardUnknown()

func (*JobSetRequest) XXX_Marshal 

func (m *JobSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSetRequest) XXX_Merge 

func (m *JobSetRequest) XXX_Merge(src proto.Message)

func (*JobSetRequest) XXX_Size 

func (m *JobSetRequest) XXX_Size() int

func (*JobSetRequest) XXX_Unmarshal 

func (m *JobSetRequest) XXX_Unmarshal(b []byte) error

type JobState 

type JobState int32

swagger:model 

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) EnumDescriptor() ([]byte, []int)

func (JobState) String 

func (x JobState) String() string

func (*JobState) UnmarshalJSON 

func (x *JobState) UnmarshalJSON(data []byte) error

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 (this *JobStatusRequest) String() string

func (*JobStatusRequest) Unmarshal added in v0.4.20 

func (m *JobStatusRequest) Unmarshal(dAtA []byte) error

func (*JobStatusRequest) XXX_DiscardUnknown added in v0.4.20 

func (m *JobStatusRequest) XXX_DiscardUnknown()

func (*JobStatusRequest) XXX_Marshal added in v0.4.20 

func (m *JobStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatusRequest) XXX_Merge added in v0.4.20 

func (m *JobStatusRequest) XXX_Merge(src proto.Message)

func (*JobStatusRequest) XXX_Size added in v0.4.20 

func (m *JobStatusRequest) XXX_Size() int

func (*JobStatusRequest) XXX_Unmarshal added in v0.4.20 

func (m *JobStatusRequest) XXX_Unmarshal(b []byte) error

type JobStatusResponse added in v0.4.20 

type JobStatusResponse struct {
	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 (this *JobStatusResponse) String() string

func (*JobStatusResponse) Unmarshal added in v0.4.20 

func (m *JobStatusResponse) Unmarshal(dAtA []byte) error

func (*JobStatusResponse) XXX_DiscardUnknown added in v0.4.20 

func (m *JobStatusResponse) XXX_DiscardUnknown()

func (*JobStatusResponse) XXX_Marshal added in v0.4.20 

func (m *JobStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobStatusResponse) XXX_Merge added in v0.4.20 

func (m *JobStatusResponse) XXX_Merge(src proto.Message)

func (*JobStatusResponse) XXX_Size added in v0.4.20 

func (m *JobStatusResponse) XXX_Size() int

func (*JobStatusResponse) XXX_Unmarshal added in v0.4.20 

func (m *JobStatusResponse) XXX_Unmarshal(b []byte) error

type JobSubmitRequest 

type JobSubmitRequest struct {
	Queue           string                  `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	JobSetId        string                  `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	JobRequestItems []*JobSubmitRequestItem `protobuf:"bytes,3,rep,name=job_request_items,json=jobRequestItems,proto3" json:"jobRequestItems,omitempty"`
}

swagger:model

func (*JobSubmitRequest) Descriptor 

func (*JobSubmitRequest) Descriptor() ([]byte, []int)

func (*JobSubmitRequest) GetJobRequestItems 

func (m *JobSubmitRequest) GetJobRequestItems() []*JobSubmitRequestItem

func (*JobSubmitRequest) GetJobSetId 

func (m *JobSubmitRequest) GetJobSetId() string

func (*JobSubmitRequest) GetQueue 

func (m *JobSubmitRequest) GetQueue() string

func (*JobSubmitRequest) Marshal 

func (m *JobSubmitRequest) Marshal() (dAtA []byte, err error)

func (*JobSubmitRequest) MarshalTo 

func (m *JobSubmitRequest) MarshalTo(dAtA []byte) (int, error)

func (*JobSubmitRequest) MarshalToSizedBuffer 

func (m *JobSubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSubmitRequest) ProtoMessage 

func (*JobSubmitRequest) ProtoMessage()

func (*JobSubmitRequest) Reset 

func (m *JobSubmitRequest) Reset()

func (*JobSubmitRequest) Size 

func (m *JobSubmitRequest) Size() (n int)

func (*JobSubmitRequest) String 

func (this *JobSubmitRequest) String() string

func (*JobSubmitRequest) Unmarshal 

func (m *JobSubmitRequest) Unmarshal(dAtA []byte) error

func (*JobSubmitRequest) XXX_DiscardUnknown 

func (m *JobSubmitRequest) XXX_DiscardUnknown()

func (*JobSubmitRequest) XXX_Marshal 

func (m *JobSubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSubmitRequest) XXX_Merge 

func (m *JobSubmitRequest) XXX_Merge(src proto.Message)

func (*JobSubmitRequest) XXX_Size 

func (m *JobSubmitRequest) XXX_Size() int

func (*JobSubmitRequest) XXX_Unmarshal 

func (m *JobSubmitRequest) XXX_Unmarshal(b []byte) error

type JobSubmitRequestItem 

type JobSubmitRequestItem struct {
	Priority           float64           `protobuf:"fixed64,1,opt,name=priority,proto3" json:"priority,omitempty"`
	Namespace          string            `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ClientId           string            `protobuf:"bytes,8,opt,name=client_id,json=clientId,proto3" json:"clientId,omitempty"`
	Labels             map[string]string `` /* 153-byte string literal not displayed */
	Annotations        map[string]string `` /* 163-byte string literal not displayed */
	RequiredNodeLabels map[string]string `` // Deprecated: Do not use.
	/* 203-byte string literal not displayed */
	PodSpec  *v1.PodSpec      `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3" json:"podSpec,omitempty"` // Deprecated: Do not use.
	PodSpecs []*v1.PodSpec    `protobuf:"bytes,7,rep,name=pod_specs,json=podSpecs,proto3" json:"podSpecs,omitempty"`
	Ingress  []*IngressConfig `protobuf:"bytes,9,rep,name=ingress,proto3" json:"ingress,omitempty"`
	Services []*ServiceConfig `protobuf:"bytes,10,rep,name=services,proto3" json:"services,omitempty"`
	// Indicates which scheduler should manage this job.
	// If empty, the default scheduler is used.
	Scheduler string `protobuf:"bytes,11,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
}

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 (this *JobSubmitRequestItem) String() string

func (*JobSubmitRequestItem) Unmarshal 

func (m *JobSubmitRequestItem) Unmarshal(dAtA []byte) error

func (*JobSubmitRequestItem) XXX_DiscardUnknown 

func (m *JobSubmitRequestItem) XXX_DiscardUnknown()

func (*JobSubmitRequestItem) XXX_Marshal 

func (m *JobSubmitRequestItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSubmitRequestItem) XXX_Merge 

func (m *JobSubmitRequestItem) XXX_Merge(src proto.Message)

func (*JobSubmitRequestItem) XXX_Size 

func (m *JobSubmitRequestItem) XXX_Size() int

func (*JobSubmitRequestItem) XXX_Unmarshal 

func (m *JobSubmitRequestItem) XXX_Unmarshal(b []byte) error

type JobSubmitResponse 

type JobSubmitResponse struct {
	JobResponseItems []*JobSubmitResponseItem `protobuf:"bytes,1,rep,name=job_response_items,json=jobResponseItems,proto3" json:"jobResponseItems,omitempty"`
}

swagger:model

func (*JobSubmitResponse) Descriptor 

func (*JobSubmitResponse) Descriptor() ([]byte, []int)

func (*JobSubmitResponse) GetJobResponseItems 

func (m *JobSubmitResponse) GetJobResponseItems() []*JobSubmitResponseItem

func (*JobSubmitResponse) Marshal 

func (m *JobSubmitResponse) Marshal() (dAtA []byte, err error)

func (*JobSubmitResponse) MarshalTo 

func (m *JobSubmitResponse) MarshalTo(dAtA []byte) (int, error)

func (*JobSubmitResponse) MarshalToSizedBuffer 

func (m *JobSubmitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSubmitResponse) ProtoMessage 

func (*JobSubmitResponse) ProtoMessage()

func (*JobSubmitResponse) Reset 

func (m *JobSubmitResponse) Reset()

func (*JobSubmitResponse) Size 

func (m *JobSubmitResponse) Size() (n int)

func (*JobSubmitResponse) String 

func (this *JobSubmitResponse) String() string

func (*JobSubmitResponse) Unmarshal 

func (m *JobSubmitResponse) Unmarshal(dAtA []byte) error

func (*JobSubmitResponse) XXX_DiscardUnknown 

func (m *JobSubmitResponse) XXX_DiscardUnknown()

func (*JobSubmitResponse) XXX_Marshal 

func (m *JobSubmitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSubmitResponse) XXX_Merge 

func (m *JobSubmitResponse) XXX_Merge(src proto.Message)

func (*JobSubmitResponse) XXX_Size 

func (m *JobSubmitResponse) XXX_Size() int

func (*JobSubmitResponse) XXX_Unmarshal 

func (m *JobSubmitResponse) XXX_Unmarshal(b []byte) error

type JobSubmitResponseItem 

type JobSubmitResponseItem struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*JobSubmitResponseItem) Descriptor 

func (*JobSubmitResponseItem) Descriptor() ([]byte, []int)

func (*JobSubmitResponseItem) GetError 

func (m *JobSubmitResponseItem) GetError() string

func (*JobSubmitResponseItem) GetJobId 

func (m *JobSubmitResponseItem) GetJobId() string

func (*JobSubmitResponseItem) Marshal 

func (m *JobSubmitResponseItem) Marshal() (dAtA []byte, err error)

func (*JobSubmitResponseItem) MarshalTo 

func (m *JobSubmitResponseItem) MarshalTo(dAtA []byte) (int, error)

func (*JobSubmitResponseItem) MarshalToSizedBuffer 

func (m *JobSubmitResponseItem) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSubmitResponseItem) ProtoMessage 

func (*JobSubmitResponseItem) ProtoMessage()

func (*JobSubmitResponseItem) Reset 

func (m *JobSubmitResponseItem) Reset()

func (*JobSubmitResponseItem) Size 

func (m *JobSubmitResponseItem) Size() (n int)

func (*JobSubmitResponseItem) String 

func (this *JobSubmitResponseItem) String() string

func (*JobSubmitResponseItem) Unmarshal 

func (m *JobSubmitResponseItem) Unmarshal(dAtA []byte) error

func (*JobSubmitResponseItem) XXX_DiscardUnknown 

func (m *JobSubmitResponseItem) XXX_DiscardUnknown()

func (*JobSubmitResponseItem) XXX_Marshal 

func (m *JobSubmitResponseItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSubmitResponseItem) XXX_Merge 

func (m *JobSubmitResponseItem) XXX_Merge(src proto.Message)

func (*JobSubmitResponseItem) XXX_Size 

func (m *JobSubmitResponseItem) XXX_Size() int

func (*JobSubmitResponseItem) XXX_Unmarshal 

func (m *JobSubmitResponseItem) XXX_Unmarshal(b []byte) error

type JobSubmittedEvent 

type JobSubmittedEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	Job      Job       `protobuf:"bytes,5,opt,name=job,proto3" json:"job"`
}

func (*JobSubmittedEvent) Descriptor 

func (*JobSubmittedEvent) Descriptor() ([]byte, []int)

func (*JobSubmittedEvent) GetCreated 

func (m *JobSubmittedEvent) GetCreated() time.Time

func (*JobSubmittedEvent) GetJob 

func (m *JobSubmittedEvent) GetJob() Job

func (*JobSubmittedEvent) GetJobId 

func (m *JobSubmittedEvent) GetJobId() string

func (*JobSubmittedEvent) GetJobSetId 

func (m *JobSubmittedEvent) GetJobSetId() string

func (*JobSubmittedEvent) GetQueue 

func (m *JobSubmittedEvent) GetQueue() string

func (*JobSubmittedEvent) Marshal 

func (m *JobSubmittedEvent) Marshal() (dAtA []byte, err error)

func (*JobSubmittedEvent) MarshalTo 

func (m *JobSubmittedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobSubmittedEvent) MarshalToSizedBuffer 

func (m *JobSubmittedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSubmittedEvent) ProtoMessage 

func (*JobSubmittedEvent) ProtoMessage()

func (*JobSubmittedEvent) Reset 

func (m *JobSubmittedEvent) Reset()

func (*JobSubmittedEvent) Size 

func (m *JobSubmittedEvent) Size() (n int)

func (*JobSubmittedEvent) String 

func (this *JobSubmittedEvent) String() string

func (*JobSubmittedEvent) Unmarshal 

func (m *JobSubmittedEvent) Unmarshal(dAtA []byte) error

func (*JobSubmittedEvent) XXX_DiscardUnknown 

func (m *JobSubmittedEvent) XXX_DiscardUnknown()

func (*JobSubmittedEvent) XXX_Marshal 

func (m *JobSubmittedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSubmittedEvent) XXX_Merge 

func (m *JobSubmittedEvent) XXX_Merge(src proto.Message)

func (*JobSubmittedEvent) XXX_Size 

func (m *JobSubmittedEvent) XXX_Size() int

func (*JobSubmittedEvent) XXX_Unmarshal 

func (m *JobSubmittedEvent) XXX_Unmarshal(b []byte) error

type JobSucceededEvent 

type JobSucceededEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber    int32     `protobuf:"varint,8,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string    `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string    `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
}

func (*JobSucceededEvent) Descriptor 

func (*JobSucceededEvent) Descriptor() ([]byte, []int)

func (*JobSucceededEvent) GetClusterId 

func (m *JobSucceededEvent) GetClusterId() string

func (*JobSucceededEvent) GetCreated 

func (m *JobSucceededEvent) GetCreated() time.Time

func (*JobSucceededEvent) GetJobId 

func (m *JobSucceededEvent) GetJobId() string

func (*JobSucceededEvent) GetJobSetId 

func (m *JobSucceededEvent) GetJobSetId() string

func (*JobSucceededEvent) GetKubernetesId 

func (m *JobSucceededEvent) GetKubernetesId() string

func (*JobSucceededEvent) GetNodeName 

func (m *JobSucceededEvent) GetNodeName() string

func (*JobSucceededEvent) GetPodName 

func (m *JobSucceededEvent) GetPodName() string

func (*JobSucceededEvent) GetPodNamespace 

func (m *JobSucceededEvent) GetPodNamespace() string

func (*JobSucceededEvent) GetPodNumber 

func (m *JobSucceededEvent) GetPodNumber() int32

func (*JobSucceededEvent) GetQueue 

func (m *JobSucceededEvent) GetQueue() string

func (*JobSucceededEvent) Marshal 

func (m *JobSucceededEvent) Marshal() (dAtA []byte, err error)

func (*JobSucceededEvent) MarshalTo 

func (m *JobSucceededEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobSucceededEvent) MarshalToSizedBuffer 

func (m *JobSucceededEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSucceededEvent) ProtoMessage 

func (*JobSucceededEvent) ProtoMessage()

func (*JobSucceededEvent) Reset 

func (m *JobSucceededEvent) Reset()

func (*JobSucceededEvent) Size 

func (m *JobSucceededEvent) Size() (n int)

func (*JobSucceededEvent) String 

func (this *JobSucceededEvent) String() string

func (*JobSucceededEvent) Unmarshal 

func (m *JobSucceededEvent) Unmarshal(dAtA []byte) error

func (*JobSucceededEvent) XXX_DiscardUnknown 

func (m *JobSucceededEvent) XXX_DiscardUnknown()

func (*JobSucceededEvent) XXX_Marshal 

func (m *JobSucceededEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobSucceededEvent) XXX_Merge 

func (m *JobSucceededEvent) XXX_Merge(src proto.Message)

func (*JobSucceededEvent) XXX_Size 

func (m *JobSucceededEvent) XXX_Size() int

func (*JobSucceededEvent) XXX_Unmarshal 

func (m *JobSucceededEvent) XXX_Unmarshal(b []byte) error

type JobTerminatedEvent 

type JobTerminatedEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	PodNumber    int32     `protobuf:"varint,7,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string    `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string    `protobuf:"bytes,10,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
	Reason       string    `protobuf:"bytes,8,opt,name=reason,proto3" json:"reason,omitempty"`
}

func (*JobTerminatedEvent) Descriptor 

func (*JobTerminatedEvent) Descriptor() ([]byte, []int)

func (*JobTerminatedEvent) GetClusterId 

func (m *JobTerminatedEvent) GetClusterId() string

func (*JobTerminatedEvent) GetCreated 

func (m *JobTerminatedEvent) GetCreated() time.Time

func (*JobTerminatedEvent) GetJobId 

func (m *JobTerminatedEvent) GetJobId() string

func (*JobTerminatedEvent) GetJobSetId 

func (m *JobTerminatedEvent) GetJobSetId() string

func (*JobTerminatedEvent) GetKubernetesId 

func (m *JobTerminatedEvent) GetKubernetesId() string

func (*JobTerminatedEvent) GetPodName 

func (m *JobTerminatedEvent) GetPodName() string

func (*JobTerminatedEvent) GetPodNamespace 

func (m *JobTerminatedEvent) GetPodNamespace() string

func (*JobTerminatedEvent) GetPodNumber 

func (m *JobTerminatedEvent) GetPodNumber() int32

func (*JobTerminatedEvent) GetQueue 

func (m *JobTerminatedEvent) GetQueue() string

func (*JobTerminatedEvent) GetReason 

func (m *JobTerminatedEvent) GetReason() string

func (*JobTerminatedEvent) Marshal 

func (m *JobTerminatedEvent) Marshal() (dAtA []byte, err error)

func (*JobTerminatedEvent) MarshalTo 

func (m *JobTerminatedEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobTerminatedEvent) MarshalToSizedBuffer 

func (m *JobTerminatedEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobTerminatedEvent) ProtoMessage 

func (*JobTerminatedEvent) ProtoMessage()

func (*JobTerminatedEvent) Reset 

func (m *JobTerminatedEvent) Reset()

func (*JobTerminatedEvent) Size 

func (m *JobTerminatedEvent) Size() (n int)

func (*JobTerminatedEvent) String 

func (this *JobTerminatedEvent) String() string

func (*JobTerminatedEvent) Unmarshal 

func (m *JobTerminatedEvent) Unmarshal(dAtA []byte) error

func (*JobTerminatedEvent) XXX_DiscardUnknown 

func (m *JobTerminatedEvent) XXX_DiscardUnknown()

func (*JobTerminatedEvent) XXX_Marshal 

func (m *JobTerminatedEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobTerminatedEvent) XXX_Merge 

func (m *JobTerminatedEvent) XXX_Merge(src proto.Message)

func (*JobTerminatedEvent) XXX_Size 

func (m *JobTerminatedEvent) XXX_Size() int

func (*JobTerminatedEvent) XXX_Unmarshal 

func (m *JobTerminatedEvent) XXX_Unmarshal(b []byte) error

type JobUnableToScheduleEvent 

type JobUnableToScheduleEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Reason       string    `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	KubernetesId string    `protobuf:"bytes,7,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,8,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber    int32     `protobuf:"varint,9,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName      string    `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace string    `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
}

func (*JobUnableToScheduleEvent) Descriptor 

func (*JobUnableToScheduleEvent) Descriptor() ([]byte, []int)

func (*JobUnableToScheduleEvent) GetClusterId 

func (m *JobUnableToScheduleEvent) GetClusterId() string

func (*JobUnableToScheduleEvent) GetCreated 

func (m *JobUnableToScheduleEvent) GetCreated() time.Time

func (*JobUnableToScheduleEvent) GetJobId 

func (m *JobUnableToScheduleEvent) GetJobId() string

func (*JobUnableToScheduleEvent) GetJobSetId 

func (m *JobUnableToScheduleEvent) GetJobSetId() string

func (*JobUnableToScheduleEvent) GetKubernetesId 

func (m *JobUnableToScheduleEvent) GetKubernetesId() string

func (*JobUnableToScheduleEvent) GetNodeName 

func (m *JobUnableToScheduleEvent) GetNodeName() string

func (*JobUnableToScheduleEvent) GetPodName 

func (m *JobUnableToScheduleEvent) GetPodName() string

func (*JobUnableToScheduleEvent) GetPodNamespace 

func (m *JobUnableToScheduleEvent) GetPodNamespace() string

func (*JobUnableToScheduleEvent) GetPodNumber 

func (m *JobUnableToScheduleEvent) GetPodNumber() int32

func (*JobUnableToScheduleEvent) GetQueue 

func (m *JobUnableToScheduleEvent) GetQueue() string

func (*JobUnableToScheduleEvent) GetReason 

func (m *JobUnableToScheduleEvent) GetReason() string

func (*JobUnableToScheduleEvent) Marshal 

func (m *JobUnableToScheduleEvent) Marshal() (dAtA []byte, err error)

func (*JobUnableToScheduleEvent) MarshalTo 

func (m *JobUnableToScheduleEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobUnableToScheduleEvent) MarshalToSizedBuffer 

func (m *JobUnableToScheduleEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobUnableToScheduleEvent) ProtoMessage 

func (*JobUnableToScheduleEvent) ProtoMessage()

func (*JobUnableToScheduleEvent) Reset 

func (m *JobUnableToScheduleEvent) Reset()

func (*JobUnableToScheduleEvent) Size 

func (m *JobUnableToScheduleEvent) Size() (n int)

func (*JobUnableToScheduleEvent) String 

func (this *JobUnableToScheduleEvent) String() string

func (*JobUnableToScheduleEvent) Unmarshal 

func (m *JobUnableToScheduleEvent) Unmarshal(dAtA []byte) error

func (*JobUnableToScheduleEvent) XXX_DiscardUnknown 

func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()

func (*JobUnableToScheduleEvent) XXX_Marshal 

func (m *JobUnableToScheduleEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobUnableToScheduleEvent) XXX_Merge 

func (m *JobUnableToScheduleEvent) XXX_Merge(src proto.Message)

func (*JobUnableToScheduleEvent) XXX_Size 

func (m *JobUnableToScheduleEvent) XXX_Size() int

func (*JobUnableToScheduleEvent) XXX_Unmarshal 

func (m *JobUnableToScheduleEvent) XXX_Unmarshal(b []byte) error

type JobUtilisationEvent 

type JobUtilisationEvent struct {
	JobId                 string                       `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId              string                       `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue                 string                       `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created               time.Time                    `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId             string                       `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	KubernetesId          string                       `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	MaxResourcesForPeriod map[string]resource.Quantity `` /* 173-byte string literal not displayed */
	NodeName              string                       `protobuf:"bytes,8,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber             int32                        `protobuf:"varint,9,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName               string                       `protobuf:"bytes,10,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace          string                       `protobuf:"bytes,11,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
	TotalCumulativeUsage  map[string]resource.Quantity `` /* 200-byte string literal not displayed */
}

func (*JobUtilisationEvent) Descriptor 

func (*JobUtilisationEvent) Descriptor() ([]byte, []int)

func (*JobUtilisationEvent) GetClusterId 

func (m *JobUtilisationEvent) GetClusterId() string

func (*JobUtilisationEvent) GetCreated 

func (m *JobUtilisationEvent) GetCreated() time.Time

func (*JobUtilisationEvent) GetJobId 

func (m *JobUtilisationEvent) GetJobId() string

func (*JobUtilisationEvent) GetJobSetId 

func (m *JobUtilisationEvent) GetJobSetId() string

func (*JobUtilisationEvent) GetKubernetesId 

func (m *JobUtilisationEvent) GetKubernetesId() string

func (*JobUtilisationEvent) GetMaxResourcesForPeriod 

func (m *JobUtilisationEvent) GetMaxResourcesForPeriod() map[string]resource.Quantity

func (*JobUtilisationEvent) GetNodeName 

func (m *JobUtilisationEvent) GetNodeName() string

func (*JobUtilisationEvent) GetPodName 

func (m *JobUtilisationEvent) GetPodName() string

func (*JobUtilisationEvent) GetPodNamespace 

func (m *JobUtilisationEvent) GetPodNamespace() string

func (*JobUtilisationEvent) GetPodNumber 

func (m *JobUtilisationEvent) GetPodNumber() int32

func (*JobUtilisationEvent) GetQueue 

func (m *JobUtilisationEvent) GetQueue() string

func (*JobUtilisationEvent) GetTotalCumulativeUsage 

func (m *JobUtilisationEvent) GetTotalCumulativeUsage() map[string]resource.Quantity

func (*JobUtilisationEvent) Marshal 

func (m *JobUtilisationEvent) Marshal() (dAtA []byte, err error)

func (*JobUtilisationEvent) MarshalTo 

func (m *JobUtilisationEvent) MarshalTo(dAtA []byte) (int, error)

func (*JobUtilisationEvent) MarshalToSizedBuffer 

func (m *JobUtilisationEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobUtilisationEvent) ProtoMessage 

func (*JobUtilisationEvent) ProtoMessage()

func (*JobUtilisationEvent) Reset 

func (m *JobUtilisationEvent) Reset()

func (*JobUtilisationEvent) Size 

func (m *JobUtilisationEvent) Size() (n int)

func (*JobUtilisationEvent) String 

func (this *JobUtilisationEvent) String() string

func (*JobUtilisationEvent) Unmarshal 

func (m *JobUtilisationEvent) Unmarshal(dAtA []byte) error

func (*JobUtilisationEvent) XXX_DiscardUnknown 

func (m *JobUtilisationEvent) XXX_DiscardUnknown()

func (*JobUtilisationEvent) XXX_Marshal 

func (m *JobUtilisationEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobUtilisationEvent) XXX_Merge 

func (m *JobUtilisationEvent) XXX_Merge(src proto.Message)

func (*JobUtilisationEvent) XXX_Size 

func (m *JobUtilisationEvent) XXX_Size() int

func (*JobUtilisationEvent) XXX_Unmarshal 

func (m *JobUtilisationEvent) XXX_Unmarshal(b []byte) error

type 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 KubernetesEvent interface {
	Event
	GetKubernetesId() string
	GetClusterId() string
	GetPodNumber() int32
	GetPodName() string
	GetPodNamespace() string
}

type PriorityClassPoolResourceLimits added in v0.4.29 

type PriorityClassPoolResourceLimits struct {
	MaximumResourceFraction map[string]float64 `` /* 210-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 (this *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 `` /* 210-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 `` /* 228-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 (this *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 `` /* 241-byte string literal not displayed */
	Permissions                       []*Queue_Permissions                   `protobuf:"bytes,6,rep,name=permissions,proto3" json:"permissions,omitempty"`
}

swagger:model

func (*Queue) Descriptor 

func (*Queue) Descriptor() ([]byte, []int)

func (*Queue) GetGroupOwners 

func (m *Queue) GetGroupOwners() []string

func (*Queue) GetName 

func (m *Queue) GetName() string

func (*Queue) GetPermissions 

func (m *Queue) GetPermissions() []*Queue_Permissions

func (*Queue) GetPriorityFactor 

func (m *Queue) GetPriorityFactor() float64

func (*Queue) GetResourceLimits deprecated 

func (m *Queue) GetResourceLimits() map[string]float64

Deprecated: Do not use.

func (*Queue) GetResourceLimitsByPriorityClassName added in v0.4.29 

func (m *Queue) GetResourceLimitsByPriorityClassName() map[string]PriorityClassResourceLimits

func (*Queue) GetUserOwners 

func (m *Queue) GetUserOwners() []string

func (*Queue) Marshal 

func (m *Queue) Marshal() (dAtA []byte, err error)

func (*Queue) MarshalTo 

func (m *Queue) MarshalTo(dAtA []byte) (int, error)

func (*Queue) MarshalToSizedBuffer 

func (m *Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Queue) ProtoMessage 

func (*Queue) ProtoMessage()

func (*Queue) Reset 

func (m *Queue) Reset()

func (*Queue) Size 

func (m *Queue) Size() (n int)

func (*Queue) String 

func (this *Queue) String() string

func (*Queue) Unmarshal 

func (m *Queue) Unmarshal(dAtA []byte) error

func (*Queue) XXX_DiscardUnknown 

func (m *Queue) XXX_DiscardUnknown()

func (*Queue) XXX_Marshal 

func (m *Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Queue) XXX_Merge 

func (m *Queue) XXX_Merge(src proto.Message)

func (*Queue) XXX_Size 

func (m *Queue) XXX_Size() int

func (*Queue) XXX_Unmarshal 

func (m *Queue) 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 (this *QueueCreateResponse) String() string

func (*QueueCreateResponse) Unmarshal 

func (m *QueueCreateResponse) Unmarshal(dAtA []byte) error

func (*QueueCreateResponse) XXX_DiscardUnknown 

func (m *QueueCreateResponse) XXX_DiscardUnknown()

func (*QueueCreateResponse) XXX_Marshal 

func (m *QueueCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueCreateResponse) XXX_Merge 

func (m *QueueCreateResponse) XXX_Merge(src proto.Message)

func (*QueueCreateResponse) XXX_Size 

func (m *QueueCreateResponse) XXX_Size() int

func (*QueueCreateResponse) XXX_Unmarshal 

func (m *QueueCreateResponse) XXX_Unmarshal(b []byte) error

type QueueDeleteRequest 

type QueueDeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*QueueDeleteRequest) Descriptor 

func (*QueueDeleteRequest) Descriptor() ([]byte, []int)

func (*QueueDeleteRequest) GetName 

func (m *QueueDeleteRequest) GetName() string

func (*QueueDeleteRequest) Marshal 

func (m *QueueDeleteRequest) Marshal() (dAtA []byte, err error)

func (*QueueDeleteRequest) MarshalTo 

func (m *QueueDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueueDeleteRequest) MarshalToSizedBuffer 

func (m *QueueDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueDeleteRequest) ProtoMessage 

func (*QueueDeleteRequest) ProtoMessage()

func (*QueueDeleteRequest) Reset 

func (m *QueueDeleteRequest) Reset()

func (*QueueDeleteRequest) Size 

func (m *QueueDeleteRequest) Size() (n int)

func (*QueueDeleteRequest) String 

func (this *QueueDeleteRequest) String() string

func (*QueueDeleteRequest) Unmarshal 

func (m *QueueDeleteRequest) Unmarshal(dAtA []byte) error

func (*QueueDeleteRequest) XXX_DiscardUnknown 

func (m *QueueDeleteRequest) XXX_DiscardUnknown()

func (*QueueDeleteRequest) XXX_Marshal 

func (m *QueueDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueDeleteRequest) XXX_Merge 

func (m *QueueDeleteRequest) XXX_Merge(src proto.Message)

func (*QueueDeleteRequest) XXX_Size 

func (m *QueueDeleteRequest) XXX_Size() int

func (*QueueDeleteRequest) XXX_Unmarshal 

func (m *QueueDeleteRequest) XXX_Unmarshal(b []byte) error

type QueueGetRequest 

type QueueGetRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*QueueGetRequest) Descriptor 

func (*QueueGetRequest) Descriptor() ([]byte, []int)

func (*QueueGetRequest) GetName 

func (m *QueueGetRequest) GetName() string

func (*QueueGetRequest) Marshal 

func (m *QueueGetRequest) Marshal() (dAtA []byte, err error)

func (*QueueGetRequest) MarshalTo 

func (m *QueueGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueueGetRequest) MarshalToSizedBuffer 

func (m *QueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueGetRequest) ProtoMessage 

func (*QueueGetRequest) ProtoMessage()

func (*QueueGetRequest) Reset 

func (m *QueueGetRequest) Reset()

func (*QueueGetRequest) Size 

func (m *QueueGetRequest) Size() (n int)

func (*QueueGetRequest) String 

func (this *QueueGetRequest) String() string

func (*QueueGetRequest) Unmarshal 

func (m *QueueGetRequest) Unmarshal(dAtA []byte) error

func (*QueueGetRequest) XXX_DiscardUnknown 

func (m *QueueGetRequest) XXX_DiscardUnknown()

func (*QueueGetRequest) XXX_Marshal 

func (m *QueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueGetRequest) XXX_Merge 

func (m *QueueGetRequest) XXX_Merge(src proto.Message)

func (*QueueGetRequest) XXX_Size 

func (m *QueueGetRequest) XXX_Size() int

func (*QueueGetRequest) XXX_Unmarshal 

func (m *QueueGetRequest) XXX_Unmarshal(b []byte) error

type QueueList 

type QueueList struct {
	Queues []*Queue `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
}

swagger:model

func (*QueueList) Descriptor 

func (*QueueList) Descriptor() ([]byte, []int)

func (*QueueList) GetQueues 

func (m *QueueList) GetQueues() []*Queue

func (*QueueList) Marshal 

func (m *QueueList) Marshal() (dAtA []byte, err error)

func (*QueueList) MarshalTo 

func (m *QueueList) MarshalTo(dAtA []byte) (int, error)

func (*QueueList) MarshalToSizedBuffer 

func (m *QueueList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueList) ProtoMessage 

func (*QueueList) ProtoMessage()

func (*QueueList) Reset 

func (m *QueueList) Reset()

func (*QueueList) Size 

func (m *QueueList) Size() (n int)

func (*QueueList) String 

func (this *QueueList) String() string

func (*QueueList) Unmarshal 

func (m *QueueList) Unmarshal(dAtA []byte) error

func (*QueueList) XXX_DiscardUnknown 

func (m *QueueList) XXX_DiscardUnknown()

func (*QueueList) XXX_Marshal 

func (m *QueueList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueList) XXX_Merge 

func (m *QueueList) XXX_Merge(src proto.Message)

func (*QueueList) XXX_Size 

func (m *QueueList) XXX_Size() int

func (*QueueList) XXX_Unmarshal 

func (m *QueueList) XXX_Unmarshal(b []byte) error

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)
}

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
}

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 QueueUpdateResponse 

type QueueUpdateResponse struct {
	Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*QueueUpdateResponse) Descriptor 

func (*QueueUpdateResponse) Descriptor() ([]byte, []int)

func (*QueueUpdateResponse) GetError 

func (m *QueueUpdateResponse) GetError() string

func (*QueueUpdateResponse) GetQueue 

func (m *QueueUpdateResponse) GetQueue() *Queue

func (*QueueUpdateResponse) Marshal 

func (m *QueueUpdateResponse) Marshal() (dAtA []byte, err error)

func (*QueueUpdateResponse) MarshalTo 

func (m *QueueUpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueueUpdateResponse) MarshalToSizedBuffer 

func (m *QueueUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueUpdateResponse) ProtoMessage 

func (*QueueUpdateResponse) ProtoMessage()

func (*QueueUpdateResponse) Reset 

func (m *QueueUpdateResponse) Reset()

func (*QueueUpdateResponse) Size 

func (m *QueueUpdateResponse) Size() (n int)

func (*QueueUpdateResponse) String 

func (this *QueueUpdateResponse) String() string

func (*QueueUpdateResponse) Unmarshal 

func (m *QueueUpdateResponse) Unmarshal(dAtA []byte) error

func (*QueueUpdateResponse) XXX_DiscardUnknown 

func (m *QueueUpdateResponse) XXX_DiscardUnknown()

func (*QueueUpdateResponse) XXX_Marshal 

func (m *QueueUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueUpdateResponse) XXX_Merge 

func (m *QueueUpdateResponse) XXX_Merge(src proto.Message)

func (*QueueUpdateResponse) XXX_Size 

func (m *QueueUpdateResponse) XXX_Size() int

func (*QueueUpdateResponse) XXX_Unmarshal 

func (m *QueueUpdateResponse) XXX_Unmarshal(b []byte) error

type Queue_Permissions 

type Queue_Permissions struct {
	Subjects []*Queue_Permissions_Subject `protobuf:"bytes,1,rep,name=subjects,proto3" json:"subjects,omitempty"`
	Verbs    []string                     `protobuf:"bytes,2,rep,name=verbs,proto3" json:"verbs,omitempty"`
}

func (*Queue_Permissions) Descriptor 

func (*Queue_Permissions) Descriptor() ([]byte, []int)

func (*Queue_Permissions) GetSubjects 

func (m *Queue_Permissions) GetSubjects() []*Queue_Permissions_Subject

func (*Queue_Permissions) GetVerbs 

func (m *Queue_Permissions) GetVerbs() []string

func (*Queue_Permissions) Marshal 

func (m *Queue_Permissions) Marshal() (dAtA []byte, err error)

func (*Queue_Permissions) MarshalTo 

func (m *Queue_Permissions) MarshalTo(dAtA []byte) (int, error)

func (*Queue_Permissions) MarshalToSizedBuffer 

func (m *Queue_Permissions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Queue_Permissions) ProtoMessage 

func (*Queue_Permissions) ProtoMessage()

func (*Queue_Permissions) Reset 

func (m *Queue_Permissions) Reset()

func (*Queue_Permissions) Size 

func (m *Queue_Permissions) Size() (n int)

func (*Queue_Permissions) String 

func (this *Queue_Permissions) String() string

func (*Queue_Permissions) Unmarshal 

func (m *Queue_Permissions) Unmarshal(dAtA []byte) error

func (*Queue_Permissions) XXX_DiscardUnknown 

func (m *Queue_Permissions) XXX_DiscardUnknown()

func (*Queue_Permissions) XXX_Marshal 

func (m *Queue_Permissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Queue_Permissions) XXX_Merge 

func (m *Queue_Permissions) XXX_Merge(src proto.Message)

func (*Queue_Permissions) XXX_Size 

func (m *Queue_Permissions) XXX_Size() int

func (*Queue_Permissions) XXX_Unmarshal 

func (m *Queue_Permissions) XXX_Unmarshal(b []byte) error

type Queue_Permissions_Subject 

type Queue_Permissions_Subject struct {
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*Queue_Permissions_Subject) Descriptor 

func (*Queue_Permissions_Subject) Descriptor() ([]byte, []int)

func (*Queue_Permissions_Subject) GetKind 

func (m *Queue_Permissions_Subject) GetKind() string

func (*Queue_Permissions_Subject) GetName 

func (m *Queue_Permissions_Subject) GetName() string

func (*Queue_Permissions_Subject) Marshal 

func (m *Queue_Permissions_Subject) Marshal() (dAtA []byte, err error)

func (*Queue_Permissions_Subject) MarshalTo 

func (m *Queue_Permissions_Subject) MarshalTo(dAtA []byte) (int, error)

func (*Queue_Permissions_Subject) MarshalToSizedBuffer 

func (m *Queue_Permissions_Subject) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Queue_Permissions_Subject) ProtoMessage 

func (*Queue_Permissions_Subject) ProtoMessage()

func (*Queue_Permissions_Subject) Reset 

func (m *Queue_Permissions_Subject) Reset()

func (*Queue_Permissions_Subject) Size 

func (m *Queue_Permissions_Subject) Size() (n int)

func (*Queue_Permissions_Subject) String 

func (this *Queue_Permissions_Subject) String() string

func (*Queue_Permissions_Subject) Unmarshal 

func (m *Queue_Permissions_Subject) Unmarshal(dAtA []byte) error

func (*Queue_Permissions_Subject) XXX_DiscardUnknown 

func (m *Queue_Permissions_Subject) XXX_DiscardUnknown()

func (*Queue_Permissions_Subject) XXX_Marshal 

func (m *Queue_Permissions_Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Queue_Permissions_Subject) XXX_Merge 

func (m *Queue_Permissions_Subject) XXX_Merge(src proto.Message)

func (*Queue_Permissions_Subject) XXX_Size 

func (m *Queue_Permissions_Subject) XXX_Size() int

func (*Queue_Permissions_Subject) XXX_Unmarshal 

func (m *Queue_Permissions_Subject) XXX_Unmarshal(b []byte) error

type ServiceConfig 

type ServiceConfig struct {
	Type  ServiceType `protobuf:"varint,1,opt,name=type,proto3,enum=api.ServiceType" json:"type,omitempty"`
	Ports []uint32    `protobuf:"varint,2,rep,packed,name=ports,proto3" json:"ports,omitempty"`
}

func (*ServiceConfig) Descriptor 

func (*ServiceConfig) Descriptor() ([]byte, []int)

func (*ServiceConfig) GetPorts 

func (m *ServiceConfig) GetPorts() []uint32

func (*ServiceConfig) GetType 

func (m *ServiceConfig) GetType() ServiceType

func (*ServiceConfig) Marshal 

func (m *ServiceConfig) Marshal() (dAtA []byte, err error)

func (*ServiceConfig) MarshalTo 

func (m *ServiceConfig) MarshalTo(dAtA []byte) (int, error)

func (*ServiceConfig) MarshalToSizedBuffer 

func (m *ServiceConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceConfig) ProtoMessage 

func (*ServiceConfig) ProtoMessage()

func (*ServiceConfig) Reset 

func (m *ServiceConfig) Reset()

func (*ServiceConfig) Size 

func (m *ServiceConfig) Size() (n int)

func (*ServiceConfig) String 

func (this *ServiceConfig) String() string

func (*ServiceConfig) Unmarshal 

func (m *ServiceConfig) Unmarshal(dAtA []byte) error

func (*ServiceConfig) XXX_DiscardUnknown 

func (m *ServiceConfig) XXX_DiscardUnknown()

func (*ServiceConfig) XXX_Marshal 

func (m *ServiceConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceConfig) XXX_Merge 

func (m *ServiceConfig) XXX_Merge(src proto.Message)

func (*ServiceConfig) XXX_Size 

func (m *ServiceConfig) XXX_Size() int

func (*ServiceConfig) XXX_Unmarshal 

func (m *ServiceConfig) XXX_Unmarshal(b []byte) error

type ServiceType 

type ServiceType int32
const (
	ServiceType_NodePort ServiceType = 0
	ServiceType_Headless ServiceType = 1
)

func (ServiceType) EnumDescriptor 

func (ServiceType) EnumDescriptor() ([]byte, []int)

func (ServiceType) String 

func (x ServiceType) String() string

func (*ServiceType) UnmarshalJSON 

func (x *ServiceType) UnmarshalJSON(data []byte) error

type StreamingQueueGetRequest added in v0.3.100 

type StreamingQueueGetRequest struct {
	Num uint32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
}

func (*StreamingQueueGetRequest) Descriptor added in v0.3.100 

func (*StreamingQueueGetRequest) Descriptor() ([]byte, []int)

func (*StreamingQueueGetRequest) GetNum added in v0.3.100 

func (m *StreamingQueueGetRequest) GetNum() uint32

func (*StreamingQueueGetRequest) Marshal added in v0.3.100 

func (m *StreamingQueueGetRequest) Marshal() (dAtA []byte, err error)

func (*StreamingQueueGetRequest) MarshalTo added in v0.3.100 

func (m *StreamingQueueGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*StreamingQueueGetRequest) MarshalToSizedBuffer added in v0.3.100 

func (m *StreamingQueueGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamingQueueGetRequest) ProtoMessage added in v0.3.100 

func (*StreamingQueueGetRequest) ProtoMessage()

func (*StreamingQueueGetRequest) Reset added in v0.3.100 

func (m *StreamingQueueGetRequest) Reset()

func (*StreamingQueueGetRequest) Size added in v0.3.100 

func (m *StreamingQueueGetRequest) Size() (n int)

func (*StreamingQueueGetRequest) String added in v0.3.100 

func (this *StreamingQueueGetRequest) String() string

func (*StreamingQueueGetRequest) Unmarshal added in v0.3.100 

func (m *StreamingQueueGetRequest) Unmarshal(dAtA []byte) error

func (*StreamingQueueGetRequest) XXX_DiscardUnknown added in v0.3.100 

func (m *StreamingQueueGetRequest) XXX_DiscardUnknown()

func (*StreamingQueueGetRequest) XXX_Marshal added in v0.3.100 

func (m *StreamingQueueGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingQueueGetRequest) XXX_Merge added in v0.3.100 

func (m *StreamingQueueGetRequest) XXX_Merge(src proto.Message)

func (*StreamingQueueGetRequest) XXX_Size added in v0.3.100 

func (m *StreamingQueueGetRequest) XXX_Size() int

func (*StreamingQueueGetRequest) XXX_Unmarshal added in v0.3.100 

func (m *StreamingQueueGetRequest) XXX_Unmarshal(b []byte) error

type StreamingQueueMessage added in v0.3.100 

type StreamingQueueMessage struct {
	// Types that are valid to be assigned to Event:
	//	*StreamingQueueMessage_Queue
	//	*StreamingQueueMessage_End
	Event isStreamingQueueMessage_Event `protobuf_oneof:"event"`
}

func (*StreamingQueueMessage) Descriptor added in v0.3.100 

func (*StreamingQueueMessage) Descriptor() ([]byte, []int)

func (*StreamingQueueMessage) GetEnd added in v0.3.100 

func (m *StreamingQueueMessage) GetEnd() *EndMarker

func (*StreamingQueueMessage) GetEvent added in v0.3.100 

func (m *StreamingQueueMessage) GetEvent() isStreamingQueueMessage_Event

func (*StreamingQueueMessage) GetQueue added in v0.3.100 

func (m *StreamingQueueMessage) GetQueue() *Queue

func (*StreamingQueueMessage) Marshal added in v0.3.100 

func (m *StreamingQueueMessage) Marshal() (dAtA []byte, err error)

func (*StreamingQueueMessage) MarshalTo added in v0.3.100 

func (m *StreamingQueueMessage) MarshalTo(dAtA []byte) (int, error)

func (*StreamingQueueMessage) MarshalToSizedBuffer added in v0.3.100 

func (m *StreamingQueueMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamingQueueMessage) ProtoMessage added in v0.3.100 

func (*StreamingQueueMessage) ProtoMessage()

func (*StreamingQueueMessage) Reset added in v0.3.100 

func (m *StreamingQueueMessage) Reset()

func (*StreamingQueueMessage) Size added in v0.3.100 

func (m *StreamingQueueMessage) Size() (n int)

func (*StreamingQueueMessage) String added in v0.3.100 

func (this *StreamingQueueMessage) String() string

func (*StreamingQueueMessage) Unmarshal added in v0.3.100 

func (m *StreamingQueueMessage) Unmarshal(dAtA []byte) error

func (*StreamingQueueMessage) XXX_DiscardUnknown added in v0.3.100 

func (m *StreamingQueueMessage) XXX_DiscardUnknown()

func (*StreamingQueueMessage) XXX_Marshal added in v0.3.100 

func (m *StreamingQueueMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingQueueMessage) XXX_Merge added in v0.3.100 

func (m *StreamingQueueMessage) XXX_Merge(src proto.Message)

func (*StreamingQueueMessage) XXX_OneofWrappers added in v0.3.100 

func (*StreamingQueueMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamingQueueMessage) XXX_Size added in v0.3.100 

func (m *StreamingQueueMessage) XXX_Size() int

func (*StreamingQueueMessage) XXX_Unmarshal added in v0.3.100 

func (m *StreamingQueueMessage) XXX_Unmarshal(b []byte) error

type StreamingQueueMessage_End added in v0.3.100 

type StreamingQueueMessage_End struct {
	End *EndMarker `protobuf:"bytes,2,opt,name=end,proto3,oneof" json:"end,omitempty"`
}

func (*StreamingQueueMessage_End) MarshalTo added in v0.3.100 

func (m *StreamingQueueMessage_End) MarshalTo(dAtA []byte) (int, error)

func (*StreamingQueueMessage_End) MarshalToSizedBuffer added in v0.3.100 

func (m *StreamingQueueMessage_End) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamingQueueMessage_End) Size added in v0.3.100 

func (m *StreamingQueueMessage_End) Size() (n int)

func (*StreamingQueueMessage_End) String added in v0.3.100 

func (this *StreamingQueueMessage_End) String() string

type StreamingQueueMessage_Queue added in v0.3.100 

type StreamingQueueMessage_Queue struct {
	Queue *Queue `protobuf:"bytes,1,opt,name=queue,proto3,oneof" json:"queue,omitempty"`
}

func (*StreamingQueueMessage_Queue) MarshalTo added in v0.3.100 

func (m *StreamingQueueMessage_Queue) MarshalTo(dAtA []byte) (int, error)

func (*StreamingQueueMessage_Queue) MarshalToSizedBuffer added in v0.3.100 

func (m *StreamingQueueMessage_Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamingQueueMessage_Queue) Size added in v0.3.100 

func (m *StreamingQueueMessage_Queue) Size() (n int)

func (*StreamingQueueMessage_Queue) String added in v0.3.100 

func (this *StreamingQueueMessage_Queue) String() string

type SubmitClient 

type SubmitClient interface {
	SubmitJobs(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)
	CancelJobs(ctx context.Context, in *JobCancelRequest, opts ...grpc.CallOption) (*CancellationResult, error)
	CancelJobSet(ctx context.Context, in *JobSetCancelRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ReprioritizeJobs(ctx context.Context, in *JobReprioritizeRequest, opts ...grpc.CallOption) (*JobReprioritizeResponse, error)
	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 time.Duration `protobuf:"bytes,7,opt,name=interval,proto3,stdduration" json:"interval"`
	// Number of seconds to wait for jobs to finish.
	Timeout time.Duration   `protobuf:"bytes,8,opt,name=timeout,proto3,stdduration" json:"timeout"`
	Cancel  TestSpec_Cancel `protobuf:"varint,9,opt,name=cancel,proto3,enum=api.TestSpec_Cancel" json:"cancel,omitempty"`
	// Test name. Defaults to the filename if not provided.
	Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	// Randomize clientId if not provided
	RandomClientId bool `protobuf:"varint,11,opt,name=random_client_id,json=randomClientId,proto3" json:"randomClientId,omitempty"`
	// Toggle should testsuite scrape Armada Job (pod) logs
	GetLogs bool `protobuf:"varint,12,opt,name=get_logs,json=getLogs,proto3" json:"getLogs,omitempty"`
	// Value of the environment label set on exported Prometheus metrics.
	Environment string `protobuf:"bytes,13,opt,name=environment,proto3" json:"environment,omitempty"`
	// Value of the target label set on exported Prometheus metrics.
	Target string `protobuf:"bytes,14,opt,name=target,proto3" json:"target,omitempty"`
}

Defines a test case for the Armada test suite. Defined as a proto message to enable unmarshalling oneof fields.

func (*TestSpec) Descriptor 

func (*TestSpec) Descriptor() ([]byte, []int)

func (*TestSpec) GetBatchSize 

func (m *TestSpec) GetBatchSize() uint32

func (*TestSpec) GetCancel 

func (m *TestSpec) GetCancel() TestSpec_Cancel

func (*TestSpec) GetEnvironment added in v0.3.94 

func (m *TestSpec) GetEnvironment() string

func (*TestSpec) GetExpectedEvents 

func (m *TestSpec) GetExpectedEvents() []*EventMessage

func (*TestSpec) GetGetLogs 

func (m *TestSpec) GetGetLogs() bool

func (*TestSpec) GetInterval 

func (m *TestSpec) GetInterval() time.Duration

func (*TestSpec) GetJobSetId 

func (m *TestSpec) GetJobSetId() string

func (*TestSpec) GetJobs 

func (m *TestSpec) GetJobs() []*JobSubmitRequestItem

func (*TestSpec) GetName 

func (m *TestSpec) GetName() string

func (*TestSpec) GetNumBatches 

func (m *TestSpec) GetNumBatches() uint32

func (*TestSpec) GetQueue 

func (m *TestSpec) GetQueue() string

func (*TestSpec) GetRandomClientId 

func (m *TestSpec) GetRandomClientId() bool

func (*TestSpec) GetTarget added in v0.3.94 

func (m *TestSpec) GetTarget() string

func (*TestSpec) GetTimeout 

func (m *TestSpec) GetTimeout() time.Duration

func (*TestSpec) Marshal 

func (m *TestSpec) Marshal() (dAtA []byte, err error)

func (*TestSpec) MarshalTo 

func (m *TestSpec) MarshalTo(dAtA []byte) (int, error)

func (*TestSpec) MarshalToSizedBuffer 

func (m *TestSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TestSpec) ProtoMessage 

func (*TestSpec) ProtoMessage()

func (*TestSpec) Reset 

func (m *TestSpec) Reset()

func (*TestSpec) ShortString 

func (testSpec *TestSpec) ShortString() string

func (*TestSpec) Size 

func (m *TestSpec) Size() (n int)

func (*TestSpec) String 

func (this *TestSpec) String() string

func (*TestSpec) Unmarshal 

func (m *TestSpec) Unmarshal(dAtA []byte) error

func (*TestSpec) XXX_DiscardUnknown 

func (m *TestSpec) XXX_DiscardUnknown()

func (*TestSpec) XXX_Marshal 

func (m *TestSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestSpec) XXX_Merge 

func (m *TestSpec) XXX_Merge(src proto.Message)

func (*TestSpec) XXX_Size 

func (m *TestSpec) XXX_Size() int

func (*TestSpec) XXX_Unmarshal 

func (m *TestSpec) XXX_Unmarshal(b []byte) error

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) CreateQueue added in v0.7.0 

func (*UnimplementedQueueServiceServer) CreateQueue(ctx context.Context, req *Queue) (*types.Empty, error)

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) UpdateQueue added in v0.7.0 

func (*UnimplementedQueueServiceServer) UpdateQueue(ctx context.Context, req *Queue) (*types.Empty, error)

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) CreateQueue(ctx context.Context, req *Queue) (*types.Empty, error)

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) UpdateQueue(ctx context.Context, req *Queue) (*types.Empty, error)

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) MarshalTo 

func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatchRequest) MarshalToSizedBuffer 

func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size 

func (m *WatchRequest) Size() (n int)

func (*WatchRequest) String 

func (this *WatchRequest) String() string

func (*WatchRequest) Unmarshal 

func (m *WatchRequest) Unmarshal(dAtA []byte) error

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchRequest) XXX_Merge 

func (m *WatchRequest) XXX_Merge(src proto.Message)

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

func (m *WatchRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package binoculars is a reverse proxy.
 Package binoculars is a reverse proxy.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.