api

package

Go to main page

Versions in this module

v0

v0.1.1

Mar 3, 2020

v0.1.0

Feb 28, 2020

Changes in this version

type JobSetRequest

+ Queue string

+ func (m *JobSetRequest) GetQueue() string

v0.0.11

Feb 20, 2020

Changes in this version

type EventClient

+ ReportMultiple func(ctx context.Context, in *EventList, opts ...grpc.CallOption) (*types.Empty, error)

+ type EventList struct

+ Events []*EventMessage

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

+ func (*EventList) ProtoMessage()

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

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

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

+ func (m *EventList) Reset()

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

+ func (m *EventList) String() string

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

+ func (m *EventList) XXX_DiscardUnknown()

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

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

+ func (m *EventList) XXX_Size() int

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

type EventServer

+ ReportMultiple func(context.Context, *EventList) (*types.Empty, error)

v0.0.10

Dec 20, 2019

v0.0.9

Dec 20, 2019

v0.0.8

Dec 19, 2019

v0.0.7

Dec 17, 2019

v0.0.6

Dec 17, 2019

Changes in this version

type Job

+ RequiredNodeLabels map[string]string

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

type JobFailedEvent

+ ExitCodes map[string]int32

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

type JobSubmitRequestItem

+ RequiredNodeLabels map[string]string

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

type LeaseRequest

+ AvailableLabels []*NodeLabeling

+ func (m *LeaseRequest) GetAvailableLabels() []*NodeLabeling

+ type NodeLabeling struct

+ Labels map[string]string

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

+ func (*NodeLabeling) ProtoMessage()

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

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

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

+ func (m *NodeLabeling) Reset()

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

+ func (m *NodeLabeling) String() string

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

+ func (m *NodeLabeling) XXX_DiscardUnknown()

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

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

+ func (m *NodeLabeling) XXX_Size() int

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

v0.0.5

Dec 5, 2019

Changes in this version

type Job

+ Annotations map[string]string

+ Labels map[string]string

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

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

type JobSubmitRequestItem

+ Annotations map[string]string

+ Labels map[string]string

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

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

v0.0.4

Nov 15, 2019

v0.0.3

Nov 15, 2019

Changes in this version

+ func RegisterEventHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterEventHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventClient) error

+ func RegisterEventHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterEventHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServer) error

+ func RegisterSubmitHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterSubmitHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubmitClient) error

+ func RegisterSubmitHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterSubmitHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubmitServer) error

+ func SwaggerJsonTemplate() string

type EventMessage

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

+ func (message *EventMessage) UnmarshalJSON(data []byte) error

type Job

+ Namespace string

+ Owner string

+ func (m *Job) GetNamespace() string

+ func (m *Job) GetOwner() string

+ type JobSubmitRequest struct

+ JobRequestItems []*JobSubmitRequestItem

+ JobSetId string

+ Queue string

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

+ func (*JobSubmitRequest) ProtoMessage()

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

+ func (m *JobSubmitRequest) GetJobSetId() string

+ func (m *JobSubmitRequest) GetQueue() string

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

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

+ func (m *JobSubmitRequest) Reset()

+ func (m *JobSubmitRequest) Size() (n int)

+ func (m *JobSubmitRequest) String() string

+ func (m *JobSubmitRequest) Unmarshal(dAtA []byte) error

+ func (m *JobSubmitRequest) XXX_DiscardUnknown()

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

+ func (m *JobSubmitRequest) XXX_Merge(src proto.Message)

+ func (m *JobSubmitRequest) XXX_Size() int

+ func (m *JobSubmitRequest) XXX_Unmarshal(b []byte) error

+ type JobSubmitRequestItem struct

+ Namespace string

+ PodSpec *v1.PodSpec

+ Priority float64

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

+ func (*JobSubmitRequestItem) ProtoMessage()

+ func (m *JobSubmitRequestItem) GetNamespace() string

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

+ func (m *JobSubmitRequestItem) GetPriority() float64

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

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

