api

package
v0.4.21 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2024 License: Apache-2.0 Imports: 37 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.

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 (
	ErrInvalidLengthQueryapi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryapi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryapi = 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",
}
View Source 
var Cause_value = map[string]int32{
	"Error":            0,
	"Evicted":          1,
	"OOM":              2,
	"DeadlineExceeded": 3,
}
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 JobState_name = map[int32]string{
	0: "QUEUED",
	1: "PENDING",
	2: "RUNNING",
	3: "SUCCEEDED",
	4: "FAILED",
	5: "UNKNOWN",
}
View Source 
var JobState_value = map[string]int32{
	"QUEUED":    0,
	"PENDING":   1,
	"RUNNING":   2,
	"SUCCEEDED": 3,
	"FAILED":    4,
	"UNKNOWN":   5,
}
View Source 
var JobStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SUBMITTED",
	2: "QUEUED",
	3: "LEASED",
	4: "PENDING",
	5: "RUNNING",
	6: "SUCCEEDED",
	7: "FAILED",
	8: "PREEMPTED",
	9: "CANCELLED",
}
View Source 
var JobStatus_value = map[string]int32{
	"UNKNOWN":   0,
	"SUBMITTED": 1,
	"QUEUED":    2,
	"LEASED":    3,
	"PENDING":   4,
	"RUNNING":   5,
	"SUCCEEDED": 6,
	"FAILED":    7,
	"PREEMPTED": 8,
	"CANCELLED": 9,
}
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 PriorityFromPodSpec added in v0.3.70 

func PriorityFromPodSpec(podSpec *v1.PodSpec, priorityClasses map[string]types.PriorityClass) (int32, bool)

PriorityFromPodSpec returns the priority in a pod spec. If priority is set directly, that value is returned. Otherwise, it returns the value of the key podSpec. In both cases the value along with true boolean is returned. PriorityClassName in priorityByPriorityClassName map. If no priority is set for the pod spec, 0 along with a false boolean would be returned

func RegisterEventHandler 

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 RegisterQueryApiServer added in v0.4.20 

func RegisterQueryApiServer(s *grpc.Server, srv QueryApiServer)

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 SchedulingOrderCompare added in v0.4.0 

func SchedulingOrderCompare(job, other *Job) int

SchedulingOrderCompare defines the order in which jobs in a queue should be scheduled (both when scheduling new jobs and when re-scheduling evicted jobs). Specifically, compare returns

  • 0 if the jobs have equal job id,
  • -1 if job should be scheduled before other,
  • +1 if other should be scheduled before other.

func SchedulingResourceRequirementsFromPodSpec added in v0.3.70 

func SchedulingResourceRequirementsFromPodSpec(podSpec *v1.PodSpec) v1.ResourceRequirements

SchedulingResourceRequirementsFromPodSpec returns resource requests and limits necessary for scheduling a pod. The requests and limits are set to:

max( 

sum across all containers,
max over all init containers,

)

This is because containers run in parallel, whereas initContainers run serially.

func ShortStringFromEventMessages 

func ShortStringFromEventMessages(msgs []*EventMessage) string

func SwaggerJsonTemplate 

func SwaggerJsonTemplate() string

SwaggerJsonTemplate is a generated function returning the template as a string. That string should be parsed by the functions of the golang's template package.

Types

type BatchQueueCreateResponse 

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

func (*BatchQueueCreateResponse) Descriptor 

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

func (*BatchQueueCreateResponse) GetFailedQueues 

func (m *BatchQueueCreateResponse) GetFailedQueues() []*QueueCreateResponse

func (*BatchQueueCreateResponse) Marshal 

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

func (*BatchQueueCreateResponse) MarshalTo 

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

func (*BatchQueueCreateResponse) MarshalToSizedBuffer 

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

func (*BatchQueueCreateResponse) ProtoMessage 

func (*BatchQueueCreateResponse) ProtoMessage()

func (*BatchQueueCreateResponse) Reset 

func (m *BatchQueueCreateResponse) Reset()

func (*BatchQueueCreateResponse) Size 

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

func (*BatchQueueCreateResponse) String 

func (this *BatchQueueCreateResponse) String() string

func (*BatchQueueCreateResponse) Unmarshal 

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

func (*BatchQueueCreateResponse) XXX_DiscardUnknown 

func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()

func (*BatchQueueCreateResponse) XXX_Marshal 

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

func (*BatchQueueCreateResponse) XXX_Merge 

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

func (*BatchQueueCreateResponse) XXX_Size 

func (m *BatchQueueCreateResponse) XXX_Size() int

func (*BatchQueueCreateResponse) XXX_Unmarshal 

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

type BatchQueueUpdateResponse 

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

func (*BatchQueueUpdateResponse) Descriptor 

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

func (*BatchQueueUpdateResponse) GetFailedQueues 

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

func (*BatchQueueUpdateResponse) Marshal 

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

func (*BatchQueueUpdateResponse) MarshalTo 

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

func (*BatchQueueUpdateResponse) MarshalToSizedBuffer 

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

func (*BatchQueueUpdateResponse) ProtoMessage 

func (*BatchQueueUpdateResponse) ProtoMessage()

func (*BatchQueueUpdateResponse) Reset 

func (m *BatchQueueUpdateResponse) Reset()

func (*BatchQueueUpdateResponse) Size 

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

func (*BatchQueueUpdateResponse) String 

func (this *BatchQueueUpdateResponse) String() string

func (*BatchQueueUpdateResponse) Unmarshal 

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

func (*BatchQueueUpdateResponse) XXX_DiscardUnknown 

func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()

func (*BatchQueueUpdateResponse) XXX_Marshal 

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

func (*BatchQueueUpdateResponse) XXX_Merge 

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

func (*BatchQueueUpdateResponse) XXX_Size 

func (m *BatchQueueUpdateResponse) XXX_Size() int

func (*BatchQueueUpdateResponse) XXX_Unmarshal 

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

type CancellationResult 

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

swagger:model

func (*CancellationResult) Descriptor 

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

func (*CancellationResult) GetCancelledIds 

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

func (*CancellationResult) Marshal 

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

func (*CancellationResult) MarshalTo 

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

func (*CancellationResult) MarshalToSizedBuffer 

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

func (*CancellationResult) ProtoMessage 

func (*CancellationResult) ProtoMessage()

func (*CancellationResult) Reset 

func (m *CancellationResult) Reset()

func (*CancellationResult) Size 

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

func (*CancellationResult) String 

func (this *CancellationResult) String() string

func (*CancellationResult) Unmarshal 

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

func (*CancellationResult) XXX_DiscardUnknown 

func (m *CancellationResult) XXX_DiscardUnknown()

func (*CancellationResult) XXX_Marshal 

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

func (*CancellationResult) XXX_Merge 

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

func (*CancellationResult) XXX_Size 

func (m *CancellationResult) XXX_Size() int

func (*CancellationResult) XXX_Unmarshal 

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

type Cause 

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

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_DuplicateFound
	//	*EventMessage_Leased
	//	*EventMessage_LeaseReturned
	//	*EventMessage_LeaseExpired
	//	*EventMessage_Pending
	//	*EventMessage_Running
	//	*EventMessage_UnableToSchedule
	//	*EventMessage_Failed
	//	*EventMessage_Succeeded
	//	*EventMessage_Reprioritized
	//	*EventMessage_Cancelling
	//	*EventMessage_Cancelled
	//	*EventMessage_Terminated
	//	*EventMessage_Utilisation
	//	*EventMessage_IngressInfo
	//	*EventMessage_Reprioritizing
	//	*EventMessage_Updated
	//	*EventMessage_FailedCompressed
	//	*EventMessage_Preempted
	Events isEventMessage_Events `protobuf_oneof:"events"`
}

func Wrap 

func Wrap(event Event) (*EventMessage, error)

func (*EventMessage) Descriptor 

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

func (*EventMessage) GetCancelled 

func (m *EventMessage) GetCancelled() *JobCancelledEvent

func (*EventMessage) GetCancelling 

func (m *EventMessage) GetCancelling() *JobCancellingEvent

func (*EventMessage) GetDuplicateFound 

func (m *EventMessage) GetDuplicateFound() *JobDuplicateFoundEvent

func (*EventMessage) GetEvents 

func (m *EventMessage) GetEvents() isEventMessage_Events

func (*EventMessage) GetFailed 

func (m *EventMessage) GetFailed() *JobFailedEvent

func (*EventMessage) GetFailedCompressed 

func (m *EventMessage) GetFailedCompressed() *JobFailedEventCompressed

func (*EventMessage) GetIngressInfo 

func (m *EventMessage) GetIngressInfo() *JobIngressInfoEvent

func (*EventMessage) GetLeaseExpired 

func (m *EventMessage) GetLeaseExpired() *JobLeaseExpiredEvent

