api

package

Go to main page

Versions in this module

v0

v0.3.45

Jan 13, 2023

Changes in this version

type ReturnLeaseRequest

+ JobRunAttempted bool

+ func (m *ReturnLeaseRequest) GetJobRunAttempted() bool

v0.3.44

Dec 14, 2022

Changes in this version

+ func JobSetIdFromApiEvent(msg *EventMessage) string

+ func ShortStringFromEventMessages(msgs []*EventMessage) string

type EventMessage

+ func (msg *EventMessage) ShortString() string

type JobCancelRequest

+ JobIds []string

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

type TestSpec

+ func (testSpec *TestSpec) ShortString() string

type TestSpec_Cancel

+ const TestSpec_BY_IDS

v0.3.43

Dec 6, 2022

v0.3.42

Nov 24, 2022

v0.3.41

Nov 23, 2022

v0.3.40

Nov 22, 2022

v0.3.39

Nov 3, 2022

v0.3.38

Oct 31, 2022

v0.3.37

Oct 28, 2022

v0.3.36

Oct 19, 2022

v0.3.35

Oct 18, 2022

Changes in this version

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

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

+ var ErrUnexpectedEndOfGroupHealth = fmt.Errorf("proto: unexpected end of group")

+ var HealthCheckResponse_ServingStatus_name = map[int32]string

+ var HealthCheckResponse_ServingStatus_value = map[string]int32

type EventClient

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

type EventServer

+ Health func(context.Context, *types.Empty) (*HealthCheckResponse, error)

+ type HealthCheckResponse struct

+ Status HealthCheckResponse_ServingStatus

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

+ func (*HealthCheckResponse) ProtoMessage()

+ func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

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

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

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

+ func (m *HealthCheckResponse) Reset()

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

+ func (m *HealthCheckResponse) String() string

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

+ func (m *HealthCheckResponse) XXX_DiscardUnknown()

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

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

+ func (m *HealthCheckResponse) XXX_Size() int

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

+ type HealthCheckResponse_ServingStatus int32

+ const HealthCheckResponse_NOT_SERVING

+ const HealthCheckResponse_SERVING

+ const HealthCheckResponse_UNKNOWN

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

+ func (x HealthCheckResponse_ServingStatus) String() string

type QueueLeasedReport

+ ResourcesLeasedByPriority map[int32]ComputeResource

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

type SubmitClient

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

type SubmitServer

+ Health func(context.Context, *types.Empty) (*HealthCheckResponse, error)

type UnimplementedEventServer

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

type UnimplementedSubmitServer

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

v0.3.34

Sep 22, 2022

v0.3.33

Sep 22, 2022

Changes in this version

type EventMessage

+ func (m *EventMessage) GetPreempted() *JobPreemptedEvent

+ type EventMessage_Preempted struct

+ Preempted *JobPreemptedEvent

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

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

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

+ func (this *EventMessage_Preempted) String() string

+ type JobPreemptedEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ PreemptiveJobId string

+ PreemptiveRunId string

+ Queue string

+ RunId string

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

+ func (*JobPreemptedEvent) ProtoMessage()

+ func (m *JobPreemptedEvent) GetClusterId() string

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

+ func (m *JobPreemptedEvent) GetJobId() string

+ func (m *JobPreemptedEvent) GetJobSetId() string

+ func (m *JobPreemptedEvent) GetPreemptiveJobId() string

+ func (m *JobPreemptedEvent) GetPreemptiveRunId() string

+ func (m *JobPreemptedEvent) GetQueue() string

+ func (m *JobPreemptedEvent) GetRunId() string

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

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

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

+ func (m *JobPreemptedEvent) Reset()

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

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

+ func (m *JobPreemptedEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobPreemptedEvent) XXX_Size() int

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

+ func (this *JobPreemptedEvent) String() string

v0.3.32

Sep 16, 2022

Changes in this version

type Job

+ Scheduler string

+ func (m *Job) GetScheduler() string

type JobSubmitRequestItem

+ Scheduler string

+ func (m *JobSubmitRequestItem) GetScheduler() string

v0.3.31

Sep 13, 2022

v0.3.30

Sep 13, 2022

Changes in this version

type Job

+ CompressedQueueOwnershipUserGroups []byte

+ func (m *Job) GetCompressedQueueOwnershipUserGroups() []byte

type JobSetRequest

+ ForceLegacy bool

+ ForceNew bool

+ func (m *JobSetRequest) GetForceLegacy() bool

+ func (m *JobSetRequest) GetForceNew() bool

type WatchRequest

+ ForceLegacy bool

+ ForceNew bool

+ func (m *WatchRequest) GetForceLegacy() bool

+ func (m *WatchRequest) GetForceNew() bool

v0.3.29

Aug 23, 2022

Changes in this version

type NodeInfo

+ AllocatedResources map[int32]ComputeResource

+ TotalResources map[string]resource.Quantity

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

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

v0.3.28

Aug 11, 2022

Changes in this version

type TestSpec

+ GetLogs bool

+ func (m *TestSpec) GetGetLogs() bool

v0.3.27

Aug 10, 2022

v0.3.26

Aug 9, 2022

Changes in this version

type TestSpec

+ RandomClientId bool

+ func (m *TestSpec) GetRandomClientId() bool

v0.3.25

Aug 8, 2022

Changes in this version

+ var JobState_name = map[int32]string

+ var JobState_value = map[string]int32

type EventMessage

+ func (m *EventMessage) GetFailedCompressed() *JobFailedEventCompressed

+ type EventMessage_FailedCompressed struct

+ FailedCompressed *JobFailedEventCompressed

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

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

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

+ func (this *EventMessage_FailedCompressed) String() string

+ type JobFailedEventCompressed struct

+ Event []byte

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

+ func (*JobFailedEventCompressed) ProtoMessage()

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

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

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

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

+ func (m *JobFailedEventCompressed) Reset()

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

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

+ func (m *JobFailedEventCompressed) XXX_DiscardUnknown()

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

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

+ func (m *JobFailedEventCompressed) XXX_Size() int

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

+ func (this *JobFailedEventCompressed) String() string

+ type JobSetCancelRequest struct

+ Filter *JobSetFilter

+ JobSetId string

+ Queue string

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

+ func (*JobSetCancelRequest) ProtoMessage()

+ func (m *JobSetCancelRequest) GetFilter() *JobSetFilter

+ func (m *JobSetCancelRequest) GetJobSetId() string

+ func (m *JobSetCancelRequest) GetQueue() string

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

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

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

+ func (m *JobSetCancelRequest) Reset()

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

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

