api

package
v0.3.100 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 36 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 (
	ErrInvalidLengthQueue        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueue          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueue = 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 (
	ErrInvalidLengthUsage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUsage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUsage = 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 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 NewNodeFromNodeInfo ¶ added in v0.3.47 

func NewNodeFromNodeInfo(nodeInfo *NodeInfo, executor string, allowedPriorities []int32, lastSeen time.Time) (*schedulerobjects.Node, error)

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 RegisterAggregatedQueueServer ¶ 

func RegisterAggregatedQueueServer(s *grpc.Server, srv AggregatedQueueServer)

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 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 RegisterUsageServer ¶ 

func RegisterUsageServer(s *grpc.Server, srv UsageServer)

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 AggregatedQueueClient ¶ 

type AggregatedQueueClient interface {
	StreamingLeaseJobs(ctx context.Context, opts ...grpc.CallOption) (AggregatedQueue_StreamingLeaseJobsClient, error)
	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*IdList, error)
	ReturnLease(ctx context.Context, in *ReturnLeaseRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ReportDone(ctx context.Context, in *IdList, opts ...grpc.CallOption) (*IdList, error)
}

AggregatedQueueClient is the client API for AggregatedQueue service.

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

func NewAggregatedQueueClient ¶ 

func NewAggregatedQueueClient(cc *grpc.ClientConn) AggregatedQueueClient

type AggregatedQueueServer ¶ 

type AggregatedQueueServer interface {
	StreamingLeaseJobs(AggregatedQueue_StreamingLeaseJobsServer) error
	RenewLease(context.Context, *RenewLeaseRequest) (*IdList, error)
	ReturnLease(context.Context, *ReturnLeaseRequest) (*types.Empty, error)
	ReportDone(context.Context, *IdList) (*IdList, error)
}

AggregatedQueueServer is the server API for AggregatedQueue service.

type AggregatedQueue_StreamingLeaseJobsClient ¶ 

type AggregatedQueue_StreamingLeaseJobsClient interface {
	Send(*StreamingLeaseRequest) error
	Recv() (*StreamingJobLease, error)
	grpc.ClientStream
}

type AggregatedQueue_StreamingLeaseJobsServer ¶ 

type AggregatedQueue_StreamingLeaseJobsServer interface {
	Send(*StreamingJobLease) error
	Recv() (*StreamingLeaseRequest, error)
	grpc.ServerStream
}

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 ClusterLeasedReport ¶ 

type ClusterLeasedReport struct {
	ClusterId  string    `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	ReportTime time.Time `protobuf:"bytes,2,opt,name=report_time,json=reportTime,proto3,stdtime" json:"reportTime"`
	// For each queue, the total resources allocated to jobs from that queue.
	Queues []*QueueLeasedReport `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"`
}

func (*ClusterLeasedReport) Descriptor ¶ 

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

func (*ClusterLeasedReport) GetClusterId ¶ 

func (m *ClusterLeasedReport) GetClusterId() string

func (*ClusterLeasedReport) GetQueues ¶ 

func (m *ClusterLeasedReport) GetQueues() []*QueueLeasedReport

func (*ClusterLeasedReport) GetReportTime ¶ 

func (m *ClusterLeasedReport) GetReportTime() time.Time

func (*ClusterLeasedReport) Marshal ¶ 

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

func (*ClusterLeasedReport) MarshalTo ¶ 

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

func (*ClusterLeasedReport) MarshalToSizedBuffer ¶ 

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

func (*ClusterLeasedReport) ProtoMessage ¶ 

func (*ClusterLeasedReport) ProtoMessage()

func (*ClusterLeasedReport) Reset ¶ 

func (m *ClusterLeasedReport) Reset()

func (*ClusterLeasedReport) Size ¶ 

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

func (*ClusterLeasedReport) String ¶ 

func (this *ClusterLeasedReport) String() string

func (*ClusterLeasedReport) Unmarshal ¶ 

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

func (*ClusterLeasedReport) XXX_DiscardUnknown ¶ 

func (m *ClusterLeasedReport) XXX_DiscardUnknown()

func (*ClusterLeasedReport) XXX_Marshal ¶ 

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

func (*ClusterLeasedReport) XXX_Merge ¶ 

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

func (*ClusterLeasedReport) XXX_Size ¶ 

func (m *ClusterLeasedReport) XXX_Size() int

func (*ClusterLeasedReport) XXX_Unmarshal ¶ 

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

type ClusterSchedulingInfoReport ¶ 

type ClusterSchedulingInfoReport struct {
	ClusterId      string                       `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Pool           string                       `protobuf:"bytes,7,opt,name=pool,proto3" json:"pool,omitempty"`
	ReportTime     time.Time                    `protobuf:"bytes,2,opt,name=report_time,json=reportTime,proto3,stdtime" json:"reportTime"`
	NodeTypes      []*NodeType                  `protobuf:"bytes,5,rep,name=node_types,json=nodeTypes,proto3" json:"nodeTypes,omitempty"`
	MinimumJobSize map[string]resource.Quantity `` /* 181-byte string literal not displayed */
}

Used to store last info in Redis

func (*ClusterSchedulingInfoReport) Descriptor ¶ 

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

func (*ClusterSchedulingInfoReport) GetClusterId ¶ 

func (m *ClusterSchedulingInfoReport) GetClusterId() string

func (*ClusterSchedulingInfoReport) GetMinimumJobSize ¶ 

func (m *ClusterSchedulingInfoReport) GetMinimumJobSize() map[string]resource.Quantity

func (*ClusterSchedulingInfoReport) GetNodeTypes ¶ 

func (m *ClusterSchedulingInfoReport) GetNodeTypes() []*NodeType

func (*ClusterSchedulingInfoReport) GetPool ¶ 

func (m *ClusterSchedulingInfoReport) GetPool() string

func (*ClusterSchedulingInfoReport) GetReportTime ¶ 

func (m *ClusterSchedulingInfoReport) GetReportTime() time.Time

func (*ClusterSchedulingInfoReport) Marshal ¶ 

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

func (*ClusterSchedulingInfoReport) MarshalTo ¶ 

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

func (*ClusterSchedulingInfoReport) MarshalToSizedBuffer ¶ 

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

func (*ClusterSchedulingInfoReport) ProtoMessage ¶ 

func (*ClusterSchedulingInfoReport) ProtoMessage()

func (*ClusterSchedulingInfoReport) Reset ¶ 

func (m *ClusterSchedulingInfoReport) Reset()

func (*ClusterSchedulingInfoReport) Size ¶ 

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

func (*ClusterSchedulingInfoReport) String ¶ 

func (this *ClusterSchedulingInfoReport) String() string

func (*ClusterSchedulingInfoReport) Unmarshal ¶ 

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

func (*ClusterSchedulingInfoReport) XXX_DiscardUnknown ¶ 

func (m *ClusterSchedulingInfoReport) XXX_DiscardUnknown()

func (*ClusterSchedulingInfoReport) XXX_Marshal ¶ 

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

func (*ClusterSchedulingInfoReport) XXX_Merge ¶ 

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

func (*ClusterSchedulingInfoReport) XXX_Size ¶ 

func (m *ClusterSchedulingInfoReport) XXX_Size() int

func (*ClusterSchedulingInfoReport) XXX_Unmarshal ¶ 

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

type ClusterUsageReport ¶ 

type ClusterUsageReport struct {
	ClusterId       string                       `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Pool            string                       `protobuf:"bytes,6,opt,name=pool,proto3" json:"pool,omitempty"`
	ReportTime      time.Time                    `protobuf:"bytes,2,opt,name=report_time,json=reportTime,proto3,stdtime" json:"reportTime"`
	Queues          []*QueueReport               `protobuf:"bytes,3,rep,name=queues,proto3" json:"queues,omitempty"` // Deprecated: Do not use.
	ClusterCapacity map[string]resource.Quantity ``                                                                  // Deprecated: Do not use.
	/* 183-byte string literal not displayed */
	ClusterAvailableCapacity map[string]resource.Quantity `` // Deprecated: Do not use.
	/* 211-byte string literal not displayed */
	NodeTypeUsageReports []NodeTypeUsageReport `protobuf:"bytes,7,rep,name=node_type_usage_reports,json=nodeTypeUsageReports,proto3" json:"nodeTypeUsageReports"`
}

func (*ClusterUsageReport) Descriptor ¶ 

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

func (*ClusterUsageReport) GetClusterAvailableCapacity deprecated 

func (m *ClusterUsageReport) GetClusterAvailableCapacity() map[string]resource.Quantity

Deprecated: Do not use.

func (*ClusterUsageReport) GetClusterCapacity deprecated 

func (m *ClusterUsageReport) GetClusterCapacity() map[string]resource.Quantity

Deprecated: Do not use.

func (*ClusterUsageReport) GetClusterId ¶ 

func (m *ClusterUsageReport) GetClusterId() string

func (*ClusterUsageReport) GetNodeTypeUsageReports ¶ 

func (m *ClusterUsageReport) GetNodeTypeUsageReports() []NodeTypeUsageReport

func (*ClusterUsageReport) GetPool ¶ 

func (m *ClusterUsageReport) GetPool() string

func (*ClusterUsageReport) GetQueues deprecated 

func (m *ClusterUsageReport) GetQueues() []*QueueReport

Deprecated: Do not use.

func (*ClusterUsageReport) GetReportTime ¶ 

func (m *ClusterUsageReport) GetReportTime() time.Time

func (*ClusterUsageReport) Marshal ¶ 

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

func (*ClusterUsageReport) MarshalTo ¶ 

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

func (*ClusterUsageReport) MarshalToSizedBuffer ¶ 

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

func (*ClusterUsageReport) ProtoMessage ¶ 

func (*ClusterUsageReport) ProtoMessage()

func (*ClusterUsageReport) Reset ¶ 

func (m *ClusterUsageReport) Reset()

func (*ClusterUsageReport) Size ¶ 

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

func (*ClusterUsageReport) String ¶ 

func (this *ClusterUsageReport) String() string

func (*ClusterUsageReport) Unmarshal ¶ 

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

func (*ClusterUsageReport) XXX_DiscardUnknown ¶ 

func (m *ClusterUsageReport) XXX_DiscardUnknown()

func (*ClusterUsageReport) XXX_Marshal ¶ 

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

func (*ClusterUsageReport) XXX_Merge ¶ 

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

func (*ClusterUsageReport) XXX_Size ¶ 

func (m *ClusterUsageReport) XXX_Size() int

func (*ClusterUsageReport) XXX_Unmarshal ¶ 

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

type ComputeResource ¶ 

type ComputeResource struct {
	Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
}

func (*ComputeResource) Descriptor ¶ 

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

func (*ComputeResource) GetResources ¶ 

func (m *ComputeResource) GetResources() map[string]resource.Quantity

func (*ComputeResource) Marshal ¶ 

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

func (*ComputeResource) MarshalTo ¶ 

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

func (*ComputeResource) MarshalToSizedBuffer ¶ 

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

func (*ComputeResource) ProtoMessage ¶ 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) Reset ¶ 

func (m *ComputeResource) Reset()

func (*ComputeResource) Size ¶ 

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

func (*ComputeResource) String ¶ 

func (this *ComputeResource) String() string

func (*ComputeResource) Unmarshal ¶ 

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

func (*ComputeResource) XXX_DiscardUnknown ¶ 

func (m *ComputeResource) XXX_DiscardUnknown()

func (*ComputeResource) XXX_Marshal ¶ 

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

func (*ComputeResource) XXX_Merge ¶ 

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

func (*ComputeResource) XXX_Size ¶ 

func (m *ComputeResource) XXX_Size() int

func (*ComputeResource) XXX_Unmarshal ¶ 

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

type ContainerStatus ¶ 

type ContainerStatus struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ExitCode int32  `protobuf:"varint,2,opt,name=exitCode,proto3" json:"exitCode,omitempty"`
	Message  string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Reason   string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Cause    Cause  `protobuf:"varint,5,opt,name=cause,proto3,enum=api.Cause" json:"cause,omitempty"`
}