func (*EventMessage) GetLeaseReturned 

func (m *EventMessage) GetLeaseReturned() *JobLeaseReturnedEvent

func (*EventMessage) GetLeased 

func (m *EventMessage) GetLeased() *JobLeasedEvent

func (*EventMessage) GetPending 

func (m *EventMessage) GetPending() *JobPendingEvent

func (*EventMessage) GetPreempted 

func (m *EventMessage) GetPreempted() *JobPreemptedEvent

func (*EventMessage) GetQueued 

func (m *EventMessage) GetQueued() *JobQueuedEvent

func (*EventMessage) GetReprioritized 

func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent

func (*EventMessage) GetReprioritizing 

func (m *EventMessage) GetReprioritizing() *JobReprioritizingEvent

func (*EventMessage) GetRunning 

func (m *EventMessage) GetRunning() *JobRunningEvent

func (*EventMessage) GetSubmitted 

func (m *EventMessage) GetSubmitted() *JobSubmittedEvent

func (*EventMessage) GetSucceeded 

func (m *EventMessage) GetSucceeded() *JobSucceededEvent

func (*EventMessage) GetTerminated 

func (m *EventMessage) GetTerminated() *JobTerminatedEvent

func (*EventMessage) GetUnableToSchedule 

func (m *EventMessage) GetUnableToSchedule() *JobUnableToScheduleEvent

func (*EventMessage) GetUpdated 

func (m *EventMessage) GetUpdated() *JobUpdatedEvent

func (*EventMessage) GetUtilisation 

func (m *EventMessage) GetUtilisation() *JobUtilisationEvent

func (*EventMessage) Marshal 

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

func (*EventMessage) MarshalJSON 

func (message *EventMessage) MarshalJSON() ([]byte, error)

customise oneof serialisation

func (*EventMessage) 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_DuplicateFound 

type EventMessage_DuplicateFound struct {
	DuplicateFound *JobDuplicateFoundEvent `protobuf:"bytes,16,opt,name=duplicate_found,json=duplicateFound,proto3,oneof" json:"duplicateFound,omitempty"`
}

func (*EventMessage_DuplicateFound) MarshalTo 

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

func (*EventMessage_DuplicateFound) MarshalToSizedBuffer 

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

func (*EventMessage_DuplicateFound) Size 

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

func (*EventMessage_DuplicateFound) String 

func (this *EventMessage_DuplicateFound) String() string

type EventMessage_Failed 

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

func (*EventMessage_Failed) MarshalTo 

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

func (*EventMessage_Failed) MarshalToSizedBuffer 

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

func (*EventMessage_Failed) Size 

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

func (*EventMessage_Failed) String 

func (this *EventMessage_Failed) String() string

type EventMessage_FailedCompressed 

type EventMessage_FailedCompressed struct {
	FailedCompressed *JobFailedEventCompressed `protobuf:"bytes,20,opt,name=failedCompressed,proto3,oneof" json:"failedCompressed,omitempty"`
}

func (*EventMessage_FailedCompressed) MarshalTo 

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

func (*EventMessage_FailedCompressed) MarshalToSizedBuffer 

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

func (*EventMessage_FailedCompressed) Size 

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

func (*EventMessage_FailedCompressed) String 

func (this *EventMessage_FailedCompressed) String() string

type EventMessage_IngressInfo 

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

func (*EventMessage_IngressInfo) MarshalTo 

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

func (*EventMessage_IngressInfo) MarshalToSizedBuffer 

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

func (*EventMessage_IngressInfo) Size 

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

func (*EventMessage_IngressInfo) String 

func (this *EventMessage_IngressInfo) String() string

type EventMessage_LeaseExpired 

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

func (*EventMessage_LeaseExpired) MarshalTo 

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

func (*EventMessage_LeaseExpired) MarshalToSizedBuffer 

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

func (*EventMessage_LeaseExpired) Size 

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

func (*EventMessage_LeaseExpired) String 

func (this *EventMessage_LeaseExpired) String() string

type EventMessage_LeaseReturned 

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

func (*EventMessage_LeaseReturned) MarshalTo 

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

func (*EventMessage_LeaseReturned) MarshalToSizedBuffer 

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

func (*EventMessage_LeaseReturned) Size 

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

func (*EventMessage_LeaseReturned) String 

func (this *EventMessage_LeaseReturned) String() string

type EventMessage_Leased 

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

func (*EventMessage_Leased) MarshalTo 

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

func (*EventMessage_Leased) MarshalToSizedBuffer 

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

func (*EventMessage_Leased) Size 

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

func (*EventMessage_Leased) String 

func (this *EventMessage_Leased) String() string

type EventMessage_Pending 

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

func (*EventMessage_Pending) MarshalTo 

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

func (*EventMessage_Pending) MarshalToSizedBuffer 

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

func (*EventMessage_Pending) Size 

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

func (*EventMessage_Pending) String 

func (this *EventMessage_Pending) String() string

type EventMessage_Preempted 

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

func (*EventMessage_Preempted) MarshalTo 

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

func (*EventMessage_Preempted) MarshalToSizedBuffer 

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

func (*EventMessage_Preempted) Size 

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

func (*EventMessage_Preempted) String 

func (this *EventMessage_Preempted) String() string

type EventMessage_Queued 

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

func (*EventMessage_Queued) MarshalTo 

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

func (*EventMessage_Queued) MarshalToSizedBuffer 

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

func (*EventMessage_Queued) Size 

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

func (*EventMessage_Queued) String 

func (this *EventMessage_Queued) String() string

type EventMessage_Reprioritized 

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

func (*EventMessage_Reprioritized) MarshalTo 

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

func (*EventMessage_Reprioritized) MarshalToSizedBuffer 

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

func (*EventMessage_Reprioritized) Size 

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

func (*EventMessage_Reprioritized) String 

func (this *EventMessage_Reprioritized) String() string

type EventMessage_Reprioritizing 

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

func (*EventMessage_Reprioritizing) MarshalTo 

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

func (*EventMessage_Reprioritizing) MarshalToSizedBuffer 

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

func (*EventMessage_Reprioritizing) Size 

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

func (*EventMessage_Reprioritizing) String 

func (this *EventMessage_Reprioritizing) String() string

type EventMessage_Running 

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

func (*EventMessage_Running) MarshalTo 

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

func (*EventMessage_Running) MarshalToSizedBuffer 

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

func (*EventMessage_Running) Size 

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

func (*EventMessage_Running) String 

func (this *EventMessage_Running) String() string

type EventMessage_Submitted 

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

func (*EventMessage_Submitted) MarshalTo 

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

func (*EventMessage_Submitted) MarshalToSizedBuffer 

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

func (*EventMessage_Submitted) Size 

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

func (*EventMessage_Submitted) String 

func (this *EventMessage_Submitted) String() string

type EventMessage_Succeeded 

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

func (*EventMessage_Succeeded) MarshalTo 

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

func (*EventMessage_Succeeded) MarshalToSizedBuffer 

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

func (*EventMessage_Succeeded) Size 

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

func (*EventMessage_Succeeded) String 

func (this *EventMessage_Succeeded) String() string

type EventMessage_Terminated 

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

func (*EventMessage_Terminated) MarshalTo 

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

func (*EventMessage_Terminated) MarshalToSizedBuffer 

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

func (*EventMessage_Terminated) Size 

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

func (*EventMessage_Terminated) String 

func (this *EventMessage_Terminated) String() string

type EventMessage_UnableToSchedule 

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

func (*EventMessage_UnableToSchedule) MarshalTo 

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

func (*EventMessage_UnableToSchedule) MarshalToSizedBuffer 

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

func (*EventMessage_UnableToSchedule) Size 

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

func (*EventMessage_UnableToSchedule) String 

func (this *EventMessage_UnableToSchedule) String() string

type EventMessage_Updated 

type EventMessage_Updated struct {
	Updated *JobUpdatedEvent `protobuf:"bytes,19,opt,name=updated,proto3,oneof" json:"updated,omitempty"`
}

func (*EventMessage_Updated) MarshalTo 

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

func (*EventMessage_Updated) MarshalToSizedBuffer 

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

func (*EventMessage_Updated) Size 

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

func (*EventMessage_Updated) String 

func (this *EventMessage_Updated) String() string

type EventMessage_Utilisation 

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

func (*EventMessage_Utilisation) MarshalTo 

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

func (*EventMessage_Utilisation) MarshalToSizedBuffer 

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

func (*EventMessage_Utilisation) Size 

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

func (*EventMessage_Utilisation) String 

func (this *EventMessage_Utilisation) String() string

type EventServer 

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

EventServer is the server API for Event service.

type EventStreamMessage 

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

swagger:model

func (*EventStreamMessage) Descriptor 

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

func (*EventStreamMessage) GetId 

func (m *EventStreamMessage) GetId() string

