)
):
self.state.message_host = message_host
- self.state.message_port = message_port
+ self.state.message_port = int(message_port)
self.on.configure_pod.emit()
def _on_kafka_relation_departed(self, event: EventBase) -> NoReturn:
)
):
self.state.keystone_host = keystone_host
- self.state.keystone_port = keystone_port
+ self.state.keystone_port = int(keystone_port)
self.state.keystone_user_domain_name = keystone_user_domain_name
self.state.keystone_project_domain_name = keystone_project_domain_name
self.state.keystone_username = keystone_username
)
):
self.state.prometheus_host = prometheus_host
- self.state.prometheus_port = prometheus_port
+ self.state.prometheus_port = int(prometheus_port)
self.on.configure_pod.emit()
def _on_prometheus_relation_departed(self, event: EventBase) -> NoReturn:
Args:
event (EventBase): NBI relation event.
"""
- if self.unit.is_leader():
- rel_data = {
- "host": self.model.app.name,
- "port": str(NBI_PORT),
- }
- for k, v in rel_data.items():
- event.relation.data[self.model.app][k] = v
+ rel_data = {
+ "host": self.model.app.name,
+ "port": str(NBI_PORT),
+ }
+ for k, v in rel_data.items():
+ event.relation.data[self.unit][k] = v
def _missing_relations(self) -> str:
"""Checks if there missing relations.