api

package
v0.3.45 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2023 License: Apache-2.0 Imports: 29 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",
}
View Source 
var JobState_value = map[string]int32{
	"QUEUED":  0,
	"PENDING": 1,
	"RUNNING": 2,
}
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 added in v0.3.15 

func JobIdFromApiEvent(msg *EventMessage) string

func JobSetIdFromApiEvent added in v0.3.44 

func JobSetIdFromApiEvent(msg *EventMessage) string

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 ShortStringFromEventMessages added in v0.3.44 

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

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

type AggregatedQueue_StreamingLeaseJobsServer added in v0.3.15 

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

type BatchQueueCreateResponse added in v0.3.15 

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

func (*BatchQueueCreateResponse) Descriptor added in v0.3.15 

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

func (*BatchQueueCreateResponse) GetFailedQueues added in v0.3.15 

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

func (*BatchQueueCreateResponse) Marshal added in v0.3.15 

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

func (*BatchQueueCreateResponse) MarshalTo added in v0.3.15 

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

func (*BatchQueueCreateResponse) MarshalToSizedBuffer added in v0.3.15 

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

func (*BatchQueueCreateResponse) ProtoMessage added in v0.3.15 

func (*BatchQueueCreateResponse) ProtoMessage()

func (*BatchQueueCreateResponse) Reset added in v0.3.15 

func (m *BatchQueueCreateResponse) Reset()

func (*BatchQueueCreateResponse) Size added in v0.3.15 

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

func (*BatchQueueCreateResponse) String added in v0.3.15 

func (this *BatchQueueCreateResponse) String() string

func (*BatchQueueCreateResponse) Unmarshal added in v0.3.15 

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

func (*BatchQueueCreateResponse) XXX_DiscardUnknown added in v0.3.15 

func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()

func (*BatchQueueCreateResponse) XXX_Marshal added in v0.3.15 

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

func (*BatchQueueCreateResponse) XXX_Merge added in v0.3.15 

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

func (*BatchQueueCreateResponse) XXX_Size added in v0.3.15 

func (m *BatchQueueCreateResponse) XXX_Size() int

func (*BatchQueueCreateResponse) XXX_Unmarshal added in v0.3.15 

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

type BatchQueueUpdateResponse added in v0.3.15 

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

func (*BatchQueueUpdateResponse) Descriptor added in v0.3.15 

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

func (*BatchQueueUpdateResponse) GetFailedQueues added in v0.3.15 

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

func (*BatchQueueUpdateResponse) Marshal added in v0.3.15 

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

func (*BatchQueueUpdateResponse) MarshalTo added in v0.3.15 

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

func (*BatchQueueUpdateResponse) MarshalToSizedBuffer added in v0.3.15 

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

func (*BatchQueueUpdateResponse) ProtoMessage added in v0.3.15 

func (*BatchQueueUpdateResponse) ProtoMessage()

func (*BatchQueueUpdateResponse) Reset added in v0.3.15 

func (m *BatchQueueUpdateResponse) Reset()

func (*BatchQueueUpdateResponse) Size added in v0.3.15 

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

func (*BatchQueueUpdateResponse) String added in v0.3.15 

func (this *BatchQueueUpdateResponse) String() string

func (*BatchQueueUpdateResponse) Unmarshal added in v0.3.15 

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

func (*BatchQueueUpdateResponse) XXX_DiscardUnknown added in v0.3.15 

func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()

func (*BatchQueueUpdateResponse) XXX_Marshal added in v0.3.15 

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

func (*BatchQueueUpdateResponse) XXX_Merge added in v0.3.15 

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

func (*BatchQueueUpdateResponse) XXX_Size added in v0.3.15 

func (m *BatchQueueUpdateResponse) XXX_Size() int

func (*BatchQueueUpdateResponse) XXX_Unmarshal added in v0.3.15 

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

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

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

func (Cause) EnumDescriptor added in v0.1.24 

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

func (Cause) String added in v0.1.24 

func (x Cause) String() string

type ClusterLeasedReport added in v0.1.6 

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

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

func (*ClusterLeasedReport) GetClusterId added in v0.1.6 

func (m *ClusterLeasedReport) GetClusterId() string

func (*ClusterLeasedReport) GetQueues added in v0.1.6 

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

func (*ClusterLeasedReport) GetReportTime added in v0.1.6 

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

func (*ClusterLeasedReport) Marshal added in v0.1.6 

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

func (*ClusterLeasedReport) MarshalTo added in v0.1.6 

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

func (*ClusterLeasedReport) MarshalToSizedBuffer added in v0.1.16 

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

func (*ClusterLeasedReport) ProtoMessage added in v0.1.6 

func (*ClusterLeasedReport) ProtoMessage()

func (*ClusterLeasedReport) Reset added in v0.1.6 

func (m *ClusterLeasedReport) Reset()

func (*ClusterLeasedReport) Size added in v0.1.6 

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

func (*ClusterLeasedReport) String added in v0.1.6 

func (this *ClusterLeasedReport) String() string

func (*ClusterLeasedReport) Unmarshal added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_DiscardUnknown added in v0.1.6 

func (m *ClusterLeasedReport) XXX_DiscardUnknown()

func (*ClusterLeasedReport) XXX_Marshal added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_Merge added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_Size added in v0.1.6 

func (m *ClusterLeasedReport) XXX_Size() int

func (*ClusterLeasedReport) XXX_Unmarshal added in v0.1.6 

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

type ClusterSchedulingInfoReport added in v0.1.6 

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

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

func (*ClusterSchedulingInfoReport) GetClusterId added in v0.1.6 

func (m *ClusterSchedulingInfoReport) GetClusterId() string

func (*ClusterSchedulingInfoReport) GetMinimumJobSize added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) GetNodeTypes added in v0.1.14 

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

func (*ClusterSchedulingInfoReport) GetPool added in v0.1.24 

func (m *ClusterSchedulingInfoReport) GetPool() string

func (*ClusterSchedulingInfoReport) GetReportTime added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) Marshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) MarshalTo added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) MarshalToSizedBuffer added in v0.1.16 

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

func (*ClusterSchedulingInfoReport) ProtoMessage added in v0.1.6 

func (*ClusterSchedulingInfoReport) ProtoMessage()

func (*ClusterSchedulingInfoReport) Reset added in v0.1.6 

func (m *ClusterSchedulingInfoReport) Reset()

func (*ClusterSchedulingInfoReport) Size added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) String added in v0.1.6 

func (this *ClusterSchedulingInfoReport) String() string

func (*ClusterSchedulingInfoReport) Unmarshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_DiscardUnknown added in v0.1.6 

func (m *ClusterSchedulingInfoReport) XXX_DiscardUnknown()

func (*ClusterSchedulingInfoReport) XXX_Marshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_Merge added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_Size added in v0.1.6 

func (m *ClusterSchedulingInfoReport) XXX_Size() int

func (*ClusterSchedulingInfoReport) XXX_Unmarshal added in v0.1.6 

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

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

func (*ClusterUsageReport) GetPool added in v0.1.24 

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

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

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

func (*ComputeResource) Descriptor added in v0.1.6 

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

func (*ComputeResource) GetResources added in v0.1.6 

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

func (*ComputeResource) Marshal added in v0.1.6 

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

func (*ComputeResource) MarshalTo added in v0.1.6 

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

func (*ComputeResource) MarshalToSizedBuffer added in v0.1.16 

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

func (*ComputeResource) ProtoMessage added in v0.1.6 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) Reset added in v0.1.6 

func (m *ComputeResource) Reset()

func (*ComputeResource) Size added in v0.1.6 

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

func (*ComputeResource) String added in v0.1.6 

func (this *ComputeResource) String() string

func (*ComputeResource) Unmarshal added in v0.1.6 

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

func (*ComputeResource) XXX_DiscardUnknown added in v0.1.6 

func (m *ComputeResource) XXX_DiscardUnknown()

func (*ComputeResource) XXX_Marshal added in v0.1.6 

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

func (*ComputeResource) XXX_Merge added in v0.1.6 

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

func (*ComputeResource) XXX_Size added in v0.1.6 

func (m *ComputeResource) XXX_Size() int

func (*ComputeResource) XXX_Unmarshal added in v0.1.6 

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

type ContainerStatus added in v0.1.24 

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

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

func (*ContainerStatus) GetCause added in v0.1.24 

func (m *ContainerStatus) GetCause() Cause

func (*ContainerStatus) GetExitCode added in v0.1.24 

func (m *ContainerStatus) GetExitCode() int32

func (*ContainerStatus) GetMessage added in v0.1.24 

func (m *ContainerStatus) GetMessage() string

func (*ContainerStatus) GetName added in v0.1.24 

func (m *ContainerStatus) GetName() string

func (*ContainerStatus) GetReason added in v0.1.24 

func (m *ContainerStatus) GetReason() string

func (*ContainerStatus) Marshal added in v0.1.24 

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

func (*ContainerStatus) MarshalTo added in v0.1.24 

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

func (*ContainerStatus) MarshalToSizedBuffer added in v0.1.24 

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

func (*ContainerStatus) ProtoMessage added in v0.1.24 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset added in v0.1.24 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size added in v0.1.24 

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

func (*ContainerStatus) String added in v0.1.24 

func (this *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal added in v0.1.24 

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

func (*ContainerStatus) XXX_DiscardUnknown added in v0.1.24 

func (m *ContainerStatus) XXX_DiscardUnknown()

func (*ContainerStatus) XXX_Marshal added in v0.1.24 

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

func (*ContainerStatus) XXX_Merge added in v0.1.24 

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

func (*ContainerStatus) XXX_Size added in v0.1.24 

func (m *ContainerStatus) XXX_Size() int

func (*ContainerStatus) XXX_Unmarshal added in v0.1.24 

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

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

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

func (m *EventMessage) GetFailedCompressed() *JobFailedEventCompressed

func (*EventMessage) GetIngressInfo added in v0.1.34 

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

func (m *EventMessage) GetPreempted() *JobPreemptedEvent

func (*EventMessage) GetQueued 

func (m *EventMessage) GetQueued() *JobQueuedEvent

func (*EventMessage) GetReprioritized 

func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent

func (*EventMessage) GetReprioritizing added in v0.1.39 

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

func (m *EventMessage) GetUpdated() *JobUpdatedEvent

func (*EventMessage) GetUtilisation added in v0.1.9 

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

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

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) Reset 

func (m *EventMessage) Reset()

func (*EventMessage) ShortString added in v0.3.44 

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

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

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

func (*EventMessage_Cancelled) Size 

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

func (*EventMessage_Cancelled) String added in v0.1.9 

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

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

func (*EventMessage_Cancelling) Size 

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

func (*EventMessage_Cancelling) String added in v0.1.9 

