|
2 | 2 | import json |
3 | 3 | import subprocess |
4 | 4 | import os |
| 5 | +from crmetrics import CRBase |
5 | 6 |
|
6 | 7 |
|
7 | | -class ProviderKubeconfigRetriever(object): |
| 8 | +class KubeconfigRetriever(CRBase): |
8 | 9 |
|
9 | | - def retrieve_kubeconfig(self, kubeplusNS, serverURL, kubeconfigFor, kubeconfig): |
| 10 | + def retrieve_kubeconfig(self, serverURL, kubeconfigFor, kubeconfig): |
10 | 11 |
|
| 12 | + kubeplusNS = self.get_kubeplus_namespace(kubeconfig) |
11 | 13 | if kubeconfigFor == 'provider': |
12 | 14 | cmd = "kubectl get configmaps kubeplus-saas-provider -n " + kubeplusNS + " -o jsonpath=\"{.data.kubeplus-saas-provider\.json}\"" |
13 | 15 | if kubeconfigFor == 'consumer': |
@@ -38,9 +40,8 @@ def retrieve_kubeconfig(self, kubeplusNS, serverURL, kubeconfigFor, kubeconfig): |
38 | 40 |
|
39 | 41 | if __name__ == '__main__': |
40 | 42 |
|
41 | | - kubeplusNS = sys.argv[1] |
42 | | - serverURL = sys.argv[2] # <api server url> |
43 | | - kubeconfigFor = sys.argv[3] |
44 | | - kubeconfigPath = sys.argv[4] # <complete kubeconfig path> |
45 | | - providerKfgRetriever = ProviderKubeconfigRetriever() |
46 | | - providerKfgRetriever.retrieve_kubeconfig(kubeplusNS, serverURL, kubeconfigFor, kubeconfigPath) |
| 43 | + serverURL = sys.argv[1] # <api server url> |
| 44 | + kubeconfigFor = sys.argv[2] |
| 45 | + kubeconfigPath = sys.argv[3] # <complete kubeconfig path> |
| 46 | + kfgRetriever = KubeconfigRetriever() |
| 47 | + kfgRetriever.retrieve_kubeconfig(serverURL, kubeconfigFor, kubeconfigPath) |
0 commit comments