func (*EventStreamMessage) GetMessage 

func (m *EventStreamMessage) GetMessage() *EventMessage

func (*EventStreamMessage) Marshal 

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

func (*EventStreamMessage) MarshalTo 

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

func (*EventStreamMessage) MarshalToSizedBuffer 

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

func (*EventStreamMessage) ProtoMessage 

func (*EventStreamMessage) ProtoMessage()

func (*EventStreamMessage) Reset 

func (m *EventStreamMessage) Reset()

func (*EventStreamMessage) Size 

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

func (*EventStreamMessage) String 

func (this *EventStreamMessage) String() string

func (*EventStreamMessage) Unmarshal 

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

func (*EventStreamMessage) XXX_DiscardUnknown 

func (m *EventStreamMessage) XXX_DiscardUnknown()

func (*EventStreamMessage) XXX_Marshal 

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

func (*EventStreamMessage) XXX_Merge 

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

func (*EventStreamMessage) XXX_Size 

func (m *EventStreamMessage) XXX_Size() int

func (*EventStreamMessage) XXX_Unmarshal 

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

type Event_GetJobSetEventsClient 

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

type Event_GetJobSetEventsServer 

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

type Event_WatchClient 

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

type Event_WatchServer 

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

type HealthCheckResponse 

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

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) Marshal 

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

func (*HealthCheckResponse) MarshalTo 

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

func (*HealthCheckResponse) MarshalToSizedBuffer 

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

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size 

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

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal 

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

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

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

func (*HealthCheckResponse) XXX_Merge 

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

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

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

type HealthCheckResponse_ServingStatus 

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

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

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

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type IngressConfig 

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

func (*IngressConfig) Descriptor 

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

func (*IngressConfig) GetAnnotations 

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

func (*IngressConfig) GetCertName 

func (m *IngressConfig) GetCertName() string

func (*IngressConfig) GetPorts 

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

func (*IngressConfig) GetTlsEnabled 

func (m *IngressConfig) GetTlsEnabled() bool

func (*IngressConfig) GetType deprecated 

func (m *IngressConfig) GetType() IngressType

Deprecated: Do not use.

func (*IngressConfig) GetUseClusterIP 

func (m *IngressConfig) GetUseClusterIP() bool

func (*IngressConfig) Marshal 

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

func (*IngressConfig) 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) GetAffinity added in v0.3.71 

func (job *Job) GetAffinity() *v1.Affinity

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) GetJobSet added in v0.3.50 

func (job *Job) GetJobSet() string

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) GetNodeSelector added in v0.3.71 

func (job *Job) GetNodeSelector() map[string]string

func (*Job) GetOwner 

func (m *Job) GetOwner() string

func (*Job) GetPerQueuePriority added in v0.3.77 

func (job *Job) GetPerQueuePriority() uint32

func (*Job) GetPodRequirements added in v0.3.78 

func (job *Job) GetPodRequirements(priorityClasses map[string]types.PriorityClass) *schedulerobjects.PodRequirements

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) GetPriorityClassName added in v0.3.70 

func (job *Job) GetPriorityClassName() string

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) GetResourceRequirements added in v0.3.71 

func (job *Job) GetResourceRequirements() v1.ResourceRequirements

func (*Job) GetScheduledAtPriority added in v0.4.8 

func (job *Job) GetScheduledAtPriority() (int32, bool)

func (*Job) GetScheduler 

func (m *Job) GetScheduler() string

func (*Job) GetSchedulingKey added in v0.3.100 

func (job *Job) GetSchedulingKey() (schedulerobjects.SchedulingKey, bool)

GetSchedulingKey returns the scheduling key associated with a job. The second return value is always false since scheduling keys are not pre-computed for these jobs.

func (*Job) GetSchedulingResourceRequirements added in v0.3.70 

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

func (*Job) GetServices 

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

func (*Job) GetSubmitTime added in v0.3.77 

func (job *Job) GetSubmitTime() time.Time

func (*Job) GetTolerations added in v0.3.71 

func (job *Job) GetTolerations() []v1.Toleration

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) SchedulingOrderCompare added in v0.4.0 

func (job *Job) SchedulingOrderCompare(other interfaces.LegacySchedulerJob) int

SchedulingOrderCompare defines the order in which jobs in a particular queue should be scheduled,

func (*Job) Size 

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

func (*Job) String 

func (this *Job) String() string

func (*Job) TotalResourceRequest added in v0.3.47 

func (job *Job) TotalResourceRequest() armadaresource.ComputeResources

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 JobDuplicateFoundEvent 

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

func (*JobDuplicateFoundEvent) Descriptor 

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

func (*JobDuplicateFoundEvent) GetCreated 

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

func (*JobDuplicateFoundEvent) GetJobId 

func (m *JobDuplicateFoundEvent) GetJobId() string

func (*JobDuplicateFoundEvent) GetJobSetId 

func (m *JobDuplicateFoundEvent) GetJobSetId() string

func (*JobDuplicateFoundEvent) GetOriginalJobId 

func (m *JobDuplicateFoundEvent) GetOriginalJobId() string

func (*JobDuplicateFoundEvent) GetQueue 

func (m *JobDuplicateFoundEvent) GetQueue() string

func (*JobDuplicateFoundEvent) Marshal 

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

func (*JobDuplicateFoundEvent) MarshalTo 

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

func (*JobDuplicateFoundEvent) MarshalToSizedBuffer 

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

func (*JobDuplicateFoundEvent) ProtoMessage 

func (*JobDuplicateFoundEvent) ProtoMessage()

func (*JobDuplicateFoundEvent) Reset 

func (m *JobDuplicateFoundEvent) Reset()

func (*JobDuplicateFoundEvent) Size 

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

func (*JobDuplicateFoundEvent) String 

func (this *JobDuplicateFoundEvent) String() string

func (*JobDuplicateFoundEvent) Unmarshal 

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

func (*JobDuplicateFoundEvent) XXX_DiscardUnknown 

func (m *JobDuplicateFoundEvent) XXX_DiscardUnknown()

func (*JobDuplicateFoundEvent) XXX_Marshal 

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

func (*JobDuplicateFoundEvent) XXX_Merge 

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

func (*JobDuplicateFoundEvent) XXX_Size 

func (m *JobDuplicateFoundEvent) XXX_Size() int

func (*JobDuplicateFoundEvent) XXX_Unmarshal 

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

type JobFailedEvent 

type JobFailedEvent struct {
	JobId     string           `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId  string           `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue     string           `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created   time.Time        `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId string           `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Reason    string           `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	ExitCodes map[string]int32 `` // Deprecated: Do not use.
	/* 176-byte string literal not displayed */
	KubernetesId      string             `protobuf:"bytes,8,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	NodeName          string             `protobuf:"bytes,9,opt,name=node_name,json=nodeName,proto3" json:"nodeName,omitempty"`
	PodNumber         int32              `protobuf:"varint,10,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	PodName           string             `protobuf:"bytes,13,opt,name=pod_name,json=podName,proto3" json:"podName,omitempty"`
	PodNamespace      string             `protobuf:"bytes,14,opt,name=pod_namespace,json=podNamespace,proto3" json:"podNamespace,omitempty"`
	ContainerStatuses []*ContainerStatus `protobuf:"bytes,11,rep,name=container_statuses,json=containerStatuses,proto3" json:"containerStatuses,omitempty"`
	Cause             Cause              `protobuf:"varint,12,opt,name=cause,proto3,enum=api.Cause" json:"cause,omitempty"`
}

func (*JobFailedEvent) Descriptor 

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

func (*JobFailedEvent) GetCause 

func (m *JobFailedEvent) GetCause() Cause

func (*JobFailedEvent) GetClusterId 

func (m *JobFailedEvent) GetClusterId() string

func (*JobFailedEvent) GetContainerStatuses 

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

func (*JobFailedEvent) GetCreated 

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

func (*JobFailedEvent) GetExitCodes deprecated 

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

Deprecated: Do not use.

func (*JobFailedEvent) GetJobId 

func (m *JobFailedEvent) GetJobId() string

func (*JobFailedEvent) GetJobSetId 

func (m *JobFailedEvent) GetJobSetId() string

func (*JobFailedEvent) GetKubernetesId 

func (m *JobFailedEvent) GetKubernetesId() string

func (*JobFailedEvent) GetNodeName 

func (m *JobFailedEvent) GetNodeName() string

func (*JobFailedEvent) GetPodName 

func (m *JobFailedEvent) GetPodName() string

func (*JobFailedEvent) GetPodNamespace 

func (m *JobFailedEvent) GetPodNamespace() string

func (*JobFailedEvent) GetPodNumber 

func (m *JobFailedEvent) GetPodNumber() int32

func (*JobFailedEvent) GetQueue 

func (m *JobFailedEvent) GetQueue() string

func (*JobFailedEvent) GetReason 