+ func (m *JobSubmitRequestItem) Reset()

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

+ func (m *JobSubmitRequestItem) String() string

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

+ func (m *JobSubmitRequestItem) XXX_DiscardUnknown()

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

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

+ func (m *JobSubmitRequestItem) XXX_Size() int

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

type JobSubmitResponse

+ JobResponseItems []*JobSubmitResponseItem

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

+ type JobSubmitResponseItem struct

+ Error string

+ JobId string

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

+ func (*JobSubmitResponseItem) ProtoMessage()

+ func (m *JobSubmitResponseItem) GetError() string

+ func (m *JobSubmitResponseItem) GetJobId() string

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

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

+ func (m *JobSubmitResponseItem) Reset()

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

+ func (m *JobSubmitResponseItem) String() string

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

+ func (m *JobSubmitResponseItem) XXX_DiscardUnknown()

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

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

+ func (m *JobSubmitResponseItem) XXX_Size() int

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

type SubmitClient

+ SubmitJobs func(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)

type SubmitServer

+ SubmitJobs func(context.Context, *JobSubmitRequest) (*JobSubmitResponse, error)

v0.0.2

Nov 4, 2019

v0.0.1

Oct 29, 2019

Changes in this version

+ var ErrIntOverflowEvent = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowQueue = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowSubmit = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowUsage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthQueue = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthSubmit = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthUsage = fmt.Errorf("proto: negative length found during unmarshaling")

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

+ func RegisterEventServer(s *grpc.Server, srv EventServer)

+ func RegisterSubmitServer(s *grpc.Server, srv SubmitServer)

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

+ type AggregatedQueueClient interface

+ LeaseJobs func(ctx context.Context, in *LeaseRequest, opts ...grpc.CallOption) (*JobLease, error)

+ RenewLease func(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*IdList, error)

+ ReportDone func(ctx context.Context, in *IdList, opts ...grpc.CallOption) (*IdList, error)

+ ReturnLease func(ctx context.Context, in *ReturnLeaseRequest, opts ...grpc.CallOption) (*types.Empty, error)

+ func NewAggregatedQueueClient(cc *grpc.ClientConn) AggregatedQueueClient

+ type AggregatedQueueServer interface

+ LeaseJobs func(context.Context, *LeaseRequest) (*JobLease, error)

+ RenewLease func(context.Context, *RenewLeaseRequest) (*IdList, error)

+ ReportDone func(context.Context, *IdList) (*IdList, error)

+ ReturnLease func(context.Context, *ReturnLeaseRequest) (*types.Empty, error)

+ type CancellationResult struct

+ CancelledIds []string

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

+ func (*CancellationResult) ProtoMessage()

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

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

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

+ func (m *CancellationResult) Reset()

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

+ func (m *CancellationResult) String() string

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

+ func (m *CancellationResult) XXX_DiscardUnknown()

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

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

+ func (m *CancellationResult) XXX_Size() int

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

+ type ClusterUsageReport struct

+ ClusterCapacity map[string]resource.Quantity

+ ClusterId string

+ Queues []*QueueReport

+ ReportTime time.Time

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

+ func (*ClusterUsageReport) ProtoMessage()

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

+ func (m *ClusterUsageReport) GetClusterId() string

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

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

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

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

+ func (m *ClusterUsageReport) Reset()

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

+ func (m *ClusterUsageReport) String() string

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

+ func (m *ClusterUsageReport) XXX_DiscardUnknown()

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

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

+ func (m *ClusterUsageReport) XXX_Size() int

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

+ type Event interface

+ GetCreated func() time.Time

+ GetJobId func() string

+ GetJobSetId func() string

+ GetQueue func() string

+ func UnwrapEvent(message *EventMessage) (Event, error)

+ type EventClient interface

+ GetJobSetEvents func(ctx context.Context, in *JobSetRequest, opts ...grpc.CallOption) (Event_GetJobSetEventsClient, error)

+ Report func(ctx context.Context, in *EventMessage, opts ...grpc.CallOption) (*types.Empty, error)

