diff --git a/pkg/kubelet/cm/topologymanager/policy_preferred.go b/pkg/kubelet/cm/topologymanager/policy_preferred.go new file mode 100644 index 00000000000..6db6fb5641a --- /dev/null +++ b/pkg/kubelet/cm/topologymanager/policy_preferred.go @@ -0,0 +1,43 @@ +/* +Copyright 2015 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package topologymanager + +import ( + "k8s.io/kubernetes/pkg/kubelet/lifecycle" +) + +type preferredPolicy struct{} + +var _ Policy = &preferredPolicy{} + +// PolicyPreferred policy name. +const PolicyPreferred policyName = "preferred" + +// NewPreferredPolicy returns preferred policy. +func NewPreferredPolicy() Policy { + return &preferredPolicy{} +} + +func (p *preferredPolicy) Name() string { + return string(PolicyPreferred) +} + +func (p *preferredPolicy) CanAdmitPodResult(result TopologyHints) lifecycle.PodAdmitResult { + return lifecycle.PodAdmitResult{ + Admit: true, + } +} diff --git a/pkg/kubelet/cm/topologymanager/policy_strict.go b/pkg/kubelet/cm/topologymanager/policy_strict.go new file mode 100644 index 00000000000..9e3cc6a51e9 --- /dev/null +++ b/pkg/kubelet/cm/topologymanager/policy_strict.go @@ -0,0 +1,51 @@ +/* +Copyright 2015 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package topologymanager + +import ( + "k8s.io/kubernetes/pkg/kubelet/lifecycle" +) + +type strictPolicy struct{} + +var _ Policy = &strictPolicy{} + +// PolicyStrict policy name. +const PolicyStrict policyName = "strict" + +// NewStrictPolicy returns strict policy. +func NewStrictPolicy() Policy { + return &strictPolicy{} +} + +func (p *strictPolicy) Name() string { + return string(PolicyStrict) +} + +func (p *strictPolicy) CanAdmitPodResult(result TopologyHints) lifecycle.PodAdmitResult { + affinity := result.Affinity + if !affinity { + return lifecycle.PodAdmitResult{ + Admit: false, + Reason: "Topology Affinity Error", + Message: "Resources cannot be allocated with Topology Locality", + } + } + return lifecycle.PodAdmitResult{ + Admit: true, + } +}