v1beta1

package
v0.20.11 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package v1beta1 is the v1beta1 version of the API.

Index

Constants

View Source 
const GroupName = "kubescheduler.config.k8s.io"

GroupName is the group name used in this package

Variables

View Source 
var (

	// Default 1 core CPU usage for containers without requests and limits i.e. Best Effort QoS.
	DefaultRequestsMilliCores int64 = 1000
	// DefaultRequestsMultiplier for containers without limits predicted as 1.5*requests i.e. Burstable QoS class
	DefaultRequestsMultiplier = "1.5"
	// DefaultTargetUtilizationPercent Recommended to keep -10 than desired limit.
	DefaultTargetUtilizationPercent int64 = 40

	// Risk is usually calculated as average (aka. mu) plus standard deviation (aka. sigma).
	// In order to allow customization in the calculation of risk, two parameters are provided:
	// Margin and Sensitivity. Margin is a multiplier of sigma, and Sensitivity is a root power of sigma.
	// For example, Margin=3 and Sensitivity=2 leads to a risk evaluated as: mu + 3 sqrt(sigma).
	// The default value for both parameters is 1, leading to: mu + sigma.
	// DefaultSafeVarianceMargin is one
	DefaultSafeVarianceMargin = 1.0
	// DefaultSafeVarianceSensitivity is one
	DefaultSafeVarianceSensitivity = 1.0
	// DefaultMetricProviderType is the Kubernetes metrics server
	DefaultMetricProviderType = pluginConfig.KubernetesMetricsServer
)
View Source 
var (

	// AddToScheme is a global function that registers this API group & version to a scheme
	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1beta1"}

SchemeGroupVersion is group version used to register these objects

Functions

func Convert_config_CapacitySchedulingArgs_To_v1beta1_CapacitySchedulingArgs 

func Convert_config_CapacitySchedulingArgs_To_v1beta1_CapacitySchedulingArgs(in *config.CapacitySchedulingArgs, out *CapacitySchedulingArgs, s conversion.Scope) error

Convert_config_CapacitySchedulingArgs_To_v1beta1_CapacitySchedulingArgs is an autogenerated conversion function.

func Convert_config_CoschedulingArgs_To_v1beta1_CoschedulingArgs 

func Convert_config_CoschedulingArgs_To_v1beta1_CoschedulingArgs(in *config.CoschedulingArgs, out *CoschedulingArgs, s conversion.Scope) error

Convert_config_CoschedulingArgs_To_v1beta1_CoschedulingArgs is an autogenerated conversion function.

func Convert_config_LoadVariationRiskBalancingArgs_To_v1beta1_LoadVariationRiskBalancingArgs 

func Convert_config_LoadVariationRiskBalancingArgs_To_v1beta1_LoadVariationRiskBalancingArgs(in *config.LoadVariationRiskBalancingArgs, out *LoadVariationRiskBalancingArgs, s conversion.Scope) error

Convert_config_LoadVariationRiskBalancingArgs_To_v1beta1_LoadVariationRiskBalancingArgs is an autogenerated conversion function.

func Convert_config_MetricProviderSpec_To_v1beta1_MetricProviderSpec 

func Convert_config_MetricProviderSpec_To_v1beta1_MetricProviderSpec(in *config.MetricProviderSpec, out *MetricProviderSpec, s conversion.Scope) error

Convert_config_MetricProviderSpec_To_v1beta1_MetricProviderSpec is an autogenerated conversion function.

func Convert_config_NodeResourceTopologyMatchArgs_To_v1beta1_NodeResourceTopologyMatchArgs 

func Convert_config_NodeResourceTopologyMatchArgs_To_v1beta1_NodeResourceTopologyMatchArgs(in *config.NodeResourceTopologyMatchArgs, out *NodeResourceTopologyMatchArgs, s conversion.Scope) error

Convert_config_NodeResourceTopologyMatchArgs_To_v1beta1_NodeResourceTopologyMatchArgs is an autogenerated conversion function.

func Convert_config_NodeResourcesAllocatableArgs_To_v1beta1_NodeResourcesAllocatableArgs 

func Convert_config_NodeResourcesAllocatableArgs_To_v1beta1_NodeResourcesAllocatableArgs(in *config.NodeResourcesAllocatableArgs, out *NodeResourcesAllocatableArgs, s conversion.Scope) error

Convert_config_NodeResourcesAllocatableArgs_To_v1beta1_NodeResourcesAllocatableArgs is an autogenerated conversion function.

func Convert_config_ScoringStrategy_To_v1beta1_ScoringStrategy 

func Convert_config_ScoringStrategy_To_v1beta1_ScoringStrategy(in *config.ScoringStrategy, out *ScoringStrategy, s conversion.Scope) error

Convert_config_ScoringStrategy_To_v1beta1_ScoringStrategy is an autogenerated conversion function.

func Convert_config_TargetLoadPackingArgs_To_v1beta1_TargetLoadPackingArgs 

func Convert_config_TargetLoadPackingArgs_To_v1beta1_TargetLoadPackingArgs(in *config.TargetLoadPackingArgs, out *TargetLoadPackingArgs, s conversion.Scope) error

Convert_config_TargetLoadPackingArgs_To_v1beta1_TargetLoadPackingArgs is an autogenerated conversion function.

func Convert_v1beta1_CapacitySchedulingArgs_To_config_CapacitySchedulingArgs 

func Convert_v1beta1_CapacitySchedulingArgs_To_config_CapacitySchedulingArgs(in *CapacitySchedulingArgs, out *config.CapacitySchedulingArgs, s conversion.Scope) error

Convert_v1beta1_CapacitySchedulingArgs_To_config_CapacitySchedulingArgs is an autogenerated conversion function.

func Convert_v1beta1_CoschedulingArgs_To_config_CoschedulingArgs 

func Convert_v1beta1_CoschedulingArgs_To_config_CoschedulingArgs(in *CoschedulingArgs, out *config.CoschedulingArgs, s conversion.Scope) error

Convert_v1beta1_CoschedulingArgs_To_config_CoschedulingArgs is an autogenerated conversion function.

func Convert_v1beta1_LoadVariationRiskBalancingArgs_To_config_LoadVariationRiskBalancingArgs 

func Convert_v1beta1_LoadVariationRiskBalancingArgs_To_config_LoadVariationRiskBalancingArgs(in *LoadVariationRiskBalancingArgs, out *config.LoadVariationRiskBalancingArgs, s conversion.Scope) error

Convert_v1beta1_LoadVariationRiskBalancingArgs_To_config_LoadVariationRiskBalancingArgs is an autogenerated conversion function.

func Convert_v1beta1_MetricProviderSpec_To_config_MetricProviderSpec 

func Convert_v1beta1_MetricProviderSpec_To_config_MetricProviderSpec(in *MetricProviderSpec, out *config.MetricProviderSpec, s conversion.Scope) error

Convert_v1beta1_MetricProviderSpec_To_config_MetricProviderSpec is an autogenerated conversion function.

func Convert_v1beta1_NodeResourceTopologyMatchArgs_To_config_NodeResourceTopologyMatchArgs 

func Convert_v1beta1_NodeResourceTopologyMatchArgs_To_config_NodeResourceTopologyMatchArgs(in *NodeResourceTopologyMatchArgs, out *config.NodeResourceTopologyMatchArgs, s conversion.Scope) error

Convert_v1beta1_NodeResourceTopologyMatchArgs_To_config_NodeResourceTopologyMatchArgs is an autogenerated conversion function.

func Convert_v1beta1_NodeResourcesAllocatableArgs_To_config_NodeResourcesAllocatableArgs 

func Convert_v1beta1_NodeResourcesAllocatableArgs_To_config_NodeResourcesAllocatableArgs(in *NodeResourcesAllocatableArgs, out *config.NodeResourcesAllocatableArgs, s conversion.Scope) error

Convert_v1beta1_NodeResourcesAllocatableArgs_To_config_NodeResourcesAllocatableArgs is an autogenerated conversion function.

func Convert_v1beta1_ScoringStrategy_To_config_ScoringStrategy 

func Convert_v1beta1_ScoringStrategy_To_config_ScoringStrategy(in *ScoringStrategy, out *config.ScoringStrategy, s conversion.Scope) error

Convert_v1beta1_ScoringStrategy_To_config_ScoringStrategy is an autogenerated conversion function.

func Convert_v1beta1_TargetLoadPackingArgs_To_config_TargetLoadPackingArgs 

func Convert_v1beta1_TargetLoadPackingArgs_To_config_TargetLoadPackingArgs(in *TargetLoadPackingArgs, out *config.TargetLoadPackingArgs, s conversion.Scope) error

Convert_v1beta1_TargetLoadPackingArgs_To_config_TargetLoadPackingArgs is an autogenerated conversion function.

func RegisterConversions 

func RegisterConversions(s *runtime.Scheme) error

RegisterConversions adds conversion functions to the given scheme. Public to allow building arbitrary schemes.

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

func SetDefaultLoadVariationRiskBalancingArgs 

func SetDefaultLoadVariationRiskBalancingArgs(args *LoadVariationRiskBalancingArgs)

SetDefaultLoadVariationRiskBalancingArgs sets the default parameters for LoadVariationRiskBalancing plugin

func SetDefaultTargetLoadPackingArgs 

func SetDefaultTargetLoadPackingArgs(args *TargetLoadPackingArgs)

SetDefaultTargetLoadPackingArgs sets the default parameters for TargetLoadPacking plugin

func SetDefaultsCapacitySchedulingArgs 

func SetDefaultsCapacitySchedulingArgs(obj *CapacitySchedulingArgs)

SetDefaultsCapacitySchedulingArgs sets the default parameters for CapacityScheduling plugin.

func SetDefaultsCoschedulingArgs 

func SetDefaultsCoschedulingArgs(obj *CoschedulingArgs)

SetDefaultsCoschedulingArgs sets the default parameters for Coscheduling plugin.

func SetDefaultsNodeResourceTopologyMatchArgs 

func SetDefaultsNodeResourceTopologyMatchArgs(obj *NodeResourceTopologyMatchArgs)

SetDefaultsNodeResourceTopologyMatchArgs sets the default parameters for NodeResourceTopologyMatch plugin.

func SetDefaultsNodeResourcesAllocatableArgs 

func SetDefaultsNodeResourcesAllocatableArgs(obj *NodeResourcesAllocatableArgs)

SetDefaultsNodeResourcesAllocatableArgs sets the defaults parameters for NodeResourceAllocatable.

func SetObjectDefaultsCapacitySchedulingArgs 

func SetObjectDefaultsCapacitySchedulingArgs(in *CapacitySchedulingArgs)

func SetObjectDefaultsCoschedulingArgs 

func SetObjectDefaultsCoschedulingArgs(in *CoschedulingArgs)

func SetObjectDefaultsLoadVariationRiskBalancingArgs 

func SetObjectDefaultsLoadVariationRiskBalancingArgs(in *LoadVariationRiskBalancingArgs)

func SetObjectDefaultsNodeResourceTopologyMatchArgs 

func SetObjectDefaultsNodeResourceTopologyMatchArgs(in *NodeResourceTopologyMatchArgs)

func SetObjectDefaultsNodeResourcesAllocatableArgs 

func SetObjectDefaultsNodeResourcesAllocatableArgs(in *NodeResourcesAllocatableArgs)

func SetObjectDefaultsTargetLoadPackingArgs 

func SetObjectDefaultsTargetLoadPackingArgs(in *TargetLoadPackingArgs)

Types

type CapacitySchedulingArgs 

type CapacitySchedulingArgs struct {
	metav1.TypeMeta `json:",inline"`

	// KubeConfigPath is the path of kubeconfig.
	KubeConfigPath *string `json:"kubeConfigPath,omitempty"`
}

CapacitySchedulingArgs defines the scheduling parameters for CapacityScheduling plugin.

func (*CapacitySchedulingArgs) DeepCopy 

func (in *CapacitySchedulingArgs) DeepCopy() *CapacitySchedulingArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CapacitySchedulingArgs.

func (*CapacitySchedulingArgs) DeepCopyInto 

func (in *CapacitySchedulingArgs) DeepCopyInto(out *CapacitySchedulingArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CapacitySchedulingArgs) DeepCopyObject 

func (in *CapacitySchedulingArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CoschedulingArgs 

type CoschedulingArgs struct {
	metav1.TypeMeta `json:",inline"`

	// PermitWaitingTime is the wait timeout in seconds.
	PermitWaitingTimeSeconds *int64 `json:"permitWaitingTimeSeconds,omitempty"`
	// DeniedPGExpirationTimeSeconds is the expiration time of the denied podgroup store.
	DeniedPGExpirationTimeSeconds *int64 `json:"deniedPGExpirationTimeSeconds,omitempty"`
	// KubeMaster is the url of api-server
	KubeMaster *string `json:"kubeMaster,omitempty"`
	// KubeConfigPath for scheduler
	KubeConfigPath *string `json:"kubeConfigPath,omitempty"`
}

CoschedulingArgs defines the scheduling parameters for Coscheduling plugin.

func (*CoschedulingArgs) DeepCopy 

func (in *CoschedulingArgs) DeepCopy() *CoschedulingArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CoschedulingArgs.

func (*CoschedulingArgs) DeepCopyInto 

func (in *CoschedulingArgs) DeepCopyInto(out *CoschedulingArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CoschedulingArgs) DeepCopyObject 

func (in *CoschedulingArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type LoadVariationRiskBalancingArgs 

type LoadVariationRiskBalancingArgs struct {
	metav1.TypeMeta `json:",inline"`

	// Metric Provider specification when using load watcher as library
	MetricProvider MetricProviderSpec `json:"metricProvider,omitempty"`
	// Address of load watcher service
	WatcherAddress *string `json:"watcherAddress,omitempty"`
	// Multiplier of standard deviation in risk value
	SafeVarianceMargin *float64 `json:"safeVarianceMargin,omitempty"`
	// Root power of standard deviation in risk value
	SafeVarianceSensitivity *float64 `json:"safeVarianceSensitivity,omitempty"`
}

LoadVariationRiskBalancingArgs holds arguments used to configure LoadVariationRiskBalancing plugin.

func (*LoadVariationRiskBalancingArgs) DeepCopy 

func (in *LoadVariationRiskBalancingArgs) DeepCopy() *LoadVariationRiskBalancingArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoadVariationRiskBalancingArgs.

func (*LoadVariationRiskBalancingArgs) DeepCopyInto 

func (in *LoadVariationRiskBalancingArgs) DeepCopyInto(out *LoadVariationRiskBalancingArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LoadVariationRiskBalancingArgs) DeepCopyObject 

func (in *LoadVariationRiskBalancingArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type MetricProviderSpec 

type MetricProviderSpec struct {
	// Types of the metric provider
	Type MetricProviderType `json:"type,omitempty"`
	// The address of the metric provider
	Address *string `json:"address,omitempty"`
	// The authentication token of the metric provider
	Token *string `json:"token,omitempty"`
}

Denote the spec of the metric provider

func (*MetricProviderSpec) DeepCopy 

func (in *MetricProviderSpec) DeepCopy() *MetricProviderSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetricProviderSpec.

func (*MetricProviderSpec) DeepCopyInto 

func (in *MetricProviderSpec) DeepCopyInto(out *MetricProviderSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MetricProviderType 

type MetricProviderType string

MetricProviderType is a "string" type. 

const (
	KubernetesMetricsServer MetricProviderType = "KubernetesMetricsServer"
	Prometheus              MetricProviderType = "Prometheus"
	SignalFx                MetricProviderType = "SignalFx"
)

type ModeType 

type ModeType string

ModeType is a type "string". 

const (
	// Least is the string "Least".
	Least ModeType = "Least"
	// Most is the string "Most".
	Most ModeType = "Most"
)

type NodeResourceTopologyMatchArgs 

type NodeResourceTopologyMatchArgs struct {
	metav1.TypeMeta `json:",inline"`

	KubeConfigPath  *string          `json:"kubeconfigpath,omitempty"`
	MasterOverride  *string          `json:"masteroverride,omitempty"`
	Namespaces      []string         `json:"namespaces,omitempty"`
	ScoringStrategy *ScoringStrategy `json:"scoringStrategy,omitempty"`
}

NodeResourceTopologyMatchArgs holds arguments used to configure the NodeResourceTopologyMatch plugin

func (*NodeResourceTopologyMatchArgs) DeepCopy 

func (in *NodeResourceTopologyMatchArgs) DeepCopy() *NodeResourceTopologyMatchArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeResourceTopologyMatchArgs.

func (*NodeResourceTopologyMatchArgs) DeepCopyInto 

func (in *NodeResourceTopologyMatchArgs) DeepCopyInto(out *NodeResourceTopologyMatchArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NodeResourceTopologyMatchArgs) DeepCopyObject 

func (in *NodeResourceTopologyMatchArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type NodeResourcesAllocatableArgs 

type NodeResourcesAllocatableArgs struct {
	metav1.TypeMeta `json:",inline"`

	// Resources to be considered when scoring.
	// Allowed weights start from 1.
	// An example resource set might include "cpu" (millicores) and "memory" (bytes)
	// with weights of 1<<20 and 1 respectfully. That would mean 1 MiB has equivalent
	// weight as 1 millicore.
	Resources []schedulerconfig.ResourceSpec `json:"resources,omitempty"`

	// Whether to prioritize nodes with least or most allocatable resources.
	Mode ModeType `json:"mode,omitempty"`
}

NodeResourcesAllocatableArgs holds arguments used to configure NodeResourcesAllocatable plugin.

func (*NodeResourcesAllocatableArgs) DeepCopy 

func (in *NodeResourcesAllocatableArgs) DeepCopy() *NodeResourcesAllocatableArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeResourcesAllocatableArgs.

func (*NodeResourcesAllocatableArgs) DeepCopyInto 

func (in *NodeResourcesAllocatableArgs) DeepCopyInto(out *NodeResourcesAllocatableArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*NodeResourcesAllocatableArgs) DeepCopyObject 

func (in *NodeResourcesAllocatableArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ScoringStrategy 

type ScoringStrategy struct {
	Type      ScoringStrategyType            `json:"type,omitempty"`
	Resources []schedulerconfig.ResourceSpec `json:"resources,omitempty"`
}

func (*ScoringStrategy) DeepCopy 

func (in *ScoringStrategy) DeepCopy() *ScoringStrategy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScoringStrategy.

func (*ScoringStrategy) DeepCopyInto 

func (in *ScoringStrategy) DeepCopyInto(out *ScoringStrategy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ScoringStrategyType 

type ScoringStrategyType string

ScoringStrategyType is a "string" type. 

const (
	// MostAllocated strategy favors node with the least amount of available resource
	MostAllocated ScoringStrategyType = "MostAllocated"
	// BalancedAllocation strategy favors nodes with balanced resource usage rate
	BalancedAllocation ScoringStrategyType = "BalancedAllocation"
	// LeastAllocated strategy favors node with the most amount of available resource
	LeastAllocated ScoringStrategyType = "LeastAllocated"
)

type TargetLoadPackingArgs 

type TargetLoadPackingArgs struct {
	metav1.TypeMeta `json:",inline"`

	// Default requests to use for best effort QoS
	DefaultRequests v1.ResourceList `json:"defaultRequests,omitempty"`
	// Default requests multiplier for busrtable QoS
	DefaultRequestsMultiplier *string `json:"defaultRequestsMultiplier,omitempty"`
	// Node target CPU Utilization for bin packing
	TargetUtilization *int64 `json:"targetUtilization,omitempty"`
	// Specify the metric provider type, address and token using MetricProviderSpec
	MetricProvider MetricProviderSpec `json:"metricProvider,omitempty"`
	// Address of load watcher service
	WatcherAddress *string `json:"watcherAddress,omitempty"`
}

TargetLoadPackingArgs holds arguments used to configure TargetLoadPacking plugin.

func (*TargetLoadPackingArgs) DeepCopy 

func (in *TargetLoadPackingArgs) DeepCopy() *TargetLoadPackingArgs

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TargetLoadPackingArgs.

func (*TargetLoadPackingArgs) DeepCopyInto 

func (in *TargetLoadPackingArgs) DeepCopyInto(out *TargetLoadPackingArgs)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TargetLoadPackingArgs) DeepCopyObject 

func (in *TargetLoadPackingArgs) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.