+ func (m *JobSetCancelRequest) XXX_DiscardUnknown()

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

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

+ func (m *JobSetCancelRequest) XXX_Size() int

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

+ func (this *JobSetCancelRequest) String() string

+ type JobSetFilter struct

+ States []JobState

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

+ func (*JobSetFilter) ProtoMessage()

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

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

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

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

+ func (m *JobSetFilter) Reset()

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

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

+ func (m *JobSetFilter) XXX_DiscardUnknown()

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

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

+ func (m *JobSetFilter) XXX_Size() int

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

+ func (this *JobSetFilter) String() string

+ type JobState int32

+ const JobState_PENDING

+ const JobState_QUEUED

+ const JobState_RUNNING

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

+ func (x *JobState) UnmarshalJSON(data []byte) error

+ func (x JobState) String() string

type SubmitClient

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

type SubmitServer

+ CancelJobSet func(context.Context, *JobSetCancelRequest) (*types.Empty, error)

type UnimplementedSubmitServer

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

v0.3.24

Jul 29, 2022

v0.3.23

Jul 25, 2022

v0.3.22

Jul 22, 2022

v0.3.21

Jul 21, 2022

v0.3.20

Jul 19, 2022

Changes in this version

type ReturnLeaseRequest

+ KubernetesId string

+ Reason string

+ func (m *ReturnLeaseRequest) GetKubernetesId() string

+ func (m *ReturnLeaseRequest) GetReason() string

v0.3.19

Jul 15, 2022

v0.3.18

Jul 14, 2022

v0.3.17

Jun 29, 2022

v0.3.16

Jun 28, 2022

v0.3.15

Jun 24, 2022

Changes in this version

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

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

+ var ErrUnexpectedEndOfGroupTestspec = fmt.Errorf("proto: unexpected end of group")

+ var TestSpec_Cancel_name = map[int32]string

+ var TestSpec_Cancel_value = map[string]int32

+ func JobIdFromApiEvent(msg *EventMessage) string

type AggregatedQueueClient

+ StreamingLeaseJobs func(ctx context.Context, opts ...grpc.CallOption) (AggregatedQueue_StreamingLeaseJobsClient, error)

type AggregatedQueueServer

+ StreamingLeaseJobs func(AggregatedQueue_StreamingLeaseJobsServer) error

+ type AggregatedQueue_StreamingLeaseJobsClient interface

+ Recv func() (*StreamingJobLease, error)

+ Send func(*StreamingLeaseRequest) error

+ type AggregatedQueue_StreamingLeaseJobsServer interface

+ Recv func() (*StreamingLeaseRequest, error)

+ Send func(*StreamingJobLease) error

+ type BatchQueueCreateResponse struct

+ FailedQueues []*QueueCreateResponse

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

+ func (*BatchQueueCreateResponse) ProtoMessage()

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

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

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

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

+ func (m *BatchQueueCreateResponse) Reset()

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

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

+ func (m *BatchQueueCreateResponse) XXX_DiscardUnknown()

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

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

+ func (m *BatchQueueCreateResponse) XXX_Size() int

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

+ func (this *BatchQueueCreateResponse) String() string

+ type BatchQueueUpdateResponse struct

+ FailedQueues []*QueueUpdateResponse

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

+ func (*BatchQueueUpdateResponse) ProtoMessage()

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

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

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

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

+ func (m *BatchQueueUpdateResponse) Reset()

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

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

+ func (m *BatchQueueUpdateResponse) XXX_DiscardUnknown()

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

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

+ func (m *BatchQueueUpdateResponse) XXX_Size() int

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

+ func (this *BatchQueueUpdateResponse) String() string

+ type QueueCreateResponse struct

+ Error string

+ Queue *Queue

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

+ func (*QueueCreateResponse) ProtoMessage()

+ func (m *QueueCreateResponse) GetError() string

+ func (m *QueueCreateResponse) GetQueue() *Queue

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

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

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

+ func (m *QueueCreateResponse) Reset()

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

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

+ func (m *QueueCreateResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueCreateResponse) XXX_Size() int

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

+ func (this *QueueCreateResponse) String() string

+ type QueueList struct

+ Queues []*Queue

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

+ func (*QueueList) ProtoMessage()

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

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

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

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

+ func (m *QueueList) Reset()

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

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

+ func (m *QueueList) XXX_DiscardUnknown()

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

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

+ func (m *QueueList) XXX_Size() int

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

+ func (this *QueueList) String() string

+ type QueueUpdateResponse struct

+ Error string

+ Queue *Queue

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

+ func (*QueueUpdateResponse) ProtoMessage()

+ func (m *QueueUpdateResponse) GetError() string

+ func (m *QueueUpdateResponse) GetQueue() *Queue

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

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

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

+ func (m *QueueUpdateResponse) Reset()

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

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

+ func (m *QueueUpdateResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueueUpdateResponse) XXX_Size() int

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

+ func (this *QueueUpdateResponse) String() string

+ type StreamingJobLease struct

+ Job *Job

+ NumAcked uint32

+ NumJobs uint32

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

+ func (*StreamingJobLease) ProtoMessage()

+ func (m *StreamingJobLease) GetJob() *Job

+ func (m *StreamingJobLease) GetNumAcked() uint32

+ func (m *StreamingJobLease) GetNumJobs() uint32

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

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

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

+ func (m *StreamingJobLease) Reset()

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

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

+ func (m *StreamingJobLease) XXX_DiscardUnknown()

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

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

+ func (m *StreamingJobLease) XXX_Size() int

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

+ func (this *StreamingJobLease) String() string

+ type StreamingLeaseRequest struct

+ ClusterId string

+ ClusterLeasedReport ClusterLeasedReport

+ MinimumJobSize map[string]resource.Quantity

+ Nodes []NodeInfo

+ Pool string

+ ReceivedJobIds []string

+ Resources map[string]resource.Quantity

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

+ func (*StreamingLeaseRequest) ProtoMessage()

+ func (m *StreamingLeaseRequest) GetClusterId() string

