Documentation ¶
Index ¶
- Constants
- func APICRD() (*apiextensionv1.CustomResourceDefinition, error)
- func ClusterRole(component, subComponent string) (*rbacv1.ClusterRole, error)
- func ClusterRoleBinding(component, subComponent string) (*rbacv1.ClusterRoleBinding, error)
- func ConfigMap(component, subComponent string) (*corev1.ConfigMap, error)
- func DaemonSet(component, subComponent string, namespace string) (*appsv1.DaemonSet, error)
- func Deployment(component, subComponent, namespace string) (*appsv1.Deployment, error)
- func DeserializeObjectFromData(data []byte) (runtime.Object, error)
- func MachineConfig(component string, ver platform.Version, withCRIHooks bool) (*machineconfigv1.MachineConfig, error)
- func Namespace(component string) (*corev1.Namespace, error)
- func RenderObjects(objs []client.Object, w io.Writer) error
- func Role(component, subComponent, namespace string) (*rbacv1.Role, error)
- func RoleBinding(component, subComponent, roleName, namespace string) (*rbacv1.RoleBinding, error)
- func SchedulerCRD() (*apiextensionv1.CustomResourceDefinition, error)
- func SecurityContextConstraint(component string, withCustomSELinuxPolicy bool) (*securityv1.SecurityContextConstraints, error)
- func SecurityContextConstraintV2(component string) (*securityv1.SecurityContextConstraints, error)
- func SerializeObject(obj runtime.Object, out io.Writer) error
- func SerializeObjectToData(obj runtime.Object) ([]byte, error)
- func Service(component, subComponent, namespace string) (*corev1.Service, error)
- func ServiceAccount(component, subComponent, namespace string) (*corev1.ServiceAccount, error)
- func SetDefaultsConfigCacheParams(params *ConfigCacheParams)
- func SetDefaultsLeaderElection(lep *LeaderElectionParams)
- func ValidateCacheInformerMode(value string) error
- func ValidateCacheResyncMethod(value string) error
- func ValidateForeignPodsDetectMode(value string) error
- func ValidateScoringStrategyType(value string) error
- type ConfigCacheParams
- type ConfigParams
- type LeaderElectionParams
- type ResourceSpecParams
- type ScoringStrategyParams
Constants ¶
View Source
const ( ComponentAPI = "api" ComponentSchedulerPlugin = "sched" ComponentResourceTopologyExporter = "rte" ComponentNodeFeatureDiscovery = "nfd" )
View Source
const ( SubComponentSchedulerPluginScheduler = "scheduler" SubComponentSchedulerPluginController = "controller" SubComponentNodeFeatureDiscoveryTopologyUpdater = "topologyupdater" )
View Source
const ( RoleNameAuthReader = "authreader" RoleNameLeaderElect = "leaderelect" )
View Source
const ( ContainerNameRTE = "resource-topology-exporter" ContainerNameNFDTopologyUpdater = "nfd-topology-updater" )
View Source
const ( DefaultUpdaterSyncPeriod = 10 * time.Second DefaultUpdaterVerbose = 1 )
View Source
const ( SchedulerConfigFileName = "scheduler-config.yaml" // TODO duplicate from yaml SchedulerPluginName = "NodeResourceTopologyMatch" )
View Source
const ( ForeignPodsDetectNone = "None" ForeignPodsDetectAll = "All" ForeignPodsDetectOnlyExclusiveResources = "OnlyExclusiveResources" )
View Source
const ( CacheResyncAutodetect = "Autodetect" CacheResyncAll = "All" CacheResyncOnlyExclusiveResources = "OnlyExclusiveResources" )
View Source
const ( CacheInformerDedicated = "Dedicated" )
View Source
const ( ScoringStrategyMostAllocated = "MostAllocated" ScoringStrategyBalancedAllocation = "BalancedAllocation" ScoringStrategyLeastAllocated = "LeastAllocated" )
View Source
const ( LeaderElectionDefaultName = "nrtmatch-scheduler" LeaderElectionDefaultNamespace = "tas-scheduler" )
Variables ¶
This section is empty.
Functions ¶
func APICRD ¶
func APICRD() (*apiextensionv1.CustomResourceDefinition, error)
func ClusterRole ¶
func ClusterRole(component, subComponent string) (*rbacv1.ClusterRole, error)
func ClusterRoleBinding ¶
func ClusterRoleBinding(component, subComponent string) (*rbacv1.ClusterRoleBinding, error)
func Deployment ¶
func Deployment(component, subComponent, namespace string) (*appsv1.Deployment, error)
func DeserializeObjectFromData ¶ added in v0.8.0
func MachineConfig ¶ added in v0.0.12
func MachineConfig(component string, ver platform.Version, withCRIHooks bool) (*machineconfigv1.MachineConfig, error)
func RoleBinding ¶ added in v0.0.9
func RoleBinding(component, subComponent, roleName, namespace string) (*rbacv1.RoleBinding, error)
func SchedulerCRD ¶
func SchedulerCRD() (*apiextensionv1.CustomResourceDefinition, error)
func SecurityContextConstraint ¶ added in v0.0.12
func SecurityContextConstraint(component string, withCustomSELinuxPolicy bool) (*securityv1.SecurityContextConstraints, error)
func SecurityContextConstraintV2 ¶ added in v0.21.2
func SecurityContextConstraintV2(component string) (*securityv1.SecurityContextConstraints, error)
func SerializeObjectToData ¶ added in v0.8.0
func ServiceAccount ¶
func ServiceAccount(component, subComponent, namespace string) (*corev1.ServiceAccount, error)
func SetDefaultsConfigCacheParams ¶ added in v0.20.0
func SetDefaultsConfigCacheParams(params *ConfigCacheParams)
func SetDefaultsLeaderElection ¶ added in v0.19.1
func SetDefaultsLeaderElection(lep *LeaderElectionParams)
func ValidateCacheInformerMode ¶ added in v0.17.2
func ValidateCacheResyncMethod ¶ added in v0.17.2
func ValidateForeignPodsDetectMode ¶ added in v0.17.2
func ValidateScoringStrategyType ¶ added in v0.19.0
Types ¶
type ConfigCacheParams ¶ added in v0.12.2
type ConfigCacheParams struct { ResyncPeriodSeconds *int64 `json:"-"` ResyncMethod *string `json:"resyncMethod,omitempty"` ForeignPodsDetectMode *string `json:"foreignPodsDetect,omitempty"` InformerMode *string `json:"informerMode,omitempty"` }
func NewConfigCacheParams ¶ added in v0.20.0
func NewConfigCacheParams() *ConfigCacheParams
type ConfigParams ¶ added in v0.12.2
type ConfigParams struct { // can't be empty, so no need for pointer ProfileName string `json:"profileName"` Cache *ConfigCacheParams `json:"cache"` ScoringStrategy *ScoringStrategyParams `json:"scoringStrategy,omitempty"` LeaderElection *LeaderElectionParams `json:"leaderElection"` }
func DecodeSchedulerProfilesFromData ¶ added in v0.12.2
func DecodeSchedulerProfilesFromData(data []byte) ([]ConfigParams, error)
func FindSchedulerProfileByName ¶ added in v0.12.2
func FindSchedulerProfileByName(profileParams []ConfigParams, schedulerName string) *ConfigParams
type LeaderElectionParams ¶ added in v0.19.1
type ResourceSpecParams ¶ added in v0.19.0
type ScoringStrategyParams ¶ added in v0.19.0
type ScoringStrategyParams struct { Type string `json:"type,omitempty"` Resources []ResourceSpecParams `json:"resources,omitempty"` }
Click to show internal directories.
Click to hide internal directories.