This repository was archived by the owner on Dec 16, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +28
-0
lines changed
src/rookify/modules/create_rook_resources Expand file tree Collapse file tree 1 file changed +28
-0
lines changed Original file line number Diff line number Diff line change 22
33import kubernetes
44import json
5+ from collections import OrderedDict
56from typing import Any , Dict
67from ..exception import ModuleException
78from ..machine import Machine
@@ -135,6 +136,33 @@ def execute(self) -> None:
135136 "CreateRookResourcesHandler"
136137 ).secret = secret .to_dict ()
137138
139+ def get_readable_key_value_state (self ) -> Dict [str , str ]:
140+ kv_state_data = OrderedDict ()
141+
142+ configmap = self .machine .get_preflight_state_data (
143+ "CreateRookResourcesHandler" , "configmap"
144+ )
145+
146+ if configmap is None :
147+ kv_state_data ["rook-ceph-mon-endpoints" ] = "Not created yet"
148+ else :
149+ kv_state_data ["rook-ceph-mon-endpoints" ] = self ._get_readable_json_dump (
150+ configmap
151+ )
152+
153+ secret = self .machine .get_execution_state_data (
154+ "CreateRookResourcesHandler" , "secret"
155+ )
156+
157+ if secret is None :
158+ kv_state_data ["rook-ceph-mon-endpoints has been created" ] = "False"
159+ kv_state_data ["rook-ceph-mon" ] = "Not created yet"
160+ else :
161+ kv_state_data ["rook-ceph-mon-endpoints has been created" ] = "True"
162+ kv_state_data ["rook-ceph-mon" ] = self ._get_readable_json_dump (secret )
163+
164+ return kv_state_data
165+
138166 @staticmethod
139167 def register_execution_state (
140168 machine : Machine , state_name : str , handler : ModuleHandler , ** kwargs : Any
You can’t perform that action at this time.
0 commit comments