func (*ContainerStatus) Descriptor ¶ 

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

func (*ContainerStatus) GetCause ¶ 

func (m *ContainerStatus) GetCause() Cause

func (*ContainerStatus) GetExitCode ¶ 

func (m *ContainerStatus) GetExitCode() int32

func (*ContainerStatus) GetMessage ¶ 

func (m *ContainerStatus) GetMessage() string

func (*ContainerStatus) GetName ¶ 

func (m *ContainerStatus) GetName() string

func (*ContainerStatus) GetReason ¶ 

func (m *ContainerStatus) GetReason() string

func (*ContainerStatus) Marshal ¶ 

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

func (*ContainerStatus) 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 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 {
	ReportMultiple(ctx context.Context, in *EventList, opts ...grpc.CallOption) (*types.Empty, error)
	Report(ctx context.Context, in *EventMessage, opts ...grpc.CallOption) (*types.Empty, error)
	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 EventList ¶ 

type EventList struct {
	Events []*EventMessage `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
}

func (*EventList) Descriptor ¶ 

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

func (*EventList) GetEvents ¶ 

func (m *EventList) GetEvents() []*EventMessage

func (*EventList) Marshal ¶ 

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

func (*EventList) MarshalTo ¶ 

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

func (*EventList) MarshalToSizedBuffer ¶ 

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

func (*EventList) ProtoMessage ¶ 

func (*EventList) ProtoMessage()

func (*EventList) Reset ¶ 

func (m *EventList) Reset()

func (*EventList) Size ¶ 

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

func (*EventList) String ¶ 

func (this *EventList) String() string

func (*EventList) Unmarshal ¶ 

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

func (*EventList) XXX_DiscardUnknown ¶ 

func (m *EventList) XXX_DiscardUnknown()

func (*EventList) XXX_Marshal ¶ 

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

func (*EventList) XXX_Merge ¶ 

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

func (*EventList) XXX_Size ¶ 

func (m *EventList) XXX_Size() int

func (*EventList) XXX_Unmarshal ¶ 

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

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 {
	ReportMultiple(context.Context, *EventList) (*types.Empty, error)
	Report(context.Context, *EventMessage) (*types.Empty, error)
	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 IdList ¶ 

type IdList struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
}

func (*IdList) Descriptor ¶ 

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

func (*IdList) GetIds ¶ 

func (m *IdList) GetIds() []string

func (*IdList) Marshal ¶ 

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

func (*IdList) MarshalTo ¶ 

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

func (*IdList) MarshalToSizedBuffer ¶ 

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

func (*IdList) ProtoMessage ¶ 

func (*IdList) ProtoMessage()

func (*IdList) Reset ¶ 

func (m *IdList) Reset()

func (*IdList) Size ¶ 

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

func (*IdList) String ¶ 

func (this *IdList) String() string

func (*IdList) Unmarshal ¶ 

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

func (*IdList) XXX_DiscardUnknown ¶ 

func (m *IdList) XXX_DiscardUnknown()

func (*IdList) XXX_Marshal ¶ 

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

func (*IdList) XXX_Merge ¶ 

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

func (*IdList) XXX_Size ¶ 

func (m *IdList) XXX_Size() int

func (*IdList) XXX_Unmarshal ¶ 

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

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) 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) 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 JobLease ¶ 

type JobLease struct {
	Job []*Job `protobuf:"bytes,1,rep,name=job,proto3" json:"job,omitempty"`
}

func (*JobLease) Descriptor ¶ 

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

func (*JobLease) GetJob ¶ 

func (m *JobLease) GetJob() []*Job

func (*JobLease) Marshal ¶ 

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

func (*JobLease) MarshalTo ¶ 

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

func (*JobLease) MarshalToSizedBuffer ¶ 

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

func (*JobLease) ProtoMessage ¶ 

func (*JobLease) ProtoMessage()

func (*JobLease) Reset ¶ 

func (m *JobLease) Reset()

func (*JobLease) Size ¶ 

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

func (*JobLease) String ¶ 

func (this *JobLease) String() string

func (*JobLease) Unmarshal ¶ 

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

func (*JobLease) XXX_DiscardUnknown ¶ 

func (m *JobLease) XXX_DiscardUnknown()

func (*JobLease) XXX_Marshal ¶ 

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

func (*JobLease) XXX_Merge ¶ 

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

func (*JobLease) XXX_Size ¶ 

func (m *JobLease) XXX_Size() int

func (*JobLease) XXX_Unmarshal ¶ 

func (m *JobLease) 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 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 NodeInfo ¶ 

type NodeInfo struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Taints []v1.Taint        `protobuf:"bytes,2,rep,name=taints,proto3" json:"taints"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// To be deprecated in favour of total_resources + allocated_resources.
	AllocatableResources map[string]resource.Quantity `` /* 198-byte string literal not displayed */
	// To be deprecated in favour of total_resources + allocated_resources.
	AvailableResources map[string]resource.Quantity `` /* 192-byte string literal not displayed */
	// Total node resources.
	// Resources available for allocation is given by the difference between this and allocated_resources.
	TotalResources map[string]resource.Quantity `` /* 180-byte string literal not displayed */
	// Each pod is created with a priority class. Each priority class has an integer priority associated with it.
	// This is a map from priority to the total amount of resources allocated to pods with that priority.
	// It is used by the scheduler to decide whether more jobs should be sent to an executor.
	// In particular, jobs may be sent to an executor even if all resources are allocated
	// if the sent jobs are of higher priority.
	AllocatedResources map[int32]ComputeResource `` /* 193-byte string literal not displayed */
	// All run ids of jobs on the node, mapped to their current state
	// this should be of type armadaevents.uuid, but this creates a circular loop
	// once the old scheduler has gone, we can correct this
	RunIdsByState map[string]JobState `` /* 198-byte string literal not displayed */
	// The amount of resource allocated to non-armada pods by priority
	NonArmadaAllocatedResources map[int32]ComputeResource `` /* 222-byte string literal not displayed */
	Unschedulable               bool                      `protobuf:"varint,10,opt,name=unschedulable,proto3" json:"unschedulable,omitempty"`
	// This should only be used for metrics
	// An aggregated real usage of jobs by queue
	ResourceUsageByQueue map[string]*ComputeResource `` /* 211-byte string literal not displayed */
	// This should only be used for metrics
	// This is the type the node should be reported as. It is simple a label to categorise the group the node belongs to
	NodeType string `protobuf:"bytes,12,opt,name=node_type,json=nodeType,proto3" json:"nodeType,omitempty"`
}

Used by the scheduler when allocating jobs to executors.

func (*NodeInfo) Descriptor ¶ 

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

func (*NodeInfo) GetAllocatableResources ¶ 

func (m *NodeInfo) GetAllocatableResources() map[string]resource.Quantity

func (*NodeInfo) GetAllocatedResources ¶ 

func (m *NodeInfo) GetAllocatedResources() map[int32]ComputeResource

func (*NodeInfo) GetAvailableResources ¶ 

func (m *NodeInfo) GetAvailableResources() map[string]resource.Quantity

func (*NodeInfo) GetLabels ¶ 

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

func (*NodeInfo) GetName ¶ 

func (m *NodeInfo) GetName() string

func (*NodeInfo) GetNodeType ¶ added in v0.3.66 

func (m *NodeInfo) GetNodeType() string

func (*NodeInfo) GetNonArmadaAllocatedResources ¶ added in v0.3.50 

func (m *NodeInfo) GetNonArmadaAllocatedResources() map[int32]ComputeResource

func (*NodeInfo) GetResourceUsageByQueue ¶ added in v0.3.66 

func (m *NodeInfo) GetResourceUsageByQueue() map[string]*ComputeResource

func (*NodeInfo) GetRunIdsByState ¶ added in v0.3.49 

func (m *NodeInfo) GetRunIdsByState() map[string]JobState

func (*NodeInfo) GetTaints ¶ 

func (m *NodeInfo) GetTaints() []v1.Taint

func (*NodeInfo) GetTotalResources ¶ 

func (m *NodeInfo) GetTotalResources() map[string]resource.Quantity

func (*NodeInfo) GetUnschedulable ¶ added in v0.3.65 

func (m *NodeInfo) GetUnschedulable() bool

func (*NodeInfo) Marshal ¶ 

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

func (*NodeInfo) MarshalTo ¶ 

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

func (*NodeInfo) MarshalToSizedBuffer ¶ 

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

func (*NodeInfo) ProtoMessage ¶ 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset ¶ 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size ¶ 

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

func (*NodeInfo) String ¶ 

func (this *NodeInfo) String() string

func (*NodeInfo) Unmarshal ¶ 

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

func (*NodeInfo) XXX_DiscardUnknown ¶ 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal ¶ 

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

func (*NodeInfo) XXX_Merge ¶ 

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

func (*NodeInfo) XXX_Size ¶ 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal ¶ 

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

type NodeLabeling ¶ 

type NodeLabeling struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
}