+ func NewEventClient(cc *grpc.ClientConn) EventClient

+ type EventMessage struct

+ Events isEventMessage_Events

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

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

+ func (*EventMessage) ProtoMessage()

+ func (*EventMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *EventMessage) GetCancelled() *JobCancelledEvent

+ func (m *EventMessage) GetCancelling() *JobCancellingEvent

+ func (m *EventMessage) GetEvents() isEventMessage_Events

+ func (m *EventMessage) GetFailed() *JobFailedEvent

+ func (m *EventMessage) GetLeaseExpired() *JobLeaseExpiredEvent

+ func (m *EventMessage) GetLeaseReturned() *JobLeaseReturnedEvent

+ func (m *EventMessage) GetLeased() *JobLeasedEvent

+ func (m *EventMessage) GetPending() *JobPendingEvent

+ func (m *EventMessage) GetQueued() *JobQueuedEvent

+ func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent

+ func (m *EventMessage) GetRunning() *JobRunningEvent

+ func (m *EventMessage) GetSubmitted() *JobSubmittedEvent

+ func (m *EventMessage) GetSucceeded() *JobSucceededEvent

+ func (m *EventMessage) GetTerminated() *JobTerminatedEvent

+ func (m *EventMessage) GetUnableToSchedule() *JobUnableToScheduleEvent

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

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

+ func (m *EventMessage) Reset()

+ func (m *EventMessage) Size() (n int)

+ func (m *EventMessage) String() string

+ func (m *EventMessage) Unmarshal(dAtA []byte) error

+ func (m *EventMessage) XXX_DiscardUnknown()

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

+ func (m *EventMessage) XXX_Merge(src proto.Message)

+ func (m *EventMessage) XXX_Size() int

+ func (m *EventMessage) XXX_Unmarshal(b []byte) error

+ type EventMessage_Cancelled struct

+ Cancelled *JobCancelledEvent

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

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

+ type EventMessage_Cancelling struct

+ Cancelling *JobCancellingEvent

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

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

+ type EventMessage_Failed struct

+ Failed *JobFailedEvent

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

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

+ type EventMessage_LeaseExpired struct

+ LeaseExpired *JobLeaseExpiredEvent

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

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

+ type EventMessage_LeaseReturned struct

+ LeaseReturned *JobLeaseReturnedEvent

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

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

+ type EventMessage_Leased struct

+ Leased *JobLeasedEvent

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

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

+ type EventMessage_Pending struct

+ Pending *JobPendingEvent

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

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

+ type EventMessage_Queued struct

+ Queued *JobQueuedEvent

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

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

+ type EventMessage_Reprioritized struct

+ Reprioritized *JobReprioritizedEvent

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

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

+ type EventMessage_Running struct

+ Running *JobRunningEvent

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

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

+ type EventMessage_Submitted struct

+ Submitted *JobSubmittedEvent

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

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

+ type EventMessage_Succeeded struct

+ Succeeded *JobSucceededEvent

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

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

+ type EventMessage_Terminated struct

+ Terminated *JobTerminatedEvent

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

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

+ type EventMessage_UnableToSchedule struct

+ UnableToSchedule *JobUnableToScheduleEvent

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

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

+ type EventServer interface

+ GetJobSetEvents func(*JobSetRequest, Event_GetJobSetEventsServer) error

+ Report func(context.Context, *EventMessage) (*types.Empty, error)

+ type EventStreamMessage struct

+ Id string

+ Message *EventMessage

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

+ func (*EventStreamMessage) ProtoMessage()

+ func (m *EventStreamMessage) GetId() string

+ func (m *EventStreamMessage) GetMessage() *EventMessage

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

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

+ func (m *EventStreamMessage) Reset()

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

+ func (m *EventStreamMessage) String() string

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

+ func (m *EventStreamMessage) XXX_DiscardUnknown()

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

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

+ func (m *EventStreamMessage) XXX_Size() int

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

+ type Event_GetJobSetEventsClient interface

+ Recv func() (*EventStreamMessage, error)