func (m *JobFailedEvent) GetReason() string

func (*JobFailedEvent) Marshal 

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

func (*JobFailedEvent) 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 JobFailedEventCompressed 

type JobFailedEventCompressed struct {
	Event []byte `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
}

Only used internally by Armada

func (*JobFailedEventCompressed) Descriptor 

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

func (*JobFailedEventCompressed) GetEvent 

func (m *JobFailedEventCompressed) GetEvent() []byte

func (*JobFailedEventCompressed) Marshal 

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

func (*JobFailedEventCompressed) MarshalTo 

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

func (*JobFailedEventCompressed) MarshalToSizedBuffer 

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

func (*JobFailedEventCompressed) ProtoMessage 

func (*JobFailedEventCompressed) ProtoMessage()

func (*JobFailedEventCompressed) Reset 

func (m *JobFailedEventCompressed) Reset()

func (*JobFailedEventCompressed) Size 

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

func (*JobFailedEventCompressed) String 

func (this *JobFailedEventCompressed) String() string

func (*JobFailedEventCompressed) Unmarshal 

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

func (*JobFailedEventCompressed) XXX_DiscardUnknown 

func (m *JobFailedEventCompressed) XXX_DiscardUnknown()

func (*JobFailedEventCompressed) XXX_Marshal 

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

func (*JobFailedEventCompressed) XXX_Merge 

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

func (*JobFailedEventCompressed) XXX_Size 

func (m *JobFailedEventCompressed) XXX_Size() int

func (*JobFailedEventCompressed) XXX_Unmarshal 

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

type JobIngressInfoEvent 

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

func (*JobIngressInfoEvent) Descriptor 

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

func (*JobIngressInfoEvent) GetClusterId 

func (m *JobIngressInfoEvent) GetClusterId() string

func (*JobIngressInfoEvent) GetCreated 

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

func (*JobIngressInfoEvent) GetIngressAddresses 

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

func (*JobIngressInfoEvent) GetJobId 

func (m *JobIngressInfoEvent) GetJobId() string

func (*JobIngressInfoEvent) GetJobSetId 

func (m *JobIngressInfoEvent) GetJobSetId() string

func (*JobIngressInfoEvent) GetKubernetesId 

func (m *JobIngressInfoEvent) GetKubernetesId() string

func (*JobIngressInfoEvent) GetNodeName 

func (m *JobIngressInfoEvent) GetNodeName() string

func (*JobIngressInfoEvent) GetPodName 

func (m *JobIngressInfoEvent) GetPodName() string

func (*JobIngressInfoEvent) GetPodNamespace 

func (m *JobIngressInfoEvent) GetPodNamespace() string

func (*JobIngressInfoEvent) GetPodNumber 

func (m *JobIngressInfoEvent) GetPodNumber() int32

func (*JobIngressInfoEvent) GetQueue 

func (m *JobIngressInfoEvent) GetQueue() string

func (*JobIngressInfoEvent) Marshal 

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

func (*JobIngressInfoEvent) MarshalTo 

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

func (*JobIngressInfoEvent) MarshalToSizedBuffer 

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

func (*JobIngressInfoEvent) ProtoMessage 

func (*JobIngressInfoEvent) ProtoMessage()

func (*JobIngressInfoEvent) Reset 

func (m *JobIngressInfoEvent) Reset()

func (*JobIngressInfoEvent) Size 

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

func (*JobIngressInfoEvent) String 

func (this *JobIngressInfoEvent) String() string

func (*JobIngressInfoEvent) Unmarshal 

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

func (*JobIngressInfoEvent) XXX_DiscardUnknown 

func (m *JobIngressInfoEvent) XXX_DiscardUnknown()

func (*JobIngressInfoEvent) XXX_Marshal 

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

func (*JobIngressInfoEvent) XXX_Merge 

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

func (*JobIngressInfoEvent) XXX_Size 

func (m *JobIngressInfoEvent) XXX_Size() int

func (*JobIngressInfoEvent) XXX_Unmarshal 

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

type JobLeaseExpiredEvent 

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

func (*JobLeaseExpiredEvent) Descriptor 

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

func (*JobLeaseExpiredEvent) GetCreated 

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

func (*JobLeaseExpiredEvent) GetJobId 

func (m *JobLeaseExpiredEvent) GetJobId() string

func (*JobLeaseExpiredEvent) GetJobSetId 

func (m *JobLeaseExpiredEvent) GetJobSetId() string

func (*JobLeaseExpiredEvent) GetQueue 

func (m *JobLeaseExpiredEvent) GetQueue() string

func (*JobLeaseExpiredEvent) Marshal 

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

func (*JobLeaseExpiredEvent) MarshalTo 

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

func (*JobLeaseExpiredEvent) MarshalToSizedBuffer 

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

func (*JobLeaseExpiredEvent) ProtoMessage 

func (*JobLeaseExpiredEvent) ProtoMessage()

func (*JobLeaseExpiredEvent) Reset 

func (m *JobLeaseExpiredEvent) Reset()

func (*JobLeaseExpiredEvent) Size 

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

func (*JobLeaseExpiredEvent) String 

func (this *JobLeaseExpiredEvent) String() string

func (*JobLeaseExpiredEvent) Unmarshal 

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

func (*JobLeaseExpiredEvent) XXX_DiscardUnknown 

func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()

func (*JobLeaseExpiredEvent) XXX_Marshal 

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

func (*JobLeaseExpiredEvent) XXX_Merge 

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

func (*JobLeaseExpiredEvent) XXX_Size 

func (m *JobLeaseExpiredEvent) XXX_Size() int

func (*JobLeaseExpiredEvent) XXX_Unmarshal 

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

type JobLeaseReturnedEvent 

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

func (*JobLeaseReturnedEvent) Descriptor 

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

func (*JobLeaseReturnedEvent) GetClusterId 

func (m *JobLeaseReturnedEvent) GetClusterId() string

func (*JobLeaseReturnedEvent) GetCreated 

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

func (*JobLeaseReturnedEvent) GetJobId 

func (m *JobLeaseReturnedEvent) GetJobId() string

func (*JobLeaseReturnedEvent) GetJobSetId 

func (m *JobLeaseReturnedEvent) GetJobSetId() string

func (*JobLeaseReturnedEvent) GetKubernetesId 

func (m *JobLeaseReturnedEvent) GetKubernetesId() string

func (*JobLeaseReturnedEvent) GetPodNumber 

func (m *JobLeaseReturnedEvent) GetPodNumber() int32

func (*JobLeaseReturnedEvent) GetQueue 

func (m *JobLeaseReturnedEvent) GetQueue() string

func (*JobLeaseReturnedEvent) GetReason 

func (m *JobLeaseReturnedEvent) GetReason() string

func (*JobLeaseReturnedEvent) GetRunAttempted added in v0.3.48 

func (m *JobLeaseReturnedEvent) GetRunAttempted() bool

func (*JobLeaseReturnedEvent) Marshal 

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

func (*JobLeaseReturnedEvent) MarshalTo 

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

func (*JobLeaseReturnedEvent) MarshalToSizedBuffer 

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

func (*JobLeaseReturnedEvent) ProtoMessage 

func (*JobLeaseReturnedEvent) ProtoMessage()

func (*JobLeaseReturnedEvent) Reset 

func (m *JobLeaseReturnedEvent) Reset()

func (*JobLeaseReturnedEvent) Size 

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

func (*JobLeaseReturnedEvent) String 

func (this *JobLeaseReturnedEvent) String() string

func (*JobLeaseReturnedEvent) Unmarshal 

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

func (*JobLeaseReturnedEvent) XXX_DiscardUnknown 

func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()

func (*JobLeaseReturnedEvent) XXX_Marshal 

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

func (*JobLeaseReturnedEvent) XXX_Merge 

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

func (*JobLeaseReturnedEvent) XXX_Size 

func (m *JobLeaseReturnedEvent) XXX_Size() int

func (*JobLeaseReturnedEvent) XXX_Unmarshal 

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

type JobLeasedEvent 

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

func (*JobLeasedEvent) Descriptor 

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

func (*JobLeasedEvent) GetClusterId 

func (m *JobLeasedEvent) GetClusterId() string

func (*JobLeasedEvent) GetCreated 

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

func (*JobLeasedEvent) GetJobId 

func (m *JobLeasedEvent) GetJobId() string

func (*JobLeasedEvent) GetJobSetId 

func (m *JobLeasedEvent) GetJobSetId() string

func (*JobLeasedEvent) GetQueue 

func (m *JobLeasedEvent) GetQueue() string

func (*JobLeasedEvent) Marshal 

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

func (*JobLeasedEvent) 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 JobPreemptedEvent 

type JobPreemptedEvent struct {
	JobId           string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId        string    `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue           string    `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Created         time.Time `protobuf:"bytes,4,opt,name=created,proto3,stdtime" json:"created"`
	ClusterId       string    `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	RunId           string    `protobuf:"bytes,6,opt,name=run_id,json=runId,proto3" json:"runId,omitempty"`
	PreemptiveJobId string    `protobuf:"bytes,7,opt,name=preemptive_job_id,json=preemptiveJobId,proto3" json:"preemptiveJobId,omitempty"`
	PreemptiveRunId string    `protobuf:"bytes,8,opt,name=preemptive_run_id,json=preemptiveRunId,proto3" json:"preemptiveRunId,omitempty"`
}