func (this *EventMessage_Cancelling) String() string

type EventMessage_DuplicateFound added in v0.1.33 

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

func (*EventMessage_DuplicateFound) MarshalTo added in v0.1.33 

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

func (*EventMessage_DuplicateFound) MarshalToSizedBuffer added in v0.1.33 

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

func (*EventMessage_DuplicateFound) Size added in v0.1.33 

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

func (*EventMessage_DuplicateFound) String added in v0.1.33 

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

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

func (*EventMessage_Failed) Size 

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

func (*EventMessage_Failed) String added in v0.1.9 

func (this *EventMessage_Failed) String() string

type EventMessage_FailedCompressed added in v0.3.25 

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

func (*EventMessage_FailedCompressed) MarshalTo added in v0.3.25 

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

func (*EventMessage_FailedCompressed) MarshalToSizedBuffer added in v0.3.25 

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

func (*EventMessage_FailedCompressed) Size added in v0.3.25 

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

func (*EventMessage_FailedCompressed) String added in v0.3.25 

func (this *EventMessage_FailedCompressed) String() string

type EventMessage_IngressInfo added in v0.1.34 

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

func (*EventMessage_IngressInfo) MarshalTo added in v0.1.34 

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

func (*EventMessage_IngressInfo) MarshalToSizedBuffer added in v0.1.34 

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

func (*EventMessage_IngressInfo) Size added in v0.1.34 

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

func (*EventMessage_IngressInfo) String added in v0.1.34 

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

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

func (*EventMessage_LeaseExpired) Size 

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

func (*EventMessage_LeaseExpired) String added in v0.1.9 

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

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

func (*EventMessage_LeaseReturned) Size 

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

func (*EventMessage_LeaseReturned) String added in v0.1.9 

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

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

func (*EventMessage_Leased) Size 

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

func (*EventMessage_Leased) String added in v0.1.9 

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

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

func (*EventMessage_Pending) Size 

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

func (*EventMessage_Pending) String added in v0.1.9 

func (this *EventMessage_Pending) String() string

type EventMessage_Preempted added in v0.3.33 

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

func (*EventMessage_Preempted) MarshalTo added in v0.3.33 

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

func (*EventMessage_Preempted) MarshalToSizedBuffer added in v0.3.33 

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

func (*EventMessage_Preempted) Size added in v0.3.33 

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

func (*EventMessage_Preempted) String added in v0.3.33 

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

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

func (*EventMessage_Queued) Size 

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

func (*EventMessage_Queued) String added in v0.1.9 

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

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

func (*EventMessage_Reprioritized) Size 

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

func (*EventMessage_Reprioritized) String added in v0.1.9 

func (this *EventMessage_Reprioritized) String() string

type EventMessage_Reprioritizing added in v0.1.39 

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

func (*EventMessage_Reprioritizing) MarshalTo added in v0.1.39 

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

func (*EventMessage_Reprioritizing) MarshalToSizedBuffer added in v0.1.39 

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

func (*EventMessage_Reprioritizing) Size added in v0.1.39 

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

func (*EventMessage_Reprioritizing) String added in v0.1.39 

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

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

func (*EventMessage_Running) Size 

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

func (*EventMessage_Running) String added in v0.1.9 

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

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

func (*EventMessage_Submitted) Size 

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

func (*EventMessage_Submitted) String added in v0.1.9 

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

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

func (*EventMessage_Succeeded) Size 

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

func (*EventMessage_Succeeded) String added in v0.1.9 

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

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

func (*EventMessage_Terminated) Size 

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

func (*EventMessage_Terminated) String added in v0.1.9 

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

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

func (*EventMessage_UnableToSchedule) Size 

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

func (*EventMessage_UnableToSchedule) String added in v0.1.9 

func (this *EventMessage_UnableToSchedule) String() string

type EventMessage_Updated added in v0.2.8 

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

func (*EventMessage_Updated) MarshalTo added in v0.2.8 

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

func (*EventMessage_Updated) MarshalToSizedBuffer added in v0.2.8 

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

func (*EventMessage_Updated) Size added in v0.2.8 

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

func (*EventMessage_Updated) String added in v0.2.8 

func (this *EventMessage_Updated) String() string

type EventMessage_Utilisation added in v0.1.9 

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

func (*EventMessage_Utilisation) MarshalTo added in v0.1.9 

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

func (*EventMessage_Utilisation) MarshalToSizedBuffer added in v0.1.16 

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

func (*EventMessage_Utilisation) Size added in v0.1.9 

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

func (*EventMessage_Utilisation) String added in v0.1.9 

func (this *EventMessage_Utilisation) String() string

type EventServer 

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

EventServer is the server API for Event service.

type EventStreamMessage 

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

swagger:model

func (*EventStreamMessage) Descriptor 

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

func (*EventStreamMessage) GetId 

func (m *EventStreamMessage) GetId() string

func (*EventStreamMessage) GetMessage 

func (m *EventStreamMessage) GetMessage() *EventMessage

func (*EventStreamMessage) Marshal 

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

func (*EventStreamMessage) MarshalTo 

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

func (*EventStreamMessage) MarshalToSizedBuffer added in v0.1.16 

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

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

type Event_WatchServer added in v0.2.11 

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

type HealthCheckResponse added in v0.3.35 

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

func (*HealthCheckResponse) Descriptor added in v0.3.35 

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

func (*HealthCheckResponse) GetStatus added in v0.3.35 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) Marshal added in v0.3.35 

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

func (*HealthCheckResponse) MarshalTo added in v0.3.35 

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

func (*HealthCheckResponse) MarshalToSizedBuffer added in v0.3.35 

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

func (*HealthCheckResponse) ProtoMessage added in v0.3.35 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset added in v0.3.35 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size added in v0.3.35 

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

func (*HealthCheckResponse) String added in v0.3.35 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal added in v0.3.35 

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

func (*HealthCheckResponse) XXX_DiscardUnknown added in v0.3.35 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal added in v0.3.35 

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

func (*HealthCheckResponse) XXX_Merge added in v0.3.35 

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

func (*HealthCheckResponse) XXX_Size added in v0.3.35 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal added in v0.3.35 

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

type HealthCheckResponse_ServingStatus added in v0.3.35 

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

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

func (HealthCheckResponse_ServingStatus) String added in v0.3.35 

func (x HealthCheckResponse_ServingStatus) String() string

type IdList 

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

func (*IdList) Descriptor 

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

func (*IdList) GetIds 

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

func (*IdList) Marshal 

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

func (*IdList) MarshalTo 

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

func (*IdList) MarshalToSizedBuffer added in v0.1.16 

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

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

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

func (*IngressConfig) GetAnnotations added in v0.2.3 

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

func (*IngressConfig) GetCertName added in v0.2.12 

func (m *IngressConfig) GetCertName() string

func (*IngressConfig) GetPorts added in v0.1.34 

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

func (*IngressConfig) GetTlsEnabled added in v0.2.12 

func (m *IngressConfig) GetTlsEnabled() bool

func (*IngressConfig) GetType deprecated added in v0.1.34 

func (m *IngressConfig) GetType() IngressType

Deprecated: Do not use.

func (*IngressConfig) GetUseClusterIP added in v0.2.16 

func (m *IngressConfig) GetUseClusterIP() bool

func (*IngressConfig) Marshal added in v0.1.34 

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

func (*IngressConfig) MarshalTo added in v0.1.34 

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

func (*IngressConfig) MarshalToSizedBuffer added in v0.1.34 

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

func (*IngressConfig) ProtoMessage added in v0.1.34 

func (*IngressConfig) ProtoMessage()

func (*IngressConfig) Reset added in v0.1.34 

func (m *IngressConfig) Reset()

func (*IngressConfig) Size added in v0.1.34 

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

func (*IngressConfig) String added in v0.1.34 

func (this *IngressConfig) String() string

func (*IngressConfig) Unmarshal added in v0.1.34 

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

func (*IngressConfig) XXX_DiscardUnknown added in v0.1.34 

func (m *IngressConfig) XXX_DiscardUnknown()

func (*IngressConfig) XXX_Marshal added in v0.1.34 

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

func (*IngressConfig) XXX_Merge added in v0.1.34 

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

func (*IngressConfig) XXX_Size added in v0.1.34 

func (m *IngressConfig) XXX_Size() int

func (*IngressConfig) XXX_Unmarshal added in v0.1.34 

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

type IngressType added in v0.1.34 

type IngressType int32

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

const (
	IngressType_Ingress IngressType = 0
)

func (IngressType) EnumDescriptor added in v0.1.34 

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

func (IngressType) String added in v0.1.34 

func (x IngressType) String() string

func (*IngressType) UnmarshalJSON added in v0.1.34 

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"`
	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) GetAllPodSpecs added in v0.1.23 

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

func (*Job) GetAnnotations 

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

func (*Job) GetClientId added in v0.1.28 

func (m *Job) GetClientId() string

func (*Job) GetCompressedQueueOwnershipUserGroups added in v0.3.30 

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

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

func (*Job) GetJobSetId 

func (m *Job) GetJobSetId() string

func (*Job) GetK8SIngress added in v0.3.0 

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

func (*Job) GetK8SService added in v0.3.0 

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

func (*Job) GetLabels 

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

func (*Job) GetNamespace 

func (m *Job) GetNamespace() string

func (*Job) GetOwner 

func (m *Job) GetOwner() string

func (*Job) GetPodSpec deprecated 

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

Deprecated: Do not use.

func (*Job) GetPodSpecs added in v0.1.23 

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

func (*Job) GetPriority 

func (m *Job) GetPriority() float64

func (*Job) GetQueue 

func (m *Job) GetQueue() string

func (*Job) GetQueueOwnershipUserGroups added in v0.1.37 

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

func (*Job) GetRequiredNodeLabels deprecated 

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

Deprecated: Do not use.

func (*Job) GetScheduler added in v0.3.32 

func (m *Job) GetScheduler() string

func (*Job) GetServices added in v0.2.14 

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

func (*Job) Marshal 

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

func (*Job) MarshalTo 

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

func (*Job) MarshalToSizedBuffer added in v0.1.16 

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

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

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

func (*Job) String 

func (this *Job) String() string

func (*Job) Unmarshal 

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

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type JobCancelRequest 

type JobCancelRequest struct {
	JobId    string   `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
	JobSetId string   `protobuf:"bytes,2,opt,name=job_set_id,json=jobSetId,proto3" json:"jobSetId,omitempty"`
	Queue    string   `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	JobIds   []string `protobuf:"bytes,4,rep,name=job_ids,json=jobIds,proto3" json:"jobIds,omitempty"`
}

swagger:model

func (*JobCancelRequest) Descriptor 

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

func (*JobCancelRequest) GetJobId 

