@@ -134,56 +134,69 @@ def create(
134
134
:param ext_id_svr_group_attribute str
135
135
:param ext_id_svr_security_protocol str
136
136
:param ext_id_svr_base_dn str
137
- :param ext_id_svr_verify_peer str
137
+ :param ext_id_svr_verify_peer bool
138
138
:param ext_id_svr_type str
139
- :param ext_id_svr_port str
139
+ :param ext_id_svr_port int
140
140
"""
141
141
host_config = [
142
142
K8sClusterHostConfig .create_from_list (h .split (":" ))
143
143
for h in k8shosts_config .split ("," )
144
144
]
145
145
146
- if external_identity_server and not isinstance (
147
- external_identity_server , dict
148
- ):
149
- print (
150
- (
151
- "Could not parse 'external_identity_server' parameter"
152
- " - is it valid json?\n "
153
- "Received: " + external_identity_server + "\n "
154
- ),
155
- file = sys .stderr ,
156
- )
157
- sys .exit (1 )
146
+ if external_identity_server :
147
+ if not isinstance (external_identity_server , dict ):
148
+ print (
149
+ (
150
+ "Could not parse 'external_identity_server' parameter"
151
+ " - is it valid json?\n "
152
+ "Received: " + external_identity_server + "\n "
153
+ ),
154
+ file = sys .stderr ,
155
+ )
156
+ sys .exit (1 )
157
+ else :
158
+ external_identity_server = {}
158
159
159
160
if ext_id_svr_bind_pwd is not None :
160
161
external_identity_server ["bind_pwd" ] = ext_id_svr_bind_pwd
162
+
161
163
if ext_id_svr_user_attribute is not None :
162
164
external_identity_server [
163
165
"user_attribute"
164
166
] = ext_id_svr_user_attribute
167
+
165
168
if ext_id_svr_bind_type is not None :
166
169
external_identity_server ["bind_type" ] = ext_id_svr_bind_type
170
+
167
171
if ext_id_svr_bind_dn is not None :
168
172
external_identity_server ["bind_dn" ] = ext_id_svr_bind_dn
173
+
169
174
if ext_id_svr_host is not None :
170
175
external_identity_server ["host" ] = ext_id_svr_host
176
+
171
177
if ext_id_svr_group_attribute is not None :
172
178
external_identity_server [
173
179
"group_attribute"
174
180
] = ext_id_svr_group_attribute
181
+
175
182
if ext_id_svr_security_protocol is not None :
176
183
external_identity_server [
177
184
"security_protocol"
178
185
] = ext_id_svr_security_protocol
186
+
179
187
if ext_id_svr_base_dn is not None :
180
188
external_identity_server ["base_dn" ] = ext_id_svr_base_dn
189
+
181
190
if ext_id_svr_verify_peer is not None :
182
- external_identity_server ["verify_peer" ] = ext_id_svr_verify_peer
191
+ external_identity_server ["verify_peer" ] = json .loads (
192
+ ext_id_svr_verify_peer .lower ()
193
+ )
194
+
183
195
if ext_id_svr_type is not None :
184
196
external_identity_server ["svr_type" ] = ext_id_svr_type
197
+
185
198
if ext_id_svr_port is not None :
186
- external_identity_server ["svr_port" ] = ext_id_svr_port
199
+ external_identity_server ["svr_port" ] = int ( ext_id_svr_port )
187
200
188
201
print (
189
202
base .get_client ().k8s_cluster .create (
0 commit comments