func (*JobPreemptedEvent) Descriptor 

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

func (*JobPreemptedEvent) GetClusterId 

func (m *JobPreemptedEvent) GetClusterId() string

func (*JobPreemptedEvent) GetCreated 

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

func (*JobPreemptedEvent) GetJobId 

func (m *JobPreemptedEvent) GetJobId() string

func (*JobPreemptedEvent) GetJobSetId 

func (m *JobPreemptedEvent) GetJobSetId() string

func (*JobPreemptedEvent) GetPreemptiveJobId 

func (m *JobPreemptedEvent) GetPreemptiveJobId() string

func (*JobPreemptedEvent) GetPreemptiveRunId 

func (m *JobPreemptedEvent) GetPreemptiveRunId() string

func (*JobPreemptedEvent) GetQueue 

func (m *JobPreemptedEvent) GetQueue() string

func (*JobPreemptedEvent) GetRunId 

func (m *JobPreemptedEvent) GetRunId() string

func (*JobPreemptedEvent) Marshal 

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

func (*JobPreemptedEvent) MarshalTo 

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

func (*JobPreemptedEvent) MarshalToSizedBuffer 

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

func (*JobPreemptedEvent) ProtoMessage 

func (*JobPreemptedEvent) ProtoMessage()

func (*JobPreemptedEvent) Reset 

func (m *JobPreemptedEvent) Reset()

func (*JobPreemptedEvent) Size 

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

func (*JobPreemptedEvent) String 

func (this *JobPreemptedEvent) String() string

func (*JobPreemptedEvent) Unmarshal 

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

func (*JobPreemptedEvent) XXX_DiscardUnknown 

func (m *JobPreemptedEvent) XXX_DiscardUnknown()

func (*JobPreemptedEvent) XXX_Marshal 

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

func (*JobPreemptedEvent) XXX_Merge 

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

func (*JobPreemptedEvent) XXX_Size 

func (m *JobPreemptedEvent) XXX_Size() int

func (*JobPreemptedEvent) XXX_Unmarshal 

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

type JobQueuedEvent 

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

func (*JobQueuedEvent) Descriptor 

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

func (*JobQueuedEvent) GetCreated 

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

func (*JobQueuedEvent) GetJobId 

func (m *JobQueuedEvent) GetJobId() string

func (*JobQueuedEvent) GetJobSetId 

func (m *JobQueuedEvent) GetJobSetId() string

func (*JobQueuedEvent) GetQueue 

func (m *JobQueuedEvent) GetQueue() string

func (*JobQueuedEvent) Marshal 

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

func (*JobQueuedEvent) 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 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"`
	ForceLegacy    bool   `protobuf:"varint,6,opt,name=force_legacy,json=forceLegacy,proto3" json:"forceLegacy,omitempty"`
	ForceNew       bool   `protobuf:"varint,7,opt,name=force_new,json=forceNew,proto3" json:"forceNew,omitempty"`
}

swagger:model

func (*JobSetRequest) Descriptor 

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

func (*JobSetRequest) GetErrorIfMissing 

func (m *JobSetRequest) GetErrorIfMissing() bool

func (*JobSetRequest) GetForceLegacy 

func (m *JobSetRequest) GetForceLegacy() bool

func (*JobSetRequest) GetForceNew 

func (m *JobSetRequest) GetForceNew() bool

func (*JobSetRequest) GetFromMessageId 

func (m *JobSetRequest) GetFromMessageId() string

func (*JobSetRequest) GetId 

func (m *JobSetRequest) GetId() string

func (*JobSetRequest) GetQueue 

func (m *JobSetRequest) GetQueue() string

func (*JobSetRequest) GetWatch 

func (m *JobSetRequest) GetWatch() bool

func (*JobSetRequest) Marshal 

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

func (*JobSetRequest) 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
)

func (JobState) EnumDescriptor 

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

func (JobState) IsTerminal added in v0.3.50 

func (s JobState) IsTerminal() bool

IsTerminal returns true if the JobState s corresponds to a state that indicates the job has been terminated.

func (JobState) String 

func (x JobState) String() string

func (*JobState) UnmarshalJSON 

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

type JobStatus added in v0.4.20 

type JobStatus int32
const (
	JobStatus_UNKNOWN   JobStatus = 0
	JobStatus_SUBMITTED JobStatus = 1
	JobStatus_QUEUED    JobStatus = 2
	JobStatus_LEASED    JobStatus = 3
	JobStatus_PENDING   JobStatus = 4
	JobStatus_RUNNING   JobStatus = 5
	JobStatus_SUCCEEDED JobStatus = 6
	JobStatus_FAILED    JobStatus = 7
	JobStatus_PREEMPTED JobStatus = 8
	JobStatus_CANCELLED JobStatus = 9
)

func (JobStatus) EnumDescriptor added in v0.4.20 

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

func (JobStatus) String added in v0.4.20 

func (x JobStatus) String() string

type JobStatusRequest added in v0.4.20 

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

func (*JobStatusRequest) Descriptor added in v0.4.20 

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

func (*JobStatusRequest) GetJobId added in v0.4.20 

func (m *JobStatusRequest) GetJobId() string

func (*JobStatusRequest) Marshal added in v0.4.20 

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

func (*JobStatusRequest) MarshalTo added in v0.4.20 

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

func (*JobStatusRequest) MarshalToSizedBuffer added in v0.4.20 

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

func (*JobStatusRequest) ProtoMessage added in v0.4.20 

func (*JobStatusRequest) ProtoMessage()

func (*JobStatusRequest) Reset added in v0.4.20 

func (m *JobStatusRequest) Reset()

func (*JobStatusRequest) Size added in v0.4.20 

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

func (*JobStatusRequest) String added in v0.4.20 

func (this *JobStatusRequest) String() string

func (*JobStatusRequest) Unmarshal added in v0.4.20 

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

func (*JobStatusRequest) XXX_DiscardUnknown added in v0.4.20 

func (m *JobStatusRequest) XXX_DiscardUnknown()

func (*JobStatusRequest) XXX_Marshal added in v0.4.20 

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

func (*JobStatusRequest) XXX_Merge added in v0.4.20 

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

func (*JobStatusRequest) XXX_Size added in v0.4.20 

func (m *JobStatusRequest) XXX_Size() int

func (*JobStatusRequest) XXX_Unmarshal added in v0.4.20 

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

type JobStatusResponse added in v0.4.20 

type JobStatusResponse struct {
	JobId     string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobStatus JobStatus `protobuf:"varint,2,opt,name=job_status,json=jobStatus,proto3,enum=queryapi.JobStatus" json:"jobStatus,omitempty"`
}

func (*JobStatusResponse) Descriptor added in v0.4.20 

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

func (*JobStatusResponse) GetJobId added in v0.4.20 

func (m *JobStatusResponse) GetJobId() string

func (*JobStatusResponse) GetJobStatus added in v0.4.20 

func (m *JobStatusResponse) GetJobStatus() JobStatus

func (*JobStatusResponse) Marshal added in v0.4.20 

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

func (*JobStatusResponse) MarshalTo added in v0.4.20 

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

func (*JobStatusResponse) MarshalToSizedBuffer added in v0.4.20 

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

func (*JobStatusResponse) ProtoMessage added in v0.4.20 

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) Reset added in v0.4.20 

func (m *JobStatusResponse) Reset()

func (*JobStatusResponse) Size added in v0.4.20 

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

func (*JobStatusResponse) String added in v0.4.20 

func (this *JobStatusResponse) String() string

func (*JobStatusResponse) Unmarshal added in v0.4.20 

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

func (*JobStatusResponse) XXX_DiscardUnknown added in v0.4.20 

func (m *JobStatusResponse) XXX_DiscardUnknown()

func (*JobStatusResponse) XXX_Marshal added in v0.4.20 

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

func (*JobStatusResponse) XXX_Merge added in v0.4.20 

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

func (*JobStatusResponse) XXX_Size added in v0.4.20 

func (m *JobStatusResponse) XXX_Size() int

func (*JobStatusResponse) XXX_Unmarshal added in v0.4.20 

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

type JobSubmitRequest 

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

swagger:model

func (*JobSubmitRequest) Descriptor 

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

func (*JobSubmitRequest) GetJobRequestItems 

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