+ func (m *StreamingLeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

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

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

+ func (m *StreamingLeaseRequest) GetPool() string

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

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

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

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

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

+ func (m *StreamingLeaseRequest) Reset()

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

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

+ func (m *StreamingLeaseRequest) XXX_DiscardUnknown()

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

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

+ func (m *StreamingLeaseRequest) XXX_Size() int

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

+ func (this *StreamingLeaseRequest) String() string

type SubmitClient

+ CreateQueues func(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueCreateResponse, error)

+ UpdateQueues func(ctx context.Context, in *QueueList, opts ...grpc.CallOption) (*BatchQueueUpdateResponse, error)

type SubmitServer

+ CreateQueues func(context.Context, *QueueList) (*BatchQueueCreateResponse, error)

+ UpdateQueues func(context.Context, *QueueList) (*BatchQueueUpdateResponse, error)

+ type TestSpec struct

+ BatchSize uint32

+ Cancel TestSpec_Cancel

+ ExpectedEvents []*EventMessage

+ Interval time.Duration

+ JobSetId string

+ Jobs []*JobSubmitRequestItem

+ Name string

+ NumBatches uint32

+ Queue string

+ Timeout time.Duration

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

+ func (*TestSpec) ProtoMessage()

+ func (m *TestSpec) GetBatchSize() uint32

+ func (m *TestSpec) GetCancel() TestSpec_Cancel

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

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

+ func (m *TestSpec) GetJobSetId() string

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

+ func (m *TestSpec) GetName() string

+ func (m *TestSpec) GetNumBatches() uint32

+ func (m *TestSpec) GetQueue() string

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

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

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

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

+ func (m *TestSpec) Reset()

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

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

+ func (m *TestSpec) XXX_DiscardUnknown()

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

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

+ func (m *TestSpec) XXX_Size() int

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

+ func (this *TestSpec) String() string

+ type TestSpec_Cancel int32

+ const TestSpec_BY_ID

+ const TestSpec_BY_SET

+ const TestSpec_NO

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

+ func (x TestSpec_Cancel) String() string

type UnimplementedAggregatedQueueServer

+ func (*UnimplementedAggregatedQueueServer) StreamingLeaseJobs(srv AggregatedQueue_StreamingLeaseJobsServer) error

type UnimplementedSubmitServer

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

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

v0.3.14

May 30, 2022

Changes in this version

type JobSetRequest

+ ForceRedis bool

+ func (m *JobSetRequest) GetForceRedis() bool

type WatchRequest

+ ForceRedis bool

+ func (m *WatchRequest) GetForceRedis() bool

v0.3.13

May 26, 2022

v0.3.12

May 26, 2022

v0.3.11

May 25, 2022

v0.3.10

May 25, 2022

v0.3.9

May 24, 2022

v0.3.8

May 23, 2022

Changes in this version

type NodeTypeUsageReport

+ SchedulableNodes int32

+ TotalNodes int32

+ func (m *NodeTypeUsageReport) GetSchedulableNodes() int32

+ func (m *NodeTypeUsageReport) GetTotalNodes() int32

v0.3.7

May 17, 2022

v0.3.6

May 16, 2022

v0.3.5

May 11, 2022

v0.3.4

May 11, 2022

v0.3.3

May 10, 2022

v0.3.2

May 9, 2022

v0.3.1

May 5, 2022

v0.3.0

May 3, 2022

Changes in this version

type Job

+ K8SIngress []*v11.Ingress

+ K8SService []*v1.Service

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

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

v0.2.19

Feb 11, 2022

Changes in this version

type JobSetRequest

+ ErrorIfMissing bool

+ func (m *JobSetRequest) GetErrorIfMissing() bool

v0.2.18

Feb 4, 2022

Changes in this version

type Queue

+ Permissions []*Queue_Permissions

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

+ type Queue_Permissions struct

+ Subjects []*Queue_Permissions_Subject

+ Verbs []string

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

+ func (*Queue_Permissions) ProtoMessage()

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

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

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

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

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

+ func (m *Queue_Permissions) Reset()

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

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

+ func (m *Queue_Permissions) XXX_DiscardUnknown()

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

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

+ func (m *Queue_Permissions) XXX_Size() int

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

+ func (this *Queue_Permissions) String() string

+ type Queue_Permissions_Subject struct

+ Kind string

+ Name string

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

+ func (*Queue_Permissions_Subject) ProtoMessage()

+ func (m *Queue_Permissions_Subject) GetKind() string

+ func (m *Queue_Permissions_Subject) GetName() string

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

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

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

+ func (m *Queue_Permissions_Subject) Reset()

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

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

+ func (m *Queue_Permissions_Subject) XXX_DiscardUnknown()

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

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

+ func (m *Queue_Permissions_Subject) XXX_Size() int

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

+ func (this *Queue_Permissions_Subject) String() string

v0.2.17

Jan 19, 2022

v0.2.16

Jan 17, 2022

Changes in this version

type IngressConfig

+ UseClusterIP bool

+ func (m *IngressConfig) GetUseClusterIP() bool

v0.2.15

Jan 11, 2022

Changes in this version

type NodeTypeUsageReport

+ CordonedUsage map[string]resource.Quantity

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

v0.2.14

Dec 14, 2021

Changes in this version

+ var ServiceType_name = map[int32]string

+ var ServiceType_value = map[string]int32

type Job

+ Services []*ServiceConfig

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

type JobSubmitRequestItem

+ Services []*ServiceConfig

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

+ type ServiceConfig struct

+ Ports []uint32

+ Type ServiceType

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

+ func (*ServiceConfig) ProtoMessage()

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

+ func (m *ServiceConfig) GetType() ServiceType

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

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

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

+ func (m *ServiceConfig) Reset()

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

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

+ func (m *ServiceConfig) XXX_DiscardUnknown()

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

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

+ func (m *ServiceConfig) XXX_Size() int

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

+ func (this *ServiceConfig) String() string

+ type ServiceType int32

+ const ServiceType_Headless

+ const ServiceType_NodePort

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

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

+ func (x ServiceType) String() string

v0.2.13

Dec 6, 2021

v0.2.12

Dec 2, 2021

Changes in this version

type IngressConfig

+ CertName string

+ TlsEnabled bool

+ func (m *IngressConfig) GetCertName() string

+ func (m *IngressConfig) GetTlsEnabled() bool

v0.2.11

Nov 26, 2021

Changes in this version

type EventClient

+ Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Event_WatchClient, error)

type EventServer

+ Watch func(*WatchRequest, Event_WatchServer) error

+ type Event_WatchClient interface

+ Recv func() (*EventStreamMessage, error)

+ type Event_WatchServer interface

+ Send func(*EventStreamMessage) error

type JobLeaseReturnedEvent

+ KubernetesId string

+ PodNumber int32

+ func (m *JobLeaseReturnedEvent) GetKubernetesId() string

+ func (m *JobLeaseReturnedEvent) GetPodNumber() int32

type UnimplementedEventServer

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

+ type WatchRequest struct

+ FromId string

+ JobSetId string

+ Queue string

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

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) GetFromId() string

+ func (m *WatchRequest) GetJobSetId() string

+ func (m *WatchRequest) GetQueue() string

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

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

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