func (*NodeLabeling) Descriptor ¶ 

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

func (*NodeLabeling) GetLabels ¶ 

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

func (*NodeLabeling) Marshal ¶ 

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

func (*NodeLabeling) MarshalTo ¶ 

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

func (*NodeLabeling) MarshalToSizedBuffer ¶ 

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

func (*NodeLabeling) ProtoMessage ¶ 

func (*NodeLabeling) ProtoMessage()

func (*NodeLabeling) Reset ¶ 

func (m *NodeLabeling) Reset()

func (*NodeLabeling) Size ¶ 

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

func (*NodeLabeling) String ¶ 

func (this *NodeLabeling) String() string

func (*NodeLabeling) Unmarshal ¶ 

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

func (*NodeLabeling) XXX_DiscardUnknown ¶ 

func (m *NodeLabeling) XXX_DiscardUnknown()

func (*NodeLabeling) XXX_Marshal ¶ 

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

func (*NodeLabeling) XXX_Merge ¶ 

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

func (*NodeLabeling) XXX_Size ¶ 

func (m *NodeLabeling) XXX_Size() int

func (*NodeLabeling) XXX_Unmarshal ¶ 

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

type NodeType ¶ 

type NodeType struct {
	Taints               []v1.Taint                   `protobuf:"bytes,1,rep,name=taints,proto3" json:"taints"`
	Labels               map[string]string            `` /* 153-byte string literal not displayed */
	AllocatableResources map[string]resource.Quantity `` /* 198-byte string literal not displayed */
}