+ type Event_GetJobSetEventsServer interface

+ Send func(*EventStreamMessage) error

+ type IdList struct

+ Ids []string

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

+ func (*IdList) ProtoMessage()

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

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

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

+ func (m *IdList) Reset()

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

+ func (m *IdList) String() string

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

+ func (m *IdList) XXX_DiscardUnknown()

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

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

+ func (m *IdList) XXX_Size() int

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

+ type Job struct

+ Created time.Time

+ Id string

+ JobSetId string

+ PodSpec *v1.PodSpec

+ Priority float64

+ Queue string

+ func (*Job) Descriptor() ([]byte, []int)

+ func (*Job) ProtoMessage()

+ func (m *Job) GetCreated() time.Time

+ func (m *Job) GetId() string

+ func (m *Job) GetJobSetId() string

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

+ func (m *Job) GetPriority() float64

+ func (m *Job) GetQueue() string

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

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

+ func (m *Job) Reset()

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

+ func (m *Job) String() string

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

+ func (m *Job) XXX_DiscardUnknown()

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

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

+ func (m *Job) XXX_Size() int

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

+ type JobCancelRequest struct

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobCancelRequest) ProtoMessage()

+ func (m *JobCancelRequest) GetJobId() string

+ func (m *JobCancelRequest) GetJobSetId() string

+ func (m *JobCancelRequest) GetQueue() string

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

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

+ func (m *JobCancelRequest) Reset()

+ func (m *JobCancelRequest) Size() (n int)

+ func (m *JobCancelRequest) String() string

+ func (m *JobCancelRequest) Unmarshal(dAtA []byte) error

+ func (m *JobCancelRequest) XXX_DiscardUnknown()

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

+ func (m *JobCancelRequest) XXX_Merge(src proto.Message)

+ func (m *JobCancelRequest) XXX_Size() int

+ func (m *JobCancelRequest) XXX_Unmarshal(b []byte) error

+ type JobCancelledEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ func (*JobCancelledEvent) Descriptor() ([]byte, []int)

+ func (*JobCancelledEvent) ProtoMessage()

+ func (m *JobCancelledEvent) GetCreated() time.Time

+ func (m *JobCancelledEvent) GetJobId() string

+ func (m *JobCancelledEvent) GetJobSetId() string

+ func (m *JobCancelledEvent) GetQueue() string

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

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

+ func (m *JobCancelledEvent) Reset()

+ func (m *JobCancelledEvent) Size() (n int)

+ func (m *JobCancelledEvent) String() string

+ func (m *JobCancelledEvent) Unmarshal(dAtA []byte) error

+ func (m *JobCancelledEvent) XXX_DiscardUnknown()

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

+ func (m *JobCancelledEvent) XXX_Merge(src proto.Message)

+ func (m *JobCancelledEvent) XXX_Size() int

+ func (m *JobCancelledEvent) XXX_Unmarshal(b []byte) error

+ type JobCancellingEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ func (*JobCancellingEvent) Descriptor() ([]byte, []int)

+ func (*JobCancellingEvent) ProtoMessage()

+ func (m *JobCancellingEvent) GetCreated() time.Time

+ func (m *JobCancellingEvent) GetJobId() string

+ func (m *JobCancellingEvent) GetJobSetId() string

+ func (m *JobCancellingEvent) GetQueue() string

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

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

+ func (m *JobCancellingEvent) Reset()

+ func (m *JobCancellingEvent) Size() (n int)

+ func (m *JobCancellingEvent) String() string

+ func (m *JobCancellingEvent) Unmarshal(dAtA []byte) error

+ func (m *JobCancellingEvent) XXX_DiscardUnknown()

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

+ func (m *JobCancellingEvent) XXX_Merge(src proto.Message)

+ func (m *JobCancellingEvent) XXX_Size() int

+ func (m *JobCancellingEvent) XXX_Unmarshal(b []byte) error

+ type JobFailedEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ Reason string

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

+ func (*JobFailedEvent) ProtoMessage()