+ func (m *WatchRequest) Reset()

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

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

+ func (m *WatchRequest) XXX_DiscardUnknown()

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

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

+ func (m *WatchRequest) XXX_Size() int

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

+ func (this *WatchRequest) String() string

v0.2.10

Nov 3, 2021

v0.2.9

Nov 1, 2021

v0.2.8

Oct 19, 2021

Changes in this version

type EventMessage

+ func (m *EventMessage) GetUpdated() *JobUpdatedEvent

+ type EventMessage_Updated struct

+ Updated *JobUpdatedEvent

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

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

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

+ func (this *EventMessage_Updated) String() string

+ type JobUpdatedEvent struct

+ Created time.Time

+ Job Job

+ JobId string

+ JobSetId string

+ Queue string

+ Requestor string

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

+ func (*JobUpdatedEvent) ProtoMessage()

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

+ func (m *JobUpdatedEvent) GetJob() Job

+ func (m *JobUpdatedEvent) GetJobId() string

+ func (m *JobUpdatedEvent) GetJobSetId() string

+ func (m *JobUpdatedEvent) GetQueue() string

+ func (m *JobUpdatedEvent) GetRequestor() string

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

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

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

+ func (m *JobUpdatedEvent) Reset()

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

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

+ func (m *JobUpdatedEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobUpdatedEvent) XXX_Size() int

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

+ func (this *JobUpdatedEvent) String() string

+ type OrderedStringMap struct

+ Entries []*StringKeyValuePair

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

+ func (*OrderedStringMap) ProtoMessage()

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

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

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

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

+ func (m *OrderedStringMap) Reset()

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

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

+ func (m *OrderedStringMap) XXX_DiscardUnknown()

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

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

+ func (m *OrderedStringMap) XXX_Size() int

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

+ func (this *OrderedStringMap) String() string

+ type StringKeyValuePair struct

+ Key string

+ Value string

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

+ func (*StringKeyValuePair) ProtoMessage()

+ func (m *StringKeyValuePair) GetKey() string

+ func (m *StringKeyValuePair) GetValue() string

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

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

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

+ func (m *StringKeyValuePair) Reset()

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

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

+ func (m *StringKeyValuePair) XXX_DiscardUnknown()

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

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

+ func (m *StringKeyValuePair) XXX_Size() int

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

+ func (this *StringKeyValuePair) String() string

v0.2.7

Oct 8, 2021

v0.2.6

Oct 7, 2021

Changes in this version

type ReturnLeaseRequest

+ AvoidNodeLabels map[string]string

+ func (m *ReturnLeaseRequest) GetAvoidNodeLabels() map[string]string

v0.2.5

Sep 16, 2021

v0.2.4

Sep 16, 2021

Changes in this version

type ClusterUsageReport

+ NodeTypeUsageReports []NodeTypeUsageReport

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

+ type NodeTypeIdentifier struct

+ Id string

+ Taints []v1.Taint

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

+ func (*NodeTypeIdentifier) ProtoMessage()

+ func (m *NodeTypeIdentifier) GetId() string

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

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

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

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

+ func (m *NodeTypeIdentifier) Reset()

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

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

+ func (m *NodeTypeIdentifier) XXX_DiscardUnknown()

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

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

+ func (m *NodeTypeIdentifier) XXX_Size() int

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

+ func (this *NodeTypeIdentifier) String() string

+ type NodeTypeUsageReport struct

+ AvailableCapacity map[string]resource.Quantity

+ Capacity map[string]resource.Quantity

+ NodeType *NodeTypeIdentifier

+ Queues []*QueueReport

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

+ func (*NodeTypeUsageReport) ProtoMessage()

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

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

+ func (m *NodeTypeUsageReport) GetNodeType() *NodeTypeIdentifier

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

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

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

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

+ func (m *NodeTypeUsageReport) Reset()

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

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

+ func (m *NodeTypeUsageReport) XXX_DiscardUnknown()

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

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

+ func (m *NodeTypeUsageReport) XXX_Size() int

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

+ func (this *NodeTypeUsageReport) String() string

type QueueReport

+ CountOfPodsByPhase map[string]uint32

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

v0.2.3

Aug 4, 2021

Changes in this version

type IngressConfig

+ Annotations map[string]string

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

type IngressType

+ const IngressType_Ingress

type JobCancelledEvent

+ Requestor string

+ func (m *JobCancelledEvent) GetRequestor() string

type JobCancellingEvent

+ Requestor string

+ func (m *JobCancellingEvent) GetRequestor() string

type JobReprioritizedEvent

+ Requestor string

+ func (m *JobReprioritizedEvent) GetRequestor() string

type JobReprioritizingEvent

+ Requestor string

+ func (m *JobReprioritizingEvent) GetRequestor() string

type JobUtilisationEvent

+ TotalCumulativeUsage map[string]resource.Quantity

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

+ type QueueGetRequest struct

+ Name string

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

+ func (*QueueGetRequest) ProtoMessage()

+ func (m *QueueGetRequest) GetName() string

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

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

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

+ func (m *QueueGetRequest) Reset()

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

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

+ func (m *QueueGetRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueGetRequest) XXX_Size() int

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

+ func (this *QueueGetRequest) String() string

type SubmitClient

+ GetQueue func(ctx context.Context, in *QueueGetRequest, opts ...grpc.CallOption) (*Queue, error)

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

type SubmitServer

+ GetQueue func(context.Context, *QueueGetRequest) (*Queue, error)

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

type UnimplementedSubmitServer

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

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

v0.2.2

Jul 30, 2021

v0.2.1

Jul 26, 2021

v0.2.0

Jul 22, 2021

v0.1.43

Jul 14, 2021

v0.1.42

Jul 12, 2021

v0.1.41

Jul 5, 2021

v0.1.40

Jun 18, 2021

v0.1.39

Jun 8, 2021

Changes in this version

type EventMessage

+ func (m *EventMessage) GetReprioritizing() *JobReprioritizingEvent

+ type EventMessage_Reprioritizing struct

+ Reprioritizing *JobReprioritizingEvent

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

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

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

+ func (this *EventMessage_Reprioritizing) String() string

+ type JobReprioritizeRequest struct

+ JobIds []string

+ JobSetId string

+ NewPriority float64

+ Queue string

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

+ func (*JobReprioritizeRequest) ProtoMessage()

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

+ func (m *JobReprioritizeRequest) GetJobSetId() string

+ func (m *JobReprioritizeRequest) GetNewPriority() float64

+ func (m *JobReprioritizeRequest) GetQueue() string

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

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

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

+ func (m *JobReprioritizeRequest) Reset()

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

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

