api

package
v0.3.79-rc-295390f Latest Latest
Warning

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

Go to latest
Published: Jun 29, 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 PriorityFromPodSpec added in v0.3.70

func PriorityFromPodSpec(podSpec *v1.PodSpec, priorityClasses map[string]configuration.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 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

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 (*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

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"`
}

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]configuration.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) 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) 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"`
}

func (*JobSubmitRequestItem) Descriptor

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

func (*JobSubmitRequestItem) GetAnnotations

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

func (*JobSubmitRequestItem) GetClientId

func (m *JobSubmitRequestItem) GetClientId() string

func (*JobSubmitRequestItem) GetIngress

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

func (*JobSubmitRequestItem) GetLabels

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

func (*JobSubmitRequestItem) GetMainPodSpec added in v0.3.70

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

func (*JobSubmitRequestItem) GetNamespace

func (m *JobSubmitRequestItem) GetNamespace() string

func (*JobSubmitRequestItem) GetPodSpec deprecated

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

Deprecated: Do not use.

func (*JobSubmitRequestItem) GetPodSpecs

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

func (*JobSubmitRequestItem) GetPriority

func (m *JobSubmitRequestItem) GetPriority() float64

func (*JobSubmitRequestItem) GetRequiredNodeLabels deprecated

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

Deprecated: Do not use.

func (*JobSubmitRequestItem) GetScheduler

func (m *JobSubmitRequestItem) GetScheduler() string

func (*JobSubmitRequestItem) GetServices

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

func (*JobSubmitRequestItem) Marshal

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

func (*JobSubmitRequestItem) MarshalTo

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

func (*JobSubmitRequestItem) MarshalToSizedBuffer

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

func (*JobSubmitRequestItem) ProtoMessage

func (*JobSubmitRequestItem) ProtoMessage()

func (*JobSubmitRequestItem) Reset

func (m *JobSubmitRequestItem) Reset()

func (*JobSubmitRequestItem) Size

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

func (*JobSubmitRequestItem) String

func (this *JobSubmitRequestItem) String() string

func (*JobSubmitRequestItem) Unmarshal

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

func (*JobSubmitRequestItem) XXX_DiscardUnknown

func (m *JobSubmitRequestItem) XXX_DiscardUnknown()

func (*JobSubmitRequestItem) XXX_Marshal

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

func (*JobSubmitRequestItem) XXX_Merge

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

func (*JobSubmitRequestItem) XXX_Size

func (m *JobSubmitRequestItem) XXX_Size() int

func (*JobSubmitRequestItem) XXX_Unmarshal

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

type JobSubmitResponse

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

swagger:model

func (*JobSubmitResponse) Descriptor

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

func (*JobSubmitResponse) GetJobResponseItems

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

func (*JobSubmitResponse) Marshal

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

func (*JobSubmitResponse) MarshalTo

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

func (*JobSubmitResponse) MarshalToSizedBuffer

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

func (*JobSubmitResponse) ProtoMessage

func (*JobSubmitResponse) ProtoMessage()

func (*JobSubmitResponse) Reset

func (m *JobSubmitResponse) Reset()

func (*JobSubmitResponse) Size

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

func (*JobSubmitResponse) String

func (this *JobSubmitResponse) String() string

func (*JobSubmitResponse) Unmarshal

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

func (*JobSubmitResponse) XXX_DiscardUnknown

func (m *JobSubmitResponse) XXX_DiscardUnknown()

func (*JobSubmitResponse) XXX_Marshal

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

func (*JobSubmitResponse) XXX_Merge

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

func (*JobSubmitResponse) XXX_Size

func (m *JobSubmitResponse) XXX_Size() int

func (*JobSubmitResponse) XXX_Unmarshal

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

type JobSubmitResponseItem

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

func (*JobSubmitResponseItem) Descriptor

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

func (*JobSubmitResponseItem) GetError

func (m *JobSubmitResponseItem) GetError() string

func (*JobSubmitResponseItem) GetJobId

func (m *JobSubmitResponseItem) GetJobId() string

func (*JobSubmitResponseItem) Marshal

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

func (*JobSubmitResponseItem) MarshalTo

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

func (*JobSubmitResponseItem) MarshalToSizedBuffer

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

func (*JobSubmitResponseItem) ProtoMessage

func (*JobSubmitResponseItem) ProtoMessage()

func (*JobSubmitResponseItem) Reset

func (m *JobSubmitResponseItem) Reset()

func (*JobSubmitResponseItem) Size

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

func (*JobSubmitResponseItem) String

func (this *JobSubmitResponseItem) String() string

func (*JobSubmitResponseItem) Unmarshal

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

func (*JobSubmitResponseItem) XXX_DiscardUnknown

func (m *JobSubmitResponseItem) XXX_DiscardUnknown()

func (*JobSubmitResponseItem) XXX_Marshal

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

func (*JobSubmitResponseItem) XXX_Merge

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

func (*JobSubmitResponseItem) XXX_Size

func (m *JobSubmitResponseItem) XXX_Size() int