+ func (m *JobFailedEvent) GetClusterId() string

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

+ func (m *JobFailedEvent) GetJobId() string

+ func (m *JobFailedEvent) GetJobSetId() string

+ func (m *JobFailedEvent) GetQueue() string

+ func (m *JobFailedEvent) GetReason() string

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

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

+ func (m *JobFailedEvent) Reset()

+ func (m *JobFailedEvent) Size() (n int)

+ func (m *JobFailedEvent) String() string

+ func (m *JobFailedEvent) Unmarshal(dAtA []byte) error

+ func (m *JobFailedEvent) XXX_DiscardUnknown()

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

+ func (m *JobFailedEvent) XXX_Merge(src proto.Message)

+ func (m *JobFailedEvent) XXX_Size() int

+ func (m *JobFailedEvent) XXX_Unmarshal(b []byte) error

+ type JobLease struct

+ Job []*Job

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

+ func (*JobLease) ProtoMessage()

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

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

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

+ func (m *JobLease) Reset()

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

+ func (m *JobLease) String() string

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

+ func (m *JobLease) XXX_DiscardUnknown()

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

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

+ func (m *JobLease) XXX_Size() int

+ func (m *JobLease) XXX_Unmarshal(b []byte) error

+ type JobLeaseExpiredEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobLeaseExpiredEvent) ProtoMessage()

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

+ func (m *JobLeaseExpiredEvent) GetJobId() string

+ func (m *JobLeaseExpiredEvent) GetJobSetId() string

+ func (m *JobLeaseExpiredEvent) GetQueue() string

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

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

+ func (m *JobLeaseExpiredEvent) Reset()

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

+ func (m *JobLeaseExpiredEvent) String() string

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

+ func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobLeaseExpiredEvent) XXX_Size() int

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

+ type JobLeaseReturnedEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ Reason string

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

+ func (*JobLeaseReturnedEvent) ProtoMessage()

+ func (m *JobLeaseReturnedEvent) GetClusterId() string

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

+ func (m *JobLeaseReturnedEvent) GetJobId() string

+ func (m *JobLeaseReturnedEvent) GetJobSetId() string

+ func (m *JobLeaseReturnedEvent) GetQueue() string

+ func (m *JobLeaseReturnedEvent) GetReason() string

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

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

+ func (m *JobLeaseReturnedEvent) Reset()

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

+ func (m *JobLeaseReturnedEvent) String() string

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

+ func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobLeaseReturnedEvent) XXX_Size() int

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

+ type JobLeasedEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobLeasedEvent) ProtoMessage()

+ func (m *JobLeasedEvent) GetClusterId() string

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

+ func (m *JobLeasedEvent) GetJobId() string

+ func (m *JobLeasedEvent) GetJobSetId() string

+ func (m *JobLeasedEvent) GetQueue() string

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

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

+ func (m *JobLeasedEvent) Reset()

+ func (m *JobLeasedEvent) Size() (n int)

+ func (m *JobLeasedEvent) String() string

+ func (m *JobLeasedEvent) Unmarshal(dAtA []byte) error

+ func (m *JobLeasedEvent) XXX_DiscardUnknown()

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

+ func (m *JobLeasedEvent) XXX_Merge(src proto.Message)

+ func (m *JobLeasedEvent) XXX_Size() int

+ func (m *JobLeasedEvent) XXX_Unmarshal(b []byte) error

+ type JobPendingEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ func (*JobPendingEvent) Descriptor() ([]byte, []int)

+ func (*JobPendingEvent) ProtoMessage()

+ func (m *JobPendingEvent) GetClusterId() string

+ func (m *JobPendingEvent) GetCreated() time.Time

+ func (m *JobPendingEvent) GetJobId() string

+ func (m *JobPendingEvent) GetJobSetId() string

+ func (m *JobPendingEvent) GetQueue() string

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

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

+ func (m *JobPendingEvent) Reset()

+ func (m *JobPendingEvent) Size() (n int)

+ func (m *JobPendingEvent) String() string

