@@ -39,6 +39,8 @@ def __init__(self, config, trawler):
39
39
self .find_hostname_and_certs ()
40
40
else :
41
41
self .find_hostname_and_certs ()
42
+ logger .trace ("Hostname is %s" , self .hostname )
43
+ logger .trace ("Certificate file is %s" , self .certificates .name )
42
44
43
45
def load_certs_from_secret (self , v1 , secret_name ):
44
46
# Get certificates to communicate with analytics
@@ -58,10 +60,11 @@ def find_hostname_and_certs(self):
58
60
# Initialise the k8s API
59
61
if self .use_kubeconfig :
60
62
config .load_kube_config ()
63
+ logger .info ("Not in cluster, so will assume port-forward" )
61
64
v1 = client .CoreV1Api ()
62
65
else :
63
66
config .load_incluster_config ()
64
- logger .info ("In cluster, so looking for analytics-storage service " )
67
+ logger .info ("In cluster, so looking for analytics services " )
65
68
v1 = client .CoreV1Api ()
66
69
# Identify analytics version
67
70
customObjectsApi = client .CustomObjectsApi ()
@@ -72,7 +75,7 @@ def find_hostname_and_certs(self):
72
75
self .version = analytics_clusters ['items' ][0 ]['status' ]['versions' ]['reconciled' ]
73
76
if self .version > '10.0.5' :
74
77
director_svc = analytics_clusters ['items' ][0 ]['status' ]['services' ]['director' ]
75
- self .hostname = '{}.{}.svc:3009' .format (self .namespace , director_svc )
78
+ self .hostname = '{}.{}.svc:3009' .format (director_svc , self .namespace )
76
79
if self .use_kubeconfig :
77
80
self .hostname = 'localhost:3009'
78
81
self .load_certs_from_secret (v1 , analytics_clusters ['items' ][0 ]['status' ]['serviceClientSecret' ])
0 commit comments