The Armada scheduler must account for taints, labels, and available resources. These together make up the NodeType of a particular node. Nodes with equal NodeType are considered as equivalent for scheduling and accounting.

func (*NodeType) Descriptor ¶ 

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

func (*NodeType) GetAllocatableResources ¶ 

func (m *NodeType) GetAllocatableResources() map[string]resource.Quantity

func (*NodeType) GetLabels ¶ 

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

func (*NodeType) GetTaints ¶ 

func (m *NodeType) GetTaints() []v1.Taint

func (*NodeType) Marshal ¶ 

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

func (*NodeType) MarshalTo ¶ 

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

func (*NodeType) MarshalToSizedBuffer ¶ 

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

func (*NodeType) ProtoMessage ¶ 

func (*NodeType) ProtoMessage()

func (*NodeType) Reset ¶ 

func (m *NodeType) Reset()

func (*NodeType) Size ¶ 

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

func (*NodeType) String ¶ 

func (this *NodeType) String() string

func (*NodeType) Unmarshal ¶ 

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

func (*NodeType) XXX_DiscardUnknown ¶ 

func (m *NodeType) XXX_DiscardUnknown()

func (*NodeType) XXX_Marshal ¶ 

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

func (*NodeType) XXX_Merge ¶ 

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

func (*NodeType) XXX_Size ¶ 

func (m *NodeType) XXX_Size() int

func (*NodeType) XXX_Unmarshal ¶ 

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

type NodeTypeIdentifier ¶ 

type NodeTypeIdentifier struct {
	Id     string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Taints []v1.Taint `protobuf:"bytes,2,rep,name=taints,proto3" json:"taints"`
}

func (*NodeTypeIdentifier) Descriptor ¶ 

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

func (*NodeTypeIdentifier) GetId ¶ 

func (m *NodeTypeIdentifier) GetId() string

func (*NodeTypeIdentifier) GetTaints ¶ 

func (m *NodeTypeIdentifier) GetTaints() []v1.Taint

func (*NodeTypeIdentifier) Marshal ¶ 

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

func (*NodeTypeIdentifier) MarshalTo ¶ 

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

func (*NodeTypeIdentifier) MarshalToSizedBuffer ¶ 

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

func (*NodeTypeIdentifier) ProtoMessage ¶ 

func (*NodeTypeIdentifier) ProtoMessage()

func (*NodeTypeIdentifier) Reset ¶ 

func (m *NodeTypeIdentifier) Reset()

func (*NodeTypeIdentifier) Size ¶ 

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

func (*NodeTypeIdentifier) String ¶ 

func (this *NodeTypeIdentifier) String() string

func (*NodeTypeIdentifier) Unmarshal ¶ 

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

func (*NodeTypeIdentifier) XXX_DiscardUnknown ¶ 

func (m *NodeTypeIdentifier) XXX_DiscardUnknown()

func (*NodeTypeIdentifier) XXX_Marshal ¶ 

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

func (*NodeTypeIdentifier) XXX_Merge ¶ 

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

func (*NodeTypeIdentifier) XXX_Size ¶ 

func (m *NodeTypeIdentifier) XXX_Size() int

func (*NodeTypeIdentifier) XXX_Unmarshal ¶ 

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

type NodeTypeUsageReport ¶ 

type NodeTypeUsageReport struct {
	NodeType          *NodeTypeIdentifier          `protobuf:"bytes,1,opt,name=node_type,json=nodeType,proto3" json:"nodeType,omitempty"`
	Capacity          map[string]resource.Quantity `` /* 147-byte string literal not displayed */
	AvailableCapacity map[string]resource.Quantity `` /* 189-byte string literal not displayed */
	CordonedUsage     map[string]resource.Quantity `` /* 177-byte string literal not displayed */
	Queues            []*QueueReport               `protobuf:"bytes,4,rep,name=queues,proto3" json:"queues,omitempty"`
	TotalNodes        int32                        `protobuf:"varint,7,opt,name=totalNodes,proto3" json:"totalNodes,omitempty"`
	SchedulableNodes  int32                        `protobuf:"varint,6,opt,name=schedulableNodes,proto3" json:"schedulableNodes,omitempty"`
}