func (m *JobCancelRequest) GetJobId() string

func (*JobCancelRequest) GetJobIds added in v0.3.44 

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

func (*JobCancelRequest) GetJobSetId 

func (m *JobCancelRequest) GetJobSetId() string

func (*JobCancelRequest) GetQueue 

func (m *JobCancelRequest) GetQueue() 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 added in v0.1.16 

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

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) GetRequestor added in v0.2.3 

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

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

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) GetRequestor added in v0.2.3 

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

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

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

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

func (*JobDuplicateFoundEvent) GetCreated added in v0.1.33 

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

func (*JobDuplicateFoundEvent) GetJobId added in v0.1.33 

func (m *JobDuplicateFoundEvent) GetJobId() string

func (*JobDuplicateFoundEvent) GetJobSetId added in v0.1.33 

func (m *JobDuplicateFoundEvent) GetJobSetId() string

func (*JobDuplicateFoundEvent) GetOriginalJobId added in v0.1.33 

func (m *JobDuplicateFoundEvent) GetOriginalJobId() string

func (*JobDuplicateFoundEvent) GetQueue added in v0.1.33 

func (m *JobDuplicateFoundEvent) GetQueue() string

func (*JobDuplicateFoundEvent) Marshal added in v0.1.33 

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

func (*JobDuplicateFoundEvent) MarshalTo added in v0.1.33 

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

func (*JobDuplicateFoundEvent) MarshalToSizedBuffer added in v0.1.33 

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

func (*JobDuplicateFoundEvent) ProtoMessage added in v0.1.33 

func (*JobDuplicateFoundEvent) ProtoMessage()

func (*JobDuplicateFoundEvent) Reset added in v0.1.33 

func (m *JobDuplicateFoundEvent) Reset()

func (*JobDuplicateFoundEvent) Size added in v0.1.33 

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

func (*JobDuplicateFoundEvent) String added in v0.1.33 

func (this *JobDuplicateFoundEvent) String() string

func (*JobDuplicateFoundEvent) Unmarshal added in v0.1.33 

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

func (*JobDuplicateFoundEvent) XXX_DiscardUnknown added in v0.1.33 

func (m *JobDuplicateFoundEvent) XXX_DiscardUnknown()

func (*JobDuplicateFoundEvent) XXX_Marshal added in v0.1.33 

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

func (*JobDuplicateFoundEvent) XXX_Merge added in v0.1.33 

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

func (*JobDuplicateFoundEvent) XXX_Size added in v0.1.33 

func (m *JobDuplicateFoundEvent) XXX_Size() int

func (*JobDuplicateFoundEvent) XXX_Unmarshal added in v0.1.33 

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

func (m *JobFailedEvent) GetCause() Cause

func (*JobFailedEvent) GetClusterId 

func (m *JobFailedEvent) GetClusterId() string

func (*JobFailedEvent) GetContainerStatuses added in v0.1.24 

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

func (m *JobFailedEvent) GetKubernetesId() string

func (*JobFailedEvent) GetNodeName added in v0.1.12 

func (m *JobFailedEvent) GetNodeName() string

func (*JobFailedEvent) GetPodName added in v0.1.36 

func (m *JobFailedEvent) GetPodName() string

func (*JobFailedEvent) GetPodNamespace added in v0.1.36 

func (m *JobFailedEvent) GetPodNamespace() string

func (*JobFailedEvent) GetPodNumber added in v0.1.23 

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

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

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

Only used internally by Armada

func (*JobFailedEventCompressed) Descriptor added in v0.3.25 

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

func (*JobFailedEventCompressed) GetEvent added in v0.3.25 

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

func (*JobFailedEventCompressed) Marshal added in v0.3.25 

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

func (*JobFailedEventCompressed) MarshalTo added in v0.3.25 

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

func (*JobFailedEventCompressed) MarshalToSizedBuffer added in v0.3.25 

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

func (*JobFailedEventCompressed) ProtoMessage added in v0.3.25 

func (*JobFailedEventCompressed) ProtoMessage()

func (*JobFailedEventCompressed) Reset added in v0.3.25 

func (m *JobFailedEventCompressed) Reset()

func (*JobFailedEventCompressed) Size added in v0.3.25 

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

func (*JobFailedEventCompressed) String added in v0.3.25 

func (this *JobFailedEventCompressed) String() string

func (*JobFailedEventCompressed) Unmarshal added in v0.3.25 

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

func (*JobFailedEventCompressed) XXX_DiscardUnknown added in v0.3.25 

func (m *JobFailedEventCompressed) XXX_DiscardUnknown()

func (*JobFailedEventCompressed) XXX_Marshal added in v0.3.25 

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

func (*JobFailedEventCompressed) XXX_Merge added in v0.3.25 

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

func (*JobFailedEventCompressed) XXX_Size added in v0.3.25 

func (m *JobFailedEventCompressed) XXX_Size() int

func (*JobFailedEventCompressed) XXX_Unmarshal added in v0.3.25 

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

type JobIngressInfoEvent added in v0.1.34 

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

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

func (*JobIngressInfoEvent) GetClusterId added in v0.1.34 

func (m *JobIngressInfoEvent) GetClusterId() string

func (*JobIngressInfoEvent) GetCreated added in v0.1.34 

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

func (*JobIngressInfoEvent) GetIngressAddresses added in v0.1.34 

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

func (*JobIngressInfoEvent) GetJobId added in v0.1.34 

func (m *JobIngressInfoEvent) GetJobId() string

func (*JobIngressInfoEvent) GetJobSetId added in v0.1.34 

func (m *JobIngressInfoEvent) GetJobSetId() string

func (*JobIngressInfoEvent) GetKubernetesId added in v0.1.34 

func (m *JobIngressInfoEvent) GetKubernetesId() string

func (*JobIngressInfoEvent) GetNodeName added in v0.1.34 

func (m *JobIngressInfoEvent) GetNodeName() string

func (*JobIngressInfoEvent) GetPodName added in v0.1.36 

func (m *JobIngressInfoEvent) GetPodName() string

func (*JobIngressInfoEvent) GetPodNamespace added in v0.1.36 

func (m *JobIngressInfoEvent) GetPodNamespace() string

func (*JobIngressInfoEvent) GetPodNumber added in v0.1.34 

func (m *JobIngressInfoEvent) GetPodNumber() int32

func (*JobIngressInfoEvent) GetQueue added in v0.1.34 

func (m *JobIngressInfoEvent) GetQueue() string

func (*JobIngressInfoEvent) Marshal added in v0.1.34 

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

func (*JobIngressInfoEvent) MarshalTo added in v0.1.34 

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

func (*JobIngressInfoEvent) MarshalToSizedBuffer added in v0.1.34 

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

func (*JobIngressInfoEvent) ProtoMessage added in v0.1.34 

func (*JobIngressInfoEvent) ProtoMessage()

func (*JobIngressInfoEvent) Reset added in v0.1.34 

func (m *JobIngressInfoEvent) Reset()

func (*JobIngressInfoEvent) Size added in v0.1.34 

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

func (*JobIngressInfoEvent) String added in v0.1.34 

func (this *JobIngressInfoEvent) String() string

func (*JobIngressInfoEvent) Unmarshal added in v0.1.34 

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

func (*JobIngressInfoEvent) XXX_DiscardUnknown added in v0.1.34 

func (m *JobIngressInfoEvent) XXX_DiscardUnknown()

func (*JobIngressInfoEvent) XXX_Marshal added in v0.1.34 

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

func (*JobIngressInfoEvent) XXX_Merge added in v0.1.34 

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

func (*JobIngressInfoEvent) XXX_Size added in v0.1.34 

func (m *JobIngressInfoEvent) XXX_Size() int

func (*JobIngressInfoEvent) XXX_Unmarshal added in v0.1.34 

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

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

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

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

func (m *JobLeaseReturnedEvent) GetKubernetesId() string

func (*JobLeaseReturnedEvent) GetPodNumber added in v0.2.11 

func (m *JobLeaseReturnedEvent) GetPodNumber() int32

func (*JobLeaseReturnedEvent) GetQueue 

func (m *JobLeaseReturnedEvent) GetQueue() string

func (*JobLeaseReturnedEvent) GetReason 

func (m *JobLeaseReturnedEvent) GetReason() string

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

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

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

func (m *JobPendingEvent) GetKubernetesId() string

func (*JobPendingEvent) GetPodName added in v0.1.36 

func (m *JobPendingEvent) GetPodName() string

func (*JobPendingEvent) GetPodNamespace added in v0.1.36 

func (m *JobPendingEvent) GetPodNamespace() string

func (*JobPendingEvent) GetPodNumber added in v0.1.23 

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

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

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

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

func (*JobPreemptedEvent) GetClusterId added in v0.3.33 

func (m *JobPreemptedEvent) GetClusterId() string

func (*JobPreemptedEvent) GetCreated added in v0.3.33 

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

func (*JobPreemptedEvent) GetJobId added in v0.3.33 

func (m *JobPreemptedEvent) GetJobId() string

func (*JobPreemptedEvent) GetJobSetId added in v0.3.33 

func (m *JobPreemptedEvent) GetJobSetId() string

func (*JobPreemptedEvent) GetPreemptiveJobId added in v0.3.33 

func (m *JobPreemptedEvent) GetPreemptiveJobId() string

func (*JobPreemptedEvent) GetPreemptiveRunId added in v0.3.33 

func (m *JobPreemptedEvent) GetPreemptiveRunId() string

func (*JobPreemptedEvent) GetQueue added in v0.3.33 

func (m *JobPreemptedEvent) GetQueue() string

func (*JobPreemptedEvent) GetRunId added in v0.3.33 

func (m *JobPreemptedEvent) GetRunId() string

func (*JobPreemptedEvent) Marshal added in v0.3.33 

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

func (*JobPreemptedEvent) MarshalTo added in v0.3.33 

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

func (*JobPreemptedEvent) MarshalToSizedBuffer added in v0.3.33 

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

func (*JobPreemptedEvent) ProtoMessage added in v0.3.33 

func (*JobPreemptedEvent) ProtoMessage()

func (*JobPreemptedEvent) Reset added in v0.3.33 

func (m *JobPreemptedEvent) Reset()

func (*JobPreemptedEvent) Size added in v0.3.33 

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

func (*JobPreemptedEvent) String added in v0.3.33 

func (this *JobPreemptedEvent) String() string

func (*JobPreemptedEvent) Unmarshal added in v0.3.33 

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

func (*JobPreemptedEvent) XXX_DiscardUnknown added in v0.3.33 

func (m *JobPreemptedEvent) XXX_DiscardUnknown()

func (*JobPreemptedEvent) XXX_Marshal added in v0.3.33 

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

func (*JobPreemptedEvent) XXX_Merge added in v0.3.33 

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

