Documentation ¶
Index ¶
- Constants
- Variables
- func EncodeQuantity(val resource.Quantity) []byte
- 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) 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 ClusterResourceUsageReport
- func (*ClusterResourceUsageReport) Descriptor() ([]byte, []int)
- func (m *ClusterResourceUsageReport) GetCreated() time.Time
- func (m *ClusterResourceUsageReport) GetPool() string
- func (m *ClusterResourceUsageReport) GetResourcesByQueue() map[string]*QueueClusterResourceUsage
- func (m *ClusterResourceUsageReport) Marshal() (dAtA []byte, err error)
- func (m *ClusterResourceUsageReport) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterResourceUsageReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterResourceUsageReport) ProtoMessage()
- func (m *ClusterResourceUsageReport) Reset()
- func (m *ClusterResourceUsageReport) Size() (n int)
- func (m *ClusterResourceUsageReport) String() string
- func (m *ClusterResourceUsageReport) Unmarshal(dAtA []byte) error
- func (m *ClusterResourceUsageReport) XXX_DiscardUnknown()
- func (m *ClusterResourceUsageReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterResourceUsageReport) XXX_Merge(src proto.Message)
- func (m *ClusterResourceUsageReport) XXX_Size() int
- func (m *ClusterResourceUsageReport) XXX_Unmarshal(b []byte) error
- type Executor
- func (m *Executor) AllRuns() ([]uuid.UUID, error)
- func (*Executor) Descriptor() ([]byte, []int)
- func (m *Executor) GetId() string
- func (m *Executor) GetLastUpdateTime() time.Time
- func (m *Executor) GetMinimumJobSize() ResourceList
- 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 InsufficientResources
- type JobId
- func (*JobId) Descriptor() ([]byte, []int)
- func (m *JobId) GetId() string
- func (m *JobId) Marshal() (dAtA []byte, err error)
- func (m *JobId) MarshalTo(dAtA []byte) (int, error)
- func (m *JobId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobId) ProtoMessage()
- func (m *JobId) Reset()
- func (m *JobId) Size() (n int)
- func (m *JobId) String() string
- func (m *JobId) Unmarshal(dAtA []byte) error
- func (m *JobId) XXX_DiscardUnknown()
- func (m *JobId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobId) XXX_Merge(src proto.Message)
- func (m *JobId) XXX_Size() int
- func (m *JobId) 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 JobRunState
- type JobSchedulingInfo
- func (jobSchedulingInfo *JobSchedulingInfo) ClearCachedSchedulingKey()
- 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 (m *JobSchedulingInfo) GetPreemptible() bool
- func (m *JobSchedulingInfo) GetPriority() uint32
- func (m *JobSchedulingInfo) GetPriorityClassName() string
- func (m *JobSchedulingInfo) GetSubmitTime() time.Time
- func (info *JobSchedulingInfo) GetTotalResourceRequest() ResourceList
- 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 (jobSchedulingInfo *JobSchedulingInfo) SchedulingKey() (SchedulingKey, bool)
- 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 MissingLabel
- type Node
- func (node *Node) AvailableArmadaResource() ResourceList
- func (node *Node) AvailableQuantityByPriorityAndResource(priority int32, resourceType string) resource.Quantity
- func (node *Node) CompactString() string
- func (node *Node) DeepCopy() *Node
- func (*Node) Descriptor() ([]byte, []int)
- func (node *Node) DynamicPodRequirementsMet(priority int32, req *PodRequirements) (bool, int, PodRequirementsNotMetReason, error)
- func (m *Node) GetAllocatableByPriorityAndResource() map[int32]ResourceList
- func (m *Node) GetAllocatedByJobId() map[string]ResourceList
- func (m *Node) GetAllocatedByQueue() map[string]ResourceList
- func (m *Node) GetEvictedJobRunIds() map[string]bool
- 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) GetNodeType() *NodeType
- func (m *Node) GetNodeTypeId() string
- func (m *Node) GetNonArmadaAllocatedResources() map[int32]ResourceList
- func (m *Node) GetReportingNodeType() string
- func (m *Node) GetResourceUsageByQueue() map[string]*ResourceList
- func (m *Node) GetStateByJobRunId() map[string]JobRunState
- func (m *Node) GetTaints() []v1.Taint
- func (m *Node) GetTotalResources() 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 *Node) PodRequirementsMet(priority int32, req *PodRequirements) (bool, int, PodRequirementsNotMetReason, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (node *Node) StaticPodRequirementsMet(req *PodRequirements) (bool, PodRequirementsNotMetReason, error)
- 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 NodeType
- func (nodeType *NodeType) DeepCopy() *NodeType
- func (*NodeType) Descriptor() ([]byte, []int)
- func (m *NodeType) GetId() string
- func (m *NodeType) GetLabels() map[string]string
- func (m *NodeType) GetTaints() []v1.Taint
- func (m *NodeType) GetUnsetIndexedLabels() map[string]string
- func (m *NodeType) Marshal() (dAtA []byte, err error)
- func (m *NodeType) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeType) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (nodeType *NodeType) PodRequirementsMet(req *PodRequirements) (bool, PodRequirementsNotMetReason, error)
- func (*NodeType) ProtoMessage()
- func (m *NodeType) Reset()
- func (m *NodeType) Size() (n int)
- func (m *NodeType) String() string
- 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
- 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 (req *PodRequirements) ClearCachedSchedulingKey()
- 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) GetCachedSchedulingKey() []byte
- func (m *PodRequirements) GetNodeSelector() map[string]string
- func (m *PodRequirements) GetPreemptionPolicy() string
- func (m *PodRequirements) GetPriority() int32
- 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 (req *PodRequirements) SchedulingKey() SchedulingKey
- 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 PodRequirementsNotMetReason
- type PulsarSchedulerJobDetails
- func (*PulsarSchedulerJobDetails) Descriptor() ([]byte, []int)
- func (m *PulsarSchedulerJobDetails) GetJobId() string
- func (m *PulsarSchedulerJobDetails) GetJobSet() string
- func (m *PulsarSchedulerJobDetails) GetQueue() string
- func (m *PulsarSchedulerJobDetails) Marshal() (dAtA []byte, err error)
- func (m *PulsarSchedulerJobDetails) MarshalTo(dAtA []byte) (int, error)
- func (m *PulsarSchedulerJobDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PulsarSchedulerJobDetails) ProtoMessage()
- func (m *PulsarSchedulerJobDetails) Reset()
- func (m *PulsarSchedulerJobDetails) Size() (n int)
- func (m *PulsarSchedulerJobDetails) String() string
- func (m *PulsarSchedulerJobDetails) Unmarshal(dAtA []byte) error
- func (m *PulsarSchedulerJobDetails) XXX_DiscardUnknown()
- func (m *PulsarSchedulerJobDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PulsarSchedulerJobDetails) XXX_Merge(src proto.Message)
- func (m *PulsarSchedulerJobDetails) XXX_Size() int
- func (m *PulsarSchedulerJobDetails) XXX_Unmarshal(b []byte) error
- type QuantityByPriorityAndResourceType
- func (a QuantityByPriorityAndResourceType) Add(b QuantityByPriorityAndResourceType)
- func (a QuantityByPriorityAndResourceType) AddResourceList(priority int32, rlb ResourceList)
- func (a QuantityByPriorityAndResourceType) AggregateByResource() ResourceList
- func (a QuantityByPriorityAndResourceType) DeepCopy() QuantityByPriorityAndResourceType
- func (a QuantityByPriorityAndResourceType) Equal(b QuantityByPriorityAndResourceType) bool
- func (a QuantityByPriorityAndResourceType) IsStrictlyNonNegative() bool
- func (a QuantityByPriorityAndResourceType) IsZero() bool
- func (a QuantityByPriorityAndResourceType) MaxAggregatedByResource(p int32, rl ResourceList)
- func (a QuantityByPriorityAndResourceType) String() string
- func (a QuantityByPriorityAndResourceType) Sub(b QuantityByPriorityAndResourceType)
- func (a QuantityByPriorityAndResourceType) SubResourceList(priority int32, rlb ResourceList)
- type Queue
- func (*Queue) Descriptor() ([]byte, []int)
- func (m *Queue) GetName() string
- func (m *Queue) Marshal() (dAtA []byte, err error)
- func (m *Queue) MarshalTo(dAtA []byte) (int, error)
- func (m *Queue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Queue) ProtoMessage()
- 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 QueueClusterResourceUsage
- func (*QueueClusterResourceUsage) Descriptor() ([]byte, []int)
- func (m *QueueClusterResourceUsage) GetCreated() time.Time
- func (m *QueueClusterResourceUsage) GetExecutorId() string
- func (m *QueueClusterResourceUsage) GetQueue() string
- func (m *QueueClusterResourceUsage) GetResourcesByPriority() map[int32]ResourceList
- func (m *QueueClusterResourceUsage) Marshal() (dAtA []byte, err error)
- func (m *QueueClusterResourceUsage) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueClusterResourceUsage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueClusterResourceUsage) ProtoMessage()
- func (m *QueueClusterResourceUsage) Reset()
- func (m *QueueClusterResourceUsage) Size() (n int)
- func (m *QueueClusterResourceUsage) String() string
- func (m *QueueClusterResourceUsage) Unmarshal(dAtA []byte) error
- func (m *QueueClusterResourceUsage) XXX_DiscardUnknown()
- func (m *QueueClusterResourceUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueClusterResourceUsage) XXX_Merge(src proto.Message)
- func (m *QueueClusterResourceUsage) XXX_Size() int
- func (m *QueueClusterResourceUsage) XXX_Unmarshal(b []byte) error
- 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 ResourceList
- func (a *ResourceList) Add(b ResourceList)
- func (rl *ResourceList) AddQuantity(resourceType string, quantity resource.Quantity)
- func (rl ResourceList) CompactString() string
- func (rl ResourceList) DeepCopy() ResourceList
- func (*ResourceList) Descriptor() ([]byte, []int)
- func (a ResourceList) Equal(b ResourceList) bool
- func (a *ResourceList) Get(resourceType string) resource.Quantity
- func (m *ResourceList) GetResources() map[string]resource.Quantity
- func (a ResourceList) IsStrictlyLessOrEqual(b ResourceList) bool
- func (a ResourceList) IsStrictlyNonNegative() bool
- func (a ResourceList) IsZero() bool
- 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 (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 (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
- type SchedulerReportingClient
- type SchedulerReportingServer
- type SchedulingKey
- 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 UnimplementedSchedulerReportingServer
- func (*UnimplementedSchedulerReportingServer) GetJobReport(ctx context.Context, req *JobId) (*JobReport, error)
- func (*UnimplementedSchedulerReportingServer) GetQueueReport(ctx context.Context, req *Queue) (*QueueReport, error)
- func (*UnimplementedSchedulerReportingServer) GetSchedulingReport(ctx context.Context, req *types.Empty) (*SchedulingReport, error)
- type UnmatchedLabel
- type UnmatchedNodeSelector
- type UntoleratedTaint
Constants ¶
const ( // When checking if a pod fits on a node, this score indicates how well the pods fits. // However, all nodes are currently given the same score. SchedulableScore = 0 SchedulableBestScore = SchedulableScore )
const SchedulingKeySize = 20
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 EncodeQuantity ¶ added in v0.3.63
EncodeQuantity returns the canonical byte representation of a Kubernetes resource.Quantity{} used throughout the scheduler.
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 QuantityByPriorityAndResourceType
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) 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 QuantityByPriorityAndResourceType
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 ClusterResourceUsageReport ¶
type ClusterResourceUsageReport struct { Pool string `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"` Created time.Time `protobuf:"bytes,2,opt,name=created,proto3,stdtime" json:"created"` ResourcesByQueue map[string]*QueueClusterResourceUsage `` /* 173-byte string literal not displayed */ }
A collection of QueueClusterResourceUsage This is only needed to brige the gap between the redis based scheduler and the new scheduler.
func (*ClusterResourceUsageReport) Descriptor ¶
func (*ClusterResourceUsageReport) Descriptor() ([]byte, []int)
func (*ClusterResourceUsageReport) GetCreated ¶
func (m *ClusterResourceUsageReport) GetCreated() time.Time
func (*ClusterResourceUsageReport) GetPool ¶
func (m *ClusterResourceUsageReport) GetPool() string
func (*ClusterResourceUsageReport) GetResourcesByQueue ¶
func (m *ClusterResourceUsageReport) GetResourcesByQueue() map[string]*QueueClusterResourceUsage
func (*ClusterResourceUsageReport) Marshal ¶
func (m *ClusterResourceUsageReport) Marshal() (dAtA []byte, err error)
func (*ClusterResourceUsageReport) MarshalTo ¶
func (m *ClusterResourceUsageReport) MarshalTo(dAtA []byte) (int, error)
func (*ClusterResourceUsageReport) MarshalToSizedBuffer ¶
func (m *ClusterResourceUsageReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterResourceUsageReport) ProtoMessage ¶
func (*ClusterResourceUsageReport) ProtoMessage()
func (*ClusterResourceUsageReport) Reset ¶
func (m *ClusterResourceUsageReport) Reset()
func (*ClusterResourceUsageReport) Size ¶
func (m *ClusterResourceUsageReport) Size() (n int)
func (*ClusterResourceUsageReport) String ¶
func (m *ClusterResourceUsageReport) String() string
func (*ClusterResourceUsageReport) Unmarshal ¶
func (m *ClusterResourceUsageReport) Unmarshal(dAtA []byte) error
func (*ClusterResourceUsageReport) XXX_DiscardUnknown ¶
func (m *ClusterResourceUsageReport) XXX_DiscardUnknown()
func (*ClusterResourceUsageReport) XXX_Marshal ¶
func (m *ClusterResourceUsageReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterResourceUsageReport) XXX_Merge ¶
func (m *ClusterResourceUsageReport) XXX_Merge(src proto.Message)
func (*ClusterResourceUsageReport) XXX_Size ¶
func (m *ClusterResourceUsageReport) XXX_Size() int
func (*ClusterResourceUsageReport) XXX_Unmarshal ¶
func (m *ClusterResourceUsageReport) XXX_Unmarshal(b []byte) error
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"` // Minimum resources which a job must request in order to be considered for scheduling on this executor. MinimumJobSize ResourceList `protobuf:"bytes,4,opt,name=minimumJobSize,proto3" json:"minimumJobSize"` // 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) GetMinimumJobSize ¶
func (m *Executor) GetMinimumJobSize() ResourceList
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 InsufficientResources ¶
type InsufficientResources struct { Resource string Required resource.Quantity Available resource.Quantity }
func (*InsufficientResources) String ¶
func (err *InsufficientResources) String() string
type JobId ¶
type JobId struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*JobId) Descriptor ¶
func (*JobId) ProtoMessage ¶
func (*JobId) ProtoMessage()
func (*JobId) XXX_DiscardUnknown ¶
func (m *JobId) XXX_DiscardUnknown()
func (*JobId) XXX_Marshal ¶
func (*JobId) XXX_Unmarshal ¶
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 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) ClearCachedSchedulingKey ¶ added in v0.3.63
func (jobSchedulingInfo *JobSchedulingInfo) ClearCachedSchedulingKey()
ClearCachedSchedulingKey clears any cached scheduling keys. Necessary after changing scheduling requirements to avoid inconsistency.
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) 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) GetTotalResourceRequest ¶ added in v0.3.47
func (info *JobSchedulingInfo) GetTotalResourceRequest() ResourceList
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) SchedulingKey ¶ added in v0.3.63
func (jobSchedulingInfo *JobSchedulingInfo) SchedulingKey() (SchedulingKey, bool)
SchedulingKey returns the canonical hash of the scheduling requirements of a job.
The hash is of size SchedulingKeySize and is guaranteed to always be the same for equivalent requirements, unless Affinity is used, in which case they may differ as a result of unordered map keys.
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 MissingLabel ¶
type MissingLabel struct {
Label string
}
func (*MissingLabel) String ¶
func (r *MissingLabel) String() string
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"` // 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"` // The node type captures scheduling requirements of the node; // it's computed from the taints and labels associated with the node. // This field is set automatically by the NodeDb on inserting the node. NodeType *NodeType `protobuf:"bytes,3,opt,name=node_type,json=nodeType,proto3" json:"nodeType,omitempty"` // We store NodeType.id here to simplify indexing. // This field is set automatically by the NodeDb on inserting the node. NodeTypeId string `protobuf:"bytes,4,opt,name=node_type_id,json=nodeTypeId,proto3" json:"nodeTypeId,omitempty"` // 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 jobs on this node. AllocatedByJobId map[string]ResourceList `` /* 189-byte string literal not displayed */ // Resource allocated to queues on this node. AllocatedByQueue map[string]ResourceList `` /* 188-byte string literal not displayed */ // Ids of all runs evicted on this node. EvictedJobRunIds map[string]bool `` /* 190-byte string literal not displayed */ // Resource allocated to non-Armada pods on this node. NonArmadaAllocatedResources map[int32]ResourceList `` /* 223-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 // An aggregated real usage of jobs by queue ResourceUsageByQueue map[string]*ResourceList `` /* 211-byte string literal not displayed */ // 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"` }
Node represents a node in a worker cluster.
func (*Node) AvailableArmadaResource ¶ added in v0.3.66
func (node *Node) AvailableArmadaResource() ResourceList
func (*Node) AvailableQuantityByPriorityAndResource ¶
func (*Node) CompactString ¶ added in v0.3.50
func (*Node) Descriptor ¶
func (*Node) DynamicPodRequirementsMet ¶
func (node *Node) DynamicPodRequirementsMet(priority int32, req *PodRequirements) (bool, int, PodRequirementsNotMetReason, error)
DynamicPodRequirementsMet checks if a pod can be scheduled onto this node, accounting for resources allocated to pods already assigned to this node.
func (*Node) GetAllocatableByPriorityAndResource ¶
func (m *Node) GetAllocatableByPriorityAndResource() map[int32]ResourceList
func (*Node) GetAllocatedByJobId ¶ added in v0.3.47
func (m *Node) GetAllocatedByJobId() map[string]ResourceList
func (*Node) GetAllocatedByQueue ¶ added in v0.3.50
func (m *Node) GetAllocatedByQueue() map[string]ResourceList
func (*Node) GetEvictedJobRunIds ¶ added in v0.3.54
func (*Node) GetLastSeen ¶
func (*Node) GetNodeType ¶
func (*Node) GetNodeTypeId ¶
func (*Node) GetNonArmadaAllocatedResources ¶ added in v0.3.50
func (m *Node) GetNonArmadaAllocatedResources() map[int32]ResourceList
func (*Node) GetReportingNodeType ¶ added in v0.3.66
func (*Node) GetResourceUsageByQueue ¶ added in v0.3.66
func (m *Node) GetResourceUsageByQueue() map[string]*ResourceList
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) GetUnschedulable ¶ added in v0.3.65
func (*Node) PodRequirementsMet ¶
func (node *Node) PodRequirementsMet(priority int32, req *PodRequirements) (bool, int, PodRequirementsNotMetReason, error)
PodRequirementsMet determines whether a pod can be scheduled onto this node. If the pod can be scheduled, the returned score indicates how well the node fits: - 0: Pod can be scheduled by preempting running pods. - 1: Pod can be scheduled without preempting any running pods. If the requirements are not met, it returns the reason why. If the requirements can't be parsed, an error is returned.
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) StaticPodRequirementsMet ¶
func (node *Node) StaticPodRequirementsMet(req *PodRequirements) (bool, PodRequirementsNotMetReason, error)
StaticPodRequirementsMet checks if a pod can be scheduled onto this node, accounting for taints, node selectors, node affinity, and total resources available on the node.
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_Unmarshal ¶
type NodeType ¶
type NodeType struct { // Unique identifier. Used for map lookup. Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"` // Kubernetes taints. // To reduce the number of distinct node types, // may contain only a subset of the taints of the node the node type is created from. Taints []v1.Taint `protobuf:"bytes,2,rep,name=taints,proto3" json:"taints"` // Kubernetes labels. // To reduce the number of distinct node types, // may contain only a subset of the labels of the node the node type is created from. Labels map[string]string `` /* 153-byte string literal not displayed */ // Well-known labels not set by this node type. // Used to filter out nodes when looking for nodes for a pod // that requires at least one well-known label to be set. UnsetIndexedLabels map[string]string `` /* 177-byte string literal not displayed */ }
NodeType represents a particular combination of taints and labels. The scheduler groups nodes by node type. When assigning pods to nodes, the scheduler only considers nodes with a NodeType for which the taints and labels match.
func NewNodeType ¶
func NewNodeTypeFromNode ¶
func (*NodeType) Descriptor ¶
func (*NodeType) GetUnsetIndexedLabels ¶
func (*NodeType) MarshalToSizedBuffer ¶
func (*NodeType) PodRequirementsMet ¶
func (nodeType *NodeType) PodRequirementsMet(req *PodRequirements) (bool, PodRequirementsNotMetReason, error)
PodRequirementsMet determines whether a pod can be scheduled on nodes of this NodeType. If the requirements are not met, it returns the reason for why. If the requirements can't be parsed, an error is returned.
func (*NodeType) ProtoMessage ¶
func (*NodeType) ProtoMessage()
func (*NodeType) XXX_DiscardUnknown ¶
func (m *NodeType) XXX_DiscardUnknown()
func (*NodeType) XXX_Marshal ¶
func (*NodeType) 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 */ // Pod priority. Should be mapped from the priority class name of the submitted pod. Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"` // 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"` // This key is a hash of the scheduling requirements. // The hash is 20 bytes in size and is guaranteed to be the same for equivalent PodRequirements, // unless Affinity is used, in which case they may differ as a result of unordered map keys. CachedSchedulingKey []byte `protobuf:"bytes,8,opt,name=cachedSchedulingKey,proto3" json:"cachedSchedulingKey,omitempty"` }
Captures the scheduling requirements of a pod.
func (*PodRequirements) ClearCachedSchedulingKey ¶ added in v0.3.63
func (req *PodRequirements) ClearCachedSchedulingKey()
ClearCachedSchedulingKey clears any cached scheduling key. Necessary after changing scheduling requirements to avoid inconsistency.
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) GetCachedSchedulingKey ¶ added in v0.3.63
func (m *PodRequirements) GetCachedSchedulingKey() []byte
func (*PodRequirements) GetNodeSelector ¶
func (m *PodRequirements) GetNodeSelector() map[string]string
func (*PodRequirements) GetPreemptionPolicy ¶
func (m *PodRequirements) GetPreemptionPolicy() string
func (*PodRequirements) GetPriority ¶
func (m *PodRequirements) GetPriority() int32
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) SchedulingKey ¶ added in v0.3.63
func (req *PodRequirements) SchedulingKey() SchedulingKey
SchedulingKey returns the canonical hash of the scheduling requirements of a pod.
The hash is of size SchedulingKeySize and is guaranteed to always be the same for equivalent requirements, unless Affinity is used, in which case they may differ as a result of unordered map keys.
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 PulsarSchedulerJobDetails ¶ added in v0.3.49
type PulsarSchedulerJobDetails struct { JobId string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"` Queue string `protobuf:"bytes,2,opt,name=Queue,proto3" json:"Queue,omitempty"` JobSet string `protobuf:"bytes,3,opt,name=JobSet,proto3" json:"JobSet,omitempty"` }
Used to store details about pulsar scheduler jobs in Redis Can be removed once we deprecate the legacy scheduler
func (*PulsarSchedulerJobDetails) Descriptor ¶ added in v0.3.49
func (*PulsarSchedulerJobDetails) Descriptor() ([]byte, []int)
func (*PulsarSchedulerJobDetails) GetJobId ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) GetJobId() string
func (*PulsarSchedulerJobDetails) GetJobSet ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) GetJobSet() string
func (*PulsarSchedulerJobDetails) GetQueue ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) GetQueue() string
func (*PulsarSchedulerJobDetails) Marshal ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) Marshal() (dAtA []byte, err error)
func (*PulsarSchedulerJobDetails) MarshalTo ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) MarshalTo(dAtA []byte) (int, error)
func (*PulsarSchedulerJobDetails) MarshalToSizedBuffer ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PulsarSchedulerJobDetails) ProtoMessage ¶ added in v0.3.49
func (*PulsarSchedulerJobDetails) ProtoMessage()
func (*PulsarSchedulerJobDetails) Reset ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) Reset()
func (*PulsarSchedulerJobDetails) Size ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) Size() (n int)
func (*PulsarSchedulerJobDetails) String ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) String() string
func (*PulsarSchedulerJobDetails) Unmarshal ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) Unmarshal(dAtA []byte) error
func (*PulsarSchedulerJobDetails) XXX_DiscardUnknown ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) XXX_DiscardUnknown()
func (*PulsarSchedulerJobDetails) XXX_Marshal ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PulsarSchedulerJobDetails) XXX_Merge ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) XXX_Merge(src proto.Message)
func (*PulsarSchedulerJobDetails) XXX_Size ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) XXX_Size() int
func (*PulsarSchedulerJobDetails) XXX_Unmarshal ¶ added in v0.3.49
func (m *PulsarSchedulerJobDetails) XXX_Unmarshal(b []byte) error
type QuantityByPriorityAndResourceType ¶
type QuantityByPriorityAndResourceType map[int32]ResourceList
func (QuantityByPriorityAndResourceType) Add ¶
func (a QuantityByPriorityAndResourceType) Add(b QuantityByPriorityAndResourceType)
func (QuantityByPriorityAndResourceType) AddResourceList ¶ added in v0.3.50
func (a QuantityByPriorityAndResourceType) AddResourceList(priority int32, rlb ResourceList)
func (QuantityByPriorityAndResourceType) AggregateByResource ¶
func (a QuantityByPriorityAndResourceType) AggregateByResource() ResourceList
func (QuantityByPriorityAndResourceType) DeepCopy ¶
func (a QuantityByPriorityAndResourceType) DeepCopy() QuantityByPriorityAndResourceType
func (QuantityByPriorityAndResourceType) Equal ¶
func (a QuantityByPriorityAndResourceType) Equal(b QuantityByPriorityAndResourceType) bool
func (QuantityByPriorityAndResourceType) IsStrictlyNonNegative ¶ added in v0.3.55
func (a QuantityByPriorityAndResourceType) IsStrictlyNonNegative() bool
IsStrictlyNonNegative returns true if there are no quantities in a with value less than zero.
func (QuantityByPriorityAndResourceType) IsZero ¶ added in v0.3.59
func (a QuantityByPriorityAndResourceType) IsZero() bool
IsZero returns true if all quantities in a are zero.
func (QuantityByPriorityAndResourceType) MaxAggregatedByResource ¶ added in v0.3.63
func (a QuantityByPriorityAndResourceType) MaxAggregatedByResource(p int32, 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 (QuantityByPriorityAndResourceType) String ¶
func (a QuantityByPriorityAndResourceType) String() string
func (QuantityByPriorityAndResourceType) Sub ¶
func (a QuantityByPriorityAndResourceType) Sub(b QuantityByPriorityAndResourceType)
func (QuantityByPriorityAndResourceType) SubResourceList ¶ added in v0.3.55
func (a QuantityByPriorityAndResourceType) SubResourceList(priority int32, rlb ResourceList)
type Queue ¶
type Queue struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*Queue) Descriptor ¶
func (*Queue) ProtoMessage ¶
func (*Queue) ProtoMessage()
func (*Queue) XXX_DiscardUnknown ¶
func (m *Queue) XXX_DiscardUnknown()
func (*Queue) XXX_Marshal ¶
func (*Queue) XXX_Unmarshal ¶
type QueueClusterResourceUsage ¶
type QueueClusterResourceUsage struct { Created time.Time `protobuf:"bytes,1,opt,name=created,proto3,stdtime" json:"created"` Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"` ExecutorId string `protobuf:"bytes,3,opt,name=executorId,proto3" json:"executorId,omitempty"` ResourcesByPriority map[int32]ResourceList `` /* 170-byte string literal not displayed */ }
Captures the resource usage of a particular queue in a given cluster.
func (*QueueClusterResourceUsage) Descriptor ¶
func (*QueueClusterResourceUsage) Descriptor() ([]byte, []int)
func (*QueueClusterResourceUsage) GetCreated ¶
func (m *QueueClusterResourceUsage) GetCreated() time.Time
func (*QueueClusterResourceUsage) GetExecutorId ¶
func (m *QueueClusterResourceUsage) GetExecutorId() string
func (*QueueClusterResourceUsage) GetQueue ¶
func (m *QueueClusterResourceUsage) GetQueue() string
func (*QueueClusterResourceUsage) GetResourcesByPriority ¶
func (m *QueueClusterResourceUsage) GetResourcesByPriority() map[int32]ResourceList
func (*QueueClusterResourceUsage) Marshal ¶
func (m *QueueClusterResourceUsage) Marshal() (dAtA []byte, err error)
func (*QueueClusterResourceUsage) MarshalTo ¶
func (m *QueueClusterResourceUsage) MarshalTo(dAtA []byte) (int, error)
func (*QueueClusterResourceUsage) MarshalToSizedBuffer ¶
func (m *QueueClusterResourceUsage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueClusterResourceUsage) ProtoMessage ¶
func (*QueueClusterResourceUsage) ProtoMessage()
func (*QueueClusterResourceUsage) Reset ¶
func (m *QueueClusterResourceUsage) Reset()
func (*QueueClusterResourceUsage) Size ¶
func (m *QueueClusterResourceUsage) Size() (n int)
func (*QueueClusterResourceUsage) String ¶
func (m *QueueClusterResourceUsage) String() string
func (*QueueClusterResourceUsage) Unmarshal ¶
func (m *QueueClusterResourceUsage) Unmarshal(dAtA []byte) error
func (*QueueClusterResourceUsage) XXX_DiscardUnknown ¶
func (m *QueueClusterResourceUsage) XXX_DiscardUnknown()
func (*QueueClusterResourceUsage) XXX_Marshal ¶
func (m *QueueClusterResourceUsage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueClusterResourceUsage) XXX_Merge ¶
func (m *QueueClusterResourceUsage) XXX_Merge(src proto.Message)
func (*QueueClusterResourceUsage) XXX_Size ¶
func (m *QueueClusterResourceUsage) XXX_Size() int
func (*QueueClusterResourceUsage) XXX_Unmarshal ¶
func (m *QueueClusterResourceUsage) XXX_Unmarshal(b []byte) error
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 ResourceList ¶
type ResourceList struct {
Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
}
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) 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) IsStrictlyLessOrEqual ¶ added in v0.3.63
func (a ResourceList) IsStrictlyLessOrEqual(b ResourceList) bool
IsStrictlyLessOrEqual returns true if all quantities in a are strictly less or equal than those in b.
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) 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) 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) 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
type SchedulerReportingClient ¶
type SchedulerReportingClient interface { // Return the most recent scheduling report for each executor. GetSchedulingReport(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*SchedulingReport, error) // Return the most recent report scheduling for each executor for the given queue. GetQueueReport(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*QueueReport, error) // Return the most recent scheduling report for each executor for the given job. GetJobReport(ctx context.Context, in *JobId, 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, *types.Empty) (*SchedulingReport, error) // Return the most recent report scheduling for each executor for the given queue. GetQueueReport(context.Context, *Queue) (*QueueReport, error) // Return the most recent scheduling report for each executor for the given job. GetJobReport(context.Context, *JobId) (*JobReport, error) }
SchedulerReportingServer is the server API for SchedulerReporting service.
type SchedulingKey ¶ added in v0.3.65
type SchedulingKey [SchedulingKeySize]byte
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 UnimplementedSchedulerReportingServer ¶
type UnimplementedSchedulerReportingServer struct { }
UnimplementedSchedulerReportingServer can be embedded to have forward compatible implementations.
func (*UnimplementedSchedulerReportingServer) GetJobReport ¶
func (*UnimplementedSchedulerReportingServer) GetQueueReport ¶
func (*UnimplementedSchedulerReportingServer) GetQueueReport(ctx context.Context, req *Queue) (*QueueReport, error)
func (*UnimplementedSchedulerReportingServer) GetSchedulingReport ¶ added in v0.3.62
func (*UnimplementedSchedulerReportingServer) GetSchedulingReport(ctx context.Context, req *types.Empty) (*SchedulingReport, error)
type UnmatchedLabel ¶
func (*UnmatchedLabel) String ¶
func (r *UnmatchedLabel) String() string
type UnmatchedNodeSelector ¶
type UnmatchedNodeSelector struct {
NodeSelector *v1.NodeSelector
}
func (*UnmatchedNodeSelector) String ¶
func (err *UnmatchedNodeSelector) String() string
type UntoleratedTaint ¶
func (*UntoleratedTaint) String ¶
func (r *UntoleratedTaint) String() string