func (*NodeTypeUsageReport) Descriptor ¶ 

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

func (*NodeTypeUsageReport) GetAvailableCapacity ¶ 

func (m *NodeTypeUsageReport) GetAvailableCapacity() map[string]resource.Quantity

func (*NodeTypeUsageReport) GetCapacity ¶ 

func (m *NodeTypeUsageReport) GetCapacity() map[string]resource.Quantity

func (*NodeTypeUsageReport) GetCordonedUsage ¶ 

func (m *NodeTypeUsageReport) GetCordonedUsage() map[string]resource.Quantity

func (*NodeTypeUsageReport) GetNodeType ¶ 

func (m *NodeTypeUsageReport) GetNodeType() *NodeTypeIdentifier

func (*NodeTypeUsageReport) GetQueues ¶ 

func (m *NodeTypeUsageReport) GetQueues() []*QueueReport

func (*NodeTypeUsageReport) GetSchedulableNodes ¶ 

func (m *NodeTypeUsageReport) GetSchedulableNodes() int32

func (*NodeTypeUsageReport) GetTotalNodes ¶ 

func (m *NodeTypeUsageReport) GetTotalNodes() int32

func (*NodeTypeUsageReport) Marshal ¶ 

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

func (*NodeTypeUsageReport) MarshalTo ¶ 

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

func (*NodeTypeUsageReport) MarshalToSizedBuffer ¶ 

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

func (*NodeTypeUsageReport) ProtoMessage ¶ 

func (*NodeTypeUsageReport) ProtoMessage()

func (*NodeTypeUsageReport) Reset ¶ 

func (m *NodeTypeUsageReport) Reset()

func (*NodeTypeUsageReport) Size ¶ 

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

func (*NodeTypeUsageReport) String ¶ 

func (this *NodeTypeUsageReport) String() string

func (*NodeTypeUsageReport) Unmarshal ¶ 

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

func (*NodeTypeUsageReport) XXX_DiscardUnknown ¶ 

func (m *NodeTypeUsageReport) XXX_DiscardUnknown()

func (*NodeTypeUsageReport) XXX_Marshal ¶ 

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

func (*NodeTypeUsageReport) XXX_Merge ¶ 

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

func (*NodeTypeUsageReport) XXX_Size ¶ 

func (m *NodeTypeUsageReport) XXX_Size() int

func (*NodeTypeUsageReport) XXX_Unmarshal ¶ 

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

type OrderedStringMap ¶ 

