Documentation ¶
Index ¶
- Variables
- func RegisterSchedulerReportingServer(s *grpc.Server, srv SchedulerReportingServer)
- func V1ResourceListFromResourceList(rl ResourceList) v1.ResourceList
- type AllocatableByPriorityAndResourceType
- func (m AllocatableByPriorityAndResourceType) DeepCopy() AllocatableByPriorityAndResourceType
- func (allocatableByPriorityAndResourceType AllocatableByPriorityAndResourceType) Get(priority int32, resourceType string) resource.Quantity
- func (m AllocatableByPriorityAndResourceType) MarkAllocatable(p int32, rs ResourceList)
- func (m AllocatableByPriorityAndResourceType) MarkAllocatableV1ResourceList(p int32, rs v1.ResourceList)
- func (m AllocatableByPriorityAndResourceType) MarkAllocated(p int32, rs ResourceList)
- type AllocatedByPriorityAndResourceType
- func (assignedByPriorityAndResourceType AllocatedByPriorityAndResourceType) Get(priority int32, resourceType string) resource.Quantity
- func (m AllocatedByPriorityAndResourceType) MarkAllocatable(p int32, rs ResourceList)
- func (m AllocatedByPriorityAndResourceType) MarkAllocated(p int32, rs ResourceList)
- type Executor
- func (m *Executor) AllRuns() []string
- func (*Executor) Descriptor() ([]byte, []int)
- func (m *Executor) GetId() string
- func (m *Executor) GetLastUpdateTime() time.Time
- func (m *Executor) GetNodes() []*Node
- func (m *Executor) GetPool() string
- func (m *Executor) GetUnassignedJobRuns() []string
- func (m *Executor) Marshal() (dAtA []byte, err error)
- func (m *Executor) MarshalTo(dAtA []byte) (int, error)
- func (m *Executor) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Executor) ProtoMessage()
- func (m *Executor) Reset()
- func (m *Executor) Size() (n int)
- func (m *Executor) String() string
- func (m *Executor) Unmarshal(dAtA []byte) error
- func (m *Executor) XXX_DiscardUnknown()
- func (m *Executor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Executor) XXX_Merge(src proto.Message)
- func (m *Executor) XXX_Size() int
- func (m *Executor) XXX_Unmarshal(b []byte) error
- type ExecutorSettings
- func (*ExecutorSettings) Descriptor() ([]byte, []int)
- func (m *ExecutorSettings) GetCordonReason() string
- func (m *ExecutorSettings) GetCordoned() bool
- func (m *ExecutorSettings) GetExecutorId() string
- func (m *ExecutorSettings) Marshal() (dAtA []byte, err error)
- func (m *ExecutorSettings) MarshalTo(dAtA []byte) (int, error)
- func (m *ExecutorSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExecutorSettings) ProtoMessage()
- func (m *ExecutorSettings) Reset()
- func (m *ExecutorSettings) Size() (n int)
- func (m *ExecutorSettings) String() string
- func (m *ExecutorSettings) Unmarshal(dAtA []byte) error
- func (m *ExecutorSettings) XXX_DiscardUnknown()
- func (m *ExecutorSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecutorSettings) XXX_Merge(src proto.Message)
- func (m *ExecutorSettings) XXX_Size() int
- func (m *ExecutorSettings) XXX_Unmarshal(b []byte) error
- type JobReport
- func (*JobReport) Descriptor() ([]byte, []int)
- func (m *JobReport) GetReport() string
- func (m *JobReport) Marshal() (dAtA []byte, err error)
- func (m *JobReport) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReport) ProtoMessage()
- func (m *JobReport) Reset()
- func (m *JobReport) Size() (n int)
- func (m *JobReport) String() string
- func (m *JobReport) Unmarshal(dAtA []byte) error
- func (m *JobReport) XXX_DiscardUnknown()
- func (m *JobReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReport) XXX_Merge(src proto.Message)
- func (m *JobReport) XXX_Size() int
- func (m *JobReport) XXX_Unmarshal(b []byte) error
- type JobReportRequest
- func (*JobReportRequest) Descriptor() ([]byte, []int)
- func (m *JobReportRequest) GetJobId() string
- func (m *JobReportRequest) Marshal() (dAtA []byte, err error)
- func (m *JobReportRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobReportRequest) ProtoMessage()
- func (m *JobReportRequest) Reset()
- func (m *JobReportRequest) Size() (n int)
- func (m *JobReportRequest) String() string
- func (m *JobReportRequest) Unmarshal(dAtA []byte) error
- func (m *JobReportRequest) XXX_DiscardUnknown()
- func (m *JobReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobReportRequest) XXX_Merge(src proto.Message)
- func (m *JobReportRequest) XXX_Size() int
- func (m *JobReportRequest) XXX_Unmarshal(b []byte) error
- type JobRunState
- type JobSchedulingInfo
- func (*JobSchedulingInfo) Descriptor() ([]byte, []int)
- func (m *JobSchedulingInfo) GetAtMostOnce() bool
- func (m *JobSchedulingInfo) GetConcurrencySafe() bool
- func (m *JobSchedulingInfo) GetLifetime() uint32
- func (m *JobSchedulingInfo) GetObjectRequirements() []*ObjectRequirements
- func (info *JobSchedulingInfo) GetPodRequirements() *PodRequirements
- func (m *JobSchedulingInfo) GetPreemptible() bool
- func (m *JobSchedulingInfo) GetPriority() uint32
- func (m *JobSchedulingInfo) GetPriorityClassName() string
- func (m *JobSchedulingInfo) GetSubmitTime() time.Time
- func (m *JobSchedulingInfo) GetVersion() uint32
- func (m *JobSchedulingInfo) Marshal() (dAtA []byte, err error)
- func (m *JobSchedulingInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *JobSchedulingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobSchedulingInfo) ProtoMessage()
- func (m *JobSchedulingInfo) Reset()
- func (m *JobSchedulingInfo) Size() (n int)
- func (m *JobSchedulingInfo) String() string
- func (m *JobSchedulingInfo) Unmarshal(dAtA []byte) error
- func (m *JobSchedulingInfo) XXX_DiscardUnknown()
- func (m *JobSchedulingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobSchedulingInfo) XXX_Merge(src proto.Message)
- func (m *JobSchedulingInfo) XXX_Size() int
- func (m *JobSchedulingInfo) XXX_Unmarshal(b []byte) error
- type MostRecentForJob
- func (*MostRecentForJob) Descriptor() ([]byte, []int)
- func (m *MostRecentForJob) GetJobId() string
- func (m *MostRecentForJob) Marshal() (dAtA []byte, err error)
- func (m *MostRecentForJob) MarshalTo(dAtA []byte) (int, error)
- func (m *MostRecentForJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MostRecentForJob) ProtoMessage()
- func (m *MostRecentForJob) Reset()
- func (m *MostRecentForJob) Size() (n int)
- func (m *MostRecentForJob) String() string
- func (m *MostRecentForJob) Unmarshal(dAtA []byte) error
- func (m *MostRecentForJob) XXX_DiscardUnknown()
- func (m *MostRecentForJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MostRecentForJob) XXX_Merge(src proto.Message)
- func (m *MostRecentForJob) XXX_Size() int
- func (m *MostRecentForJob) XXX_Unmarshal(b []byte) error
- type MostRecentForQueue
- func (*MostRecentForQueue) Descriptor() ([]byte, []int)
- func (m *MostRecentForQueue) GetQueueName() string
- func (m *MostRecentForQueue) Marshal() (dAtA []byte, err error)
- func (m *MostRecentForQueue) MarshalTo(dAtA []byte) (int, error)
- func (m *MostRecentForQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MostRecentForQueue) ProtoMessage()
- func (m *MostRecentForQueue) Reset()
- func (m *MostRecentForQueue) Size() (n int)
- func (m *MostRecentForQueue) String() string
- func (m *MostRecentForQueue) Unmarshal(dAtA []byte) error
- func (m *MostRecentForQueue) XXX_DiscardUnknown()
- func (m *MostRecentForQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MostRecentForQueue) XXX_Merge(src proto.Message)
- func (m *MostRecentForQueue) XXX_Size() int
- func (m *MostRecentForQueue) XXX_Unmarshal(b []byte) error
- type Node
- func (node *Node) AvailableArmadaResource() ResourceList
- func (node *Node) CompactString() string
- func (node *Node) DeepCopy() *Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetAllocatableByPriorityAndResource() map[int32]ResourceList
- func (m *Node) GetExecutor() string
- func (m *Node) GetId() string
- func (m *Node) GetLabels() map[string]string
- func (m *Node) GetLastSeen() time.Time
- func (m *Node) GetName() string
- func (m *Node) GetPool() string
- func (m *Node) GetReportingNodeType() string
- func (m *Node) GetResourceUsageByQueueAndPool() []*PoolQueueResource
- func (m *Node) GetStateByJobRunId() map[string]JobRunState
- func (m *Node) GetTaints() []v1.Taint
- func (m *Node) GetTotalResources() ResourceList
- func (m *Node) GetUnallocatableResources() map[int32]ResourceList
- func (m *Node) GetUnschedulable() bool
- func (m *Node) Marshal() (dAtA []byte, err error)
- func (m *Node) MarshalTo(dAtA []byte) (int, error)
- func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (m *Node) String() string
- func (m *Node) Unmarshal(dAtA []byte) error
- func (m *Node) XXX_DiscardUnknown()
- func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Node) XXX_Merge(src proto.Message)
- func (m *Node) XXX_Size() int
- func (m *Node) XXX_Unmarshal(b []byte) error
- type ObjectRequirements
- func (*ObjectRequirements) Descriptor() ([]byte, []int)
- func (m *ObjectRequirements) GetPodRequirements() *PodRequirements
- func (m *ObjectRequirements) GetRequirements() isObjectRequirements_Requirements
- func (m *ObjectRequirements) Marshal() (dAtA []byte, err error)
- func (m *ObjectRequirements) MarshalTo(dAtA []byte) (int, error)
- func (m *ObjectRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ObjectRequirements) ProtoMessage()
- func (m *ObjectRequirements) Reset()
- func (m *ObjectRequirements) Size() (n int)
- func (m *ObjectRequirements) String() string
- func (m *ObjectRequirements) Unmarshal(dAtA []byte) error
- func (m *ObjectRequirements) XXX_DiscardUnknown()
- func (m *ObjectRequirements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectRequirements) XXX_Merge(src proto.Message)
- func (*ObjectRequirements) XXX_OneofWrappers() []interface{}
- func (m *ObjectRequirements) XXX_Size() int
- func (m *ObjectRequirements) XXX_Unmarshal(b []byte) error
- type ObjectRequirements_PodRequirements
- type PodRequirements
- func (*PodRequirements) Descriptor() ([]byte, []int)
- func (m *PodRequirements) GetAffinity() *v1.Affinity
- func (req *PodRequirements) GetAffinityNodeSelector() *v1.NodeSelector
- func (m *PodRequirements) GetAnnotations() map[string]string
- func (m *PodRequirements) GetNodeSelector() map[string]string
- func (m *PodRequirements) GetPreemptionPolicy() string
- func (m *PodRequirements) GetResourceRequirements() v1.ResourceRequirements
- func (m *PodRequirements) GetTolerations() []v1.Toleration
- func (m *PodRequirements) Marshal() (dAtA []byte, err error)
- func (m *PodRequirements) MarshalTo(dAtA []byte) (int, error)
- func (m *PodRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PodRequirements) ProtoMessage()
- func (m *PodRequirements) Reset()
- func (m *PodRequirements) Size() (n int)
- func (m *PodRequirements) String() string
- func (m *PodRequirements) Unmarshal(dAtA []byte) error
- func (m *PodRequirements) XXX_DiscardUnknown()
- func (m *PodRequirements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodRequirements) XXX_Merge(src proto.Message)
- func (m *PodRequirements) XXX_Size() int
- func (m *PodRequirements) XXX_Unmarshal(b []byte) error
- type PodRequirementsSerialiser
- func (skg *PodRequirementsSerialiser) AppendAffinity(out []byte, affinity *v1.Affinity) []byte
- func (skg *PodRequirementsSerialiser) AppendAffinityNodeSelector(out []byte, nodeSelector *v1.NodeSelector) []byte
- func (skg *PodRequirementsSerialiser) AppendNodeSelector(out []byte, nodeSelector map[string]string) []byte
- func (skg *PodRequirementsSerialiser) AppendNodeSelectorRequirements(out []byte, nodeSelectorRequirements []v1.NodeSelectorRequirement) []byte
- func (skg *PodRequirementsSerialiser) AppendRequirements(out []byte, nodeSelector map[string]string, affinity *v1.Affinity, ...) []byte
- func (skg *PodRequirementsSerialiser) AppendResourceList(out []byte, resourceList v1.ResourceList) []byte
- func (skg *PodRequirementsSerialiser) AppendTolerations(out []byte, tolerations []v1.Toleration) []byte
- type PoolQueueResource
- func (*PoolQueueResource) Descriptor() ([]byte, []int)
- func (m *PoolQueueResource) GetPool() string
- func (m *PoolQueueResource) GetQueue() string
- func (m *PoolQueueResource) GetResources() *ResourceList
- func (m *PoolQueueResource) Marshal() (dAtA []byte, err error)
- func (m *PoolQueueResource) MarshalTo(dAtA []byte) (int, error)
- func (m *PoolQueueResource) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PoolQueueResource) ProtoMessage()
- func (m *PoolQueueResource) Reset()
- func (m *PoolQueueResource) Size() (n int)
- func (m *PoolQueueResource) String() string
- func (m *PoolQueueResource) Unmarshal(dAtA []byte) error
- func (m *PoolQueueResource) XXX_DiscardUnknown()
- func (m *PoolQueueResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PoolQueueResource) XXX_Merge(src proto.Message)
- func (m *PoolQueueResource) XXX_Size() int
- func (m *PoolQueueResource) XXX_Unmarshal(b []byte) error
- type QuantityByTAndResourceType
- func (a QuantityByTAndResourceType[T]) Add(b QuantityByTAndResourceType[T])
- func (a QuantityByTAndResourceType[T]) AddResourceList(t T, rlb ResourceList)
- func (a QuantityByTAndResourceType[T]) AddV1ResourceList(t T, rlb v1.ResourceList)
- func (a QuantityByTAndResourceType[T]) AggregateByResource() ResourceList
- func (a QuantityByTAndResourceType[T]) DeepCopy() QuantityByTAndResourceType[T]
- func (a QuantityByTAndResourceType[T]) Equal(b QuantityByTAndResourceType[T]) bool
- func (a QuantityByTAndResourceType[T]) IsStrictlyNonNegative() bool
- func (a QuantityByTAndResourceType[T]) IsZero() bool
- func (a QuantityByTAndResourceType[T]) MaxAggregatedByResource(t T, rl ResourceList)
- func (a QuantityByTAndResourceType[T]) String() string
- func (a QuantityByTAndResourceType[T]) Sub(b QuantityByTAndResourceType[T])
- func (a QuantityByTAndResourceType[T]) SubResourceList(t T, rlb ResourceList)
- func (a QuantityByTAndResourceType[T]) SubV1ResourceList(t T, rlb v1.ResourceList)
- type QueueReport
- func (*QueueReport) Descriptor() ([]byte, []int)
- func (m *QueueReport) GetReport() string
- func (m *QueueReport) Marshal() (dAtA []byte, err error)
- func (m *QueueReport) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueReport) ProtoMessage()
- 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 QueueReportRequest
- func (*QueueReportRequest) Descriptor() ([]byte, []int)
- func (m *QueueReportRequest) GetQueueName() string
- func (m *QueueReportRequest) GetVerbosity() int32
- func (m *QueueReportRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueReportRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueReportRequest) ProtoMessage()
- func (m *QueueReportRequest) Reset()
- func (m *QueueReportRequest) Size() (n int)
- func (m *QueueReportRequest) String() string
- func (m *QueueReportRequest) Unmarshal(dAtA []byte) error
- func (m *QueueReportRequest) XXX_DiscardUnknown()
- func (m *QueueReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueReportRequest) XXX_Merge(src proto.Message)
- func (m *QueueReportRequest) XXX_Size() int
- func (m *QueueReportRequest) XXX_Unmarshal(b []byte) error
- type ResourceList
- func (a *ResourceList) Add(b ResourceList)
- func (rl *ResourceList) AddQuantity(resourceType string, quantity resource.Quantity)
- func (a *ResourceList) AddV1ResourceList(b v1.ResourceList)
- func (rl *ResourceList) AsWeightedMillis(weights map[string]float64) int64
- func (rl ResourceList) CompactString() string
- func (rl ResourceList) DeepCopy() ResourceList
- func (*ResourceList) Descriptor() ([]byte, []int)
- func (a ResourceList) Equal(b ResourceList) bool
- func (rl *ResourceList) Get(resourceType string) resource.Quantity
- func (m *ResourceList) GetResources() map[string]resource.Quantity
- func (a ResourceList) IsStrictlyNonNegative() bool
- func (a ResourceList) IsZero() bool
- func (a *ResourceList) LimitToZero()
- func (m *ResourceList) Marshal() (dAtA []byte, err error)
- func (m *ResourceList) MarshalTo(dAtA []byte) (int, error)
- func (m *ResourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResourceList) ProtoMessage()
- func (m *ResourceList) Reset()
- func (rl *ResourceList) Set(t string, q resource.Quantity)
- func (m *ResourceList) Size() (n int)
- func (m *ResourceList) String() string
- func (a *ResourceList) Sub(b ResourceList)
- func (rl *ResourceList) SubQuantity(resourceType string, quantity resource.Quantity)
- func (a *ResourceList) SubV1ResourceList(b v1.ResourceList)
- func (m *ResourceList) Unmarshal(dAtA []byte) error
- func (m *ResourceList) XXX_DiscardUnknown()
- func (m *ResourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResourceList) XXX_Merge(src proto.Message)
- func (m *ResourceList) XXX_Size() int
- func (m *ResourceList) XXX_Unmarshal(b []byte) error
- func (rl ResourceList) Zero()
- type SchedulerReportingClient
- type SchedulerReportingServer
- type SchedulingKey
- type SchedulingKeyGenerator
- type SchedulingReport
- func (*SchedulingReport) Descriptor() ([]byte, []int)
- func (m *SchedulingReport) GetReport() string
- func (m *SchedulingReport) Marshal() (dAtA []byte, err error)
- func (m *SchedulingReport) MarshalTo(dAtA []byte) (int, error)
- func (m *SchedulingReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SchedulingReport) ProtoMessage()
- func (m *SchedulingReport) Reset()
- func (m *SchedulingReport) Size() (n int)
- func (m *SchedulingReport) String() string
- func (m *SchedulingReport) Unmarshal(dAtA []byte) error
- func (m *SchedulingReport) XXX_DiscardUnknown()
- func (m *SchedulingReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SchedulingReport) XXX_Merge(src proto.Message)
- func (m *SchedulingReport) XXX_Size() int
- func (m *SchedulingReport) XXX_Unmarshal(b []byte) error
- type SchedulingReportRequest
- func (*SchedulingReportRequest) Descriptor() ([]byte, []int)
- func (m *SchedulingReportRequest) GetFilter() isSchedulingReportRequest_Filter
- func (m *SchedulingReportRequest) GetMostRecentForJob() *MostRecentForJob
- func (m *SchedulingReportRequest) GetMostRecentForQueue() *MostRecentForQueue
- func (m *SchedulingReportRequest) GetVerbosity() int32
- func (m *SchedulingReportRequest) Marshal() (dAtA []byte, err error)
- func (m *SchedulingReportRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SchedulingReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SchedulingReportRequest) ProtoMessage()
- func (m *SchedulingReportRequest) Reset()
- func (m *SchedulingReportRequest) Size() (n int)
- func (m *SchedulingReportRequest) String() string
- func (m *SchedulingReportRequest) Unmarshal(dAtA []byte) error
- func (m *SchedulingReportRequest) XXX_DiscardUnknown()
- func (m *SchedulingReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SchedulingReportRequest) XXX_Merge(src proto.Message)
- func (*SchedulingReportRequest) XXX_OneofWrappers() []interface{}
- func (m *SchedulingReportRequest) XXX_Size() int
- func (m *SchedulingReportRequest) XXX_Unmarshal(b []byte) error
- type SchedulingReportRequest_MostRecentForJob
- type SchedulingReportRequest_MostRecentForQueue
- type UnimplementedSchedulerReportingServer
- func (*UnimplementedSchedulerReportingServer) GetJobReport(ctx context.Context, req *JobReportRequest) (*JobReport, error)
- func (*UnimplementedSchedulerReportingServer) GetQueueReport(ctx context.Context, req *QueueReportRequest) (*QueueReport, error)
- func (*UnimplementedSchedulerReportingServer) GetSchedulingReport(ctx context.Context, req *SchedulingReportRequest) (*SchedulingReport, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthReporting = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowReporting = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupReporting = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthSchedulerobjects = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSchedulerobjects = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSchedulerobjects = fmt.Errorf("proto: unexpected end of group") )
var JobRunState_name = map[int32]string{
0: "UNKNOWN",
1: "PENDING",
2: "RUNNING",
3: "SUCCEEDED",
4: "FAILED",
}
var JobRunState_value = map[string]int32{
"UNKNOWN": 0,
"PENDING": 1,
"RUNNING": 2,
"SUCCEEDED": 3,
"FAILED": 4,
}
Functions ¶
func RegisterSchedulerReportingServer ¶
func RegisterSchedulerReportingServer(s *grpc.Server, srv SchedulerReportingServer)
func V1ResourceListFromResourceList ¶ added in v0.3.47
func V1ResourceListFromResourceList(rl ResourceList) v1.ResourceList
Types ¶
type AllocatableByPriorityAndResourceType ¶
type AllocatableByPriorityAndResourceType QuantityByTAndResourceType[int32]
AllocatableByPriorityAndResourceType accounts for resources that can be allocated to pods of a given priority. E.g., AllocatableByPriorityAndResourceType[5]["cpu"] is the amount of CPU available to pods with priority 5, where alloctable resources = unused resources + resources allocated to lower-priority pods.
func NewAllocatableByPriorityAndResourceType ¶
func NewAllocatableByPriorityAndResourceType(priorities []int32, rl ResourceList) AllocatableByPriorityAndResourceType
func (AllocatableByPriorityAndResourceType) DeepCopy ¶
func (m AllocatableByPriorityAndResourceType) DeepCopy() AllocatableByPriorityAndResourceType
func (AllocatableByPriorityAndResourceType) Get ¶
func (allocatableByPriorityAndResourceType AllocatableByPriorityAndResourceType) Get(priority int32, resourceType string) resource.Quantity
func (AllocatableByPriorityAndResourceType) MarkAllocatable ¶
func (m AllocatableByPriorityAndResourceType) MarkAllocatable(p int32, rs ResourceList)
MarkAllocatable indicates resources have been released by pods of priority p, thus increasing the resources allocatable to pods of priority p or lower.
func (AllocatableByPriorityAndResourceType) MarkAllocatableV1ResourceList ¶ added in v0.3.70
func (m AllocatableByPriorityAndResourceType) MarkAllocatableV1ResourceList(p int32, rs v1.ResourceList)
func (AllocatableByPriorityAndResourceType) MarkAllocated ¶
func (m AllocatableByPriorityAndResourceType) MarkAllocated(p int32, rs ResourceList)
MarkAllocated indicates resources have been allocated to pods of priority p, hence reducing the resources allocatable to pods of priority p or lower.
type AllocatedByPriorityAndResourceType ¶
type AllocatedByPriorityAndResourceType QuantityByTAndResourceType[int32]
AllocatedByPriorityAndResourceType accounts for resources allocated to pods of a given priority or lower. E.g., AllocatedByPriorityAndResourceType[5]["cpu"] is the amount of CPU allocated to pods with priority 5 or lower.
func NewAllocatedByPriorityAndResourceType ¶
func NewAllocatedByPriorityAndResourceType(priorities []int32) AllocatedByPriorityAndResourceType
func (AllocatedByPriorityAndResourceType) Get ¶
func (assignedByPriorityAndResourceType AllocatedByPriorityAndResourceType) Get(priority int32, resourceType string) resource.Quantity
func (AllocatedByPriorityAndResourceType) MarkAllocatable ¶
func (m AllocatedByPriorityAndResourceType) MarkAllocatable(p int32, rs ResourceList)
MarkAllocatable reduces the resources allocated to pods of priority p or lower.
func (AllocatedByPriorityAndResourceType) MarkAllocated ¶
func (m AllocatedByPriorityAndResourceType) MarkAllocated(p int32, rs ResourceList)
MarkAllocated increases the resources allocated to pods of priority p or lower.
type Executor ¶
type Executor struct { // Name of the executor. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Pool that the executor belongs to. Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"` // The nodes available for scheduling via this executor. Nodes []*Node `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"` // Last time the executor provided a heartbeat to say it was still accepting job. LastUpdateTime time.Time `protobuf:"bytes,5,opt,name=lastUpdateTime,proto3,stdtime" json:"lastUpdateTime"` // Jobs that are owned by the cluster but are not assigned to any node. UnassignedJobRuns []string `protobuf:"bytes,9,rep,name=unassigned_job_runs,json=unassignedJobRuns,proto3" json:"unassignedJobRuns,omitempty"` }
Executor represents an executor running on a worker cluster
func (*Executor) Descriptor ¶
func (*Executor) GetLastUpdateTime ¶
func (*Executor) GetUnassignedJobRuns ¶
func (*Executor) MarshalToSizedBuffer ¶
func (*Executor) ProtoMessage ¶
func (*Executor) ProtoMessage()
func (*Executor) XXX_DiscardUnknown ¶
func (m *Executor) XXX_DiscardUnknown()
func (*Executor) XXX_Marshal ¶
func (*Executor) XXX_Unmarshal ¶
type ExecutorSettings ¶ added in v0.15.0
type ExecutorSettings struct { ExecutorId string `protobuf:"bytes,1,opt,name=executorId,proto3" json:"executorId,omitempty"` Cordoned bool `protobuf:"varint,2,opt,name=cordoned,proto3" json:"cordoned,omitempty"` CordonReason string `protobuf:"bytes,3,opt,name=cordonReason,proto3" json:"cordonReason,omitempty"` }
func (*ExecutorSettings) Descriptor ¶ added in v0.15.0
func (*ExecutorSettings) Descriptor() ([]byte, []int)
func (*ExecutorSettings) GetCordonReason ¶ added in v0.15.0
func (m *ExecutorSettings) GetCordonReason() string
func (*ExecutorSettings) GetCordoned ¶ added in v0.15.0
func (m *ExecutorSettings) GetCordoned() bool
func (*ExecutorSettings) GetExecutorId ¶ added in v0.15.0
func (m *ExecutorSettings) GetExecutorId() string
func (*ExecutorSettings) Marshal ¶ added in v0.15.0
func (m *ExecutorSettings) Marshal() (dAtA []byte, err error)
func (*ExecutorSettings) MarshalTo ¶ added in v0.15.0
func (m *ExecutorSettings) MarshalTo(dAtA []byte) (int, error)
func (*ExecutorSettings) MarshalToSizedBuffer ¶ added in v0.15.0
func (m *ExecutorSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExecutorSettings) ProtoMessage ¶ added in v0.15.0
func (*ExecutorSettings) ProtoMessage()
func (*ExecutorSettings) Reset ¶ added in v0.15.0
func (m *ExecutorSettings) Reset()
func (*ExecutorSettings) Size ¶ added in v0.15.0
func (m *ExecutorSettings) Size() (n int)
func (*ExecutorSettings) String ¶ added in v0.15.0
func (m *ExecutorSettings) String() string
func (*ExecutorSettings) Unmarshal ¶ added in v0.15.0
func (m *ExecutorSettings) Unmarshal(dAtA []byte) error
func (*ExecutorSettings) XXX_DiscardUnknown ¶ added in v0.15.0
func (m *ExecutorSettings) XXX_DiscardUnknown()
func (*ExecutorSettings) XXX_Marshal ¶ added in v0.15.0
func (m *ExecutorSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutorSettings) XXX_Merge ¶ added in v0.15.0
func (m *ExecutorSettings) XXX_Merge(src proto.Message)
func (*ExecutorSettings) XXX_Size ¶ added in v0.15.0
func (m *ExecutorSettings) XXX_Size() int
func (*ExecutorSettings) XXX_Unmarshal ¶ added in v0.15.0
func (m *ExecutorSettings) XXX_Unmarshal(b []byte) error
type JobReport ¶
type JobReport struct {
Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}
func (*JobReport) Descriptor ¶
func (*JobReport) MarshalToSizedBuffer ¶
func (*JobReport) ProtoMessage ¶
func (*JobReport) ProtoMessage()
func (*JobReport) XXX_DiscardUnknown ¶
func (m *JobReport) XXX_DiscardUnknown()
func (*JobReport) XXX_Marshal ¶
func (*JobReport) XXX_Unmarshal ¶
type JobReportRequest ¶ added in v0.3.71
type JobReportRequest struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}
func (*JobReportRequest) Descriptor ¶ added in v0.3.71
func (*JobReportRequest) Descriptor() ([]byte, []int)
func (*JobReportRequest) GetJobId ¶ added in v0.3.71
func (m *JobReportRequest) GetJobId() string
func (*JobReportRequest) Marshal ¶ added in v0.3.71
func (m *JobReportRequest) Marshal() (dAtA []byte, err error)
func (*JobReportRequest) MarshalTo ¶ added in v0.3.71
func (m *JobReportRequest) MarshalTo(dAtA []byte) (int, error)
func (*JobReportRequest) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *JobReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobReportRequest) ProtoMessage ¶ added in v0.3.71
func (*JobReportRequest) ProtoMessage()
func (*JobReportRequest) Reset ¶ added in v0.3.71
func (m *JobReportRequest) Reset()
func (*JobReportRequest) Size ¶ added in v0.3.71
func (m *JobReportRequest) Size() (n int)
func (*JobReportRequest) String ¶ added in v0.3.71
func (m *JobReportRequest) String() string
func (*JobReportRequest) Unmarshal ¶ added in v0.3.71
func (m *JobReportRequest) Unmarshal(dAtA []byte) error
func (*JobReportRequest) XXX_DiscardUnknown ¶ added in v0.3.71
func (m *JobReportRequest) XXX_DiscardUnknown()
func (*JobReportRequest) XXX_Marshal ¶ added in v0.3.71
func (m *JobReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobReportRequest) XXX_Merge ¶ added in v0.3.71
func (m *JobReportRequest) XXX_Merge(src proto.Message)
func (*JobReportRequest) XXX_Size ¶ added in v0.3.71
func (m *JobReportRequest) XXX_Size() int
func (*JobReportRequest) XXX_Unmarshal ¶ added in v0.3.71
func (m *JobReportRequest) XXX_Unmarshal(b []byte) error
type JobRunState ¶ added in v0.3.49
type JobRunState int32
const ( JobRunState_UNKNOWN JobRunState = 0 JobRunState_PENDING JobRunState = 1 JobRunState_RUNNING JobRunState = 2 JobRunState_SUCCEEDED JobRunState = 3 JobRunState_FAILED JobRunState = 4 )
func (JobRunState) EnumDescriptor ¶ added in v0.3.49
func (JobRunState) EnumDescriptor() ([]byte, []int)
func (JobRunState) String ¶ added in v0.3.49
func (x JobRunState) String() string
type JobSchedulingInfo ¶
type JobSchedulingInfo struct { Lifetime uint32 `protobuf:"varint,1,opt,name=lifetime,proto3" json:"lifetime,omitempty"` AtMostOnce bool `protobuf:"varint,2,opt,name=at_most_once,json=atMostOnce,proto3" json:"atMostOnce,omitempty"` Preemptible bool `protobuf:"varint,3,opt,name=preemptible,proto3" json:"preemptible,omitempty"` ConcurrencySafe bool `protobuf:"varint,4,opt,name=concurrency_safe,json=concurrencySafe,proto3" json:"concurrencySafe,omitempty"` PriorityClassName string `protobuf:"bytes,6,opt,name=priority_class_name,json=priorityClassName,proto3" json:"priorityClassName,omitempty"` SubmitTime time.Time `protobuf:"bytes,7,opt,name=submit_time,json=submitTime,proto3,stdtime" json:"submitTime"` // In-queue priority. I.e., not the priority class priority. Priority uint32 `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"` // Kubernetes objects that make up this job and their respective scheduling requirements. ObjectRequirements []*ObjectRequirements `protobuf:"bytes,5,rep,name=object_requirements,json=objectRequirements,proto3" json:"objectRequirements,omitempty"` Version uint32 `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"` }
Minimal job representation used by the scheduler.
func (*JobSchedulingInfo) Descriptor ¶
func (*JobSchedulingInfo) Descriptor() ([]byte, []int)
func (*JobSchedulingInfo) GetAtMostOnce ¶
func (m *JobSchedulingInfo) GetAtMostOnce() bool
func (*JobSchedulingInfo) GetConcurrencySafe ¶
func (m *JobSchedulingInfo) GetConcurrencySafe() bool
func (*JobSchedulingInfo) GetLifetime ¶
func (m *JobSchedulingInfo) GetLifetime() uint32
func (*JobSchedulingInfo) GetObjectRequirements ¶
func (m *JobSchedulingInfo) GetObjectRequirements() []*ObjectRequirements
func (*JobSchedulingInfo) GetPodRequirements ¶ added in v0.3.78
func (info *JobSchedulingInfo) GetPodRequirements() *PodRequirements
func (*JobSchedulingInfo) GetPreemptible ¶
func (m *JobSchedulingInfo) GetPreemptible() bool
func (*JobSchedulingInfo) GetPriority ¶ added in v0.3.50
func (m *JobSchedulingInfo) GetPriority() uint32
func (*JobSchedulingInfo) GetPriorityClassName ¶ added in v0.3.50
func (m *JobSchedulingInfo) GetPriorityClassName() string
func (*JobSchedulingInfo) GetSubmitTime ¶ added in v0.3.50
func (m *JobSchedulingInfo) GetSubmitTime() time.Time
func (*JobSchedulingInfo) GetVersion ¶ added in v0.3.63
func (m *JobSchedulingInfo) GetVersion() uint32
func (*JobSchedulingInfo) Marshal ¶
func (m *JobSchedulingInfo) Marshal() (dAtA []byte, err error)
func (*JobSchedulingInfo) MarshalTo ¶
func (m *JobSchedulingInfo) MarshalTo(dAtA []byte) (int, error)
func (*JobSchedulingInfo) MarshalToSizedBuffer ¶
func (m *JobSchedulingInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobSchedulingInfo) ProtoMessage ¶
func (*JobSchedulingInfo) ProtoMessage()
func (*JobSchedulingInfo) Reset ¶
func (m *JobSchedulingInfo) Reset()
func (*JobSchedulingInfo) Size ¶
func (m *JobSchedulingInfo) Size() (n int)
func (*JobSchedulingInfo) String ¶
func (m *JobSchedulingInfo) String() string
func (*JobSchedulingInfo) Unmarshal ¶
func (m *JobSchedulingInfo) Unmarshal(dAtA []byte) error
func (*JobSchedulingInfo) XXX_DiscardUnknown ¶
func (m *JobSchedulingInfo) XXX_DiscardUnknown()
func (*JobSchedulingInfo) XXX_Marshal ¶
func (m *JobSchedulingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobSchedulingInfo) XXX_Merge ¶
func (m *JobSchedulingInfo) XXX_Merge(src proto.Message)
func (*JobSchedulingInfo) XXX_Size ¶
func (m *JobSchedulingInfo) XXX_Size() int
func (*JobSchedulingInfo) XXX_Unmarshal ¶
func (m *JobSchedulingInfo) XXX_Unmarshal(b []byte) error
type MostRecentForJob ¶ added in v0.3.71
type MostRecentForJob struct {
JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"jobId,omitempty"`
}
func (*MostRecentForJob) Descriptor ¶ added in v0.3.71
func (*MostRecentForJob) Descriptor() ([]byte, []int)
func (*MostRecentForJob) GetJobId ¶ added in v0.3.71
func (m *MostRecentForJob) GetJobId() string
func (*MostRecentForJob) Marshal ¶ added in v0.3.71
func (m *MostRecentForJob) Marshal() (dAtA []byte, err error)
func (*MostRecentForJob) MarshalTo ¶ added in v0.3.71
func (m *MostRecentForJob) MarshalTo(dAtA []byte) (int, error)
func (*MostRecentForJob) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *MostRecentForJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MostRecentForJob) ProtoMessage ¶ added in v0.3.71
func (*MostRecentForJob) ProtoMessage()
func (*MostRecentForJob) Reset ¶ added in v0.3.71
func (m *MostRecentForJob) Reset()
func (*MostRecentForJob) Size ¶ added in v0.3.71
func (m *MostRecentForJob) Size() (n int)
func (*MostRecentForJob) String ¶ added in v0.3.71
func (m *MostRecentForJob) String() string
func (*MostRecentForJob) Unmarshal ¶ added in v0.3.71
func (m *MostRecentForJob) Unmarshal(dAtA []byte) error
func (*MostRecentForJob) XXX_DiscardUnknown ¶ added in v0.3.71
func (m *MostRecentForJob) XXX_DiscardUnknown()
func (*MostRecentForJob) XXX_Marshal ¶ added in v0.3.71
func (m *MostRecentForJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MostRecentForJob) XXX_Merge ¶ added in v0.3.71
func (m *MostRecentForJob) XXX_Merge(src proto.Message)
func (*MostRecentForJob) XXX_Size ¶ added in v0.3.71
func (m *MostRecentForJob) XXX_Size() int
func (*MostRecentForJob) XXX_Unmarshal ¶ added in v0.3.71
func (m *MostRecentForJob) XXX_Unmarshal(b []byte) error
type MostRecentForQueue ¶ added in v0.3.71
type MostRecentForQueue struct {
QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queueName,omitempty"`
}
func (*MostRecentForQueue) Descriptor ¶ added in v0.3.71
func (*MostRecentForQueue) Descriptor() ([]byte, []int)
func (*MostRecentForQueue) GetQueueName ¶ added in v0.3.71
func (m *MostRecentForQueue) GetQueueName() string
func (*MostRecentForQueue) Marshal ¶ added in v0.3.71
func (m *MostRecentForQueue) Marshal() (dAtA []byte, err error)
func (*MostRecentForQueue) MarshalTo ¶ added in v0.3.71
func (m *MostRecentForQueue) MarshalTo(dAtA []byte) (int, error)
func (*MostRecentForQueue) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *MostRecentForQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MostRecentForQueue) ProtoMessage ¶ added in v0.3.71
func (*MostRecentForQueue) ProtoMessage()
func (*MostRecentForQueue) Reset ¶ added in v0.3.71
func (m *MostRecentForQueue) Reset()
func (*MostRecentForQueue) Size ¶ added in v0.3.71
func (m *MostRecentForQueue) Size() (n int)
func (*MostRecentForQueue) String ¶ added in v0.3.71
func (m *MostRecentForQueue) String() string
func (*MostRecentForQueue) Unmarshal ¶ added in v0.3.71
func (m *MostRecentForQueue) Unmarshal(dAtA []byte) error
func (*MostRecentForQueue) XXX_DiscardUnknown ¶ added in v0.3.71
func (m *MostRecentForQueue) XXX_DiscardUnknown()
func (*MostRecentForQueue) XXX_Marshal ¶ added in v0.3.71
func (m *MostRecentForQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MostRecentForQueue) XXX_Merge ¶ added in v0.3.71
func (m *MostRecentForQueue) XXX_Merge(src proto.Message)
func (*MostRecentForQueue) XXX_Size ¶ added in v0.3.71
func (m *MostRecentForQueue) XXX_Size() int
func (*MostRecentForQueue) XXX_Unmarshal ¶ added in v0.3.71
func (m *MostRecentForQueue) XXX_Unmarshal(b []byte) error
type Node ¶
type Node struct { // Id associated with the node. Must be unique across all clusters. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Kubernetes node name. Not guaranteed to be unique across clusters. Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"` // Name of the executor to which this node belongs. Executor string `protobuf:"bytes,19,opt,name=executor,proto3" json:"executor,omitempty"` // Time at which this node was last updated. // Used to garbage collect nodes that have been removed. LastSeen time.Time `protobuf:"bytes,2,opt,name=last_seen,json=lastSeen,proto3,stdtime" json:"lastSeen"` // Kubernetes taints. Taints []v1.Taint `protobuf:"bytes,5,rep,name=taints,proto3" json:"taints"` // Kubernetes labels. Labels map[string]string `` /* 153-byte string literal not displayed */ // Total resources on this node. TotalResources ResourceList `protobuf:"bytes,7,opt,name=total_resources,json=totalResources,proto3" json:"totalResources"` // Resources available for jobs of a given priority. // E.g., AvailableResources[5]["cpu"] is the amount of CPU available to jobs with priority 5, // where available resources = unused resources + resources assigned to lower-priority jobs. AllocatableByPriorityAndResource map[int32]ResourceList `` /* 238-byte string literal not displayed */ // Ids of the job runs currently assigned to this node and their current state. StateByJobRunId map[string]JobRunState `` /* 221-byte string literal not displayed */ // Resource allocated to non-Armada pods on this node. UnallocatableResources map[int32]ResourceList `` /* 206-byte string literal not displayed */ // If true, no new jobs should be scheduled onto this node, e.g., because the node has been cordoned. Unschedulable bool `protobuf:"varint,15,opt,name=unschedulable,proto3" json:"unschedulable,omitempty"` // This should only be used for metrics // This is the type the node should be reported as. It is simple a label to categorise the group the node belongs to ReportingNodeType string `protobuf:"bytes,17,opt,name=reporting_node_type,json=reportingNodeType,proto3" json:"reportingNodeType,omitempty"` // The pool that this node belongs to, this is used for scheduling purposes Pool string `protobuf:"bytes,18,opt,name=pool,proto3" json:"pool,omitempty"` ResourceUsageByQueueAndPool []*PoolQueueResource `` /* 146-byte string literal not displayed */ }
Node represents a node in a worker cluster.
func (*Node) AvailableArmadaResource ¶ added in v0.3.66
func (node *Node) AvailableArmadaResource() ResourceList
func (*Node) CompactString ¶ added in v0.3.50
func (*Node) Descriptor ¶
func (*Node) GetAllocatableByPriorityAndResource ¶
func (m *Node) GetAllocatableByPriorityAndResource() map[int32]ResourceList
func (*Node) GetExecutor ¶ added in v0.3.81
func (*Node) GetLastSeen ¶
func (*Node) GetReportingNodeType ¶ added in v0.3.66
func (*Node) GetResourceUsageByQueueAndPool ¶ added in v0.14.0
func (m *Node) GetResourceUsageByQueueAndPool() []*PoolQueueResource
func (*Node) GetStateByJobRunId ¶ added in v0.3.54
func (m *Node) GetStateByJobRunId() map[string]JobRunState
func (*Node) GetTotalResources ¶
func (m *Node) GetTotalResources() ResourceList
func (*Node) GetUnallocatableResources ¶ added in v0.14.0
func (m *Node) GetUnallocatableResources() map[int32]ResourceList
func (*Node) GetUnschedulable ¶ added in v0.3.65
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_Unmarshal ¶
type ObjectRequirements ¶
type ObjectRequirements struct { // Types that are valid to be assigned to Requirements: // *ObjectRequirements_PodRequirements Requirements isObjectRequirements_Requirements `protobuf_oneof:"requirements"` }
Message capturing the scheduling requirements of a particular Kubernetes object.
func (*ObjectRequirements) Descriptor ¶
func (*ObjectRequirements) Descriptor() ([]byte, []int)
func (*ObjectRequirements) GetPodRequirements ¶
func (m *ObjectRequirements) GetPodRequirements() *PodRequirements
func (*ObjectRequirements) GetRequirements ¶
func (m *ObjectRequirements) GetRequirements() isObjectRequirements_Requirements
func (*ObjectRequirements) Marshal ¶
func (m *ObjectRequirements) Marshal() (dAtA []byte, err error)
func (*ObjectRequirements) MarshalTo ¶
func (m *ObjectRequirements) MarshalTo(dAtA []byte) (int, error)
func (*ObjectRequirements) MarshalToSizedBuffer ¶
func (m *ObjectRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ObjectRequirements) ProtoMessage ¶
func (*ObjectRequirements) ProtoMessage()
func (*ObjectRequirements) Reset ¶
func (m *ObjectRequirements) Reset()
func (*ObjectRequirements) Size ¶
func (m *ObjectRequirements) Size() (n int)
func (*ObjectRequirements) String ¶
func (m *ObjectRequirements) String() string
func (*ObjectRequirements) Unmarshal ¶
func (m *ObjectRequirements) Unmarshal(dAtA []byte) error
func (*ObjectRequirements) XXX_DiscardUnknown ¶
func (m *ObjectRequirements) XXX_DiscardUnknown()
func (*ObjectRequirements) XXX_Marshal ¶
func (m *ObjectRequirements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectRequirements) XXX_Merge ¶
func (m *ObjectRequirements) XXX_Merge(src proto.Message)
func (*ObjectRequirements) XXX_OneofWrappers ¶
func (*ObjectRequirements) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ObjectRequirements) XXX_Size ¶
func (m *ObjectRequirements) XXX_Size() int
func (*ObjectRequirements) XXX_Unmarshal ¶
func (m *ObjectRequirements) XXX_Unmarshal(b []byte) error
type ObjectRequirements_PodRequirements ¶
type ObjectRequirements_PodRequirements struct {
PodRequirements *PodRequirements `protobuf:"bytes,1,opt,name=podRequirements,proto3,oneof" json:"podRequirements,omitempty"`
}
func (*ObjectRequirements_PodRequirements) MarshalTo ¶
func (m *ObjectRequirements_PodRequirements) MarshalTo(dAtA []byte) (int, error)
func (*ObjectRequirements_PodRequirements) MarshalToSizedBuffer ¶
func (m *ObjectRequirements_PodRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ObjectRequirements_PodRequirements) Size ¶
func (m *ObjectRequirements_PodRequirements) Size() (n int)
type PodRequirements ¶
type PodRequirements struct { // Kubernetes node selector. NodeSelector map[string]string `` /* 165-byte string literal not displayed */ // Kubernetes scheduling requirements. Affinity *v1.Affinity `protobuf:"bytes,2,opt,name=affinity,proto3" json:"affinity,omitempty"` // Kubernetes tolerations. Tolerations []v1.Toleration `protobuf:"bytes,3,rep,name=tolerations,proto3" json:"tolerations"` // Kubernetes annotations. Included here since we use annotations with special meaning. Annotations map[string]string `` /* 163-byte string literal not displayed */ // One of Never, PreemptLowerPriority. // Defaults to PreemptLowerPriority if unset. PreemptionPolicy string `protobuf:"bytes,5,opt,name=preemptionPolicy,proto3" json:"preemptionPolicy,omitempty"` // Sum of the resource requirements for all containers that make up this pod. ResourceRequirements v1.ResourceRequirements `protobuf:"bytes,6,opt,name=resourceRequirements,proto3" json:"resourceRequirements"` }
Captures the scheduling requirements of a pod.
func (*PodRequirements) Descriptor ¶
func (*PodRequirements) Descriptor() ([]byte, []int)
func (*PodRequirements) GetAffinity ¶
func (m *PodRequirements) GetAffinity() *v1.Affinity
func (*PodRequirements) GetAffinityNodeSelector ¶
func (req *PodRequirements) GetAffinityNodeSelector() *v1.NodeSelector
func (*PodRequirements) GetAnnotations ¶
func (m *PodRequirements) GetAnnotations() map[string]string
func (*PodRequirements) GetNodeSelector ¶
func (m *PodRequirements) GetNodeSelector() map[string]string
func (*PodRequirements) GetPreemptionPolicy ¶
func (m *PodRequirements) GetPreemptionPolicy() string
func (*PodRequirements) GetResourceRequirements ¶
func (m *PodRequirements) GetResourceRequirements() v1.ResourceRequirements
func (*PodRequirements) GetTolerations ¶
func (m *PodRequirements) GetTolerations() []v1.Toleration
func (*PodRequirements) Marshal ¶
func (m *PodRequirements) Marshal() (dAtA []byte, err error)
func (*PodRequirements) MarshalToSizedBuffer ¶
func (m *PodRequirements) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PodRequirements) ProtoMessage ¶
func (*PodRequirements) ProtoMessage()
func (*PodRequirements) Reset ¶
func (m *PodRequirements) Reset()
func (*PodRequirements) Size ¶
func (m *PodRequirements) Size() (n int)
func (*PodRequirements) String ¶
func (m *PodRequirements) String() string
func (*PodRequirements) Unmarshal ¶
func (m *PodRequirements) Unmarshal(dAtA []byte) error
func (*PodRequirements) XXX_DiscardUnknown ¶
func (m *PodRequirements) XXX_DiscardUnknown()
func (*PodRequirements) XXX_Marshal ¶
func (m *PodRequirements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PodRequirements) XXX_Merge ¶
func (m *PodRequirements) XXX_Merge(src proto.Message)
func (*PodRequirements) XXX_Size ¶
func (m *PodRequirements) XXX_Size() int
func (*PodRequirements) XXX_Unmarshal ¶
func (m *PodRequirements) XXX_Unmarshal(b []byte) error
type PodRequirementsSerialiser ¶ added in v0.3.71
type PodRequirementsSerialiser struct {
// contains filtered or unexported fields
}
PodRequirementsSerialiser produces the canonical byte representation of a set of pod scheduling requirements. The resulting byte array can, e.g., be used to produce a hash guaranteed to be equal for equivalent requirements. Not thread-safe.
Fields are separated by =, $, &, and =, since these characters are not allowed in taints and labels; see https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#syntax-and-character-set https://man.archlinux.org/man/community/kubectl/kubectl-taint.1.en
func NewPodRequirementsSerialiser ¶ added in v0.3.71
func NewPodRequirementsSerialiser() *PodRequirementsSerialiser
func (*PodRequirementsSerialiser) AppendAffinity ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendAffinity(out []byte, affinity *v1.Affinity) []byte
AppendAffinity writes a v1.Affinity into the hash. Only NodeAffinity (i.e., not PodAffinity) and RequiredDuringSchedulingIgnoredDuringExecution fields are considered.
func (*PodRequirementsSerialiser) AppendAffinityNodeSelector ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendAffinityNodeSelector(out []byte, nodeSelector *v1.NodeSelector) []byte
func (*PodRequirementsSerialiser) AppendNodeSelector ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendNodeSelector(out []byte, nodeSelector map[string]string) []byte
func (*PodRequirementsSerialiser) AppendNodeSelectorRequirements ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendNodeSelectorRequirements(out []byte, nodeSelectorRequirements []v1.NodeSelectorRequirement) []byte
func (*PodRequirementsSerialiser) AppendRequirements ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendRequirements( out []byte, nodeSelector map[string]string, affinity *v1.Affinity, tolerations []v1.Toleration, requests v1.ResourceList, priorityClassName string, ) []byte
func (*PodRequirementsSerialiser) AppendResourceList ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendResourceList(out []byte, resourceList v1.ResourceList) []byte
func (*PodRequirementsSerialiser) AppendTolerations ¶ added in v0.3.71
func (skg *PodRequirementsSerialiser) AppendTolerations(out []byte, tolerations []v1.Toleration) []byte
type PoolQueueResource ¶ added in v0.14.0
type PoolQueueResource struct { Pool string `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"` Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` Resources *ResourceList `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"` }
func (*PoolQueueResource) Descriptor ¶ added in v0.14.0
func (*PoolQueueResource) Descriptor() ([]byte, []int)
func (*PoolQueueResource) GetPool ¶ added in v0.14.0
func (m *PoolQueueResource) GetPool() string
func (*PoolQueueResource) GetQueue ¶ added in v0.14.0
func (m *PoolQueueResource) GetQueue() string
func (*PoolQueueResource) GetResources ¶ added in v0.14.0
func (m *PoolQueueResource) GetResources() *ResourceList
func (*PoolQueueResource) Marshal ¶ added in v0.14.0
func (m *PoolQueueResource) Marshal() (dAtA []byte, err error)
func (*PoolQueueResource) MarshalTo ¶ added in v0.14.0
func (m *PoolQueueResource) MarshalTo(dAtA []byte) (int, error)
func (*PoolQueueResource) MarshalToSizedBuffer ¶ added in v0.14.0
func (m *PoolQueueResource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PoolQueueResource) ProtoMessage ¶ added in v0.14.0
func (*PoolQueueResource) ProtoMessage()
func (*PoolQueueResource) Reset ¶ added in v0.14.0
func (m *PoolQueueResource) Reset()
func (*PoolQueueResource) Size ¶ added in v0.14.0
func (m *PoolQueueResource) Size() (n int)
func (*PoolQueueResource) String ¶ added in v0.14.0
func (m *PoolQueueResource) String() string
func (*PoolQueueResource) Unmarshal ¶ added in v0.14.0
func (m *PoolQueueResource) Unmarshal(dAtA []byte) error
func (*PoolQueueResource) XXX_DiscardUnknown ¶ added in v0.14.0
func (m *PoolQueueResource) XXX_DiscardUnknown()
func (*PoolQueueResource) XXX_Marshal ¶ added in v0.14.0
func (m *PoolQueueResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PoolQueueResource) XXX_Merge ¶ added in v0.14.0
func (m *PoolQueueResource) XXX_Merge(src proto.Message)
func (*PoolQueueResource) XXX_Size ¶ added in v0.14.0
func (m *PoolQueueResource) XXX_Size() int
func (*PoolQueueResource) XXX_Unmarshal ¶ added in v0.14.0
func (m *PoolQueueResource) XXX_Unmarshal(b []byte) error
type QuantityByTAndResourceType ¶ added in v0.3.76
type QuantityByTAndResourceType[T comparable] map[T]ResourceList
func (QuantityByTAndResourceType[T]) Add ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) Add(b QuantityByTAndResourceType[T])
func (QuantityByTAndResourceType[T]) AddResourceList ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) AddResourceList(t T, rlb ResourceList)
func (QuantityByTAndResourceType[T]) AddV1ResourceList ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) AddV1ResourceList(t T, rlb v1.ResourceList)
func (QuantityByTAndResourceType[T]) AggregateByResource ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) AggregateByResource() ResourceList
func (QuantityByTAndResourceType[T]) DeepCopy ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) DeepCopy() QuantityByTAndResourceType[T]
func (QuantityByTAndResourceType[T]) Equal ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) Equal(b QuantityByTAndResourceType[T]) bool
func (QuantityByTAndResourceType[T]) IsStrictlyNonNegative ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) IsStrictlyNonNegative() bool
IsStrictlyNonNegative returns true if there are no quantities in a with value less than zero.
func (QuantityByTAndResourceType[T]) IsZero ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) IsZero() bool
IsZero returns true if all quantities in a are zero.
func (QuantityByTAndResourceType[T]) MaxAggregatedByResource ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) MaxAggregatedByResource(t T, rl ResourceList)
MaxAggregatedByResource updates a in-place such that for each resource type t a[p1][t] + ... + a[pn][t] = max(a[p1][t] + ... + a[pn][t], rl[t]), where p1, ..., pn are the priorities in a, for each resource set explicitly in rl.
If necessary to add resources to make up the difference, those resources are added at priority p.
func (QuantityByTAndResourceType[T]) String ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) String() string
func (QuantityByTAndResourceType[T]) Sub ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) Sub(b QuantityByTAndResourceType[T])
func (QuantityByTAndResourceType[T]) SubResourceList ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) SubResourceList(t T, rlb ResourceList)
func (QuantityByTAndResourceType[T]) SubV1ResourceList ¶ added in v0.3.76
func (a QuantityByTAndResourceType[T]) SubV1ResourceList(t T, rlb v1.ResourceList)
type QueueReport ¶
type QueueReport struct {
Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}
func (*QueueReport) Descriptor ¶
func (*QueueReport) Descriptor() ([]byte, []int)
func (*QueueReport) GetReport ¶
func (m *QueueReport) GetReport() string
func (*QueueReport) Marshal ¶
func (m *QueueReport) Marshal() (dAtA []byte, err error)
func (*QueueReport) MarshalToSizedBuffer ¶
func (m *QueueReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueReport) ProtoMessage ¶
func (*QueueReport) ProtoMessage()
func (*QueueReport) Reset ¶
func (m *QueueReport) Reset()
func (*QueueReport) Size ¶
func (m *QueueReport) Size() (n int)
func (*QueueReport) String ¶
func (m *QueueReport) String() string
func (*QueueReport) Unmarshal ¶
func (m *QueueReport) Unmarshal(dAtA []byte) error
func (*QueueReport) XXX_DiscardUnknown ¶
func (m *QueueReport) XXX_DiscardUnknown()
func (*QueueReport) XXX_Marshal ¶
func (m *QueueReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueReport) XXX_Merge ¶
func (m *QueueReport) XXX_Merge(src proto.Message)
func (*QueueReport) XXX_Size ¶
func (m *QueueReport) XXX_Size() int
func (*QueueReport) XXX_Unmarshal ¶
func (m *QueueReport) XXX_Unmarshal(b []byte) error
type QueueReportRequest ¶ added in v0.3.71
type QueueReportRequest struct { QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queueName,omitempty"` Verbosity int32 `protobuf:"varint,2,opt,name=verbosity,proto3" json:"verbosity,omitempty"` }
func (*QueueReportRequest) Descriptor ¶ added in v0.3.71
func (*QueueReportRequest) Descriptor() ([]byte, []int)
func (*QueueReportRequest) GetQueueName ¶ added in v0.3.71
func (m *QueueReportRequest) GetQueueName() string
func (*QueueReportRequest) GetVerbosity ¶ added in v0.3.71
func (m *QueueReportRequest) GetVerbosity() int32
func (*QueueReportRequest) Marshal ¶ added in v0.3.71
func (m *QueueReportRequest) Marshal() (dAtA []byte, err error)
func (*QueueReportRequest) MarshalTo ¶ added in v0.3.71
func (m *QueueReportRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueueReportRequest) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *QueueReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueReportRequest) ProtoMessage ¶ added in v0.3.71
func (*QueueReportRequest) ProtoMessage()
func (*QueueReportRequest) Reset ¶ added in v0.3.71
func (m *QueueReportRequest) Reset()
func (*QueueReportRequest) Size ¶ added in v0.3.71
func (m *QueueReportRequest) Size() (n int)
func (*QueueReportRequest) String ¶ added in v0.3.71
func (m *QueueReportRequest) String() string
func (*QueueReportRequest) Unmarshal ¶ added in v0.3.71
func (m *QueueReportRequest) Unmarshal(dAtA []byte) error
func (*QueueReportRequest) XXX_DiscardUnknown ¶ added in v0.3.71
func (m *QueueReportRequest) XXX_DiscardUnknown()
func (*QueueReportRequest) XXX_Marshal ¶ added in v0.3.71
func (m *QueueReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueReportRequest) XXX_Merge ¶ added in v0.3.71
func (m *QueueReportRequest) XXX_Merge(src proto.Message)
func (*QueueReportRequest) XXX_Size ¶ added in v0.3.71
func (m *QueueReportRequest) XXX_Size() int
func (*QueueReportRequest) XXX_Unmarshal ¶ added in v0.3.71
func (m *QueueReportRequest) XXX_Unmarshal(b []byte) error
type ResourceList ¶
type ResourceList struct {
Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
}
func NewResourceList ¶ added in v0.3.70
func NewResourceList(n int) ResourceList
NewResourceList returns a new ResourceList, where the backing map has initial capacity n.
func NewResourceListWithDefaultSize ¶ added in v0.3.70
func NewResourceListWithDefaultSize() ResourceList
NewResourceListWithDefaultSize returns a new ResourceList, where the backing map has default initial capacity.
func ResourceListFromV1ResourceList ¶
func ResourceListFromV1ResourceList(rl v1.ResourceList) ResourceList
func (*ResourceList) Add ¶
func (a *ResourceList) Add(b ResourceList)
func (*ResourceList) AddQuantity ¶ added in v0.3.63
func (rl *ResourceList) AddQuantity(resourceType string, quantity resource.Quantity)
func (*ResourceList) AddV1ResourceList ¶ added in v0.3.70
func (a *ResourceList) AddV1ResourceList(b v1.ResourceList)
func (*ResourceList) AsWeightedMillis ¶ added in v0.3.78
func (rl *ResourceList) AsWeightedMillis(weights map[string]float64) int64
AsWeightedMillis returns the linear combination of the milli values in rl with given weights. This function overflows for values greater than MaxInt64. E.g., 1Pi is fine but not 10Pi.
func (ResourceList) CompactString ¶
func (rl ResourceList) CompactString() string
func (ResourceList) DeepCopy ¶
func (rl ResourceList) DeepCopy() ResourceList
func (*ResourceList) Descriptor ¶
func (*ResourceList) Descriptor() ([]byte, []int)
func (ResourceList) Equal ¶
func (a ResourceList) Equal(b ResourceList) bool
func (*ResourceList) GetResources ¶
func (m *ResourceList) GetResources() map[string]resource.Quantity
func (ResourceList) IsStrictlyNonNegative ¶ added in v0.3.55
func (a ResourceList) IsStrictlyNonNegative() bool
IsStrictlyNonNegative returns true if there is no quantity less than zero.
func (ResourceList) IsZero ¶ added in v0.3.50
func (a ResourceList) IsZero() bool
func (*ResourceList) LimitToZero ¶ added in v0.14.0
func (a *ResourceList) LimitToZero()
func (*ResourceList) Marshal ¶
func (m *ResourceList) Marshal() (dAtA []byte, err error)
func (*ResourceList) MarshalToSizedBuffer ¶
func (m *ResourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceList) ProtoMessage ¶
func (*ResourceList) ProtoMessage()
func (*ResourceList) Reset ¶
func (m *ResourceList) Reset()
func (*ResourceList) Set ¶ added in v0.3.70
func (rl *ResourceList) Set(t string, q resource.Quantity)
func (*ResourceList) Size ¶
func (m *ResourceList) Size() (n int)
func (*ResourceList) String ¶
func (m *ResourceList) String() string
func (*ResourceList) Sub ¶
func (a *ResourceList) Sub(b ResourceList)
func (*ResourceList) SubQuantity ¶ added in v0.3.63
func (rl *ResourceList) SubQuantity(resourceType string, quantity resource.Quantity)
func (*ResourceList) SubV1ResourceList ¶ added in v0.3.70
func (a *ResourceList) SubV1ResourceList(b v1.ResourceList)
func (*ResourceList) Unmarshal ¶
func (m *ResourceList) Unmarshal(dAtA []byte) error
func (*ResourceList) XXX_DiscardUnknown ¶
func (m *ResourceList) XXX_DiscardUnknown()
func (*ResourceList) XXX_Marshal ¶
func (m *ResourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceList) XXX_Merge ¶
func (m *ResourceList) XXX_Merge(src proto.Message)
func (*ResourceList) XXX_Size ¶
func (m *ResourceList) XXX_Size() int
func (*ResourceList) XXX_Unmarshal ¶
func (m *ResourceList) XXX_Unmarshal(b []byte) error
func (ResourceList) Zero ¶ added in v0.3.70
func (rl ResourceList) Zero()
Zero zeroes out rl in-place, such that all quantities have value 0.
type SchedulerReportingClient ¶
type SchedulerReportingClient interface { // Return the most recent scheduling report for each executor. GetSchedulingReport(ctx context.Context, in *SchedulingReportRequest, opts ...grpc.CallOption) (*SchedulingReport, error) // Return the most recent report scheduling for each executor for the given queue. GetQueueReport(ctx context.Context, in *QueueReportRequest, opts ...grpc.CallOption) (*QueueReport, error) // Return the most recent scheduling report for each executor for the given job. GetJobReport(ctx context.Context, in *JobReportRequest, opts ...grpc.CallOption) (*JobReport, error) }
SchedulerReportingClient is the client API for SchedulerReporting service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSchedulerReportingClient ¶
func NewSchedulerReportingClient(cc *grpc.ClientConn) SchedulerReportingClient
type SchedulerReportingServer ¶
type SchedulerReportingServer interface { // Return the most recent scheduling report for each executor. GetSchedulingReport(context.Context, *SchedulingReportRequest) (*SchedulingReport, error) // Return the most recent report scheduling for each executor for the given queue. GetQueueReport(context.Context, *QueueReportRequest) (*QueueReport, error) // Return the most recent scheduling report for each executor for the given job. GetJobReport(context.Context, *JobReportRequest) (*JobReport, error) }
SchedulerReportingServer is the server API for SchedulerReporting service.
type SchedulingKey ¶ added in v0.3.65
type SchedulingKey [highwayhash.Size]byte
SchedulingKey is a hash of the scheduling requirements of a job. This key is used to efficiently mark jobs as unschedulable.
var EmptySchedulingKey SchedulingKey
type SchedulingKeyGenerator ¶ added in v0.3.71
SchedulingKeyGenerator is used to generate scheduling keys efficiently. A scheduling key is the canonical hash of the scheduling requirements of a job. All memory is allocated up-front and re-used. Thread-safe.
func NewSchedulingKeyGenerator ¶ added in v0.3.71
func NewSchedulingKeyGenerator() *SchedulingKeyGenerator
func NewSchedulingKeyGeneratorWithKey ¶ added in v0.4.0
func NewSchedulingKeyGeneratorWithKey(key []byte) *SchedulingKeyGenerator
NewSchedulingKeyGeneratorWithKey returns a new SchedulingKeyGenerator using the provided key. The key should be considered secret since scheduling key collisions can be found if it's known. Key has to be of length 32.
func (*SchedulingKeyGenerator) Key ¶ added in v0.3.71
func (skg *SchedulingKeyGenerator) Key( nodeSelector map[string]string, affinity *v1.Affinity, tolerations []v1.Toleration, requests v1.ResourceList, priorityClassName string, ) SchedulingKey
type SchedulingReport ¶ added in v0.3.62
type SchedulingReport struct {
Report string `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
}
func (*SchedulingReport) Descriptor ¶ added in v0.3.62
func (*SchedulingReport) Descriptor() ([]byte, []int)
func (*SchedulingReport) GetReport ¶ added in v0.3.62
func (m *SchedulingReport) GetReport() string
func (*SchedulingReport) Marshal ¶ added in v0.3.62
func (m *SchedulingReport) Marshal() (dAtA []byte, err error)
func (*SchedulingReport) MarshalTo ¶ added in v0.3.62
func (m *SchedulingReport) MarshalTo(dAtA []byte) (int, error)
func (*SchedulingReport) MarshalToSizedBuffer ¶ added in v0.3.62
func (m *SchedulingReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulingReport) ProtoMessage ¶ added in v0.3.62
func (*SchedulingReport) ProtoMessage()
func (*SchedulingReport) Reset ¶ added in v0.3.62
func (m *SchedulingReport) Reset()
func (*SchedulingReport) Size ¶ added in v0.3.62
func (m *SchedulingReport) Size() (n int)
func (*SchedulingReport) String ¶ added in v0.3.62
func (m *SchedulingReport) String() string
func (*SchedulingReport) Unmarshal ¶ added in v0.3.62
func (m *SchedulingReport) Unmarshal(dAtA []byte) error
func (*SchedulingReport) XXX_DiscardUnknown ¶ added in v0.3.62
func (m *SchedulingReport) XXX_DiscardUnknown()
func (*SchedulingReport) XXX_Marshal ¶ added in v0.3.62
func (m *SchedulingReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SchedulingReport) XXX_Merge ¶ added in v0.3.62
func (m *SchedulingReport) XXX_Merge(src proto.Message)
func (*SchedulingReport) XXX_Size ¶ added in v0.3.62
func (m *SchedulingReport) XXX_Size() int
func (*SchedulingReport) XXX_Unmarshal ¶ added in v0.3.62
func (m *SchedulingReport) XXX_Unmarshal(b []byte) error
type SchedulingReportRequest ¶ added in v0.3.71
type SchedulingReportRequest struct { // Types that are valid to be assigned to Filter: // // *SchedulingReportRequest_MostRecentForQueue // *SchedulingReportRequest_MostRecentForJob Filter isSchedulingReportRequest_Filter `protobuf_oneof:"filter"` Verbosity int32 `protobuf:"varint,3,opt,name=verbosity,proto3" json:"verbosity,omitempty"` }
func (*SchedulingReportRequest) Descriptor ¶ added in v0.3.71
func (*SchedulingReportRequest) Descriptor() ([]byte, []int)
func (*SchedulingReportRequest) GetFilter ¶ added in v0.3.71
func (m *SchedulingReportRequest) GetFilter() isSchedulingReportRequest_Filter
func (*SchedulingReportRequest) GetMostRecentForJob ¶ added in v0.3.71
func (m *SchedulingReportRequest) GetMostRecentForJob() *MostRecentForJob
func (*SchedulingReportRequest) GetMostRecentForQueue ¶ added in v0.3.71
func (m *SchedulingReportRequest) GetMostRecentForQueue() *MostRecentForQueue
func (*SchedulingReportRequest) GetVerbosity ¶ added in v0.3.71
func (m *SchedulingReportRequest) GetVerbosity() int32
func (*SchedulingReportRequest) Marshal ¶ added in v0.3.71
func (m *SchedulingReportRequest) Marshal() (dAtA []byte, err error)
func (*SchedulingReportRequest) MarshalTo ¶ added in v0.3.71
func (m *SchedulingReportRequest) MarshalTo(dAtA []byte) (int, error)
func (*SchedulingReportRequest) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *SchedulingReportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulingReportRequest) ProtoMessage ¶ added in v0.3.71
func (*SchedulingReportRequest) ProtoMessage()
func (*SchedulingReportRequest) Reset ¶ added in v0.3.71
func (m *SchedulingReportRequest) Reset()
func (*SchedulingReportRequest) Size ¶ added in v0.3.71
func (m *SchedulingReportRequest) Size() (n int)
func (*SchedulingReportRequest) String ¶ added in v0.3.71
func (m *SchedulingReportRequest) String() string
func (*SchedulingReportRequest) Unmarshal ¶ added in v0.3.71
func (m *SchedulingReportRequest) Unmarshal(dAtA []byte) error
func (*SchedulingReportRequest) XXX_DiscardUnknown ¶ added in v0.3.71
func (m *SchedulingReportRequest) XXX_DiscardUnknown()
func (*SchedulingReportRequest) XXX_Marshal ¶ added in v0.3.71
func (m *SchedulingReportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SchedulingReportRequest) XXX_Merge ¶ added in v0.3.71
func (m *SchedulingReportRequest) XXX_Merge(src proto.Message)
func (*SchedulingReportRequest) XXX_OneofWrappers ¶ added in v0.3.71
func (*SchedulingReportRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SchedulingReportRequest) XXX_Size ¶ added in v0.3.71
func (m *SchedulingReportRequest) XXX_Size() int
func (*SchedulingReportRequest) XXX_Unmarshal ¶ added in v0.3.71
func (m *SchedulingReportRequest) XXX_Unmarshal(b []byte) error
type SchedulingReportRequest_MostRecentForJob ¶ added in v0.3.71
type SchedulingReportRequest_MostRecentForJob struct {
MostRecentForJob *MostRecentForJob `protobuf:"bytes,2,opt,name=most_recent_for_job,json=mostRecentForJob,proto3,oneof" json:"mostRecentForJob,omitempty"`
}
func (*SchedulingReportRequest_MostRecentForJob) MarshalTo ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForJob) MarshalTo(dAtA []byte) (int, error)
func (*SchedulingReportRequest_MostRecentForJob) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulingReportRequest_MostRecentForJob) Size ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForJob) Size() (n int)
type SchedulingReportRequest_MostRecentForQueue ¶ added in v0.3.71
type SchedulingReportRequest_MostRecentForQueue struct {
MostRecentForQueue *MostRecentForQueue `protobuf:"bytes,1,opt,name=most_recent_for_queue,json=mostRecentForQueue,proto3,oneof" json:"mostRecentForQueue,omitempty"`
}
func (*SchedulingReportRequest_MostRecentForQueue) MarshalTo ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForQueue) MarshalTo(dAtA []byte) (int, error)
func (*SchedulingReportRequest_MostRecentForQueue) MarshalToSizedBuffer ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulingReportRequest_MostRecentForQueue) Size ¶ added in v0.3.71
func (m *SchedulingReportRequest_MostRecentForQueue) Size() (n int)
type UnimplementedSchedulerReportingServer ¶
type UnimplementedSchedulerReportingServer struct { }
UnimplementedSchedulerReportingServer can be embedded to have forward compatible implementations.
func (*UnimplementedSchedulerReportingServer) GetJobReport ¶
func (*UnimplementedSchedulerReportingServer) GetJobReport(ctx context.Context, req *JobReportRequest) (*JobReport, error)
func (*UnimplementedSchedulerReportingServer) GetQueueReport ¶
func (*UnimplementedSchedulerReportingServer) GetQueueReport(ctx context.Context, req *QueueReportRequest) (*QueueReport, error)
func (*UnimplementedSchedulerReportingServer) GetSchedulingReport ¶ added in v0.3.62
func (*UnimplementedSchedulerReportingServer) GetSchedulingReport(ctx context.Context, req *SchedulingReportRequest) (*SchedulingReport, error)