2 # Copyright 2021 Canonical Ltd.
4 # Licensed under the Apache License, Version 2.0 (the "License"); you may
5 # not use this file except in compliance with the License. You may obtain
6 # a copy of the License at
8 # http://www.apache.org/licenses/LICENSE-2.0
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13 # License for the specific language governing permissions and limitations
16 # For those usages not covered by the Apache License, Version 2.0 please
17 # contact: legal@canonical.com
19 # To get in touch with the maintainers, please contact:
20 # osm-charmers@lists.launchpad.net
23 from ipaddress
import ip_network
25 from typing
import Any
, Dict
, List
26 from urllib
.parse
import urlparse
28 logger
= logging
.getLogger(__name__
)
31 def _validate_ip_network(network
: str) -> bool:
32 """Validate IP network.
35 network (str): IP network range.
38 bool: True if valid, false otherwise.
51 def _validate_data(config_data
: Dict
[str, Any
], relation_data
: Dict
[str, Any
]) -> bool:
52 """Validates passed information.
55 config_data (Dict[str, Any]): configuration information.
56 relation_data (Dict[str, Any]): relation information
59 ValueError: when config and/or relation data is not valid.
62 "site_url": lambda value
, _
: isinstance(value
, str)
65 "cluster_issuer": lambda value
, _
: isinstance(value
, str)
68 "ingress_whitelist_source_range": lambda value
, _
: _validate_ip_network(value
),
69 "tls_secret_name": lambda value
, _
: isinstance(value
, str)
73 relation_validators
= {
74 "kafka_host": lambda value
, _
: isinstance(value
, str) and len(value
) > 0,
75 "kafka_port": lambda value
, _
: isinstance(value
, str)
81 for key
, validator
in config_validators
.items():
82 valid
= validator(config_data
.get(key
), config_data
)
87 for key
, validator
in relation_validators
.items():
88 valid
= validator(relation_data
.get(key
), relation_data
)
94 raise ValueError("Errors found in: {}".format(", ".join(problems
)))
99 def _make_pod_ports(port
: int) -> List
[Dict
[str, Any
]]:
100 """Generate pod ports details.
103 port (int): port to expose.
106 List[Dict[str, Any]]: pod port details.
108 return [{"name": "kafka-exporter", "containerPort": port
, "protocol": "TCP"}]
111 def _make_pod_envconfig(
112 config
: Dict
[str, Any
], relation_state
: Dict
[str, Any
]
114 """Generate pod environment configuration.
117 config (Dict[str, Any]): configuration information.
118 relation_state (Dict[str, Any]): relation state information.
121 Dict[str, Any]: pod environment configuration.
128 def _make_pod_ingress_resources(
129 config
: Dict
[str, Any
], app_name
: str, port
: int
130 ) -> List
[Dict
[str, Any
]]:
131 """Generate pod ingress resources.
134 config (Dict[str, Any]): configuration information.
135 app_name (str): application name.
136 port (int): port to expose.
139 List[Dict[str, Any]]: pod ingress resources.
141 site_url
= config
.get("site_url")
146 parsed
= urlparse(site_url
)
148 if not parsed
.scheme
.startswith("http"):
151 ingress_whitelist_source_range
= config
["ingress_whitelist_source_range"]
152 cluster_issuer
= config
["cluster_issuer"]
156 if ingress_whitelist_source_range
:
158 "nginx.ingress.kubernetes.io/whitelist-source-range"
159 ] = ingress_whitelist_source_range
162 annotations
["cert-manager.io/cluster-issuer"] = cluster_issuer
164 ingress_spec_tls
= None
166 if parsed
.scheme
== "https":
167 ingress_spec_tls
= [{"hosts": [parsed
.hostname
]}]
168 tls_secret_name
= config
["tls_secret_name"]
170 ingress_spec_tls
[0]["secretName"] = tls_secret_name
172 annotations
["nginx.ingress.kubernetes.io/ssl-redirect"] = "false"
175 "name": "{}-ingress".format(app_name
),
176 "annotations": annotations
,
180 "host": parsed
.hostname
,
186 "serviceName": app_name
,
197 ingress
["spec"]["tls"] = ingress_spec_tls
202 def _make_readiness_probe(port
: int) -> Dict
[str, Any
]:
203 """Generate readiness probe.
206 port (int): service port.
209 Dict[str, Any]: readiness probe.
213 "path": "/api/health",
216 "initialDelaySeconds": 10,
219 "successThreshold": 1,
220 "failureThreshold": 3,
224 def _make_liveness_probe(port
: int) -> Dict
[str, Any
]:
225 """Generate liveness probe.
228 port (int): service port.
231 Dict[str, Any]: liveness probe.
235 "path": "/api/health",
238 "initialDelaySeconds": 60,
239 "timeoutSeconds": 30,
240 "failureThreshold": 10,
244 def _make_pod_command(relation
: Dict
[str, Any
]) -> List
[str]:
245 """Generate the startup command.
248 relation (Dict[str, Any]): Relation information.
251 List[str]: command to startup the process.
255 "--kafka.server={}:{}".format(
256 relation
.get("kafka_host"), relation
.get("kafka_port")
264 image_info
: Dict
[str, str],
265 config
: Dict
[str, Any
],
266 relation_state
: Dict
[str, Any
],
267 app_name
: str = "kafka-exporter",
270 """Generate the pod spec information.
273 image_info (Dict[str, str]): Object provided by
274 OCIImageResource("image").fetch().
275 config (Dict[str, Any]): Configuration information.
276 relation_state (Dict[str, Any]): Relation state information.
277 app_name (str, optional): Application name. Defaults to "ro".
278 port (int, optional): Port for the container. Defaults to 9090.
281 Dict[str, Any]: Pod spec dictionary for the charm.
286 _validate_data(config
, relation_state
)
288 ports
= _make_pod_ports(port
)
289 env_config
= _make_pod_envconfig(config
, relation_state
)
290 readiness_probe
= _make_readiness_probe(port
)
291 liveness_probe
= _make_liveness_probe(port
)
292 ingress_resources
= _make_pod_ingress_resources(config
, app_name
, port
)
293 command
= _make_pod_command(relation_state
)
300 "imageDetails": image_info
,
301 "imagePullPolicy": "Always",
303 "envConfig": env_config
,
306 "readinessProbe": readiness_probe
,
307 "livenessProbe": liveness_probe
,
311 "kubernetesResources": {
312 "ingressResources": ingress_resources
or [],