api

package
v0.2.11 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2021 License: Apache-2.0 Imports: 27 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 (
	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 (
	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 IngressType_name = map[int32]string{
	0: "NodePort",
	1: "Ingress",
}
View Source 
var IngressType_value = map[string]int32{
	"NodePort": 0,
	"Ingress":  1,
}

Functions

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 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 {
	LeaseJobs(ctx context.Context, in *LeaseRequest, opts ...grpc.CallOption) (*JobLease, 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 {
	LeaseJobs(context.Context, *LeaseRequest) (*JobLease, 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 CancellationResult 

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

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:"report_time"`
	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:"report_time"`
	NodeTypes      []*NodeType                  `protobuf:"bytes,5,rep,name=node_types,json=nodeTypes,proto3" json:"nodeTypes,omitempty"`
	MinimumJobSize map[string]resource.Quantity `` /* 160-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:"report_time"`
	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.
	/* 162-byte string literal not displayed */
	ClusterAvailableCapacity map[string]resource.Quantity `` // Deprecated: Do not use.
	/* 190-byte string literal not displayed */
	NodeTypeUsageReports []NodeTypeUsageReport `protobuf:"bytes,7,rep,name=node_type_usage_reports,json=nodeTypeUsageReports,proto3" json:"node_type_usage_reports"`
}

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

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

customize oneof serialization

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

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 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"`
	Ports       []uint32          `protobuf:"varint,2,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	Annotations map[string]string `` /* 163-byte string literal not displayed */
}

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

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

func (*IngressConfig) GetType added in v0.1.34 

func (m *IngressConfig) GetType() IngressType

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
const (
	IngressType_NodePort IngressType = 0
	IngressType_Ingress  IngressType = 1
)

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 */
	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"`
	Ingress                  []*IngressConfig `protobuf:"bytes,14,rep,name=ingress,proto3" json:"ingress,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) 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) 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) 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"`
}

swagger:model

func (*JobCancelRequest) Descriptor 

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

func (*JobCancelRequest) GetJobId 

func (m *JobCancelRequest) GetJobId() 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 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 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 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"`
}

swagger:model

func (*JobSetRequest) Descriptor 

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

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

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) 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 `` /* 179-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 LeaseRequest 

type LeaseRequest struct {
	ClusterId           string                       `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"clusterId,omitempty"`
	Pool                string                       `protobuf:"bytes,8,opt,name=pool,proto3" json:"pool,omitempty"`
	Resources           map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	ClusterLeasedReport ClusterLeasedReport          `protobuf:"bytes,4,opt,name=cluster_leased_report,json=clusterLeasedReport,proto3" json:"cluster_leased_report"`
	MinimumJobSize      map[string]resource.Quantity `` /* 160-byte string literal not displayed */
	Nodes               []NodeInfo                   `protobuf:"bytes,7,rep,name=nodes,proto3" json:"nodes"`
}

func (*LeaseRequest) Descriptor 

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

func (*LeaseRequest) GetClusterId 

func (m *LeaseRequest) GetClusterId() string

func (*LeaseRequest) GetClusterLeasedReport added in v0.1.6 

func (m *LeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

func (*LeaseRequest) GetMinimumJobSize added in v0.1.6 

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

func (*LeaseRequest) GetNodes added in v0.1.14 

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

func (*LeaseRequest) GetPool added in v0.1.24 

func (m *LeaseRequest) GetPool() string

func (*LeaseRequest) GetResources 

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

func (*LeaseRequest) Marshal 

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

func (*LeaseRequest) MarshalTo 

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

func (*LeaseRequest) MarshalToSizedBuffer added in v0.1.16 

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

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) Reset 

func (m *LeaseRequest) Reset()

func (*LeaseRequest) Size 

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

func (*LeaseRequest) String 

func (this *LeaseRequest) String() string

func (*LeaseRequest) Unmarshal 

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

func (*LeaseRequest) XXX_DiscardUnknown 

func (m *LeaseRequest) XXX_DiscardUnknown()

func (*LeaseRequest) XXX_Marshal 

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

func (*LeaseRequest) XXX_Merge 

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

func (*LeaseRequest) XXX_Size 

func (m *LeaseRequest) XXX_Size() int

func (*LeaseRequest) XXX_Unmarshal 

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

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 */
	AllocatableResources map[string]resource.Quantity `` /* 177-byte string literal not displayed */
	AvailableResources   map[string]resource.Quantity `` /* 171-byte string literal not displayed */
}

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) 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) 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 `` /* 177-byte string literal not displayed */
}

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 `` /* 168-byte string literal not displayed */
	Queues            []*QueueReport               `protobuf:"bytes,4,rep,name=queues,proto3" json:"queues,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) 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) 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 */
}

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) 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 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 {
	Name            string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ResourcesLeased map[string]resource.Quantity `` /* 162-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) 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 QueueReport 

type QueueReport struct {
	Name               string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Resources          map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	ResourcesUsed      map[string]resource.Quantity `` /* 156-byte string literal not displayed */
	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 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"`
}

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) 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 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)
	ReprioritizeJobs(ctx context.Context, in *JobReprioritizeRequest, opts ...grpc.CallOption) (*JobReprioritizeResponse, error)
	CreateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error)
	UpdateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, 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)
}

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)
	ReprioritizeJobs(context.Context, *JobReprioritizeRequest) (*JobReprioritizeResponse, error)
	CreateQueue(context.Context, *Queue) (*types.Empty, error)
	UpdateQueue(context.Context, *Queue) (*types.Empty, error)
	DeleteQueue(context.Context, *QueueDeleteRequest) (*types.Empty, error)
	GetQueue(context.Context, *QueueGetRequest) (*Queue, error)
	GetQueueInfo(context.Context, *QueueInfoRequest) (*QueueInfo, error)
}

SubmitServer is the server API for Submit service.

type UnimplementedAggregatedQueueServer added in v0.1.16 

type UnimplementedAggregatedQueueServer struct {
}

UnimplementedAggregatedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedAggregatedQueueServer) LeaseJobs added in v0.1.16 

func (*UnimplementedAggregatedQueueServer) LeaseJobs(ctx context.Context, req *LeaseRequest) (*JobLease, error)

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)

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

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

func (*WatchRequest) Descriptor added in v0.2.11 

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

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.