+ func (m *JobPendingEvent) Unmarshal(dAtA []byte) error

+ func (m *JobPendingEvent) XXX_DiscardUnknown()

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

+ func (m *JobPendingEvent) XXX_Merge(src proto.Message)

+ func (m *JobPendingEvent) XXX_Size() int

+ func (m *JobPendingEvent) XXX_Unmarshal(b []byte) error

+ type JobQueuedEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobQueuedEvent) ProtoMessage()

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

+ func (m *JobQueuedEvent) GetJobId() string

+ func (m *JobQueuedEvent) GetJobSetId() string

+ func (m *JobQueuedEvent) GetQueue() string

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

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

+ func (m *JobQueuedEvent) Reset()

+ func (m *JobQueuedEvent) Size() (n int)

+ func (m *JobQueuedEvent) String() string

+ func (m *JobQueuedEvent) Unmarshal(dAtA []byte) error

+ func (m *JobQueuedEvent) XXX_DiscardUnknown()

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

+ func (m *JobQueuedEvent) XXX_Merge(src proto.Message)

+ func (m *JobQueuedEvent) XXX_Size() int

+ func (m *JobQueuedEvent) XXX_Unmarshal(b []byte) error

+ type JobReprioritizedEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ func (*JobReprioritizedEvent) Descriptor() ([]byte, []int)

+ func (*JobReprioritizedEvent) ProtoMessage()

+ func (m *JobReprioritizedEvent) GetCreated() time.Time

+ func (m *JobReprioritizedEvent) GetJobId() string

+ func (m *JobReprioritizedEvent) GetJobSetId() string

+ func (m *JobReprioritizedEvent) GetQueue() string

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

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

+ func (m *JobReprioritizedEvent) Reset()

+ func (m *JobReprioritizedEvent) Size() (n int)

+ func (m *JobReprioritizedEvent) String() string

+ func (m *JobReprioritizedEvent) Unmarshal(dAtA []byte) error

+ func (m *JobReprioritizedEvent) XXX_DiscardUnknown()

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

+ func (m *JobReprioritizedEvent) XXX_Merge(src proto.Message)

+ func (m *JobReprioritizedEvent) XXX_Size() int

+ func (m *JobReprioritizedEvent) XXX_Unmarshal(b []byte) error

+ type JobRequest struct

+ JobSetId string

+ PodSpec *v1.PodSpec

+ Priority float64

+ Queue string

+ func (*JobRequest) Descriptor() ([]byte, []int)

+ func (*JobRequest) ProtoMessage()

+ func (m *JobRequest) GetJobSetId() string

+ func (m *JobRequest) GetPodSpec() *v1.PodSpec

+ func (m *JobRequest) GetPriority() float64

+ func (m *JobRequest) GetQueue() string

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

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

+ func (m *JobRequest) Reset()

+ func (m *JobRequest) Size() (n int)

+ func (m *JobRequest) String() string

+ func (m *JobRequest) Unmarshal(dAtA []byte) error

+ func (m *JobRequest) XXX_DiscardUnknown()

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

+ func (m *JobRequest) XXX_Merge(src proto.Message)

+ func (m *JobRequest) XXX_Size() int

+ func (m *JobRequest) XXX_Unmarshal(b []byte) error

+ type JobRunningEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ func (*JobRunningEvent) Descriptor() ([]byte, []int)

+ func (*JobRunningEvent) ProtoMessage()

+ func (m *JobRunningEvent) GetClusterId() string

+ func (m *JobRunningEvent) GetCreated() time.Time

+ func (m *JobRunningEvent) GetJobId() string

+ func (m *JobRunningEvent) GetJobSetId() string

+ func (m *JobRunningEvent) GetQueue() string

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

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

+ func (m *JobRunningEvent) Reset()

+ func (m *JobRunningEvent) Size() (n int)

+ func (m *JobRunningEvent) String() string

+ func (m *JobRunningEvent) Unmarshal(dAtA []byte) error

+ func (m *JobRunningEvent) XXX_DiscardUnknown()

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