func (*JobSubmitResponseItem) XXX_Unmarshal

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

type JobSubmittedEvent

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

func (*JobSubmittedEvent) Descriptor

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

func (*JobSubmittedEvent) GetCreated

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

func (*JobSubmittedEvent) GetJob

func (m *JobSubmittedEvent) GetJob() Job

func (*JobSubmittedEvent) GetJobId

func (m *JobSubmittedEvent) GetJobId() string

func (*JobSubmittedEvent) GetJobSetId

func (m *JobSubmittedEvent) GetJobSetId() string

func (*JobSubmittedEvent) GetQueue

func (m *JobSubmittedEvent) GetQueue() string

func (*JobSubmittedEvent) Marshal

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

func (*JobSubmittedEvent) MarshalTo

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

func (*JobSubmittedEvent) MarshalToSizedBuffer

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

func (*JobSubmittedEvent) ProtoMessage

func (*JobSubmittedEvent) ProtoMessage()

func (*JobSubmittedEvent) Reset

func (m *JobSubmittedEvent) Reset()

func (*JobSubmittedEvent) Size

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

func (*JobSubmittedEvent) String

func (this *JobSubmittedEvent) String() string

func (*JobSubmittedEvent) Unmarshal

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

func (*JobSubmittedEvent) XXX_DiscardUnknown

func (m *JobSubmittedEvent) XXX_DiscardUnknown()

func (*JobSubmittedEvent) XXX_Marshal

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

func (*JobSubmittedEvent) XXX_Merge

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

func (*JobSubmittedEvent) XXX_Size

func (m *JobSubmittedEvent) XXX_Size() int

func (*JobSubmittedEvent) XXX_Unmarshal

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

type JobSucceededEvent

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

func (*JobSucceededEvent) Descriptor

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

func (*JobSucceededEvent) GetClusterId

func (m *JobSucceededEvent) GetClusterId() string

func (*JobSucceededEvent) GetCreated

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

func (*JobSucceededEvent) GetJobId

func (m *JobSucceededEvent) GetJobId() string

func (*JobSucceededEvent) GetJobSetId

func (m *JobSucceededEvent) GetJobSetId() string

func (*JobSucceededEvent) GetKubernetesId

func (m *JobSucceededEvent) GetKubernetesId() string

func (*JobSucceededEvent) GetNodeName

func (m *JobSucceededEvent) GetNodeName() string

func (*JobSucceededEvent) GetPodName

func (m *JobSucceededEvent) GetPodName() string

func (*JobSucceededEvent) GetPodNamespace

func (m *JobSucceededEvent) GetPodNamespace() string

func (*JobSucceededEvent) GetPodNumber

func (m *JobSucceededEvent) GetPodNumber() int32

func (*JobSucceededEvent) GetQueue

func (m *JobSucceededEvent) GetQueue() string

func (*JobSucceededEvent) Marshal

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

func (*JobSucceededEvent) MarshalTo

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

func (*JobSucceededEvent) MarshalToSizedBuffer

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

func (*JobSucceededEvent) ProtoMessage

func (*JobSucceededEvent) ProtoMessage()

func (*JobSucceededEvent) Reset

func (m *JobSucceededEvent) Reset()

func (*JobSucceededEvent) Size

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

func (*JobSucceededEvent) String

func (this *JobSucceededEvent) String() string

func (*JobSucceededEvent) Unmarshal

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

func (*JobSucceededEvent) XXX_DiscardUnknown

func (m *JobSucceededEvent) XXX_DiscardUnknown()

func (*JobSucceededEvent) XXX_Marshal

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

func (*JobSucceededEvent) XXX_Merge

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

func (*JobSucceededEvent) XXX_Size

func (m *JobSucceededEvent) XXX_Size() int

func (*JobSucceededEvent) XXX_Unmarshal

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

type JobTerminatedEvent

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

func (*JobTerminatedEvent) Descriptor

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

func (*JobTerminatedEvent) GetClusterId

func (m *JobTerminatedEvent) GetClusterId() string

func (*JobTerminatedEvent) GetCreated

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

func (*JobTerminatedEvent) GetJobId

func (m *JobTerminatedEvent) GetJobId() string

func (*JobTerminatedEvent) GetJobSetId

func (m *JobTerminatedEvent) GetJobSetId() string

func (*JobTerminatedEvent) GetKubernetesId

func (m *JobTerminatedEvent) GetKubernetesId() string

func (*JobTerminatedEvent) GetPodName

func (m *JobTerminatedEvent) GetPodName() string

func (*JobTerminatedEvent) GetPodNamespace

func (m *JobTerminatedEvent) GetPodNamespace() string

func (*JobTerminatedEvent) GetPodNumber

func (m *JobTerminatedEvent) GetPodNumber() int32

func (*JobTerminatedEvent) GetQueue

func (m *JobTerminatedEvent) GetQueue() string

func (*JobTerminatedEvent) GetReason

func (m *JobTerminatedEvent) GetReason() string

func (*JobTerminatedEvent) Marshal

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