type OrderedStringMap struct {
	Entries []*StringKeyValuePair `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
}

func (*OrderedStringMap) Descriptor ¶ 

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

func (*OrderedStringMap) GetEntries ¶ 

func (m *OrderedStringMap) GetEntries() []*StringKeyValuePair

func (*OrderedStringMap) Marshal ¶ 

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

func (*OrderedStringMap) MarshalTo ¶ 

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

func (*OrderedStringMap) MarshalToSizedBuffer ¶ 

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

func (*OrderedStringMap) ProtoMessage ¶ 

func (*OrderedStringMap) ProtoMessage()

func (*OrderedStringMap) Reset ¶ 

func (m *OrderedStringMap) Reset()

func (*OrderedStringMap) Size ¶ 

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

func (*OrderedStringMap) String ¶ 

func (this *OrderedStringMap) String() string

func (*OrderedStringMap) Unmarshal ¶ 

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

func (*OrderedStringMap) XXX_DiscardUnknown ¶ 

func (m *OrderedStringMap) XXX_DiscardUnknown()

func (*OrderedStringMap) XXX_Marshal ¶ 

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

func (*OrderedStringMap) XXX_Merge ¶ 

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

func (*OrderedStringMap) XXX_Size ¶ 

func (m *OrderedStringMap) XXX_Size() int

func (*OrderedStringMap) XXX_Unmarshal ¶ 

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

type Queue ¶ 

type Queue struct {
	Name           string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PriorityFactor float64              `protobuf:"fixed64,2,opt,name=priority_factor,json=priorityFactor,proto3" json:"priorityFactor,omitempty"`
	UserOwners     []string             `protobuf:"bytes,3,rep,name=user_owners,json=userOwners,proto3" json:"userOwners,omitempty"`
	GroupOwners    []string             `protobuf:"bytes,4,rep,name=group_owners,json=groupOwners,proto3" json:"groupOwners,omitempty"`
	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 QueueInfo ¶ 

type QueueInfo struct {
	Name          string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ActiveJobSets []*JobSetInfo `protobuf:"bytes,2,rep,name=active_job_sets,json=activeJobSets,proto3" json:"activeJobSets,omitempty"`
}

func (*QueueInfo) Descriptor ¶ 

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

func (*QueueInfo) GetActiveJobSets ¶ 

func (m *QueueInfo) GetActiveJobSets() []*JobSetInfo

func (*QueueInfo) GetName ¶ 

func (m *QueueInfo) GetName() string

func (*QueueInfo) Marshal ¶ 

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

func (*QueueInfo) MarshalTo ¶ 

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

func (*QueueInfo) MarshalToSizedBuffer ¶ 

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

func (*QueueInfo) ProtoMessage ¶ 

func (*QueueInfo) ProtoMessage()

func (*QueueInfo) Reset ¶ 

func (m *QueueInfo) Reset()

func (*QueueInfo) Size ¶ 

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

func (*QueueInfo) String ¶ 

func (this *QueueInfo) String() string

func (*QueueInfo) Unmarshal ¶ 

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

func (*QueueInfo) XXX_DiscardUnknown ¶ 

func (m *QueueInfo) XXX_DiscardUnknown()

func (*QueueInfo) XXX_Marshal ¶ 

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

func (*QueueInfo) XXX_Merge ¶ 

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

func (*QueueInfo) XXX_Size ¶ 

func (m *QueueInfo) XXX_Size() int

func (*QueueInfo) XXX_Unmarshal ¶ 

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

type QueueInfoRequest ¶ 

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

func (*QueueInfoRequest) Descriptor ¶ 

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

func (*QueueInfoRequest) GetName ¶ 

func (m *QueueInfoRequest) GetName() string

func (*QueueInfoRequest) Marshal ¶ 

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

func (*QueueInfoRequest) MarshalTo ¶ 

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

func (*QueueInfoRequest) MarshalToSizedBuffer ¶ 

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

func (*QueueInfoRequest) ProtoMessage ¶ 

func (*QueueInfoRequest) ProtoMessage()

func (*QueueInfoRequest) Reset ¶ 

func (m *QueueInfoRequest) Reset()

func (*QueueInfoRequest) Size ¶ 

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

func (*QueueInfoRequest) String ¶ 

func (this *QueueInfoRequest) String() string

func (*QueueInfoRequest) Unmarshal ¶ 

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

func (*QueueInfoRequest) XXX_DiscardUnknown ¶ 

func (m *QueueInfoRequest) XXX_DiscardUnknown()

func (*QueueInfoRequest) XXX_Marshal ¶ 

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

func (*QueueInfoRequest) XXX_Merge ¶ 

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

func (*QueueInfoRequest) XXX_Size ¶ 

func (m *QueueInfoRequest) XXX_Size() int

func (*QueueInfoRequest) XXX_Unmarshal ¶ 

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

type QueueLeasedReport ¶ 

type QueueLeasedReport struct {
	// Queue name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Total resources allocated to jobs from this queue.
	ResourcesLeased map[string]resource.Quantity `` /* 183-byte string literal not displayed */
	// Total resources allocated to jobs from this queue,
	// grouped by pod priority.
	ResourcesLeasedByPriority map[int32]ComputeResource `` /* 216-byte string literal not displayed */
}

func (*QueueLeasedReport) Descriptor ¶ 

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

func (*QueueLeasedReport) GetName ¶ 

func (m *QueueLeasedReport) GetName() string

func (*QueueLeasedReport) GetResourcesLeased ¶ 

func (m *QueueLeasedReport) GetResourcesLeased() map[string]resource.Quantity

func (*QueueLeasedReport) GetResourcesLeasedByPriority ¶ 

func (m *QueueLeasedReport) GetResourcesLeasedByPriority() map[int32]ComputeResource

func (*QueueLeasedReport) Marshal ¶ 

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

func (*QueueLeasedReport) MarshalTo ¶ 

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

func (*QueueLeasedReport) MarshalToSizedBuffer ¶ 

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

func (*QueueLeasedReport) ProtoMessage ¶ 

func (*QueueLeasedReport) ProtoMessage()

func (*QueueLeasedReport) Reset ¶ 

func (m *QueueLeasedReport) Reset()

func (*QueueLeasedReport) Size ¶ 

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

func (*QueueLeasedReport) String ¶ 

func (this *QueueLeasedReport) String() string

func (*QueueLeasedReport) Unmarshal ¶ 

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

func (*QueueLeasedReport) XXX_DiscardUnknown ¶ 

func (m *QueueLeasedReport) XXX_DiscardUnknown()

func (*QueueLeasedReport) XXX_Marshal ¶ 

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

func (*QueueLeasedReport) XXX_Merge ¶ 

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

func (*QueueLeasedReport) XXX_Size ¶ 

func (m *QueueLeasedReport) XXX_Size() int

func (*QueueLeasedReport) XXX_Unmarshal ¶ 

func (m *QueueLeasedReport) 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 QueueReport ¶ 

type QueueReport struct {
	// Queue name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Total resources requested by pods from this queue that are currently running.
	Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	// Total resources currently being used by all pods from this queue.
	ResourcesUsed map[string]resource.Quantity `` /* 177-byte string literal not displayed */
	// For this queue, number of pods by phase (e.g., running).
	CountOfPodsByPhase map[string]uint32 `` /* 206-byte string literal not displayed */
}

func (*QueueReport) Descriptor ¶ 

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

func (*QueueReport) GetCountOfPodsByPhase ¶ 

func (m *QueueReport) GetCountOfPodsByPhase() map[string]uint32

func (*QueueReport) GetName ¶ 

func (m *QueueReport) GetName() string

func (*QueueReport) GetResources ¶ 

func (m *QueueReport) GetResources() map[string]resource.Quantity

func (*QueueReport) GetResourcesUsed ¶ 

func (m *QueueReport) GetResourcesUsed() map[string]resource.Quantity

func (*QueueReport) Marshal ¶ 

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

func (*QueueReport) MarshalTo ¶ 

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

func (*QueueReport) MarshalToSizedBuffer ¶ 

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

func (*QueueReport) ProtoMessage ¶ 

func (*QueueReport) ProtoMessage()

func (*QueueReport) Reset ¶ 

func (m *QueueReport) Reset()

func (*QueueReport) Size ¶ 

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

func (*QueueReport) String ¶ 

func (this *QueueReport) String() string

func (*QueueReport) Unmarshal ¶ 

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

func (*QueueReport) XXX_DiscardUnknown ¶ 

func (m *QueueReport) XXX_DiscardUnknown()

func (*QueueReport) XXX_Marshal ¶ 

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

func (*QueueReport) XXX_Merge ¶ 

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

func (*QueueReport) XXX_Size ¶ 

func (m *QueueReport) XXX_Size() int

func (*QueueReport) XXX_Unmarshal ¶ 

func (m *QueueReport) 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 RenewLeaseRequest ¶ 

type RenewLeaseRequest struct {
	ClusterId string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Ids       []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
}

func (*RenewLeaseRequest) Descriptor ¶ 

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

func (*RenewLeaseRequest) GetClusterId ¶ 

func (m *RenewLeaseRequest) GetClusterId() string

func (*RenewLeaseRequest) GetIds ¶ 

func (m *RenewLeaseRequest) GetIds() []string

func (*RenewLeaseRequest) Marshal ¶ 

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

func (*RenewLeaseRequest) MarshalTo ¶ 

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

func (*RenewLeaseRequest) MarshalToSizedBuffer ¶ 

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

func (*RenewLeaseRequest) ProtoMessage ¶ 

func (*RenewLeaseRequest) ProtoMessage()

func (*RenewLeaseRequest) Reset ¶ 

func (m *RenewLeaseRequest) Reset()

func (*RenewLeaseRequest) Size ¶ 

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

func (*RenewLeaseRequest) String ¶ 

func (this *RenewLeaseRequest) String() string

func (*RenewLeaseRequest) Unmarshal ¶ 

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

func (*RenewLeaseRequest) XXX_DiscardUnknown ¶ 

func (m *RenewLeaseRequest) XXX_DiscardUnknown()

func (*RenewLeaseRequest) XXX_Marshal ¶ 

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

func (*RenewLeaseRequest) XXX_Merge ¶ 

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

func (*RenewLeaseRequest) XXX_Size ¶ 

func (m *RenewLeaseRequest) XXX_Size() int

func (*RenewLeaseRequest) XXX_Unmarshal ¶ 

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

type ReturnLeaseRequest ¶ 

type ReturnLeaseRequest struct {
	ClusterId       string            `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	JobId           string            `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	AvoidNodeLabels *OrderedStringMap `protobuf:"bytes,4,opt,name=avoid_node_labels,json=avoidNodeLabels,proto3" json:"avoidNodeLabels,omitempty"`
	Reason          string            `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	KubernetesId    string            `protobuf:"bytes,6,opt,name=kubernetes_id,json=kubernetesId,proto3" json:"kubernetesId,omitempty"`
	JobRunAttempted bool              `protobuf:"varint,7,opt,name=job_run_attempted,json=jobRunAttempted,proto3" json:"jobRunAttempted,omitempty"`
	// The executor feeds back certain annotations.
	TrackedAnnotations map[string]string `` /* 202-byte string literal not displayed */
}