+ func (m *JobRunningEvent) XXX_Merge(src proto.Message)

+ func (m *JobRunningEvent) XXX_Size() int

+ func (m *JobRunningEvent) XXX_Unmarshal(b []byte) error

+ type JobSetRequest struct

+ FromMessageId string

+ Id string

+ Watch bool

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

+ func (*JobSetRequest) ProtoMessage()

+ func (m *JobSetRequest) GetFromMessageId() string

+ func (m *JobSetRequest) GetId() string

+ func (m *JobSetRequest) GetWatch() bool

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

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

+ func (m *JobSetRequest) Reset()

+ func (m *JobSetRequest) Size() (n int)

+ func (m *JobSetRequest) String() string

+ func (m *JobSetRequest) Unmarshal(dAtA []byte) error

+ func (m *JobSetRequest) XXX_DiscardUnknown()

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

+ func (m *JobSetRequest) XXX_Merge(src proto.Message)

+ func (m *JobSetRequest) XXX_Size() int

+ func (m *JobSetRequest) XXX_Unmarshal(b []byte) error

+ type JobSubmitResponse struct

+ JobId string

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

+ func (*JobSubmitResponse) ProtoMessage()

+ func (m *JobSubmitResponse) GetJobId() string

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

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

+ func (m *JobSubmitResponse) Reset()

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

+ func (m *JobSubmitResponse) String() string

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

+ func (m *JobSubmitResponse) XXX_DiscardUnknown()

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

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

+ func (m *JobSubmitResponse) XXX_Size() int

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

+ type JobSubmittedEvent struct

+ Created time.Time

+ Job Job

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobSubmittedEvent) ProtoMessage()

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

+ func (m *JobSubmittedEvent) GetJob() Job

+ func (m *JobSubmittedEvent) GetJobId() string

+ func (m *JobSubmittedEvent) GetJobSetId() string

+ func (m *JobSubmittedEvent) GetQueue() string

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

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

+ func (m *JobSubmittedEvent) Reset()

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

+ func (m *JobSubmittedEvent) String() string

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

+ func (m *JobSubmittedEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobSubmittedEvent) XXX_Size() int

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

+ type JobSucceededEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobSucceededEvent) ProtoMessage()

+ func (m *JobSucceededEvent) GetClusterId() string

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

+ func (m *JobSucceededEvent) GetJobId() string

+ func (m *JobSucceededEvent) GetJobSetId() string

+ func (m *JobSucceededEvent) GetQueue() string

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

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

+ func (m *JobSucceededEvent) Reset()

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

+ func (m *JobSucceededEvent) String() string

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

+ func (m *JobSucceededEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobSucceededEvent) XXX_Size() int

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

+ type JobTerminatedEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

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

+ func (*JobTerminatedEvent) ProtoMessage()

+ func (m *JobTerminatedEvent) GetClusterId() string

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

+ func (m *JobTerminatedEvent) GetJobId() string

+ func (m *JobTerminatedEvent) GetJobSetId() string

+ func (m *JobTerminatedEvent) GetQueue() string

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

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

+ func (m *JobTerminatedEvent) Reset()

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

+ func (m *JobTerminatedEvent) String() string

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

+ func (m *JobTerminatedEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobTerminatedEvent) XXX_Size() int

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

+ type JobUnableToScheduleEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ Queue string

+ Reason string

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

+ func (*JobUnableToScheduleEvent) ProtoMessage()

+ func (m *JobUnableToScheduleEvent) GetClusterId() string

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

+ func (m *JobUnableToScheduleEvent) GetJobId() string

+ func (m *JobUnableToScheduleEvent) GetJobSetId() string

+ func (m *JobUnableToScheduleEvent) GetQueue() string

+ func (m *JobUnableToScheduleEvent) GetReason() string

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

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

+ func (m *JobUnableToScheduleEvent) Reset()

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

+ func (m *JobUnableToScheduleEvent) String() string

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

+ func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobUnableToScheduleEvent) XXX_Size() int

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