func (*JobSubmitRequest) GetJobSetId 

func (m *JobSubmitRequest) GetJobSetId() string

func (*JobSubmitRequest) GetQueue 

func (m *JobSubmitRequest) GetQueue() string

func (*JobSubmitRequest) Marshal 

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

func (*JobSubmitRequest) 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"`
	// Queuing TTL for this job in seconds. If this job queues for more than this duration it will be cancelled. Zero indicates an infinite lifetime.
	QueueTtlSeconds int64 `protobuf:"varint,12,opt,name=queue_ttl_seconds,json=queueTtlSeconds,proto3" json:"queueTtlSeconds,omitempty"`
}

func (*JobSubmitRequestItem) Descriptor 

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

func (*JobSubmitRequestItem) GetAnnotations 

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

func (*JobSubmitRequestItem) GetClientId 

func (m *JobSubmitRequestItem) GetClientId() string

func (*JobSubmitRequestItem) GetIngress 

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

func (*JobSubmitRequestItem) GetLabels 

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

func (*JobSubmitRequestItem) GetMainPodSpec added in v0.3.70 

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

func (*JobSubmitRequestItem) GetNamespace 

func (m *JobSubmitRequestItem) GetNamespace() string

func (*JobSubmitRequestItem) GetPodSpec deprecated 

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

Deprecated: Do not use.

func (*JobSubmitRequestItem) GetPodSpecs 

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

func (*JobSubmitRequestItem) GetPriority 

func (m *JobSubmitRequestItem) GetPriority() float64

func (*JobSubmitRequestItem) GetQueueTtlSeconds added in v0.3.95 

func (m *JobSubmitRequestItem) GetQueueTtlSeconds() int64

func (*JobSubmitRequestItem) GetRequiredNodeLabels deprecated 

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

Deprecated: Do not use.

func (*JobSubmitRequestItem) GetScheduler 

func (m *JobSubmitRequestItem) GetScheduler() string

func (*JobSubmitRequestItem) GetServices 

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

func (*JobSubmitRequestItem) Marshal 

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

func (*JobSubmitRequestItem) MarshalTo 

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

func (*JobSubmitRequestItem) MarshalToSizedBuffer 

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

func (*JobSubmitRequestItem) ProtoMessage 

func (*JobSubmitRequestItem) ProtoMessage()

func (*JobSubmitRequestItem) Reset 

func (m *JobSubmitRequestItem) Reset()

func (*JobSubmitRequestItem) Size 

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

func (*JobSubmitRequestItem) String 

func (this *JobSubmitRequestItem) String() string

func (*JobSubmitRequestItem) Unmarshal 

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

func (*JobSubmitRequestItem) XXX_DiscardUnknown 

func (m *JobSubmitRequestItem) XXX_DiscardUnknown()

func (*JobSubmitRequestItem) XXX_Marshal 

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

func (*JobSubmitRequestItem) XXX_Merge 

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

func (*JobSubmitRequestItem) XXX_Size 

func (m *JobSubmitRequestItem) XXX_Size() int

func (*JobSubmitRequestItem) XXX_Unmarshal 

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

type JobSubmitResponse 

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

swagger:model

func (*JobSubmitResponse) Descriptor 

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

func (*JobSubmitResponse) GetJobResponseItems 

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

func (*JobSubmitResponse) Marshal 

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

func (*JobSubmitResponse) MarshalTo 

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

func (*JobSubmitResponse) MarshalToSizedBuffer 

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

func (*JobSubmitResponse) ProtoMessage 

func (*JobSubmitResponse) ProtoMessage()

func (*JobSubmitResponse) Reset 

func (m *JobSubmitResponse) Reset()

func (*JobSubmitResponse) Size 

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

func (*JobSubmitResponse) String 

func (this *JobSubmitResponse) String() string

func (*JobSubmitResponse) Unmarshal 

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

func (*JobSubmitResponse) XXX_DiscardUnknown 

func (m *JobSubmitResponse) XXX_DiscardUnknown()

func (*JobSubmitResponse) XXX_Marshal 

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

func (*JobSubmitResponse) XXX_Merge 

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

func (*JobSubmitResponse) XXX_Size 

func (m *JobSubmitResponse) XXX_Size() int

func (*JobSubmitResponse) XXX_Unmarshal 

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

type JobSubmitResponseItem 

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

func (*JobSubmitResponseItem) Descriptor 

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

func (*JobSubmitResponseItem) GetError 

func (m *JobSubmitResponseItem) GetError() string

func (*JobSubmitResponseItem) GetJobId 

func (m *JobSubmitResponseItem) GetJobId() string

func (*JobSubmitResponseItem) Marshal 

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

func (*JobSubmitResponseItem) MarshalTo 

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

func (*JobSubmitResponseItem) MarshalToSizedBuffer 

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

func (*JobSubmitResponseItem) ProtoMessage 

func (*JobSubmitResponseItem) ProtoMessage()

func (*JobSubmitResponseItem) Reset 

func (m *JobSubmitResponseItem) Reset()

func (*JobSubmitResponseItem) Size 

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

func (*JobSubmitResponseItem) String 

func (this *JobSubmitResponseItem) String() string

func (*JobSubmitResponseItem) Unmarshal 

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

func (*JobSubmitResponseItem) XXX_DiscardUnknown 

func (m *JobSubmitResponseItem) XXX_DiscardUnknown()

func (*JobSubmitResponseItem) XXX_Marshal 

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

func (*JobSubmitResponseItem) XXX_Merge 

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

func (*JobSubmitResponseItem) XXX_Size 

func (m *JobSubmitResponseItem) XXX_Size() int

func (*JobSubmitResponseItem) XXX_Unmarshal 

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

type JobSubmittedEvent 

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

func (*JobSubmittedEvent) Descriptor 

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

func (*JobSubmittedEvent) GetCreated 

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

func (*JobSubmittedEvent) GetJob 

func (m *JobSubmittedEvent) GetJob() Job

func (*JobSubmittedEvent) GetJobId 

func (m *JobSubmittedEvent) GetJobId() string

func (*JobSubmittedEvent) GetJobSetId 

func (m *JobSubmittedEvent) GetJobSetId() string

func (*JobSubmittedEvent) GetQueue 

func (m *JobSubmittedEvent) GetQueue() string

func (*JobSubmittedEvent) Marshal 

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

func (*JobSubmittedEvent) MarshalTo 

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

func (*JobSubmittedEvent) MarshalToSizedBuffer 

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

func (*JobSubmittedEvent) ProtoMessage 

func (*JobSubmittedEvent) ProtoMessage()

func (*JobSubmittedEvent) Reset 

func (m *JobSubmittedEvent) Reset()

func (*JobSubmittedEvent) Size 

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

func (*JobSubmittedEvent) String 

func (this *JobSubmittedEvent) String() string

func (*JobSubmittedEvent) Unmarshal 

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

func (*JobSubmittedEvent) XXX_DiscardUnknown 

func (m *JobSubmittedEvent) XXX_DiscardUnknown()

func (*JobSubmittedEvent) XXX_Marshal 

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

func (*JobSubmittedEvent) XXX_Merge 

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

func (*JobSubmittedEvent) XXX_Size 

func (m *JobSubmittedEvent) XXX_Size() int

func (*JobSubmittedEvent) XXX_Unmarshal 

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

type JobSucceededEvent 

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

func (*JobSucceededEvent) Descriptor 

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

func (*JobSucceededEvent) GetClusterId 

func (m *JobSucceededEvent) GetClusterId() string

func (*JobSucceededEvent) GetCreated 

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

func (*JobSucceededEvent) GetJobId 

func (m *JobSucceededEvent) GetJobId() string

func (*JobSucceededEvent) GetJobSetId 

func (m *JobSucceededEvent) GetJobSetId() string

func (*JobSucceededEvent) GetKubernetesId 

func (m *JobSucceededEvent) GetKubernetesId() string

func (*JobSucceededEvent) GetNodeName 

func (m *JobSucceededEvent) GetNodeName() string

func (*JobSucceededEvent) GetPodName 

func (m *JobSucceededEvent) GetPodName() string

func (*JobSucceededEvent) GetPodNamespace 

func (m *JobSucceededEvent) GetPodNamespace() string

func (*JobSucceededEvent) GetPodNumber 

func (m *JobSucceededEvent) GetPodNumber() int32

func (*JobSucceededEvent) GetQueue 

func (m *JobSucceededEvent) GetQueue() string

func (*JobSucceededEvent) Marshal 

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

func (*JobSucceededEvent) MarshalTo 

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

func (*JobSucceededEvent) MarshalToSizedBuffer 

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

func (*JobSucceededEvent) ProtoMessage 

func (*JobSucceededEvent) ProtoMessage()

func (*JobSucceededEvent) Reset 

func (m *JobSucceededEvent) Reset()