func (*ReturnLeaseRequest) Descriptor ¶ 

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

func (*ReturnLeaseRequest) GetAvoidNodeLabels ¶ 

func (m *ReturnLeaseRequest) GetAvoidNodeLabels() *OrderedStringMap

func (*ReturnLeaseRequest) GetClusterId ¶ 

func (m *ReturnLeaseRequest) GetClusterId() string

func (*ReturnLeaseRequest) GetJobId ¶ 

func (m *ReturnLeaseRequest) GetJobId() string

func (*ReturnLeaseRequest) GetJobRunAttempted ¶ 

func (m *ReturnLeaseRequest) GetJobRunAttempted() bool

func (*ReturnLeaseRequest) GetKubernetesId ¶ 

func (m *ReturnLeaseRequest) GetKubernetesId() string

func (*ReturnLeaseRequest) GetReason ¶ 

func (m *ReturnLeaseRequest) GetReason() string

func (*ReturnLeaseRequest) GetTrackedAnnotations ¶ added in v0.3.53 

func (m *ReturnLeaseRequest) GetTrackedAnnotations() map[string]string

func (*ReturnLeaseRequest) Marshal ¶ 

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

func (*ReturnLeaseRequest) MarshalTo ¶ 

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

func (*ReturnLeaseRequest) MarshalToSizedBuffer ¶ 

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

func (*ReturnLeaseRequest) ProtoMessage ¶ 

func (*ReturnLeaseRequest) ProtoMessage()

func (*ReturnLeaseRequest) Reset ¶ 

func (m *ReturnLeaseRequest) Reset()

func (*ReturnLeaseRequest) Size ¶ 

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

func (*ReturnLeaseRequest) String ¶ 

func (this *ReturnLeaseRequest) String() string

func (*ReturnLeaseRequest) Unmarshal ¶ 

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

func (*ReturnLeaseRequest) XXX_DiscardUnknown ¶ 

func (m *ReturnLeaseRequest) XXX_DiscardUnknown()

func (*ReturnLeaseRequest) XXX_Marshal ¶ 

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

func (*ReturnLeaseRequest) XXX_Merge ¶ 

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

func (*ReturnLeaseRequest) XXX_Size ¶ 

func (m *ReturnLeaseRequest) XXX_Size() int

func (*ReturnLeaseRequest) XXX_Unmarshal ¶ 

func (m *ReturnLeaseRequest) 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 StreamingJobLease ¶ 

type StreamingJobLease struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// Total number of jobs being sent over this connection.
	NumJobs uint32 `protobuf:"varint,2,opt,name=numJobs,proto3" json:"numJobs,omitempty"`
	// Number of jobs for which the server has received an ack.
	// When numAcked = numJobs, all jobs have been received and acked.
	NumAcked uint32 `protobuf:"varint,3,opt,name=numAcked,proto3" json:"numAcked,omitempty"`
}

func (*StreamingJobLease) Descriptor ¶ 

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

func (*StreamingJobLease) GetJob ¶ 

func (m *StreamingJobLease) GetJob() *Job

func (*StreamingJobLease) GetNumAcked ¶ 

func (m *StreamingJobLease) GetNumAcked() uint32

func (*StreamingJobLease) GetNumJobs ¶ 

func (m *StreamingJobLease) GetNumJobs() uint32

func (*StreamingJobLease) Marshal ¶ 

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

func (*StreamingJobLease) MarshalTo ¶ 

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

func (*StreamingJobLease) MarshalToSizedBuffer ¶ 

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

func (*StreamingJobLease) ProtoMessage ¶ 

func (*StreamingJobLease) ProtoMessage()

func (*StreamingJobLease) Reset ¶ 

func (m *StreamingJobLease) Reset()

func (*StreamingJobLease) Size ¶ 

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

func (*StreamingJobLease) String ¶ 

func (this *StreamingJobLease) String() string

func (*StreamingJobLease) Unmarshal ¶ 

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

func (*StreamingJobLease) XXX_DiscardUnknown ¶ 

func (m *StreamingJobLease) XXX_DiscardUnknown()

func (*StreamingJobLease) XXX_Marshal ¶ 

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

func (*StreamingJobLease) XXX_Merge ¶ 

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

func (*StreamingJobLease) XXX_Size ¶ 

func (m *StreamingJobLease) XXX_Size() int

func (*StreamingJobLease) XXX_Unmarshal ¶ 

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

type StreamingLeaseRequest ¶ 

type StreamingLeaseRequest struct {
	// Each cluster has a unique name associated with it.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	// Nodes are split into pools. This field indicates for which pool jobs are leased.
	Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	// Total resources available for scheduling across all nodes.
	Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	// For each queue, the total resources allocated to jobs from that queue.
	ClusterLeasedReport ClusterLeasedReport `protobuf:"bytes,4,opt,name=cluster_leased_report,json=clusterLeasedReport,proto3" json:"clusterLeasedReport"`
	// Jobs submitted to this executor must require at least this amount of resources.
	MinimumJobSize map[string]resource.Quantity `` /* 181-byte string literal not displayed */
	// For each node in the cluster:
	// - the total resources on that node,
	// - the amount of resources already assigned to jobs, and
	// - any taints and labels on the node.
	Nodes []NodeInfo `protobuf:"bytes,6,rep,name=nodes,proto3" json:"nodes"`
	// Ids of received jobs. Used to ack received jobs.
	ReceivedJobIds []string `protobuf:"bytes,7,rep,name=ReceivedJobIds,proto3" json:"ReceivedJobIds,omitempty"`
}

For the bidirectional streaming job lease request service. For the first message, populate all fields except SubmittedJobs, which should be empty. For subsequent messages, these fields may be left empty, in which case the last non-zero value received is used. By streaming back job ids, the server knows which jobs were received in case of an outage.