+ type LeaseRequest struct

+ ClusterId string

+ Resources map[string]resource.Quantity

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

+ func (*LeaseRequest) ProtoMessage()

+ func (m *LeaseRequest) GetClusterId() string

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

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

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

+ func (m *LeaseRequest) Reset()

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

+ func (m *LeaseRequest) String() string

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

+ func (m *LeaseRequest) XXX_DiscardUnknown()

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

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

+ func (m *LeaseRequest) XXX_Size() int

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

+ type Queue struct

+ GroupOwners []string

+ Name string

+ PriorityFactor float64

+ UserOwners []string

+ func (*Queue) Descriptor() ([]byte, []int)

+ func (*Queue) ProtoMessage()

+ func (m *Queue) GetGroupOwners() []string

+ func (m *Queue) GetName() string

+ func (m *Queue) GetPriorityFactor() float64

+ func (m *Queue) GetUserOwners() []string

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

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

+ func (m *Queue) Reset()

+ func (m *Queue) Size() (n int)

+ func (m *Queue) String() string

+ func (m *Queue) Unmarshal(dAtA []byte) error

+ func (m *Queue) XXX_DiscardUnknown()

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

+ func (m *Queue) XXX_Merge(src proto.Message)

+ func (m *Queue) XXX_Size() int

+ func (m *Queue) XXX_Unmarshal(b []byte) error

+ type QueueReport struct

+ Name string

+ Resources map[string]resource.Quantity

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

+ func (*QueueReport) ProtoMessage()

+ func (m *QueueReport) GetName() string

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

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

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

+ func (m *QueueReport) Reset()

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

+ func (m *QueueReport) String() string

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

+ func (m *QueueReport) XXX_DiscardUnknown()

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

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

+ func (m *QueueReport) XXX_Size() int

+ func (m *QueueReport) XXX_Unmarshal(b []byte) error

+ type RenewLeaseRequest struct

+ ClusterId string

+ Ids []string

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

+ func (*RenewLeaseRequest) ProtoMessage()

+ func (m *RenewLeaseRequest) GetClusterId() string

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

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

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

+ func (m *RenewLeaseRequest) Reset()

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

+ func (m *RenewLeaseRequest) String() string

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

+ func (m *RenewLeaseRequest) XXX_DiscardUnknown()

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

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

+ func (m *RenewLeaseRequest) XXX_Size() int

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

+ type ReturnLeaseRequest struct

+ ClusterId string

+ JobId string

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

+ func (*ReturnLeaseRequest) ProtoMessage()

+ func (m *ReturnLeaseRequest) GetClusterId() string

+ func (m *ReturnLeaseRequest) GetJobId() string

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

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

+ func (m *ReturnLeaseRequest) Reset()

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

+ func (m *ReturnLeaseRequest) String() string

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

+ func (m *ReturnLeaseRequest) XXX_DiscardUnknown()

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

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

+ func (m *ReturnLeaseRequest) XXX_Size() int

+ func (m *ReturnLeaseRequest) XXX_Unmarshal(b []byte) error

+ type SubmitClient interface

+ CancelJobs func(ctx context.Context, in *JobCancelRequest, opts ...grpc.CallOption) (*CancellationResult, error)

+ CreateQueue func(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error)

+ SubmitJob func(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)

+ func NewSubmitClient(cc *grpc.ClientConn) SubmitClient

+ type SubmitServer interface

+ CancelJobs func(context.Context, *JobCancelRequest) (*CancellationResult, error)

+ CreateQueue func(context.Context, *Queue) (*types.Empty, error)

+ SubmitJob func(context.Context, *JobRequest) (*JobSubmitResponse, error)

+ type UsageClient interface

+ ReportUsage func(ctx context.Context, in *ClusterUsageReport, opts ...grpc.CallOption) (*types.Empty, error)

+ func NewUsageClient(cc *grpc.ClientConn) UsageClient

+ type UsageServer interface

+ ReportUsage func(context.Context, *ClusterUsageReport) (*types.Empty, error)

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