+ func (m *JobReprioritizeRequest) XXX_DiscardUnknown()

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

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

+ func (m *JobReprioritizeRequest) XXX_Size() int

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

+ func (this *JobReprioritizeRequest) String() string

+ type JobReprioritizeResponse struct

+ ReprioritizationResults map[string]string

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

+ func (*JobReprioritizeResponse) ProtoMessage()

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

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

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

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

+ func (m *JobReprioritizeResponse) Reset()

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

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

+ func (m *JobReprioritizeResponse) XXX_DiscardUnknown()

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

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

+ func (m *JobReprioritizeResponse) XXX_Size() int

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

+ func (this *JobReprioritizeResponse) String() string

type JobReprioritizedEvent

+ NewPriority float64

+ func (m *JobReprioritizedEvent) GetNewPriority() float64

+ type JobReprioritizingEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ NewPriority float64

+ Queue string

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

+ func (*JobReprioritizingEvent) ProtoMessage()

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

+ func (m *JobReprioritizingEvent) GetJobId() string

+ func (m *JobReprioritizingEvent) GetJobSetId() string

+ func (m *JobReprioritizingEvent) GetNewPriority() float64

+ func (m *JobReprioritizingEvent) GetQueue() string

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

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

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

+ func (m *JobReprioritizingEvent) Reset()

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

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

+ func (m *JobReprioritizingEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobReprioritizingEvent) XXX_Size() int

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

+ func (this *JobReprioritizingEvent) String() string

type SubmitClient

+ ReprioritizeJobs func(ctx context.Context, in *JobReprioritizeRequest, opts ...grpc.CallOption) (*JobReprioritizeResponse, error)

type SubmitServer

+ ReprioritizeJobs func(context.Context, *JobReprioritizeRequest) (*JobReprioritizeResponse, error)

type UnimplementedSubmitServer

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

v0.1.38

Jun 7, 2021

v0.1.37

Jun 1, 2021

Changes in this version

type Job

+ QueueOwnershipUserGroups []string

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

v0.1.36

May 20, 2021

Changes in this version

type Cause

+ const Cause_DeadlineExceeded

type JobFailedEvent

+ PodName string

+ PodNamespace string

+ func (m *JobFailedEvent) GetPodName() string

+ func (m *JobFailedEvent) GetPodNamespace() string

type JobIngressInfoEvent

+ PodName string

+ PodNamespace string

+ func (m *JobIngressInfoEvent) GetPodName() string

+ func (m *JobIngressInfoEvent) GetPodNamespace() string

type JobPendingEvent

+ PodName string

+ PodNamespace string

+ func (m *JobPendingEvent) GetPodName() string

+ func (m *JobPendingEvent) GetPodNamespace() string

type JobRunningEvent

+ PodName string

+ PodNamespace string

+ func (m *JobRunningEvent) GetPodName() string

+ func (m *JobRunningEvent) GetPodNamespace() string

type JobSucceededEvent

+ PodName string

+ PodNamespace string

+ func (m *JobSucceededEvent) GetPodName() string

+ func (m *JobSucceededEvent) GetPodNamespace() string

type JobTerminatedEvent

+ PodName string

+ PodNamespace string

+ func (m *JobTerminatedEvent) GetPodName() string

+ func (m *JobTerminatedEvent) GetPodNamespace() string

type JobUnableToScheduleEvent

+ PodName string

+ PodNamespace string

+ func (m *JobUnableToScheduleEvent) GetPodName() string

+ func (m *JobUnableToScheduleEvent) GetPodNamespace() string

type JobUtilisationEvent

+ PodName string

+ PodNamespace string

+ func (m *JobUtilisationEvent) GetPodName() string

+ func (m *JobUtilisationEvent) GetPodNamespace() string

type KubernetesEvent

+ GetPodName func() string

+ GetPodNamespace func() string

v0.1.35

May 17, 2021

v0.1.34

May 13, 2021

Changes in this version

+ var IngressType_name = map[int32]string

+ var IngressType_value = map[string]int32

type EventMessage

+ func (m *EventMessage) GetIngressInfo() *JobIngressInfoEvent

+ type EventMessage_IngressInfo struct

+ IngressInfo *JobIngressInfoEvent

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

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

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

+ func (this *EventMessage_IngressInfo) String() string

+ type IngressConfig struct

+ Ports []uint32

+ Type IngressType

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

+ func (*IngressConfig) ProtoMessage()

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

+ func (m *IngressConfig) GetType() IngressType

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

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

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

+ func (m *IngressConfig) Reset()

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

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

+ func (m *IngressConfig) XXX_DiscardUnknown()

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

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

+ func (m *IngressConfig) XXX_Size() int

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

+ func (this *IngressConfig) String() string

+ type IngressType int32

+ const IngressType_NodePort

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

+ func (x *IngressType) UnmarshalJSON(data []byte) error

+ func (x IngressType) String() string

type Job

+ Ingress []*IngressConfig

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

+ type JobIngressInfoEvent struct

+ ClusterId string

+ Created time.Time

+ IngressAddresses map[int32]string

+ JobId string

+ JobSetId string

+ KubernetesId string

+ NodeName string

+ PodNumber int32

+ Queue string

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

+ func (*JobIngressInfoEvent) ProtoMessage()

+ func (m *JobIngressInfoEvent) GetClusterId() string

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

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

+ func (m *JobIngressInfoEvent) GetJobId() string

+ func (m *JobIngressInfoEvent) GetJobSetId() string

+ func (m *JobIngressInfoEvent) GetKubernetesId() string

+ func (m *JobIngressInfoEvent) GetNodeName() string

+ func (m *JobIngressInfoEvent) GetPodNumber() int32

+ func (m *JobIngressInfoEvent) GetQueue() string

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

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

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

+ func (m *JobIngressInfoEvent) Reset()

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

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

+ func (m *JobIngressInfoEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobIngressInfoEvent) XXX_Size() int

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

+ func (this *JobIngressInfoEvent) String() string

type JobSubmitRequestItem

+ Ingress []*IngressConfig

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

type JobTerminatedEvent

+ KubernetesId string

+ PodNumber int32

+ Reason string

+ func (m *JobTerminatedEvent) GetKubernetesId() string

+ func (m *JobTerminatedEvent) GetPodNumber() int32

+ func (m *JobTerminatedEvent) GetReason() string

v0.1.33

May 6, 2021

Changes in this version

type EventMessage

+ func (m *EventMessage) GetDuplicateFound() *JobDuplicateFoundEvent

+ type EventMessage_DuplicateFound struct

+ DuplicateFound *JobDuplicateFoundEvent

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

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

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