func (*JobPreemptedEvent) XXX_Size added in v0.3.33 

func (m *JobPreemptedEvent) XXX_Size() int

func (*JobPreemptedEvent) XXX_Unmarshal added in v0.3.33 

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

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

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

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

func (*JobReprioritizeRequest) GetJobIds added in v0.1.39 

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

func (*JobReprioritizeRequest) GetJobSetId added in v0.1.39 

func (m *JobReprioritizeRequest) GetJobSetId() string

func (*JobReprioritizeRequest) GetNewPriority added in v0.1.39 

func (m *JobReprioritizeRequest) GetNewPriority() float64

func (*JobReprioritizeRequest) GetQueue added in v0.1.39 

func (m *JobReprioritizeRequest) GetQueue() string

func (*JobReprioritizeRequest) Marshal added in v0.1.39 

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

func (*JobReprioritizeRequest) MarshalTo added in v0.1.39 

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

func (*JobReprioritizeRequest) MarshalToSizedBuffer added in v0.1.39 

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

func (*JobReprioritizeRequest) ProtoMessage added in v0.1.39 

func (*JobReprioritizeRequest) ProtoMessage()

func (*JobReprioritizeRequest) Reset added in v0.1.39 

func (m *JobReprioritizeRequest) Reset()

func (*JobReprioritizeRequest) Size added in v0.1.39 

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

func (*JobReprioritizeRequest) String added in v0.1.39 

func (this *JobReprioritizeRequest) String() string

func (*JobReprioritizeRequest) Unmarshal added in v0.1.39 

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

func (*JobReprioritizeRequest) XXX_DiscardUnknown added in v0.1.39 

func (m *JobReprioritizeRequest) XXX_DiscardUnknown()

func (*JobReprioritizeRequest) XXX_Marshal added in v0.1.39 

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

func (*JobReprioritizeRequest) XXX_Merge added in v0.1.39 

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

func (*JobReprioritizeRequest) XXX_Size added in v0.1.39 

func (m *JobReprioritizeRequest) XXX_Size() int

func (*JobReprioritizeRequest) XXX_Unmarshal added in v0.1.39 

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

type JobReprioritizeResponse added in v0.1.39 

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

swagger:model

func (*JobReprioritizeResponse) Descriptor added in v0.1.39 

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

func (*JobReprioritizeResponse) GetReprioritizationResults added in v0.1.39 

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

func (*JobReprioritizeResponse) Marshal added in v0.1.39 

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

func (*JobReprioritizeResponse) MarshalTo added in v0.1.39 

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

func (*JobReprioritizeResponse) MarshalToSizedBuffer added in v0.1.39 

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

func (*JobReprioritizeResponse) ProtoMessage added in v0.1.39 

func (*JobReprioritizeResponse) ProtoMessage()

func (*JobReprioritizeResponse) Reset added in v0.1.39 

func (m *JobReprioritizeResponse) Reset()

func (*JobReprioritizeResponse) Size added in v0.1.39 

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

func (*JobReprioritizeResponse) String added in v0.1.39 

func (this *JobReprioritizeResponse) String() string

func (*JobReprioritizeResponse) Unmarshal added in v0.1.39 

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

func (*JobReprioritizeResponse) XXX_DiscardUnknown added in v0.1.39 

func (m *JobReprioritizeResponse) XXX_DiscardUnknown()

func (*JobReprioritizeResponse) XXX_Marshal added in v0.1.39 

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

func (*JobReprioritizeResponse) XXX_Merge added in v0.1.39 

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

func (*JobReprioritizeResponse) XXX_Size added in v0.1.39 

func (m *JobReprioritizeResponse) XXX_Size() int

func (*JobReprioritizeResponse) XXX_Unmarshal added in v0.1.39 

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

func (m *JobReprioritizedEvent) GetNewPriority() float64

func (*JobReprioritizedEvent) GetQueue 

func (m *JobReprioritizedEvent) GetQueue() string

func (*JobReprioritizedEvent) GetRequestor added in v0.2.3 

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

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

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

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

func (*JobReprioritizingEvent) GetCreated added in v0.1.39 

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

func (*JobReprioritizingEvent) GetJobId added in v0.1.39 

func (m *JobReprioritizingEvent) GetJobId() string

func (*JobReprioritizingEvent) GetJobSetId added in v0.1.39 

func (m *JobReprioritizingEvent) GetJobSetId() string

func (*JobReprioritizingEvent) GetNewPriority added in v0.1.39 

func (m *JobReprioritizingEvent) GetNewPriority() float64

func (*JobReprioritizingEvent) GetQueue added in v0.1.39 

func (m *JobReprioritizingEvent) GetQueue() string

func (*JobReprioritizingEvent) GetRequestor added in v0.2.3 

func (m *JobReprioritizingEvent) GetRequestor() string

func (*JobReprioritizingEvent) Marshal added in v0.1.39 

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

func (*JobReprioritizingEvent) MarshalTo added in v0.1.39 

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

func (*JobReprioritizingEvent) MarshalToSizedBuffer added in v0.1.39 

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

func (*JobReprioritizingEvent) ProtoMessage added in v0.1.39 

func (*JobReprioritizingEvent) ProtoMessage()

func (*JobReprioritizingEvent) Reset added in v0.1.39 

func (m *JobReprioritizingEvent) Reset()

func (*JobReprioritizingEvent) Size added in v0.1.39 

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

func (*JobReprioritizingEvent) String added in v0.1.39 

func (this *JobReprioritizingEvent) String() string

func (*JobReprioritizingEvent) Unmarshal added in v0.1.39 

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

func (*JobReprioritizingEvent) XXX_DiscardUnknown added in v0.1.39 

func (m *JobReprioritizingEvent) XXX_DiscardUnknown()

func (*JobReprioritizingEvent) XXX_Marshal added in v0.1.39 

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

func (*JobReprioritizingEvent) XXX_Merge added in v0.1.39 

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

func (*JobReprioritizingEvent) XXX_Size added in v0.1.39 

func (m *JobReprioritizingEvent) XXX_Size() int

func (*JobReprioritizingEvent) XXX_Unmarshal added in v0.1.39 

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

func (m *JobRunningEvent) GetKubernetesId() string

func (*JobRunningEvent) GetNodeName added in v0.1.12 

func (m *JobRunningEvent) GetNodeName() string

func (*JobRunningEvent) GetPodName added in v0.1.36 

func (m *JobRunningEvent) GetPodName() string

func (*JobRunningEvent) GetPodNamespace added in v0.1.36 

func (m *JobRunningEvent) GetPodNamespace() string

func (*JobRunningEvent) GetPodNumber added in v0.1.23 

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

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

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

swagger:model

func (*JobSetCancelRequest) Descriptor added in v0.3.25 

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

func (*JobSetCancelRequest) GetFilter added in v0.3.25 

func (m *JobSetCancelRequest) GetFilter() *JobSetFilter

func (*JobSetCancelRequest) GetJobSetId added in v0.3.25 

func (m *JobSetCancelRequest) GetJobSetId() string

func (*JobSetCancelRequest) GetQueue added in v0.3.25 

func (m *JobSetCancelRequest) GetQueue() string

func (*JobSetCancelRequest) Marshal added in v0.3.25 

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

func (*JobSetCancelRequest) MarshalTo added in v0.3.25 

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

func (*JobSetCancelRequest) MarshalToSizedBuffer added in v0.3.25 

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

func (*JobSetCancelRequest) ProtoMessage added in v0.3.25 

func (*JobSetCancelRequest) ProtoMessage()

func (*JobSetCancelRequest) Reset added in v0.3.25 

func (m *JobSetCancelRequest) Reset()

func (*JobSetCancelRequest) Size added in v0.3.25 

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

func (*JobSetCancelRequest) String added in v0.3.25 

func (this *JobSetCancelRequest) String() string

func (*JobSetCancelRequest) Unmarshal added in v0.3.25 

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

func (*JobSetCancelRequest) XXX_DiscardUnknown added in v0.3.25 

func (m *JobSetCancelRequest) XXX_DiscardUnknown()

func (*JobSetCancelRequest) XXX_Marshal added in v0.3.25 

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

func (*JobSetCancelRequest) XXX_Merge added in v0.3.25 

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

func (*JobSetCancelRequest) XXX_Size added in v0.3.25 

func (m *JobSetCancelRequest) XXX_Size() int

func (*JobSetCancelRequest) XXX_Unmarshal added in v0.3.25 

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

type JobSetFilter added in v0.3.25 

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

swagger:model

func (*JobSetFilter) Descriptor added in v0.3.25 

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

func (*JobSetFilter) GetStates added in v0.3.25 

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

func (*JobSetFilter) Marshal added in v0.3.25 

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

func (*JobSetFilter) MarshalTo added in v0.3.25 

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

func (*JobSetFilter) MarshalToSizedBuffer added in v0.3.25 

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

func (*JobSetFilter) ProtoMessage added in v0.3.25 

func (*JobSetFilter) ProtoMessage()

func (*JobSetFilter) Reset added in v0.3.25 

func (m *JobSetFilter) Reset()

func (*JobSetFilter) Size added in v0.3.25 

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

func (*JobSetFilter) String added in v0.3.25 

func (this *JobSetFilter) String() string

func (*JobSetFilter) Unmarshal added in v0.3.25 

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

func (*JobSetFilter) XXX_DiscardUnknown added in v0.3.25 

func (m *JobSetFilter) XXX_DiscardUnknown()

func (*JobSetFilter) XXX_Marshal added in v0.3.25 

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

func (*JobSetFilter) XXX_Merge added in v0.3.25 

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

func (*JobSetFilter) XXX_Size added in v0.3.25 

func (m *JobSetFilter) XXX_Size() int

func (*JobSetFilter) XXX_Unmarshal added in v0.3.25 

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

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

func (m *JobSetRequest) GetErrorIfMissing() bool

func (*JobSetRequest) GetForceLegacy added in v0.3.30 

func (m *JobSetRequest) GetForceLegacy() bool

func (*JobSetRequest) GetForceNew added in v0.3.30 

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

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

type JobState int32

swagger:model 

const (
	JobState_QUEUED  JobState = 0
	JobState_PENDING JobState = 1
	JobState_RUNNING JobState = 2
)

func (JobState) EnumDescriptor added in v0.3.25 

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

func (JobState) String added in v0.3.25 

func (x JobState) String() string

func (*JobState) UnmarshalJSON added in v0.3.25 

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

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) GetAllPodSpecs added in v0.1.23 

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

func (*JobSubmitRequestItem) GetAnnotations 

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

func (*JobSubmitRequestItem) GetClientId added in v0.1.28 

func (m *JobSubmitRequestItem) GetClientId() string

