Set annotation name in federated replica set controller

This commit is contained in:
Marcin Wielgus 2016-08-23 11:26:05 +02:00
parent 6e75fa9745
commit 3216336923

View File

@ -29,7 +29,6 @@ import (
planner "k8s.io/kubernetes/federation/pkg/federation-controller/replicaset/planner" planner "k8s.io/kubernetes/federation/pkg/federation-controller/replicaset/planner"
fedutil "k8s.io/kubernetes/federation/pkg/federation-controller/util" fedutil "k8s.io/kubernetes/federation/pkg/federation-controller/util"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/meta"
apiv1 "k8s.io/kubernetes/pkg/api/v1" apiv1 "k8s.io/kubernetes/pkg/api/v1"
extensionsv1 "k8s.io/kubernetes/pkg/apis/extensions/v1beta1" extensionsv1 "k8s.io/kubernetes/pkg/apis/extensions/v1beta1"
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
@ -44,7 +43,7 @@ import (
) )
const ( const (
FedReplicaSetPreferencesAnnotation = "" FedReplicaSetPreferencesAnnotation = "federation.kubernetes.io/replica-set-preferences"
allClustersKey = "THE_ALL_CLUSTER_KEY" allClustersKey = "THE_ALL_CLUSTER_KEY"
UserAgentName = "Federation-replicaset-Controller" UserAgentName = "Federation-replicaset-Controller"
) )
@ -57,15 +56,10 @@ var (
) )
func parseFederationReplicaSetReference(frs *extensionsv1.ReplicaSet) (*fed.FederatedReplicaSetPreferences, error) { func parseFederationReplicaSetReference(frs *extensionsv1.ReplicaSet) (*fed.FederatedReplicaSetPreferences, error) {
accessor, err := meta.Accessor(frs) if frs.Annotations == nil {
if err != nil {
return nil, err
}
anno := accessor.GetAnnotations()
if anno == nil {
return nil, nil return nil, nil
} }
frsPrefString, found := anno[FedReplicaSetPreferencesAnnotation] frsPrefString, found := frs.Annotations[FedReplicaSetPreferencesAnnotation]
if !found { if !found {
return nil, nil return nil, nil
} }