func (*JobTerminatedEvent) MarshalTo

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

func (*JobTerminatedEvent) MarshalToSizedBuffer

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

func (*JobTerminatedEvent) ProtoMessage

func (*JobTerminatedEvent) ProtoMessage()

func (*JobTerminatedEvent) Reset

func (m *JobTerminatedEvent) Reset()

func (*JobTerminatedEvent) Size

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

func (*JobTerminatedEvent) String

func (this *JobTerminatedEvent) String() string

func (*JobTerminatedEvent) Unmarshal

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

func (*JobTerminatedEvent) XXX_DiscardUnknown

func (m *JobTerminatedEvent) XXX_DiscardUnknown()

func (*JobTerminatedEvent) XXX_Marshal

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

func (*JobTerminatedEvent) XXX_Merge

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

func (*JobTerminatedEvent) XXX_Size

func (m *JobTerminatedEvent) XXX_Size() int

func (*JobTerminatedEvent) XXX_Unmarshal

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

type JobUnableToScheduleEvent

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

func (*JobUnableToScheduleEvent) Descriptor

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

func (*JobUnableToScheduleEvent) GetClusterId

func (m *JobUnableToScheduleEvent) GetClusterId() string

func (*JobUnableToScheduleEvent) GetCreated

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

func (*JobUnableToScheduleEvent) GetJobId

func (m *JobUnableToScheduleEvent) GetJobId() string

func (*JobUnableToScheduleEvent) GetJobSetId

func (m *JobUnableToScheduleEvent) GetJobSetId() string

func (*JobUnableToScheduleEvent) GetKubernetesId

func (m *JobUnableToScheduleEvent) GetKubernetesId() string

func (*JobUnableToScheduleEvent) GetNodeName

func (m *JobUnableToScheduleEvent) GetNodeName() string

func (*JobUnableToScheduleEvent) GetPodName

func (m *JobUnableToScheduleEvent) GetPodName() string

func (*JobUnableToScheduleEvent) GetPodNamespace

func (m *JobUnableToScheduleEvent) GetPodNamespace() string

func (*JobUnableToScheduleEvent) GetPodNumber

func (m *JobUnableToScheduleEvent) GetPodNumber() int32

func (*JobUnableToScheduleEvent) GetQueue

func (m *JobUnableToScheduleEvent) GetQueue() string

func (*JobUnableToScheduleEvent) GetReason

func (m *JobUnableToScheduleEvent) GetReason() string

func (*JobUnableToScheduleEvent) Marshal

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

func (*JobUnableToScheduleEvent) MarshalTo

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

func (*JobUnableToScheduleEvent) MarshalToSizedBuffer

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

func (*JobUnableToScheduleEvent) ProtoMessage

func (*JobUnableToScheduleEvent) ProtoMessage()

func (*JobUnableToScheduleEvent) Reset

func (m *JobUnableToScheduleEvent) Reset()

func (*JobUnableToScheduleEvent) Size

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

func (*JobUnableToScheduleEvent) String

func (this *JobUnableToScheduleEvent) String() string

func (*JobUnableToScheduleEvent) Unmarshal

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

func (*JobUnableToScheduleEvent) XXX_DiscardUnknown

func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()

func (*JobUnableToScheduleEvent) XXX_Marshal

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

func (*JobUnableToScheduleEvent) XXX_Merge

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

func (*JobUnableToScheduleEvent) XXX_Size

func (m *JobUnableToScheduleEvent) XXX_Size() int

func (*JobUnableToScheduleEvent) XXX_Unmarshal

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

type 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 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)
	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 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"`
}

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

func (*UnimplementedAggregatedQueueServer) ReturnLease

func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs

type UnimplementedEventServer

type UnimplementedEventServer struct {
}

UnimplementedEventServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServer) GetJobSetEvents

func (*UnimplementedEventServer) Health

func (*UnimplementedEventServer) Report

func (*UnimplementedEventServer) ReportMultiple

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

func (*UnimplementedEventServer) Watch

type UnimplementedSubmitServer

type UnimplementedSubmitServer struct {
}

UnimplementedSubmitServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubmitServer) CancelJobSet

func (*UnimplementedSubmitServer) CancelJobs

func (*UnimplementedSubmitServer) CreateQueue

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

func (*UnimplementedSubmitServer) CreateQueues

func (*UnimplementedSubmitServer) DeleteQueue

func (*UnimplementedSubmitServer) GetQueue

func (*UnimplementedSubmitServer) GetQueueInfo

func (*UnimplementedSubmitServer) Health

func (*UnimplementedSubmitServer) ReprioritizeJobs

func (*UnimplementedSubmitServer) SubmitJobs

func (*UnimplementedSubmitServer) UpdateQueue

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

func (*UnimplementedSubmitServer) UpdateQueues

type UnimplementedUsageServer

type UnimplementedUsageServer struct {
}

UnimplementedUsageServer can be embedded to have forward compatible implementations.

func (*UnimplementedUsageServer) ReportUsage

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

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL