from ipaddress import ip_network
import logging
from pathlib import Path
+import secrets
from string import Template
from typing import NoReturn, Optional
from urllib.parse import urlparse
from ops.main import main
from opslib.osm.charm import CharmedOsmBase, RelationsMissing
+from opslib.osm.interfaces.grafana import GrafanaCluster
+from opslib.osm.interfaces.mysql import MysqlClient
from opslib.osm.interfaces.prometheus import PrometheusClient
from opslib.osm.pod import (
ContainerV3Builder,
logger = logging.getLogger(__name__)
-PORT = 3000
-
class ConfigModel(ModelValidator):
+ log_level: str
+ port: int
+ admin_user: str
max_file_size: int
osm_dashboards: bool
site_url: Optional[str]
tls_secret_name: Optional[str]
image_pull_policy: Optional[str]
+ @validator("log_level")
+ def validate_log_level(cls, v):
+ allowed_values = ("debug", "info", "warn", "error", "critical")
+ if v not in allowed_values:
+ separator = '", "'
+ raise ValueError(
+ f'incorrect value. Allowed values are "{separator.join(allowed_values)}"'
+ )
+ return v
+
@validator("max_file_size")
def validate_max_file_size(cls, v):
if v < 0:
def __init__(self, *args) -> NoReturn:
"""Prometheus Charm constructor."""
- super().__init__(*args, oci_image="image")
-
+ super().__init__(*args, oci_image="image", mysql_uri=True)
+ # Initialize relation objects
self.prometheus_client = PrometheusClient(self, "prometheus")
- self.framework.observe(
- self.on["prometheus"].relation_changed, self.configure_pod
- )
- self.framework.observe(
- self.on["prometheus"].relation_broken, self.configure_pod
- )
+ self.grafana_cluster = GrafanaCluster(self, "cluster")
+ self.mysql_client = MysqlClient(self, "db")
+ # Observe events
+ event_observer_mapping = {
+ self.on["prometheus"].relation_changed: self.configure_pod,
+ self.on["prometheus"].relation_broken: self.configure_pod,
+ self.on["db"].relation_changed: self.configure_pod,
+ self.on["db"].relation_broken: self.configure_pod,
+ }
+ for event, observer in event_observer_mapping.items():
+ self.framework.observe(event, observer)
def _build_dashboard_files(self, config: ConfigModel):
files_builder = FilesV3Builder()
files_builder.add_file(
"dashboard_osm.yaml",
- Path("files/default_dashboards.yaml").read_text(),
+ Path("templates/default_dashboards.yaml").read_text(),
)
if config.osm_dashboards:
osm_dashboards_mapping = {
- "kafka_exporter_dashboard.json": "files/kafka_exporter_dashboard.json",
- "mongodb_exporter_dashboard.json": "files/mongodb_exporter_dashboard.json",
- "mysql_exporter_dashboard.json": "files/mysql_exporter_dashboard.json",
- "nodes_exporter_dashboard.json": "files/nodes_exporter_dashboard.json",
- "summary_dashboard.json": "files/summary_dashboard.json",
+ "kafka_exporter_dashboard.json": "templates/kafka_exporter_dashboard.json",
+ "mongodb_exporter_dashboard.json": "templates/mongodb_exporter_dashboard.json",
+ "mysql_exporter_dashboard.json": "templates/mysql_exporter_dashboard.json",
+ "nodes_exporter_dashboard.json": "templates/nodes_exporter_dashboard.json",
+ "summary_dashboard.json": "templates/summary_dashboard.json",
}
for file_name, path in osm_dashboards_mapping.items():
files_builder.add_file(file_name, Path(path).read_text())
files_builder = FilesV3Builder()
files_builder.add_file(
"datasource_prometheus.yaml",
- Template(Path("files/default_datasources.yaml").read_text()).substitute(
+ Template(Path("templates/default_datasources.yaml").read_text()).substitute(
prometheus_host=self.prometheus_client.hostname,
prometheus_port=self.prometheus_client.port,
),
)
return files_builder.build()
- def _check_missing_dependencies(self):
+ def _check_missing_dependencies(self, config: ConfigModel, external_db: bool):
missing_relations = []
if self.prometheus_client.is_missing_data_in_app():
missing_relations.append("prometheus")
+ if not external_db and self.mysql_client.is_missing_data_in_unit():
+ missing_relations.append("db")
+
if missing_relations:
raise RelationsMissing(missing_relations)
- def build_pod_spec(self, image_info):
+ def build_pod_spec(self, image_info, **kwargs):
# Validate config
config = ConfigModel(**dict(self.config))
+ mysql_config = kwargs["mysql_config"]
+ if mysql_config.mysql_uri and not self.mysql_client.is_missing_data_in_unit():
+ raise Exception("Mysql data cannot be provided via config and relation")
+
# Check relations
- self._check_missing_dependencies()
+ external_db = True if mysql_config.mysql_uri else False
+ self._check_missing_dependencies(config, external_db)
+
+ # Get initial password
+ admin_initial_password = self.grafana_cluster.admin_initial_password
+ if not admin_initial_password:
+ admin_initial_password = _generate_random_password()
+ self.grafana_cluster.set_initial_password(admin_initial_password)
+
# Create Builder for the PodSpec
pod_spec_builder = PodSpecV3Builder()
+
# Build Container
container_builder = ContainerV3Builder(
self.app.name, image_info, config.image_pull_policy
)
- container_builder.add_port(name=self.app.name, port=PORT)
+ container_builder.add_port(name=self.app.name, port=config.port)
container_builder.add_http_readiness_probe(
"/api/health",
- PORT,
+ config.port,
initial_delay_seconds=10,
period_seconds=10,
timeout_seconds=5,
)
container_builder.add_http_liveness_probe(
"/api/health",
- PORT,
+ config.port,
initial_delay_seconds=60,
timeout_seconds=30,
failure_threshold=10,
"/etc/grafana/provisioning/datasources/",
self._build_datasources_files(),
)
+
+ container_builder.add_envs(
+ {
+ "GF_SERVER_HTTP_PORT": config.port,
+ "GF_LOG_LEVEL": config.log_level,
+ "GF_SECURITY_ADMIN_USER": config.admin_user,
+ "GF_SECURITY_ADMIN_PASSWORD": {
+ "secret": {"name": "grafana-admin-secret", "key": "admin-password"}
+ },
+ "GF_DATABASE_URL": {
+ "secret": {"name": "grafana-admin-secret", "key": "mysql-url"}
+ },
+ },
+ )
container = container_builder.build()
# Add container to pod spec
pod_spec_builder.add_container(container)
+ pod_spec_builder.add_secret(
+ "grafana-admin-secret",
+ {
+ "admin-password": admin_initial_password,
+ "mysql-url": mysql_config.mysql_uri or self.mysql_client.get_uri(),
+ },
+ )
# Add ingress resources to pod spec if site url exists
if config.site_url:
parsed = urlparse(config.site_url)
else:
annotations["nginx.ingress.kubernetes.io/ssl-redirect"] = "false"
- ingress_resource_builder.add_rule(parsed.hostname, self.app.name, PORT)
+ ingress_resource_builder.add_rule(
+ parsed.hostname, self.app.name, config.port
+ )
ingress_resource = ingress_resource_builder.build()
pod_spec_builder.add_ingress_resource(ingress_resource)
return pod_spec_builder.build()
+def _generate_random_password():
+ return secrets.token_hex(16)
+
+
if __name__ == "__main__":
main(GrafanaCharm)
projects / osm / devops.git / blobdiff