From 8b53924a97dc5feae60dd034e0a5effa62e4ae71 Mon Sep 17 00:00:00 2001 From: Marcin Wielgus Date: Thu, 11 Aug 2016 12:11:28 +0200 Subject: [PATCH] Federation - common libs - get clientset for cluster --- .../pkg/federation-controller/util/cluster_util.go | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/federation/pkg/federation-controller/util/cluster_util.go b/federation/pkg/federation-controller/util/cluster_util.go index 769e5ee45fd..7aafcf9b057 100644 --- a/federation/pkg/federation-controller/util/cluster_util.go +++ b/federation/pkg/federation-controller/util/cluster_util.go @@ -24,6 +24,7 @@ import ( "github.com/golang/glog" federation_v1beta1 "k8s.io/kubernetes/federation/apis/federation/v1beta1" + federation_release_1_4 "k8s.io/kubernetes/federation/client/clientset_generated/federation_release_1_4" "k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/client/restclient" client "k8s.io/kubernetes/pkg/client/unversioned" @@ -130,3 +131,13 @@ var KubeconfigGetterForSecret = func(secretName string) clientcmd.KubeconfigGett return clientcmd.Load(data) } } + +// Retruns Clientset for the given cluster. +func GetClientsetForCluster(cluster *federation_v1beta1.Cluster) (*federation_release_1_4.Clientset, error) { + clusterConfig, err := BuildClusterConfig(cluster) + if err != nil && clusterConfig != nil { + clientset := federation_release_1_4.NewForConfigOrDie(restclient.AddUserAgent(clusterConfig, userAgentName)) + return clientset, nil + } + return nil, err +}