manifests

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 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
  • func NewConfigCacheParams() *ConfigCacheParams
• type ConfigParams
  • func DecodeSchedulerProfilesFromData(data []byte) ([]ConfigParams, error)
  • func FindSchedulerProfileByName(profileParams []ConfigParams, schedulerName string) *ConfigParams
• type LeaderElectionParams
• type ResourceSpecParams
• type ScoringStrategyParams

Constants

const (
	ComponentAPI                      = "api"
	ComponentSchedulerPlugin          = "sched"
	ComponentResourceTopologyExporter = "rte"
	ComponentNodeFeatureDiscovery     = "nfd"
)

const (
	SubComponentSchedulerPluginScheduler            = "scheduler"
	SubComponentSchedulerPluginController           = "controller"
	SubComponentNodeFeatureDiscoveryTopologyUpdater = "topologyupdater"
)

const (
	RoleNameAuthReader  = "authreader"
	RoleNameLeaderElect = "leaderelect"
)

const (
	ContainerNameRTE                = "resource-topology-exporter"
	ContainerNameNFDTopologyUpdater = "nfd-topology-updater"
)

const (
	DefaultUpdaterSyncPeriod = 10 * time.Second
	DefaultUpdaterVerbose    = 1
)

const (
	SchedulerConfigFileName = "scheduler-config.yaml" // TODO duplicate from yaml
	SchedulerPluginName     = "NodeResourceTopologyMatch"
)

const (
	ForeignPodsDetectNone                   = "None"
	ForeignPodsDetectAll                    = "All"
	ForeignPodsDetectOnlyExclusiveResources = "OnlyExclusiveResources"
)

const (
	CacheResyncAutodetect             = "Autodetect"
	CacheResyncAll                    = "All"
	CacheResyncOnlyExclusiveResources = "OnlyExclusiveResources"
)

const (
	CacheInformerShared    = "Shared"
	CacheInformerDedicated = "Dedicated"
)

const (
	ScoringStrategyMostAllocated      = "MostAllocated"
	ScoringStrategyBalancedAllocation = "BalancedAllocation"
	ScoringStrategyLeastAllocated     = "LeastAllocated"
)

const (
	LeaderElectionDefaultName      = "nrtmatch-scheduler"
	LeaderElectionDefaultNamespace = "tas-scheduler"
)

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 ConfigMap

func ConfigMap(component, subComponent string) (*corev1.ConfigMap, error)

func DaemonSet

func DaemonSet(component, subComponent string, namespace string) (*appsv1.DaemonSet, error)

func Deployment

func Deployment(component, subComponent, namespace string) (*appsv1.Deployment, error)

func DeserializeObjectFromData

func DeserializeObjectFromData(data []byte) (runtime.Object, error)

func MachineConfig

func MachineConfig(component string, ver platform.Version, withCRIHooks bool) (*machineconfigv1.MachineConfig, error)

func Namespace

func Namespace(component string) (*corev1.Namespace, error)

func RenderObjects

func RenderObjects(objs []client.Object, w io.Writer) error

func Role

func Role(component, subComponent, namespace string) (*rbacv1.Role, error)

func RoleBinding

func RoleBinding(component, subComponent, roleName, namespace string) (*rbacv1.RoleBinding, error)

func SchedulerCRD

func SchedulerCRD() (*apiextensionv1.CustomResourceDefinition, error)

func SecurityContextConstraint

func SecurityContextConstraint(component string, withCustomSELinuxPolicy bool) (*securityv1.SecurityContextConstraints, error)

func SerializeObject

func SerializeObject(obj runtime.Object, out io.Writer) error

func SerializeObjectToData

func SerializeObjectToData(obj runtime.Object) ([]byte, error)

func Service

func Service(component, subComponent, namespace string) (*corev1.Service, error)

func ServiceAccount

func ServiceAccount(component, subComponent, namespace string) (*corev1.ServiceAccount, error)

func SetDefaultsConfigCacheParams

func SetDefaultsConfigCacheParams(params *ConfigCacheParams)

func SetDefaultsLeaderElection

func SetDefaultsLeaderElection(lep *LeaderElectionParams)

func ValidateCacheInformerMode

func ValidateCacheInformerMode(value string) error

func ValidateCacheResyncMethod

func ValidateCacheResyncMethod(value string) error

func ValidateForeignPodsDetectMode

func ValidateForeignPodsDetectMode(value string) error

func ValidateScoringStrategyType

func ValidateScoringStrategyType(value string) error

Types

type ConfigCacheParams

type ConfigCacheParams struct {
	ResyncPeriodSeconds   *int64  `json:"-"`
	ResyncMethod          *string `json:"resyncMethod,omitempty"`
	ForeignPodsDetectMode *string `json:"foreignPodsDetect,omitempty"`
	InformerMode          *string `json:"informerMode,omitempty"`
}

func NewConfigCacheParams

func NewConfigCacheParams() *ConfigCacheParams

type ConfigParams

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

func DecodeSchedulerProfilesFromData(data []byte) ([]ConfigParams, error)

func FindSchedulerProfileByName

func FindSchedulerProfileByName(profileParams []ConfigParams, schedulerName string) *ConfigParams

type LeaderElectionParams

type LeaderElectionParams struct {
	LeaderElect       bool   `json:"leaderElect"`
	ResourceNamespace string `json:"resourceNamespace,omitempty"`
	ResourceName      string `json:"resourceName,omitempty"`
}

type ResourceSpecParams

type ResourceSpecParams struct {
	// Name of the resource.
	Name string `json:"name"`
	// Weight of the resource.
	Weight int64 `json:"weight,omitempty"`
}

type ScoringStrategyParams

type ScoringStrategyParams struct {
	Type      string               `json:"type,omitempty"`
	Resources []ResourceSpecParams `json:"resources,omitempty"`
}