+ func (this *EventMessage_DuplicateFound) String() string

+ type JobDuplicateFoundEvent struct

+ Created time.Time

+ JobId string

+ JobSetId string

+ OriginalJobId string

+ Queue string

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

+ func (*JobDuplicateFoundEvent) ProtoMessage()

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

+ func (m *JobDuplicateFoundEvent) GetJobId() string

+ func (m *JobDuplicateFoundEvent) GetJobSetId() string

+ func (m *JobDuplicateFoundEvent) GetOriginalJobId() string

+ func (m *JobDuplicateFoundEvent) GetQueue() string

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

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

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

+ func (m *JobDuplicateFoundEvent) Reset()

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

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

+ func (m *JobDuplicateFoundEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobDuplicateFoundEvent) XXX_Size() int

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

+ func (this *JobDuplicateFoundEvent) String() string

v0.1.32

Apr 29, 2021

v0.1.31

Apr 22, 2021

v0.1.30

Apr 8, 2021

v0.1.29

Apr 8, 2021

v0.1.28

Mar 16, 2021

Changes in this version

type Job

+ ClientId string

+ func (m *Job) GetClientId() string

type JobSubmitRequestItem

+ ClientId string

+ func (m *JobSubmitRequestItem) GetClientId() string

v0.1.27

Mar 10, 2021

v0.1.26

Mar 9, 2021

v0.1.25

Mar 3, 2021

v0.1.24

Feb 23, 2021

Changes in this version

+ var Cause_name = map[int32]string

+ var Cause_value = map[string]int32

+ type Cause int32

+ const Cause_Error

+ const Cause_Evicted

+ const Cause_OOM

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

+ func (x Cause) String() string

type ClusterSchedulingInfoReport

+ Pool string

+ func (m *ClusterSchedulingInfoReport) GetPool() string

type ClusterUsageReport

+ Pool string

+ func (m *ClusterUsageReport) GetPool() string

+ type ContainerStatus struct

+ Cause Cause

+ ExitCode int32

+ Message string

+ Name string

+ Reason string

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

+ func (*ContainerStatus) ProtoMessage()

+ func (m *ContainerStatus) GetCause() Cause

+ func (m *ContainerStatus) GetExitCode() int32

+ func (m *ContainerStatus) GetMessage() string

+ func (m *ContainerStatus) GetName() string

+ func (m *ContainerStatus) GetReason() string

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

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

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

+ func (m *ContainerStatus) Reset()

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

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

+ func (m *ContainerStatus) XXX_DiscardUnknown()

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

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

+ func (m *ContainerStatus) XXX_Size() int

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

+ func (this *ContainerStatus) String() string

type JobFailedEvent

+ Cause Cause

+ ContainerStatuses []*ContainerStatus

+ func (m *JobFailedEvent) GetCause() Cause

+ func (m *JobFailedEvent) GetContainerStatuses() []*ContainerStatus

type LeaseRequest

+ Pool string

+ func (m *LeaseRequest) GetPool() string

v0.1.23

Feb 11, 2021

Changes in this version

type Job

+ PodSpecs []*v1.PodSpec

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

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

type JobFailedEvent

+ PodNumber int32

+ func (m *JobFailedEvent) GetPodNumber() int32

type JobPendingEvent

+ PodNumber int32

+ func (m *JobPendingEvent) GetPodNumber() int32

type JobRunningEvent

+ PodNumber int32

+ func (m *JobRunningEvent) GetPodNumber() int32

type JobSubmitRequestItem

+ PodSpecs []*v1.PodSpec

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

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

type JobSucceededEvent

+ PodNumber int32

+ func (m *JobSucceededEvent) GetPodNumber() int32

type JobUnableToScheduleEvent

+ PodNumber int32

+ func (m *JobUnableToScheduleEvent) GetPodNumber() int32

type JobUtilisationEvent

+ PodNumber int32

+ func (m *JobUtilisationEvent) GetPodNumber() int32

type KubernetesEvent

+ GetPodNumber func() int32

v0.1.22

Jan 25, 2021

v0.1.21

Jan 21, 2021

v0.1.20

Dec 14, 2020

v0.1.19

Dec 1, 2020

v0.1.18

Nov 18, 2020

v0.1.17

Nov 16, 2020

v0.1.16

Nov 11, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupQueue = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupSubmit = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupUsage = fmt.Errorf("proto: unexpected end of group")

type CancellationResult

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

type ClusterLeasedReport

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

type ClusterSchedulingInfoReport

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

type ClusterUsageReport

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

type ComputeResource

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

type EventList

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

type EventMessage

+ func (*EventMessage) XXX_OneofWrappers() []interface{}

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

type EventMessage_Cancelled

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

type EventMessage_Cancelling

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

type EventMessage_Failed

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

type EventMessage_LeaseExpired

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

type EventMessage_LeaseReturned

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

type EventMessage_Leased

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

type EventMessage_Pending

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

type EventMessage_Queued

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

type EventMessage_Reprioritized

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

type EventMessage_Running

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

type EventMessage_Submitted

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

type EventMessage_Succeeded

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

type EventMessage_Terminated

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

type EventMessage_UnableToSchedule

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

type EventMessage_Utilisation

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

type EventStreamMessage

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

type IdList

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

type Job

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

type JobCancelRequest

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

type JobCancelledEvent

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

type JobCancellingEvent

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

type JobFailedEvent

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

type JobLease

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

type JobLeaseExpiredEvent

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

type JobLeaseReturnedEvent

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

type JobLeasedEvent

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

type JobPendingEvent

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

type JobQueuedEvent

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

type JobReprioritizedEvent

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

type JobRunningEvent

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

type JobSetInfo

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

type JobSetRequest

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

type JobSubmitRequest

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

type JobSubmitRequestItem

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

type JobSubmitResponse

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

type JobSubmitResponseItem

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

type JobSubmittedEvent

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

type JobSucceededEvent

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

type JobTerminatedEvent

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

type JobUnableToScheduleEvent

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

type JobUtilisationEvent

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

+ type KubernetesEvent interface

+ GetClusterId func() string

+ GetKubernetesId func() string

type LeaseRequest

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

type NodeInfo

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

type NodeLabeling

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

type NodeType

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

type Queue

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

type QueueDeleteRequest

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

type QueueInfo

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

type QueueInfoRequest

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

type QueueLeasedReport

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

type QueueReport

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

type RenewLeaseRequest

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

type ReturnLeaseRequest

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

+ type UnimplementedAggregatedQueueServer struct

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

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

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

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

+ type UnimplementedEventServer struct

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

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

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

+ type UnimplementedSubmitServer struct

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

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

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

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

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