func (*JobSubmitRequestItem) GetIngress added in v0.1.34 

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

func (*JobSubmitRequestItem) GetLabels 

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

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

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

func (m *JobSubmitRequestItem) GetScheduler() string

func (*JobSubmitRequestItem) GetServices added in v0.2.14 

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

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

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

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

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

func (m *JobSucceededEvent) GetKubernetesId() string

func (*JobSucceededEvent) GetNodeName added in v0.1.12 

func (m *JobSucceededEvent) GetNodeName() string

func (*JobSucceededEvent) GetPodName added in v0.1.36 

func (m *JobSucceededEvent) GetPodName() string

func (*JobSucceededEvent) GetPodNamespace added in v0.1.36 

func (m *JobSucceededEvent) GetPodNamespace() string

func (*JobSucceededEvent) GetPodNumber added in v0.1.23 

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

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

func (m *JobTerminatedEvent) GetKubernetesId() string

func (*JobTerminatedEvent) GetPodName added in v0.1.36 

func (m *JobTerminatedEvent) GetPodName() string

func (*JobTerminatedEvent) GetPodNamespace added in v0.1.36 

func (m *JobTerminatedEvent) GetPodNamespace() string

func (*JobTerminatedEvent) GetPodNumber added in v0.1.34 

func (m *JobTerminatedEvent) GetPodNumber() int32

func (*JobTerminatedEvent) GetQueue 

func (m *JobTerminatedEvent) GetQueue() string

func (*JobTerminatedEvent) GetReason added in v0.1.34 

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

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

func (m *JobUnableToScheduleEvent) GetKubernetesId() string

func (*JobUnableToScheduleEvent) GetNodeName added in v0.1.12 

func (m *JobUnableToScheduleEvent) GetNodeName() string

func (*JobUnableToScheduleEvent) GetPodName added in v0.1.36 

func (m *JobUnableToScheduleEvent) GetPodName() string

func (*JobUnableToScheduleEvent) GetPodNamespace added in v0.1.36 

func (m *JobUnableToScheduleEvent) GetPodNamespace() string

func (*JobUnableToScheduleEvent) GetPodNumber added in v0.1.23 

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

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

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

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

func (*JobUpdatedEvent) GetCreated added in v0.2.8 

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

func (*JobUpdatedEvent) GetJob added in v0.2.8 

func (m *JobUpdatedEvent) GetJob() Job

func (*JobUpdatedEvent) GetJobId added in v0.2.8 

func (m *JobUpdatedEvent) GetJobId() string

func (*JobUpdatedEvent) GetJobSetId added in v0.2.8 

func (m *JobUpdatedEvent) GetJobSetId() string

func (*JobUpdatedEvent) GetQueue added in v0.2.8 

func (m *JobUpdatedEvent) GetQueue() string

func (*JobUpdatedEvent) GetRequestor added in v0.2.8 

func (m *JobUpdatedEvent) GetRequestor() string

func (*JobUpdatedEvent) Marshal added in v0.2.8 

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

func (*JobUpdatedEvent) MarshalTo added in v0.2.8 

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

func (*JobUpdatedEvent) MarshalToSizedBuffer added in v0.2.8 

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

func (*JobUpdatedEvent) ProtoMessage added in v0.2.8 

func (*JobUpdatedEvent) ProtoMessage()

func (*JobUpdatedEvent) Reset added in v0.2.8 

func (m *JobUpdatedEvent) Reset()

func (*JobUpdatedEvent) Size added in v0.2.8 

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

func (*JobUpdatedEvent) String added in v0.2.8 

func (this *JobUpdatedEvent) String() string

func (*JobUpdatedEvent) Unmarshal added in v0.2.8 

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

func (*JobUpdatedEvent) XXX_DiscardUnknown added in v0.2.8 

func (m *JobUpdatedEvent) XXX_DiscardUnknown()

func (*JobUpdatedEvent) XXX_Marshal added in v0.2.8 

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

func (*JobUpdatedEvent) XXX_Merge added in v0.2.8 

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

func (*JobUpdatedEvent) XXX_Size added in v0.2.8 

func (m *JobUpdatedEvent) XXX_Size() int

func (*JobUpdatedEvent) XXX_Unmarshal added in v0.2.8 

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

type JobUtilisationEvent added in v0.1.9 

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

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

func (*JobUtilisationEvent) GetClusterId added in v0.1.9 

func (m *JobUtilisationEvent) GetClusterId() string

func (*JobUtilisationEvent) GetCreated added in v0.1.9 

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

func (*JobUtilisationEvent) GetJobId added in v0.1.9 

func (m *JobUtilisationEvent) GetJobId() string

func (*JobUtilisationEvent) GetJobSetId added in v0.1.9 

func (m *JobUtilisationEvent) GetJobSetId() string

func (*JobUtilisationEvent) GetKubernetesId added in v0.1.9 

func (m *JobUtilisationEvent) GetKubernetesId() string

func (*JobUtilisationEvent) GetMaxResourcesForPeriod added in v0.1.9 

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

func (*JobUtilisationEvent) GetNodeName added in v0.1.12 

func (m *JobUtilisationEvent) GetNodeName() string

func (*JobUtilisationEvent) GetPodName added in v0.1.36 

func (m *JobUtilisationEvent) GetPodName() string

func (*JobUtilisationEvent) GetPodNamespace added in v0.1.36 

func (m *JobUtilisationEvent) GetPodNamespace() string

func (*JobUtilisationEvent) GetPodNumber added in v0.1.23 

func (m *JobUtilisationEvent) GetPodNumber() int32

func (*JobUtilisationEvent) GetQueue added in v0.1.9 

func (m *JobUtilisationEvent) GetQueue() string

func (*JobUtilisationEvent) GetTotalCumulativeUsage added in v0.2.3 

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

func (*JobUtilisationEvent) Marshal added in v0.1.9 

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

func (*JobUtilisationEvent) MarshalTo added in v0.1.9 

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

func (*JobUtilisationEvent) MarshalToSizedBuffer added in v0.1.16 

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

func (*JobUtilisationEvent) ProtoMessage added in v0.1.9 

func (*JobUtilisationEvent) ProtoMessage()

func (*JobUtilisationEvent) Reset added in v0.1.9 

func (m *JobUtilisationEvent) Reset()

func (*JobUtilisationEvent) Size added in v0.1.9 

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

func (*JobUtilisationEvent) String added in v0.1.9 

func (this *JobUtilisationEvent) String() string

func (*JobUtilisationEvent) Unmarshal added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_DiscardUnknown added in v0.1.9 

func (m *JobUtilisationEvent) XXX_DiscardUnknown()

func (*JobUtilisationEvent) XXX_Marshal added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_Merge added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_Size added in v0.1.9 

func (m *JobUtilisationEvent) XXX_Size() int

func (*JobUtilisationEvent) XXX_Unmarshal added in v0.1.9 

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

type KubernetesEvent added in v0.1.16 

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

type NodeInfo added in v0.1.14 

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 */
}

Used by the scheduler when allocating jobs to executors.

func (*NodeInfo) Descriptor added in v0.1.14 

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

func (*NodeInfo) GetAllocatableResources added in v0.1.14 

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

func (*NodeInfo) GetAllocatedResources added in v0.3.29 

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

func (*NodeInfo) GetAvailableResources added in v0.1.14 

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

func (*NodeInfo) GetLabels added in v0.1.14 

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

func (*NodeInfo) GetName added in v0.1.14 

func (m *NodeInfo) GetName() string

func (*NodeInfo) GetTaints added in v0.1.14 

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

func (*NodeInfo) GetTotalResources added in v0.3.29 

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

func (*NodeInfo) Marshal added in v0.1.14 

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

func (*NodeInfo) MarshalTo added in v0.1.14 

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

func (*NodeInfo) MarshalToSizedBuffer added in v0.1.16 

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

func (*NodeInfo) ProtoMessage added in v0.1.14 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset added in v0.1.14 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size added in v0.1.14 

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

func (*NodeInfo) String added in v0.1.14 

func (this *NodeInfo) String() string

func (*NodeInfo) Unmarshal added in v0.1.14 

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

func (*NodeInfo) XXX_DiscardUnknown added in v0.1.14 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v0.1.14 

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

func (*NodeInfo) XXX_Merge added in v0.1.14 

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

func (*NodeInfo) XXX_Size added in v0.1.14 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v0.1.14 

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

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

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

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

func (*NodeType) GetAllocatableResources added in v0.1.14 

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

func (*NodeType) GetLabels added in v0.1.14 

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

func (*NodeType) GetTaints added in v0.1.14 

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

func (*NodeType) Marshal added in v0.1.14 

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

func (*NodeType) MarshalTo added in v0.1.14 

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

func (*NodeType) MarshalToSizedBuffer added in v0.1.16 

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

func (*NodeType) ProtoMessage added in v0.1.14 

func (*NodeType) ProtoMessage()

func (*NodeType) Reset added in v0.1.14 

func (m *NodeType) Reset()

func (*NodeType) Size added in v0.1.14 

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

func (*NodeType) String added in v0.1.14 

func (this *NodeType) String() string

func (*NodeType) Unmarshal added in v0.1.14 

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

func (*NodeType) XXX_DiscardUnknown added in v0.1.14 

func (m *NodeType) XXX_DiscardUnknown()

func (*NodeType) XXX_Marshal added in v0.1.14 

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

func (*NodeType) XXX_Merge added in v0.1.14 

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

func (*NodeType) XXX_Size added in v0.1.14 

func (m *NodeType) XXX_Size() int

func (*NodeType) XXX_Unmarshal added in v0.1.14 

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

type NodeTypeIdentifier added in v0.2.4 

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

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

func (*NodeTypeIdentifier) GetId added in v0.2.4 

func (m *NodeTypeIdentifier) GetId() string

func (*NodeTypeIdentifier) GetTaints added in v0.2.4 

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

func (*NodeTypeIdentifier) Marshal added in v0.2.4 

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

func (*NodeTypeIdentifier) MarshalTo added in v0.2.4 

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

func (*NodeTypeIdentifier) MarshalToSizedBuffer added in v0.2.4 

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

func (*NodeTypeIdentifier) ProtoMessage added in v0.2.4 

func (*NodeTypeIdentifier) ProtoMessage()

func (*NodeTypeIdentifier) Reset added in v0.2.4 

func (m *NodeTypeIdentifier) Reset()

func (*NodeTypeIdentifier) Size added in v0.2.4 

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

func (*NodeTypeIdentifier) String added in v0.2.4 

func (this *NodeTypeIdentifier) String() string

func (*NodeTypeIdentifier) Unmarshal added in v0.2.4 

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

func (*NodeTypeIdentifier) XXX_DiscardUnknown added in v0.2.4 