func (*StreamingLeaseRequest) Descriptor ¶ 

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

func (*StreamingLeaseRequest) GetClusterId ¶ 

func (m *StreamingLeaseRequest) GetClusterId() string

func (*StreamingLeaseRequest) GetClusterLeasedReport ¶ 

func (m *StreamingLeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

func (*StreamingLeaseRequest) GetMinimumJobSize ¶ 

func (m *StreamingLeaseRequest) GetMinimumJobSize() map[string]resource.Quantity

func (*StreamingLeaseRequest) GetNodes ¶ 

func (m *StreamingLeaseRequest) GetNodes() []NodeInfo

func (*StreamingLeaseRequest) GetPool ¶ 

func (m *StreamingLeaseRequest) GetPool() string

func (*StreamingLeaseRequest) GetReceivedJobIds ¶ 

func (m *StreamingLeaseRequest) GetReceivedJobIds() []string

func (*StreamingLeaseRequest) GetResources ¶ 

func (m *StreamingLeaseRequest) GetResources() map[string]resource.Quantity

func (*StreamingLeaseRequest) Marshal ¶ 

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

func (*StreamingLeaseRequest) MarshalTo ¶ 

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

func (*StreamingLeaseRequest) MarshalToSizedBuffer ¶ 

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

func (*StreamingLeaseRequest) ProtoMessage ¶ 

func (*StreamingLeaseRequest) ProtoMessage()

func (*StreamingLeaseRequest) Reset ¶ 

func (m *StreamingLeaseRequest) Reset()

func (*StreamingLeaseRequest) Size ¶ 

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

func (*StreamingLeaseRequest) String ¶ 

func (this *StreamingLeaseRequest) String() string

func (*StreamingLeaseRequest) Unmarshal ¶ 

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

func (*StreamingLeaseRequest) XXX_DiscardUnknown ¶ 

func (m *StreamingLeaseRequest) XXX_DiscardUnknown()

func (*StreamingLeaseRequest) XXX_Marshal ¶ 

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

func (*StreamingLeaseRequest) XXX_Merge ¶ 

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

func (*StreamingLeaseRequest) XXX_Size ¶ 

func (m *StreamingLeaseRequest) XXX_Size() int

func (*StreamingLeaseRequest) XXX_Unmarshal ¶ 

func (m *StreamingLeaseRequest) XXX_Unmarshal(b []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 StringKeyValuePair ¶ 

type StringKeyValuePair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*StringKeyValuePair) Descriptor ¶ 

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

func (*StringKeyValuePair) GetKey ¶ 

func (m *StringKeyValuePair) GetKey() string

func (*StringKeyValuePair) GetValue ¶ 

func (m *StringKeyValuePair) GetValue() string

func (*StringKeyValuePair) Marshal ¶ 

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

func (*StringKeyValuePair) MarshalTo ¶ 

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

func (*StringKeyValuePair) MarshalToSizedBuffer ¶ 

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

func (*StringKeyValuePair) ProtoMessage ¶ 

func (*StringKeyValuePair) ProtoMessage()

func (*StringKeyValuePair) Reset ¶ 

func (m *StringKeyValuePair) Reset()

func (*StringKeyValuePair) Size ¶ 

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

func (*StringKeyValuePair) String ¶ 

func (this *StringKeyValuePair) String() string

func (*StringKeyValuePair) Unmarshal ¶ 

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

func (*StringKeyValuePair) XXX_DiscardUnknown ¶ 

func (m *StringKeyValuePair) XXX_DiscardUnknown()

func (*StringKeyValuePair) XXX_Marshal ¶ 

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

func (*StringKeyValuePair) XXX_Merge ¶ 

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

func (*StringKeyValuePair) XXX_Size ¶ 

func (m *StringKeyValuePair) XXX_Size() int

func (*StringKeyValuePair) XXX_Unmarshal ¶ 

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

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)
	GetQueueInfo(ctx context.Context, in *QueueInfoRequest, opts ...grpc.CallOption) (*QueueInfo, 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
	GetQueueInfo(context.Context, *QueueInfoRequest) (*QueueInfo, 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 UnimplementedAggregatedQueueServer ¶ 

type UnimplementedAggregatedQueueServer struct {
}

UnimplementedAggregatedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedAggregatedQueueServer) RenewLease ¶ 

func (*UnimplementedAggregatedQueueServer) RenewLease(ctx context.Context, req *RenewLeaseRequest) (*IdList, error)

func (*UnimplementedAggregatedQueueServer) ReportDone ¶ 

func (*UnimplementedAggregatedQueueServer) ReportDone(ctx context.Context, req *IdList) (*IdList, error)

func (*UnimplementedAggregatedQueueServer) ReturnLease ¶ 

func (*UnimplementedAggregatedQueueServer) ReturnLease(ctx context.Context, req *ReturnLeaseRequest) (*types.Empty, error)

func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs ¶ 

func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs(srv AggregatedQueue_StreamingLeaseJobsServer) error

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) Report ¶ 

func (*UnimplementedEventServer) Report(ctx context.Context, req *EventMessage) (*types.Empty, error)

func (*UnimplementedEventServer) ReportMultiple ¶ 

func (*UnimplementedEventServer) ReportMultiple(ctx context.Context, req *EventList) (*types.Empty, error)

func (*UnimplementedEventServer) Watch ¶ 

func (*UnimplementedEventServer) Watch(req *WatchRequest, srv Event_WatchServer) 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) GetQueueInfo ¶ 

func (*UnimplementedSubmitServer) GetQueueInfo(ctx context.Context, req *QueueInfoRequest) (*QueueInfo, 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 UnimplementedUsageServer ¶ 

type UnimplementedUsageServer struct {
}

UnimplementedUsageServer can be embedded to have forward compatible implementations.

func (*UnimplementedUsageServer) ReportUsage ¶ 

func (*UnimplementedUsageServer) ReportUsage(ctx context.Context, req *ClusterUsageReport) (*types.Empty, error)

type UsageClient ¶ 

type UsageClient interface {
	ReportUsage(ctx context.Context, in *ClusterUsageReport, opts ...grpc.CallOption) (*types.Empty, error)
}

UsageClient is the client API for Usage service.

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

func NewUsageClient ¶ 

func NewUsageClient(cc *grpc.ClientConn) UsageClient

type UsageServer ¶ 

type UsageServer interface {
	ReportUsage(context.Context, *ClusterUsageReport) (*types.Empty, error)
}

UsageServer is the server API for Usage service.

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.
JackTT - Gopher 🇻🇳