+ type UnimplementedUsageServer struct

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

v0.1.15

Sep 23, 2020

v0.1.14

Sep 10, 2020

Changes in this version

type ClusterSchedulingInfoReport

+ NodeTypes []*NodeType

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

type LeaseRequest

+ Nodes []NodeInfo

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

+ type NodeInfo struct

+ AllocatableResources map[string]resource.Quantity

+ AvailableResources map[string]resource.Quantity

+ Labels map[string]string

+ Name string

+ Taints []v1.Taint

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

+ func (*NodeInfo) ProtoMessage()

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

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

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

+ func (m *NodeInfo) GetName() string

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

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

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

+ func (m *NodeInfo) Reset()

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

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

+ func (m *NodeInfo) XXX_DiscardUnknown()

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

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

+ func (m *NodeInfo) XXX_Size() int

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

+ func (this *NodeInfo) String() string

+ type NodeType struct

+ AllocatableResources map[string]resource.Quantity

+ Labels map[string]string

+ Taints []v1.Taint

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

+ func (*NodeType) ProtoMessage()

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

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

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

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

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

+ func (m *NodeType) Reset()

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

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

+ func (m *NodeType) XXX_DiscardUnknown()

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

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

+ func (m *NodeType) XXX_Size() int

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

+ func (this *NodeType) String() string

+ type QueueDeleteRequest struct

+ Name string

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

+ func (*QueueDeleteRequest) ProtoMessage()

+ func (m *QueueDeleteRequest) GetName() string

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

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

+ func (m *QueueDeleteRequest) Reset()

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

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

+ func (m *QueueDeleteRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueDeleteRequest) XXX_Size() int

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

+ func (this *QueueDeleteRequest) String() string

type SubmitClient

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

type SubmitServer

+ DeleteQueue func(context.Context, *QueueDeleteRequest) (*types.Empty, error)

v0.1.13

Aug 11, 2020

v0.1.12

Aug 7, 2020

Changes in this version

type JobFailedEvent

+ NodeName string

+ func (m *JobFailedEvent) GetNodeName() string

type JobRunningEvent

+ NodeName string

+ func (m *JobRunningEvent) GetNodeName() string

type JobSucceededEvent

+ NodeName string

+ func (m *JobSucceededEvent) GetNodeName() string

type JobUnableToScheduleEvent

+ NodeName string

+ func (m *JobUnableToScheduleEvent) GetNodeName() string

type JobUtilisationEvent

+ NodeName string

+ func (m *JobUtilisationEvent) GetNodeName() string

v0.1.11

Jul 21, 2020

v0.1.10

Jul 20, 2020

v0.1.9

Jul 1, 2020

Changes in this version

type EventMessage

+ func (m *EventMessage) GetUtilisation() *JobUtilisationEvent

type EventMessage_Cancelled

+ func (this *EventMessage_Cancelled) String() string

type EventMessage_Cancelling

+ func (this *EventMessage_Cancelling) String() string

type EventMessage_Failed

+ func (this *EventMessage_Failed) String() string

type EventMessage_LeaseExpired

+ func (this *EventMessage_LeaseExpired) String() string

type EventMessage_LeaseReturned

+ func (this *EventMessage_LeaseReturned) String() string

type EventMessage_Leased

+ func (this *EventMessage_Leased) String() string

type EventMessage_Pending

+ func (this *EventMessage_Pending) String() string

type EventMessage_Queued

+ func (this *EventMessage_Queued) String() string

type EventMessage_Reprioritized

+ func (this *EventMessage_Reprioritized) String() string

type EventMessage_Running

+ func (this *EventMessage_Running) String() string

type EventMessage_Submitted

+ func (this *EventMessage_Submitted) String() string

type EventMessage_Succeeded

+ func (this *EventMessage_Succeeded) String() string

type EventMessage_Terminated

+ func (this *EventMessage_Terminated) String() string

type EventMessage_UnableToSchedule

+ func (this *EventMessage_UnableToSchedule) String() string

+ type EventMessage_Utilisation struct

+ Utilisation *JobUtilisationEvent

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

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

+ func (this *EventMessage_Utilisation) String() string

+ type JobUtilisationEvent struct

+ ClusterId string

+ Created time.Time

+ JobId string

+ JobSetId string

+ KubernetesId string

+ MaxResourcesForPeriod map[string]resource.Quantity

+ Queue string

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

+ func (*JobUtilisationEvent) ProtoMessage()

+ func (m *JobUtilisationEvent) GetClusterId() string

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

+ func (m *JobUtilisationEvent) GetJobId() string

+ func (m *JobUtilisationEvent) GetJobSetId() string

+ func (m *JobUtilisationEvent) GetKubernetesId() string

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

+ func (m *JobUtilisationEvent) GetQueue() string

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

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

+ func (m *JobUtilisationEvent) Reset()

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

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

+ func (m *JobUtilisationEvent) XXX_DiscardUnknown()

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

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

+ func (m *JobUtilisationEvent) XXX_Size() int

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

+ func (this *JobUtilisationEvent) String() string

v0.1.8

Jun 26, 2020

v0.1.7

Jun 12, 2020

v0.1.6

Jun 9, 2020

Changes in this version

+ type ClusterLeasedReport struct

+ ClusterId string

+ Queues []*QueueLeasedReport

+ ReportTime time.Time

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

+ func (*ClusterLeasedReport) ProtoMessage()

+ func (m *ClusterLeasedReport) GetClusterId() string

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

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

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

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

+ func (m *ClusterLeasedReport) Reset()

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

+ func (m *ClusterLeasedReport) String() string

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

+ func (m *ClusterLeasedReport) XXX_DiscardUnknown()

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

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

+ func (m *ClusterLeasedReport) XXX_Size() int

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

+ type ClusterSchedulingInfoReport struct

+ AvailableLabels []*NodeLabeling

+ ClusterId string

+ MinimumJobSize map[string]resource.Quantity

+ NodeSizes []ComputeResource

+ ReportTime time.Time

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

+ func (*ClusterSchedulingInfoReport) ProtoMessage()

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

+ func (m *ClusterSchedulingInfoReport) GetClusterId() string

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

+ func (m *ClusterSchedulingInfoReport) GetNodeSizes() []ComputeResource

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

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

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

+ func (m *ClusterSchedulingInfoReport) Reset()

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

+ func (m *ClusterSchedulingInfoReport) String() string

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

+ func (m *ClusterSchedulingInfoReport) XXX_DiscardUnknown()

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

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

+ func (m *ClusterSchedulingInfoReport) XXX_Size() int

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

+ type ComputeResource struct