func (m *NodeTypeIdentifier) XXX_DiscardUnknown()

func (*NodeTypeIdentifier) XXX_Marshal added in v0.2.4 

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

func (*NodeTypeIdentifier) XXX_Merge added in v0.2.4 

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

func (*NodeTypeIdentifier) XXX_Size added in v0.2.4 

func (m *NodeTypeIdentifier) XXX_Size() int

func (*NodeTypeIdentifier) XXX_Unmarshal added in v0.2.4 

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

type NodeTypeUsageReport added in v0.2.4 

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

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

func (*NodeTypeUsageReport) GetAvailableCapacity added in v0.2.4 

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

func (*NodeTypeUsageReport) GetCapacity added in v0.2.4 

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

func (*NodeTypeUsageReport) GetCordonedUsage added in v0.2.15 

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

func (*NodeTypeUsageReport) GetNodeType added in v0.2.4 

func (m *NodeTypeUsageReport) GetNodeType() *NodeTypeIdentifier

func (*NodeTypeUsageReport) GetQueues added in v0.2.4 

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

func (*NodeTypeUsageReport) GetSchedulableNodes added in v0.3.8 

func (m *NodeTypeUsageReport) GetSchedulableNodes() int32

func (*NodeTypeUsageReport) GetTotalNodes added in v0.3.8 

func (m *NodeTypeUsageReport) GetTotalNodes() int32

func (*NodeTypeUsageReport) Marshal added in v0.2.4 

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

func (*NodeTypeUsageReport) MarshalTo added in v0.2.4 

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

func (*NodeTypeUsageReport) MarshalToSizedBuffer added in v0.2.4 

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

func (*NodeTypeUsageReport) ProtoMessage added in v0.2.4 

func (*NodeTypeUsageReport) ProtoMessage()

func (*NodeTypeUsageReport) Reset added in v0.2.4 

func (m *NodeTypeUsageReport) Reset()

func (*NodeTypeUsageReport) Size added in v0.2.4 

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

func (*NodeTypeUsageReport) String added in v0.2.4 

func (this *NodeTypeUsageReport) String() string

func (*NodeTypeUsageReport) Unmarshal added in v0.2.4 

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

func (*NodeTypeUsageReport) XXX_DiscardUnknown added in v0.2.4 

func (m *NodeTypeUsageReport) XXX_DiscardUnknown()

func (*NodeTypeUsageReport) XXX_Marshal added in v0.2.4 

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

func (*NodeTypeUsageReport) XXX_Merge added in v0.2.4 

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

func (*NodeTypeUsageReport) XXX_Size added in v0.2.4 

func (m *NodeTypeUsageReport) XXX_Size() int

func (*NodeTypeUsageReport) XXX_Unmarshal added in v0.2.4 

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

type OrderedStringMap added in v0.2.8 

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

func (*OrderedStringMap) Descriptor added in v0.2.8 

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

func (*OrderedStringMap) GetEntries added in v0.2.8 

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

func (*OrderedStringMap) Marshal added in v0.2.8 

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

func (*OrderedStringMap) MarshalTo added in v0.2.8 

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

func (*OrderedStringMap) MarshalToSizedBuffer added in v0.2.8 

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

func (*OrderedStringMap) ProtoMessage added in v0.2.8 

func (*OrderedStringMap) ProtoMessage()

func (*OrderedStringMap) Reset added in v0.2.8 

func (m *OrderedStringMap) Reset()

func (*OrderedStringMap) Size added in v0.2.8 

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

func (*OrderedStringMap) String added in v0.2.8 

func (this *OrderedStringMap) String() string

func (*OrderedStringMap) Unmarshal added in v0.2.8 

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

func (*OrderedStringMap) XXX_DiscardUnknown added in v0.2.8 

func (m *OrderedStringMap) XXX_DiscardUnknown()

func (*OrderedStringMap) XXX_Marshal added in v0.2.8 

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

func (*OrderedStringMap) XXX_Merge added in v0.2.8 

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

func (*OrderedStringMap) XXX_Size added in v0.2.8 

func (m *OrderedStringMap) XXX_Size() int

func (*OrderedStringMap) XXX_Unmarshal added in v0.2.8 

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

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

func (*Queue) GetPriorityFactor 

func (m *Queue) GetPriorityFactor() float64

func (*Queue) GetResourceLimits added in v0.1.6 

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

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

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

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

func (*QueueCreateResponse) GetError added in v0.3.15 

func (m *QueueCreateResponse) GetError() string

func (*QueueCreateResponse) GetQueue added in v0.3.15 

func (m *QueueCreateResponse) GetQueue() *Queue

func (*QueueCreateResponse) Marshal added in v0.3.15 

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

func (*QueueCreateResponse) MarshalTo added in v0.3.15 

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

func (*QueueCreateResponse) MarshalToSizedBuffer added in v0.3.15 

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

func (*QueueCreateResponse) ProtoMessage added in v0.3.15 

func (*QueueCreateResponse) ProtoMessage()

func (*QueueCreateResponse) Reset added in v0.3.15 

func (m *QueueCreateResponse) Reset()

func (*QueueCreateResponse) Size added in v0.3.15 

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

func (*QueueCreateResponse) String added in v0.3.15 

func (this *QueueCreateResponse) String() string

func (*QueueCreateResponse) Unmarshal added in v0.3.15 

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

func (*QueueCreateResponse) XXX_DiscardUnknown added in v0.3.15 

func (m *QueueCreateResponse) XXX_DiscardUnknown()

func (*QueueCreateResponse) XXX_Marshal added in v0.3.15 

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

func (*QueueCreateResponse) XXX_Merge added in v0.3.15 

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

func (*QueueCreateResponse) XXX_Size added in v0.3.15 

func (m *QueueCreateResponse) XXX_Size() int

func (*QueueCreateResponse) XXX_Unmarshal added in v0.3.15 

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

type QueueDeleteRequest added in v0.1.14 

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

func (*QueueDeleteRequest) Descriptor added in v0.1.14 

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

func (*QueueDeleteRequest) GetName added in v0.1.14 

func (m *QueueDeleteRequest) GetName() string

func (*QueueDeleteRequest) Marshal added in v0.1.14 

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

func (*QueueDeleteRequest) MarshalTo added in v0.1.14 

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

func (*QueueDeleteRequest) MarshalToSizedBuffer added in v0.1.16 

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

func (*QueueDeleteRequest) ProtoMessage added in v0.1.14 

func (*QueueDeleteRequest) ProtoMessage()

func (*QueueDeleteRequest) Reset added in v0.1.14 

func (m *QueueDeleteRequest) Reset()

func (*QueueDeleteRequest) Size added in v0.1.14 

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

func (*QueueDeleteRequest) String added in v0.1.14 

func (this *QueueDeleteRequest) String() string

func (*QueueDeleteRequest) Unmarshal added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_DiscardUnknown added in v0.1.14 

func (m *QueueDeleteRequest) XXX_DiscardUnknown()

func (*QueueDeleteRequest) XXX_Marshal added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_Merge added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_Size added in v0.1.14 

func (m *QueueDeleteRequest) XXX_Size() int

func (*QueueDeleteRequest) XXX_Unmarshal added in v0.1.14 

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

type QueueGetRequest added in v0.2.3 

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

func (*QueueGetRequest) Descriptor added in v0.2.3 

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

func (*QueueGetRequest) GetName added in v0.2.3 

func (m *QueueGetRequest) GetName() string

func (*QueueGetRequest) Marshal added in v0.2.3 

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

func (*QueueGetRequest) MarshalTo added in v0.2.3 

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

func (*QueueGetRequest) MarshalToSizedBuffer added in v0.2.3 

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

func (*QueueGetRequest) ProtoMessage added in v0.2.3 

func (*QueueGetRequest) ProtoMessage()

func (*QueueGetRequest) Reset added in v0.2.3 

func (m *QueueGetRequest) Reset()

func (*QueueGetRequest) Size added in v0.2.3 

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

func (*QueueGetRequest) String added in v0.2.3 

func (this *QueueGetRequest) String() string

func (*QueueGetRequest) Unmarshal added in v0.2.3 

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

func (*QueueGetRequest) XXX_DiscardUnknown added in v0.2.3 

func (m *QueueGetRequest) XXX_DiscardUnknown()

func (*QueueGetRequest) XXX_Marshal added in v0.2.3 

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

func (*QueueGetRequest) XXX_Merge added in v0.2.3 

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

func (*QueueGetRequest) XXX_Size added in v0.2.3 

func (m *QueueGetRequest) XXX_Size() int

func (*QueueGetRequest) XXX_Unmarshal added in v0.2.3 

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

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

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

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

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

func (*QueueLeasedReport) GetName added in v0.1.6 

func (m *QueueLeasedReport) GetName() string

func (*QueueLeasedReport) GetResourcesLeased added in v0.1.6 

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

func (*QueueLeasedReport) GetResourcesLeasedByPriority added in v0.3.35 

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

func (*QueueLeasedReport) Marshal added in v0.1.6 

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

func (*QueueLeasedReport) MarshalTo added in v0.1.6 

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

func (*QueueLeasedReport) MarshalToSizedBuffer added in v0.1.16 

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

func (*QueueLeasedReport) ProtoMessage added in v0.1.6 

func (*QueueLeasedReport) ProtoMessage()

func (*QueueLeasedReport) Reset added in v0.1.6 

func (m *QueueLeasedReport) Reset()

func (*QueueLeasedReport) Size added in v0.1.6 

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

func (*QueueLeasedReport) String added in v0.1.6 

func (this *QueueLeasedReport) String() string

func (*QueueLeasedReport) Unmarshal added in v0.1.6 

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

func (*QueueLeasedReport) XXX_DiscardUnknown added in v0.1.6 

func (m *QueueLeasedReport) XXX_DiscardUnknown()

func (*QueueLeasedReport) XXX_Marshal added in v0.1.6 

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

func (*QueueLeasedReport) XXX_Merge added in v0.1.6 

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

func (*QueueLeasedReport) XXX_Size added in v0.1.6 

func (m *QueueLeasedReport) XXX_Size() int

func (*QueueLeasedReport) XXX_Unmarshal added in v0.1.6 

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

type QueueList added in v0.3.15 

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

swagger:model

func (*QueueList) Descriptor added in v0.3.15 

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

func (*QueueList) GetQueues added in v0.3.15 

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

func (*QueueList) Marshal added in v0.3.15 

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

func (*QueueList) MarshalTo added in v0.3.15 

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

func (*QueueList) MarshalToSizedBuffer added in v0.3.15 

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

func (*QueueList) ProtoMessage added in v0.3.15 

func (*QueueList) ProtoMessage()

func (*QueueList) Reset added in v0.3.15 

func (m *QueueList) Reset()