func (*JobSucceededEvent) Size 

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

func (*JobSucceededEvent) String 

func (this *JobSucceededEvent) String() string

func (*JobSucceededEvent) Unmarshal 

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

func (*JobSucceededEvent) XXX_DiscardUnknown 

func (m *JobSucceededEvent) XXX_DiscardUnknown()

func (*JobSucceededEvent) XXX_Marshal 

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

func (*JobSucceededEvent) XXX_Merge 

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

func (*JobSucceededEvent) XXX_Size 

func (m *JobSucceededEvent) XXX_Size() int

func (*JobSucceededEvent) XXX_Unmarshal 

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

type JobTerminatedEvent 

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

func (*JobTerminatedEvent) Descriptor 

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

func (*JobTerminatedEvent) GetClusterId 

func (m *JobTerminatedEvent) GetClusterId() string

func (*JobTerminatedEvent) GetCreated 

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

func (*JobTerminatedEvent) GetJobId 

func (m *JobTerminatedEvent) GetJobId() string

func (*JobTerminatedEvent) GetJobSetId 

func (m *JobTerminatedEvent) GetJobSetId() string

func (*JobTerminatedEvent) GetKubernetesId 

func (m *JobTerminatedEvent) GetKubernetesId() string

func (*JobTerminatedEvent) GetPodName 

func (m *JobTerminatedEvent) GetPodName() string

func (*JobTerminatedEvent) GetPodNamespace 

func (m *JobTerminatedEvent) GetPodNamespace() string

func (*JobTerminatedEvent) GetPodNumber 

func (m *JobTerminatedEvent) GetPodNumber() int32

func (*JobTerminatedEvent) GetQueue 

func (m *JobTerminatedEvent) GetQueue() string

func (*JobTerminatedEvent) GetReason 

func (m *JobTerminatedEvent) GetReason() string

func (*JobTerminatedEvent) Marshal 

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

func (*JobTerminatedEvent) MarshalTo 

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

func (*JobTerminatedEvent) MarshalToSizedBuffer 

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

func (*JobTerminatedEvent) ProtoMessage 

func (*JobTerminatedEvent) ProtoMessage()

func (*JobTerminatedEvent) Reset 

func (m *JobTerminatedEvent) Reset()

func (*JobTerminatedEvent) Size 

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

func (*JobTerminatedEvent) String 

func (this *JobTerminatedEvent) String() string

func (*JobTerminatedEvent) Unmarshal 

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

func (*JobTerminatedEvent) XXX_DiscardUnknown 

func (m *JobTerminatedEvent) XXX_DiscardUnknown()

func (*JobTerminatedEvent) XXX_Marshal 

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

func (*JobTerminatedEvent) XXX_Merge 

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

func (*JobTerminatedEvent) XXX_Size 

func (m *JobTerminatedEvent) XXX_Size() int

func (*JobTerminatedEvent) XXX_Unmarshal 

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

type JobUnableToScheduleEvent 

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

func (*JobUnableToScheduleEvent) Descriptor 

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

func (*JobUnableToScheduleEvent) GetClusterId 

func (m *JobUnableToScheduleEvent) GetClusterId() string

func (*JobUnableToScheduleEvent) GetCreated 

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

func (*JobUnableToScheduleEvent) GetJobId 

func (m *JobUnableToScheduleEvent) GetJobId() string

func (*JobUnableToScheduleEvent) GetJobSetId 

func (m *JobUnableToScheduleEvent) GetJobSetId() string

func (*JobUnableToScheduleEvent) GetKubernetesId 

func (m *JobUnableToScheduleEvent) GetKubernetesId() string

func (*JobUnableToScheduleEvent) GetNodeName 

func (m *JobUnableToScheduleEvent) GetNodeName() string

func (*JobUnableToScheduleEvent) GetPodName 

func (m *JobUnableToScheduleEvent) GetPodName() string

func (*JobUnableToScheduleEvent) GetPodNamespace 

func (m *JobUnableToScheduleEvent) GetPodNamespace() string

func (*JobUnableToScheduleEvent) GetPodNumber 

func (m *JobUnableToScheduleEvent) GetPodNumber() int32

func (*JobUnableToScheduleEvent) GetQueue 

func (m *JobUnableToScheduleEvent) GetQueue() string

func (*JobUnableToScheduleEvent) GetReason 

func (m *JobUnableToScheduleEvent) GetReason() string

func (*JobUnableToScheduleEvent) Marshal 

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

func (*JobUnableToScheduleEvent) MarshalTo 

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

func (*JobUnableToScheduleEvent) MarshalToSizedBuffer 

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

func (*JobUnableToScheduleEvent) ProtoMessage 

func (*JobUnableToScheduleEvent) ProtoMessage()

func (*JobUnableToScheduleEvent) Reset 

func (m *JobUnableToScheduleEvent) Reset()

func (*JobUnableToScheduleEvent) Size 

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

func (*JobUnableToScheduleEvent) String 

func (this *JobUnableToScheduleEvent) String() string

func (*JobUnableToScheduleEvent) Unmarshal 

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

func (*JobUnableToScheduleEvent) XXX_DiscardUnknown 

func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()

func (*JobUnableToScheduleEvent) XXX_Marshal 

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

func (*JobUnableToScheduleEvent) XXX_Merge 

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

func (*JobUnableToScheduleEvent) XXX_Size 

func (m *JobUnableToScheduleEvent) XXX_Size() int

func (*JobUnableToScheduleEvent) XXX_Unmarshal 

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

type JobUpdatedEvent 

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

func (*JobUpdatedEvent) Descriptor 

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

func (*JobUpdatedEvent) GetCreated 

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

func (*JobUpdatedEvent) GetJob 

func (m *JobUpdatedEvent) GetJob() Job

func (*JobUpdatedEvent) GetJobId 

func (m *JobUpdatedEvent) GetJobId() string

func (*JobUpdatedEvent) GetJobSetId 

func (m *JobUpdatedEvent) GetJobSetId() string

func (*JobUpdatedEvent) GetQueue 

func (m *JobUpdatedEvent) GetQueue() string

func (*JobUpdatedEvent) GetRequestor 

func (m *JobUpdatedEvent) GetRequestor() string

func (*JobUpdatedEvent) Marshal 

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

func (*JobUpdatedEvent) MarshalTo 

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

func (*JobUpdatedEvent) MarshalToSizedBuffer 

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

func (*JobUpdatedEvent) ProtoMessage 

func (*JobUpdatedEvent) ProtoMessage()

func (*JobUpdatedEvent) Reset 

func (m *JobUpdatedEvent) Reset()

func (*JobUpdatedEvent) Size 

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

func (*JobUpdatedEvent) String 

func (this *JobUpdatedEvent) String() string

func (*JobUpdatedEvent) Unmarshal 

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

func (*JobUpdatedEvent) XXX_DiscardUnknown 

func (m *JobUpdatedEvent) XXX_DiscardUnknown()

func (*JobUpdatedEvent) XXX_Marshal 

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

func (*JobUpdatedEvent) XXX_Merge 

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

func (*JobUpdatedEvent) XXX_Size 

func (m *JobUpdatedEvent) XXX_Size() int

func (*JobUpdatedEvent) XXX_Unmarshal 

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

type JobUtilisationEvent 

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

func (*JobUtilisationEvent) Descriptor 

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

func (*JobUtilisationEvent) GetClusterId 

func (m *JobUtilisationEvent) GetClusterId() string

func (*JobUtilisationEvent) GetCreated 

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

func (*JobUtilisationEvent) GetJobId 

func (m *JobUtilisationEvent) GetJobId() string

func (*JobUtilisationEvent) GetJobSetId 

func (m *JobUtilisationEvent) GetJobSetId() string

func (*JobUtilisationEvent) GetKubernetesId 

func (m *JobUtilisationEvent) GetKubernetesId() string

func (*JobUtilisationEvent) GetMaxResourcesForPeriod 

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

func (*JobUtilisationEvent) GetNodeName 

func (m *JobUtilisationEvent) GetNodeName() string

func (*JobUtilisationEvent) GetPodName 

func (m *JobUtilisationEvent) GetPodName() string

func (*JobUtilisationEvent) GetPodNamespace 

func (m *JobUtilisationEvent) GetPodNamespace() string

func (*JobUtilisationEvent) GetPodNumber 

func (m *JobUtilisationEvent) GetPodNumber() int32

func (*JobUtilisationEvent) GetQueue 

func (m *JobUtilisationEvent) GetQueue() string

func (*JobUtilisationEvent) GetTotalCumulativeUsage 

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

func (*JobUtilisationEvent) Marshal 

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

func (*JobUtilisationEvent) MarshalTo 

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

func (*JobUtilisationEvent) MarshalToSizedBuffer 

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

func (*JobUtilisationEvent) ProtoMessage 

func (*JobUtilisationEvent) ProtoMessage()