+ Resources map[string]resource.Quantity

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

+ func (*ComputeResource) ProtoMessage()

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

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

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

+ func (m *ComputeResource) Reset()

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

+ func (m *ComputeResource) String() string

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

+ func (m *ComputeResource) XXX_DiscardUnknown()

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

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

+ func (m *ComputeResource) XXX_Size() int

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

type JobFailedEvent

+ KubernetesId string

+ func (m *JobFailedEvent) GetKubernetesId() string

type JobPendingEvent

+ KubernetesId string

+ func (m *JobPendingEvent) GetKubernetesId() string

type JobRunningEvent

+ KubernetesId string

+ func (m *JobRunningEvent) GetKubernetesId() string

type JobSucceededEvent

+ KubernetesId string

+ func (m *JobSucceededEvent) GetKubernetesId() string

type JobUnableToScheduleEvent

+ KubernetesId string

+ func (m *JobUnableToScheduleEvent) GetKubernetesId() string

type LeaseRequest

+ ClusterLeasedReport ClusterLeasedReport

+ MinimumJobSize map[string]resource.Quantity

+ NodeSizes []ComputeResource

+ func (m *LeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

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

+ func (m *LeaseRequest) GetNodeSizes() []ComputeResource

type Queue

+ ResourceLimits map[string]float64

+ func (m *Queue) GetResourceLimits() map[string]float64

+ type QueueLeasedReport struct

+ Name string

+ ResourcesLeased map[string]resource.Quantity

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

+ func (*QueueLeasedReport) ProtoMessage()

+ func (m *QueueLeasedReport) GetName() string

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

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

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

+ func (m *QueueLeasedReport) Reset()

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

+ func (m *QueueLeasedReport) String() string

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

+ func (m *QueueLeasedReport) XXX_DiscardUnknown()

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

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

+ func (m *QueueLeasedReport) XXX_Size() int

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

v0.1.5

Apr 27, 2020

v0.1.4

Apr 22, 2020

v0.1.3

Apr 15, 2020

v0.1.2

Mar 25, 2020

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 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 RegisterEventServer(s *grpc.Server, srv EventServer)

+ 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 RegisterSubmitServer(s *grpc.Server, srv SubmitServer)

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

+ func SwaggerJsonTemplate() string

+ 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

+ ClusterAvailableCapacity map[string]resource.Quantity

+ ClusterCapacity map[string]resource.Quantity

+ ClusterId string

+ Queues []*QueueReport

+ ReportTime time.Time

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

+ func (*ClusterUsageReport) ProtoMessage()

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

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

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

+ func NewEventClient(cc *grpc.ClientConn) EventClient

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

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

+ func (message *EventMessage) UnmarshalJSON(data []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)

+ ReportMultiple func(context.Context, *EventList) (*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

+ Annotations map[string]string

+ Created time.Time

+ Id string

+ JobSetId string

+ Labels map[string]string

+ Namespace string

+ Owner string

+ PodSpec *v1.PodSpec

+ Priority float64

+ Queue string

+ RequiredNodeLabels map[string]string

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

+ func (*Job) ProtoMessage()

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

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

+ func (m *Job) GetId() string

+ func (m *Job) GetJobSetId() string

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

+ func (m *Job) GetNamespace() string

+ func (m *Job) GetOwner() string

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

+ func (m *Job) GetPriority() float64

+ func (m *Job) GetQueue() string

+ func (m *Job) GetRequiredNodeLabels() map[string]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

+ ExitCodes map[string]int32

+ 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) GetExitCodes() map[string]int32

+ 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 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 JobSetInfo struct

+ LeasedJobs int32

+ Name string

+ QueuedJobs int32

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

+ func (*JobSetInfo) ProtoMessage()

+ func (m *JobSetInfo) GetLeasedJobs() int32

+ func (m *JobSetInfo) GetName() string

+ func (m *JobSetInfo) GetQueuedJobs() int32

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

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

+ func (m *JobSetInfo) Reset()

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

+ func (m *JobSetInfo) String() string

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

+ func (m *JobSetInfo) XXX_DiscardUnknown()

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

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

+ func (m *JobSetInfo) XXX_Size() int

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

+ type JobSetRequest struct

+ FromMessageId string

+ Id string

+ Queue string

+ Watch bool

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

+ func (*JobSetRequest) ProtoMessage()

+ func (m *JobSetRequest) GetFromMessageId() string

+ func (m *JobSetRequest) GetId() string

+ func (m *JobSetRequest) GetQueue() 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 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

+ Annotations map[string]string

+ Labels map[string]string

+ Namespace string

+ PodSpec *v1.PodSpec

+ Priority float64

+ RequiredNodeLabels map[string]string

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

+ func (*JobSubmitRequestItem) ProtoMessage()

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

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

+ func (m *JobSubmitRequestItem) GetNamespace() string

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

+ func (m *JobSubmitRequestItem) GetPriority() float64

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

+ 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 struct

+ JobResponseItems []*JobSubmitResponseItem

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

+ func (*JobSubmitResponse) ProtoMessage()

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

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

+ AvailableLabels []*NodeLabeling

+ ClusterId string

+ Resources map[string]resource.Quantity

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

+ func (*LeaseRequest) ProtoMessage()

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

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

+ 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 QueueInfo struct

+ ActiveJobSets []*JobSetInfo

+ Name string

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

+ func (*QueueInfo) ProtoMessage()

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

+ func (m *QueueInfo) GetName() string

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

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

+ func (m *QueueInfo) Reset()

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

+ func (m *QueueInfo) String() string

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

+ func (m *QueueInfo) XXX_DiscardUnknown()

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

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

+ func (m *QueueInfo) XXX_Size() int

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

+ type QueueInfoRequest struct

+ Name string

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

+ func (*QueueInfoRequest) ProtoMessage()

+ func (m *QueueInfoRequest) GetName() string

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

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

+ func (m *QueueInfoRequest) Reset()

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

+ func (m *QueueInfoRequest) String() string

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

+ func (m *QueueInfoRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueueInfoRequest) XXX_Size() int

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

+ type QueueReport struct

+ Name string

+ Resources map[string]resource.Quantity

+ ResourcesUsed 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) GetResourcesUsed() 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)

+ GetQueueInfo func(ctx context.Context, in *QueueInfoRequest, opts ...grpc.CallOption) (*QueueInfo, error)

+ SubmitJobs func(ctx context.Context, in *JobSubmitRequest, 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)

+ GetQueueInfo func(context.Context, *QueueInfoRequest) (*QueueInfo, error)

+ SubmitJobs func(context.Context, *JobSubmitRequest) (*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