func (*QueueList) Size added in v0.3.15 

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

func (*QueueList) String added in v0.3.15 

func (this *QueueList) String() string

func (*QueueList) Unmarshal added in v0.3.15 

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

func (*QueueList) XXX_DiscardUnknown added in v0.3.15 

func (m *QueueList) XXX_DiscardUnknown()

func (*QueueList) XXX_Marshal added in v0.3.15 

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

func (*QueueList) XXX_Merge added in v0.3.15 

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

func (*QueueList) XXX_Size added in v0.3.15 

func (m *QueueList) XXX_Size() int

func (*QueueList) XXX_Unmarshal added in v0.3.15 

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

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

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

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

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

func (*QueueUpdateResponse) GetError added in v0.3.15 

func (m *QueueUpdateResponse) GetError() string

func (*QueueUpdateResponse) GetQueue added in v0.3.15 

func (m *QueueUpdateResponse) GetQueue() *Queue

func (*QueueUpdateResponse) Marshal added in v0.3.15 

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

func (*QueueUpdateResponse) MarshalTo added in v0.3.15 

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

func (*QueueUpdateResponse) MarshalToSizedBuffer added in v0.3.15 

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

func (*QueueUpdateResponse) ProtoMessage added in v0.3.15 

func (*QueueUpdateResponse) ProtoMessage()

func (*QueueUpdateResponse) Reset added in v0.3.15 

func (m *QueueUpdateResponse) Reset()

func (*QueueUpdateResponse) Size added in v0.3.15 

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

func (*QueueUpdateResponse) String added in v0.3.15 

func (this *QueueUpdateResponse) String() string

func (*QueueUpdateResponse) Unmarshal added in v0.3.15 

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

func (*QueueUpdateResponse) XXX_DiscardUnknown added in v0.3.15 

func (m *QueueUpdateResponse) XXX_DiscardUnknown()

func (*QueueUpdateResponse) XXX_Marshal added in v0.3.15 

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

func (*QueueUpdateResponse) XXX_Merge added in v0.3.15 

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

func (*QueueUpdateResponse) XXX_Size added in v0.3.15 

func (m *QueueUpdateResponse) XXX_Size() int

func (*QueueUpdateResponse) XXX_Unmarshal added in v0.3.15 

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

type Queue_Permissions added in v0.2.18 

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

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

func (*Queue_Permissions) GetSubjects added in v0.2.18 

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

func (*Queue_Permissions) GetVerbs added in v0.2.18 

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

func (*Queue_Permissions) Marshal added in v0.2.18 

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

func (*Queue_Permissions) MarshalTo added in v0.2.18 

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

func (*Queue_Permissions) MarshalToSizedBuffer added in v0.2.18 

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

func (*Queue_Permissions) ProtoMessage added in v0.2.18 

func (*Queue_Permissions) ProtoMessage()

func (*Queue_Permissions) Reset added in v0.2.18 

func (m *Queue_Permissions) Reset()

func (*Queue_Permissions) Size added in v0.2.18 

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

func (*Queue_Permissions) String added in v0.2.18 

func (this *Queue_Permissions) String() string

func (*Queue_Permissions) Unmarshal added in v0.2.18 

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

func (*Queue_Permissions) XXX_DiscardUnknown added in v0.2.18 

func (m *Queue_Permissions) XXX_DiscardUnknown()

func (*Queue_Permissions) XXX_Marshal added in v0.2.18 

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

func (*Queue_Permissions) XXX_Merge added in v0.2.18 

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

func (*Queue_Permissions) XXX_Size added in v0.2.18 

func (m *Queue_Permissions) XXX_Size() int

func (*Queue_Permissions) XXX_Unmarshal added in v0.2.18 

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

type Queue_Permissions_Subject added in v0.2.18 

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

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

func (*Queue_Permissions_Subject) GetKind added in v0.2.18 

func (m *Queue_Permissions_Subject) GetKind() string

func (*Queue_Permissions_Subject) GetName added in v0.2.18 

func (m *Queue_Permissions_Subject) GetName() string

func (*Queue_Permissions_Subject) Marshal added in v0.2.18 

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

func (*Queue_Permissions_Subject) MarshalTo added in v0.2.18 

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

func (*Queue_Permissions_Subject) MarshalToSizedBuffer added in v0.2.18 

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

func (*Queue_Permissions_Subject) ProtoMessage added in v0.2.18 

func (*Queue_Permissions_Subject) ProtoMessage()

func (*Queue_Permissions_Subject) Reset added in v0.2.18 

func (m *Queue_Permissions_Subject) Reset()

func (*Queue_Permissions_Subject) Size added in v0.2.18 

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

func (*Queue_Permissions_Subject) String added in v0.2.18 

func (this *Queue_Permissions_Subject) String() string

func (*Queue_Permissions_Subject) Unmarshal added in v0.2.18 

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

func (*Queue_Permissions_Subject) XXX_DiscardUnknown added in v0.2.18 

func (m *Queue_Permissions_Subject) XXX_DiscardUnknown()

func (*Queue_Permissions_Subject) XXX_Marshal added in v0.2.18 

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

func (*Queue_Permissions_Subject) XXX_Merge added in v0.2.18 

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

func (*Queue_Permissions_Subject) XXX_Size added in v0.2.18 

func (m *Queue_Permissions_Subject) XXX_Size() int

func (*Queue_Permissions_Subject) XXX_Unmarshal added in v0.2.18 

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

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

func (*ReturnLeaseRequest) Descriptor 

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

func (*ReturnLeaseRequest) GetAvoidNodeLabels added in v0.2.6 

func (m *ReturnLeaseRequest) GetAvoidNodeLabels() *OrderedStringMap

func (*ReturnLeaseRequest) GetClusterId 

func (m *ReturnLeaseRequest) GetClusterId() string

func (*ReturnLeaseRequest) GetJobId 

func (m *ReturnLeaseRequest) GetJobId() string

func (*ReturnLeaseRequest) GetJobRunAttempted added in v0.3.45 

func (m *ReturnLeaseRequest) GetJobRunAttempted() bool

func (*ReturnLeaseRequest) GetKubernetesId added in v0.3.20 

func (m *ReturnLeaseRequest) GetKubernetesId() string

func (*ReturnLeaseRequest) GetReason added in v0.3.20 

func (m *ReturnLeaseRequest) GetReason() 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 added in v0.1.16 

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

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

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

func (*ServiceConfig) GetPorts added in v0.2.14 

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

func (*ServiceConfig) GetType added in v0.2.14 

func (m *ServiceConfig) GetType() ServiceType

func (*ServiceConfig) Marshal added in v0.2.14 

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

func (*ServiceConfig) MarshalTo added in v0.2.14 

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

func (*ServiceConfig) MarshalToSizedBuffer added in v0.2.14 

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

func (*ServiceConfig) ProtoMessage added in v0.2.14 

func (*ServiceConfig) ProtoMessage()

func (*ServiceConfig) Reset added in v0.2.14 

func (m *ServiceConfig) Reset()

func (*ServiceConfig) Size added in v0.2.14 

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

func (*ServiceConfig) String added in v0.2.14 

func (this *ServiceConfig) String() string

func (*ServiceConfig) Unmarshal added in v0.2.14 

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

func (*ServiceConfig) XXX_DiscardUnknown added in v0.2.14 

func (m *ServiceConfig) XXX_DiscardUnknown()

func (*ServiceConfig) XXX_Marshal added in v0.2.14 

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

func (*ServiceConfig) XXX_Merge added in v0.2.14 

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

func (*ServiceConfig) XXX_Size added in v0.2.14 

func (m *ServiceConfig) XXX_Size() int

func (*ServiceConfig) XXX_Unmarshal added in v0.2.14 

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

type ServiceType added in v0.2.14 

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

func (ServiceType) EnumDescriptor added in v0.2.14 

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

func (ServiceType) String added in v0.2.14 

func (x ServiceType) String() string

func (*ServiceType) UnmarshalJSON added in v0.2.14 

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

type StreamingJobLease added in v0.3.15 

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

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

func (*StreamingJobLease) GetJob added in v0.3.15 

func (m *StreamingJobLease) GetJob() *Job

func (*StreamingJobLease) GetNumAcked added in v0.3.15 

func (m *StreamingJobLease) GetNumAcked() uint32

func (*StreamingJobLease) GetNumJobs added in v0.3.15 

func (m *StreamingJobLease) GetNumJobs() uint32

func (*StreamingJobLease) Marshal added in v0.3.15 

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

func (*StreamingJobLease) MarshalTo added in v0.3.15 

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

func (*StreamingJobLease) MarshalToSizedBuffer added in v0.3.15 

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

func (*StreamingJobLease) ProtoMessage added in v0.3.15 

func (*StreamingJobLease) ProtoMessage()

func (*StreamingJobLease) Reset added in v0.3.15 

func (m *StreamingJobLease) Reset()

func (*StreamingJobLease) Size added in v0.3.15 

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

func (*StreamingJobLease) String added in v0.3.15 

func (this *StreamingJobLease) String() string

func (*StreamingJobLease) Unmarshal added in v0.3.15 

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

func (*StreamingJobLease) XXX_DiscardUnknown added in v0.3.15 

func (m *StreamingJobLease) XXX_DiscardUnknown()

func (*StreamingJobLease) XXX_Marshal added in v0.3.15 

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

func (*StreamingJobLease) XXX_Merge added in v0.3.15 

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

func (*StreamingJobLease) XXX_Size added in v0.3.15 

func (m *StreamingJobLease) XXX_Size() int

func (*StreamingJobLease) XXX_Unmarshal added in v0.3.15 

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

type StreamingLeaseRequest added in v0.3.15 

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

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

func (*StreamingLeaseRequest) GetClusterId added in v0.3.15 

func (m *StreamingLeaseRequest) GetClusterId() string

func (*StreamingLeaseRequest) GetClusterLeasedReport added in v0.3.15 