func (*JobUtilisationEvent) Reset 

func (m *JobUtilisationEvent) Reset()

func (*JobUtilisationEvent) Size 

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

func (*JobUtilisationEvent) String 

func (this *JobUtilisationEvent) String() string

func (*JobUtilisationEvent) Unmarshal 

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

func (*JobUtilisationEvent) XXX_DiscardUnknown 

func (m *JobUtilisationEvent) XXX_DiscardUnknown()

func (*JobUtilisationEvent) XXX_Marshal 

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

func (*JobUtilisationEvent) XXX_Merge 

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

func (*JobUtilisationEvent) XXX_Size 

func (m *JobUtilisationEvent) XXX_Size() int

func (*JobUtilisationEvent) XXX_Unmarshal 

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

type KubernetesEvent 

type KubernetesEvent interface {
	Event
	GetKubernetesId() string
	GetClusterId() string
	GetPodNumber() int32
	GetPodName() string
	GetPodNamespace() string
}

type QueryApiClient added in v0.4.20 

type QueryApiClient interface {
	GetJobStatus(ctx context.Context, in *JobStatusRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
}

QueryApiClient is the client API for QueryApi service.

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

func NewQueryApiClient added in v0.4.20 

func NewQueryApiClient(cc *grpc.ClientConn) QueryApiClient

type QueryApiServer added in v0.4.20 

type QueryApiServer interface {
	GetJobStatus(context.Context, *JobStatusRequest) (*JobStatusResponse, error)
}

QueryApiServer is the server API for QueryApi service.

type Queue 

type Queue struct {
	Name           string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PriorityFactor float64              `protobuf:"fixed64,2,opt,name=priority_factor,json=priorityFactor,proto3" json:"priorityFactor,omitempty"`
	UserOwners     []string             `protobuf:"bytes,3,rep,name=user_owners,json=userOwners,proto3" json:"userOwners,omitempty"`
	GroupOwners    []string             `protobuf:"bytes,4,rep,name=group_owners,json=groupOwners,proto3" json:"groupOwners,omitempty"`
	ResourceLimits map[string]float64   `` /* 192-byte string literal not displayed */
	Permissions    []*Queue_Permissions `protobuf:"bytes,6,rep,name=permissions,proto3" json:"permissions,omitempty"`
}

swagger:model

func (*Queue) Descriptor 

func (*Queue) 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 

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

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 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)
	CreateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error)
	CreateQueues(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueCreateResponse, error)
	UpdateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error)
	UpdateQueues(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueUpdateResponse, error)
	DeleteQueue(ctx context.Context, in *QueueDeleteRequest, opts ...grpc.CallOption) (*types.Empty, error)
	GetQueue(ctx context.Context, in *QueueGetRequest, opts ...grpc.CallOption) (*Queue, error)
	GetQueues(ctx context.Context, in *StreamingQueueGetRequest, opts ...grpc.CallOption) (Submit_GetQueuesClient, error)
	Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

SubmitClient is the client API for Submit service.

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

func NewSubmitClient 

func NewSubmitClient(cc *grpc.ClientConn) SubmitClient

type SubmitServer 

type SubmitServer interface {
	SubmitJobs(context.Context, *JobSubmitRequest) (*JobSubmitResponse, error)
	CancelJobs(context.Context, *JobCancelRequest) (*CancellationResult, error)
	CancelJobSet(context.Context, *JobSetCancelRequest) (*types.Empty, error)
	ReprioritizeJobs(context.Context, *JobReprioritizeRequest) (*JobReprioritizeResponse, error)
	CreateQueue(context.Context, *Queue) (*types.Empty, error)
	CreateQueues(context.Context, *QueueList) (*BatchQueueCreateResponse, error)
	UpdateQueue(context.Context, *Queue) (*types.Empty, error)
	UpdateQueues(context.Context, *QueueList) (*BatchQueueUpdateResponse, error)
	DeleteQueue(context.Context, *QueueDeleteRequest) (*types.Empty, error)
	GetQueue(context.Context, *QueueGetRequest) (*Queue, error)
	GetQueues(*StreamingQueueGetRequest, Submit_GetQueuesServer) error
	Health(context.Context, *types.Empty) (*HealthCheckResponse, error)
}

SubmitServer is the server API for Submit service.

type Submit_GetQueuesClient added in v0.3.100 

type Submit_GetQueuesClient interface {
	Recv() (*StreamingQueueMessage, error)
	grpc.ClientStream
}

type Submit_GetQueuesServer added in v0.3.100 

type Submit_GetQueuesServer interface {
	Send(*StreamingQueueMessage) error
	grpc.ServerStream
}

type TestSpec 

type TestSpec struct {
	// Jobs to submit.
	// The n jobs herein are copied BatchSize times to produce n*BatchSize jobs.
	// A batch of n*BatchSize such jobs are submitted in each API call.
	// NumBatches such batches are submitted in total.
	Jobs []*JobSubmitRequestItem `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// Events expected in response to submitting each job.
	ExpectedEvents []*EventMessage `protobuf:"bytes,2,rep,name=expected_events,json=expectedEvents,proto3" json:"expectedEvents,omitempty"`
	// Queue to submit jobs to.
	Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	// Job set to submit jobs to.
	JobSetId string `protobuf:"bytes,4,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	// Number of batches of jobs to submit.
	// If 0, will submit forever.
	NumBatches uint32 `protobuf:"varint,5,opt,name=num_batches,json=numBatches,proto3" json:"numBatches,omitempty"`
	// Number of copies of the provided jobs to submit per batch.
	BatchSize uint32 `protobuf:"varint,6,opt,name=batch_size,json=batchSize,proto3" json:"batchSize,omitempty"`
	// Time between batches.
	// If 0, jobs are submitted as quickly as possible.
	Interval time.Duration `protobuf:"bytes,7,opt,name=interval,proto3,stdduration" json:"interval"`
	// Number of seconds to wait for jobs to finish.
	Timeout time.Duration   `protobuf:"bytes,8,opt,name=timeout,proto3,stdduration" json:"timeout"`
	Cancel  TestSpec_Cancel `protobuf:"varint,9,opt,name=cancel,proto3,enum=api.TestSpec_Cancel" json:"cancel,omitempty"`
	// Test name. Defaults to the filename if not provided.
	Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	// Randomize clientId if not provided
	RandomClientId bool `protobuf:"varint,11,opt,name=random_client_id,json=randomClientId,proto3" json:"randomClientId,omitempty"`
	// Toggle should testsuite scrape Armada Job (pod) logs
	GetLogs bool `protobuf:"varint,12,opt,name=get_logs,json=getLogs,proto3" json:"getLogs,omitempty"`
	// Value of the environment label set on exported Prometheus metrics.
	Environment string `protobuf:"bytes,13,opt,name=environment,proto3" json:"environment,omitempty"`
	// Value of the target label set on exported Prometheus metrics.
	Target string `protobuf:"bytes,14,opt,name=target,proto3" json:"target,omitempty"`
}

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

func (*TestSpec) Descriptor 

func (*TestSpec) 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 UnimplementedQueryApiServer added in v0.4.20 

type UnimplementedQueryApiServer struct {
}

UnimplementedQueryApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryApiServer) GetJobStatus added in v0.4.20 

func (*UnimplementedQueryApiServer) GetJobStatus(ctx context.Context, req *JobStatusRequest) (*JobStatusResponse, error)

type UnimplementedSubmitServer 

type UnimplementedSubmitServer struct {
}

UnimplementedSubmitServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubmitServer) CancelJobSet 

func (*UnimplementedSubmitServer) CancelJobSet(ctx context.Context, req *JobSetCancelRequest) (*types.Empty, error)

func (*UnimplementedSubmitServer) CancelJobs 

func (*UnimplementedSubmitServer) CancelJobs(ctx context.Context, req *JobCancelRequest) (*CancellationResult, error)

func (*UnimplementedSubmitServer) CreateQueue 

func (*UnimplementedSubmitServer) 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) 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"`
	ForceLegacy bool   `protobuf:"varint,4,opt,name=force_legacy,json=forceLegacy,proto3" json:"forceLegacy,omitempty"`
	ForceNew    bool   `protobuf:"varint,5,opt,name=force_new,json=forceNew,proto3" json:"forceNew,omitempty"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetForceLegacy 

func (m *WatchRequest) GetForceLegacy() bool

func (*WatchRequest) GetForceNew 

func (m *WatchRequest) GetForceNew() bool

func (*WatchRequest) GetFromId 

func (m *WatchRequest) GetFromId() string

func (*WatchRequest) GetJobSetId 

func (m *WatchRequest) GetJobSetId() string

func (*WatchRequest) GetQueue 

func (m *WatchRequest) GetQueue() string

func (*WatchRequest) Marshal 

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

func (*WatchRequest) 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.