func (m *StreamingLeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

func (*StreamingLeaseRequest) GetMinimumJobSize added in v0.3.15 

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

func (*StreamingLeaseRequest) GetNodes added in v0.3.15 

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

func (*StreamingLeaseRequest) GetPool added in v0.3.15 

func (m *StreamingLeaseRequest) GetPool() string

func (*StreamingLeaseRequest) GetReceivedJobIds added in v0.3.15 

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

func (*StreamingLeaseRequest) GetResources added in v0.3.15 

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

func (*StreamingLeaseRequest) Marshal added in v0.3.15 

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

func (*StreamingLeaseRequest) MarshalTo added in v0.3.15 

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

func (*StreamingLeaseRequest) MarshalToSizedBuffer added in v0.3.15 

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

func (*StreamingLeaseRequest) ProtoMessage added in v0.3.15 

func (*StreamingLeaseRequest) ProtoMessage()

func (*StreamingLeaseRequest) Reset added in v0.3.15 

func (m *StreamingLeaseRequest) Reset()

func (*StreamingLeaseRequest) Size added in v0.3.15 

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

func (*StreamingLeaseRequest) String added in v0.3.15 

func (this *StreamingLeaseRequest) String() string

func (*StreamingLeaseRequest) Unmarshal added in v0.3.15 

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

func (*StreamingLeaseRequest) XXX_DiscardUnknown added in v0.3.15 

func (m *StreamingLeaseRequest) XXX_DiscardUnknown()

func (*StreamingLeaseRequest) XXX_Marshal added in v0.3.15 

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

func (*StreamingLeaseRequest) XXX_Merge added in v0.3.15 

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

func (*StreamingLeaseRequest) XXX_Size added in v0.3.15 

func (m *StreamingLeaseRequest) XXX_Size() int

func (*StreamingLeaseRequest) XXX_Unmarshal added in v0.3.15 

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

type StringKeyValuePair added in v0.2.8 

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

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

func (*StringKeyValuePair) GetKey added in v0.2.8 

func (m *StringKeyValuePair) GetKey() string

func (*StringKeyValuePair) GetValue added in v0.2.8 

func (m *StringKeyValuePair) GetValue() string

func (*StringKeyValuePair) Marshal added in v0.2.8 

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

func (*StringKeyValuePair) MarshalTo added in v0.2.8 

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

func (*StringKeyValuePair) MarshalToSizedBuffer added in v0.2.8 

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

func (*StringKeyValuePair) ProtoMessage added in v0.2.8 

func (*StringKeyValuePair) ProtoMessage()

func (*StringKeyValuePair) Reset added in v0.2.8 

func (m *StringKeyValuePair) Reset()

func (*StringKeyValuePair) Size added in v0.2.8 

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

func (*StringKeyValuePair) String added in v0.2.8 

func (this *StringKeyValuePair) String() string

func (*StringKeyValuePair) Unmarshal added in v0.2.8 

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

func (*StringKeyValuePair) XXX_DiscardUnknown added in v0.2.8 

func (m *StringKeyValuePair) XXX_DiscardUnknown()

func (*StringKeyValuePair) XXX_Marshal added in v0.2.8 

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

func (*StringKeyValuePair) XXX_Merge added in v0.2.8 

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

func (*StringKeyValuePair) XXX_Size added in v0.2.8 

func (m *StringKeyValuePair) XXX_Size() int

func (*StringKeyValuePair) XXX_Unmarshal added in v0.2.8 

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 SubmitServer 

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

SubmitServer is the server API for Submit service.

type TestSpec added in v0.3.15 

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

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

func (*TestSpec) GetBatchSize added in v0.3.15 

func (m *TestSpec) GetBatchSize() uint32

func (*TestSpec) GetCancel added in v0.3.15 

func (m *TestSpec) GetCancel() TestSpec_Cancel

func (*TestSpec) GetExpectedEvents added in v0.3.15 

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

func (*TestSpec) GetGetLogs added in v0.3.28 

func (m *TestSpec) GetGetLogs() bool

func (*TestSpec) GetInterval added in v0.3.15 

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

func (*TestSpec) GetJobSetId added in v0.3.15 

func (m *TestSpec) GetJobSetId() string

func (*TestSpec) GetJobs added in v0.3.15 

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

func (*TestSpec) GetName added in v0.3.15 

func (m *TestSpec) GetName() string

func (*TestSpec) GetNumBatches added in v0.3.15 

func (m *TestSpec) GetNumBatches() uint32

func (*TestSpec) GetQueue added in v0.3.15 

func (m *TestSpec) GetQueue() string

func (*TestSpec) GetRandomClientId added in v0.3.26 

func (m *TestSpec) GetRandomClientId() bool

func (*TestSpec) GetTimeout added in v0.3.15 

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

func (*TestSpec) Marshal added in v0.3.15 

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

func (*TestSpec) MarshalTo added in v0.3.15 

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

func (*TestSpec) MarshalToSizedBuffer added in v0.3.15 

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

func (*TestSpec) ProtoMessage added in v0.3.15 

func (*TestSpec) ProtoMessage()

func (*TestSpec) Reset added in v0.3.15 

func (m *TestSpec) Reset()

func (*TestSpec) ShortString added in v0.3.44 

func (testSpec *TestSpec) ShortString() string

func (*TestSpec) Size added in v0.3.15 

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

func (*TestSpec) String added in v0.3.15 

func (this *TestSpec) String() string

func (*TestSpec) Unmarshal added in v0.3.15 

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

func (*TestSpec) XXX_DiscardUnknown added in v0.3.15 

func (m *TestSpec) XXX_DiscardUnknown()

func (*TestSpec) XXX_Marshal added in v0.3.15 

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

func (*TestSpec) XXX_Merge added in v0.3.15 

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

func (*TestSpec) XXX_Size added in v0.3.15 

func (m *TestSpec) XXX_Size() int

func (*TestSpec) XXX_Unmarshal added in v0.3.15 

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

type TestSpec_Cancel added in v0.3.15 

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

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

func (TestSpec_Cancel) String added in v0.3.15 

func (x TestSpec_Cancel) String() string

type UnimplementedAggregatedQueueServer added in v0.1.16 

type UnimplementedAggregatedQueueServer struct {
}

UnimplementedAggregatedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedAggregatedQueueServer) RenewLease added in v0.1.16 

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

func (*UnimplementedAggregatedQueueServer) ReportDone added in v0.1.16 

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

func (*UnimplementedAggregatedQueueServer) ReturnLease added in v0.1.16 

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

func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs added in v0.3.15 

func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs(srv AggregatedQueue_StreamingLeaseJobsServer) error

type UnimplementedEventServer added in v0.1.16 

type UnimplementedEventServer struct {
}

UnimplementedEventServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServer) GetJobSetEvents added in v0.1.16 

func (*UnimplementedEventServer) GetJobSetEvents(req *JobSetRequest, srv Event_GetJobSetEventsServer) error

func (*UnimplementedEventServer) Health added in v0.3.35 

func (*UnimplementedEventServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)

func (*UnimplementedEventServer) Report added in v0.1.16 

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

func (*UnimplementedEventServer) ReportMultiple added in v0.1.16 

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

func (*UnimplementedEventServer) Watch added in v0.2.11 

func (*UnimplementedEventServer) Watch(req *WatchRequest, srv Event_WatchServer) error

type UnimplementedSubmitServer added in v0.1.16 

type UnimplementedSubmitServer struct {
}

UnimplementedSubmitServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubmitServer) CancelJobSet added in v0.3.25 

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

func (*UnimplementedSubmitServer) CancelJobs added in v0.1.16 

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

func (*UnimplementedSubmitServer) CreateQueue added in v0.1.16 

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

func (*UnimplementedSubmitServer) CreateQueues added in v0.3.15 

func (*UnimplementedSubmitServer) CreateQueues(ctx context.Context, req *QueueList) (*BatchQueueCreateResponse, error)

func (*UnimplementedSubmitServer) DeleteQueue added in v0.1.16 

func (*UnimplementedSubmitServer) DeleteQueue(ctx context.Context, req *QueueDeleteRequest) (*types.Empty, error)

func (*UnimplementedSubmitServer) GetQueue added in v0.2.3 

func (*UnimplementedSubmitServer) GetQueue(ctx context.Context, req *QueueGetRequest) (*Queue, error)

func (*UnimplementedSubmitServer) GetQueueInfo added in v0.1.16 

func (*UnimplementedSubmitServer) GetQueueInfo(ctx context.Context, req *QueueInfoRequest) (*QueueInfo, error)

func (*UnimplementedSubmitServer) Health added in v0.3.35 

func (*UnimplementedSubmitServer) Health(ctx context.Context, req *types.Empty) (*HealthCheckResponse, error)

func (*UnimplementedSubmitServer) ReprioritizeJobs added in v0.1.39 

func (*UnimplementedSubmitServer) ReprioritizeJobs(ctx context.Context, req *JobReprioritizeRequest) (*JobReprioritizeResponse, error)

func (*UnimplementedSubmitServer) SubmitJobs added in v0.1.16 

func (*UnimplementedSubmitServer) SubmitJobs(ctx context.Context, req *JobSubmitRequest) (*JobSubmitResponse, error)

func (*UnimplementedSubmitServer) UpdateQueue added in v0.2.3 

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

func (*UnimplementedSubmitServer) UpdateQueues added in v0.3.15 

func (*UnimplementedSubmitServer) UpdateQueues(ctx context.Context, req *QueueList) (*BatchQueueUpdateResponse, error)

type UnimplementedUsageServer added in v0.1.16 

type UnimplementedUsageServer struct {
}

UnimplementedUsageServer can be embedded to have forward compatible implementations.

func (*UnimplementedUsageServer) ReportUsage added in v0.1.16 

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

type UsageClient 

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

UsageClient is the client API for Usage service.

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

func NewUsageClient 

func NewUsageClient(cc *grpc.ClientConn) UsageClient

type UsageServer 

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

UsageServer is the server API for Usage service.

type WatchRequest added in v0.2.11 

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

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

func (*WatchRequest) GetForceLegacy added in v0.3.30 

func (m *WatchRequest) GetForceLegacy() bool

func (*WatchRequest) GetForceNew added in v0.3.30 

func (m *WatchRequest) GetForceNew() bool

func (*WatchRequest) GetFromId added in v0.2.11 

func (m *WatchRequest) GetFromId() string

func (*WatchRequest) GetJobSetId added in v0.2.11 

func (m *WatchRequest) GetJobSetId() string

func (*WatchRequest) GetQueue added in v0.2.11 

func (m *WatchRequest) GetQueue() string

func (*WatchRequest) Marshal added in v0.2.11 

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

func (*WatchRequest) MarshalTo added in v0.2.11 

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

func (*WatchRequest) MarshalToSizedBuffer added in v0.2.11 

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

func (*WatchRequest) ProtoMessage added in v0.2.11 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset added in v0.2.11 

func (m *WatchRequest) Reset()

func (*WatchRequest) Size added in v0.2.11 

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

func (*WatchRequest) String added in v0.2.11 

func (this *WatchRequest) String() string

func (*WatchRequest) Unmarshal added in v0.2.11 

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

func (*WatchRequest) XXX_DiscardUnknown added in v0.2.11 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal added in v0.2.11 

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

func (*WatchRequest) XXX_Merge added in v0.2.11 

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

func (*WatchRequest) XXX_Size added in v0.2.11 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal added in v0.2.11 

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

Source Files

View all Source files

Directories

Path Synopsis
Package binoculars is a reverse proxy.
 Package binoculars is a reverse proxy.
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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.