github/kubeinvaders
1
0
Fork 0
mirror of https://github.com/lucky-sideburn/kubeinvaders.git synced 2026-05-06 08:46:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'feature/gui_improvements' of github.com:lucky-sideburn/KubeInvaders into feature/gui_improvements

Browse Source
This commit is contained in:
Eugenio Marzo
2022-10-29 22:07:07 +02:00
parent 8408b0c7c7 5f0855a057
commit ee679bba6a
3 changed files with 17 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
html5/index.html
View File

@@ -223,7 +223,7 @@ experiments:
</textarea>
</div>
</form>
<div id="chaosJobLogsDiv" style="margin-top: 2%; overflow-y: scroll; height:700px;"></div>
<div id="chaosJobLogsDiv" style="margin-top: 2%; overflow-y: scroll; height:1000px;"></div>
</div>
</div>

2
scripts/chaos-containers.lua
View File

@@ -53,7 +53,7 @@ elseif ngx.var.request_method == "POST" and action == "enable_log_tail" then
return ngx.exit(ngx.status)
elseif ngx.var.request_method == "POST" and action == "disable_log_tail" then
red:set("logs_enabled:" .. arg['id'], "0")
-- red:set("logs_enabled:" .. arg['id'], "0")
red:set("programming_mode", "0")
-- os.execute("> /var/www/html/chaoslogs-" .. arg['id'] .. ".html")
ngx.say("Disable Log Tail for log id " .. arg['id'])

29
scripts/logs_loop/start.py
View File

@@ -24,15 +24,15 @@ def compute_line(api_response_line, api_instance):
logrow = f"<div class='row' style='margin-top: 2%; font-size: 75%; color: #400075;'>[namespace:{pod.metadata.namespace}][pod:{pod.metadata.name}]</div><div class='row' style='margin-top: 0.5%; color: #444141; font-size: 75%; font-family: Courier New, Courier, monospace;'>>>>{api_response_line}</div>"
store = False
#store = False
sha256log = sha256(logrow.encode('utf-8')).hexdigest()
if r.exists(f"log:{logid}:{pod.metadata.name}:{sha256log}"):
current_row = r.get(f"log:{logid}:{pod.metadata.name}:{sha256log}")
if current_row != logrow:
store = True
#if r.exists(f"log:{logid}:{pod.metadata.name}:{sha256log}"):
# current_row = r.get(f"log:{logid}:{pod.metadata.name}:{sha256log}")
# if current_row != logrow:
# store = True
if not r.exists(f"log:{logid}:{pod.metadata.name}:{sha256log}") or store:
if not r.exists(f"log:{logid}:{pod.metadata.name}:{sha256log}"):
logging.info(f"[logid:{logid}] The key log:{logid}:{pod.metadata.name}:{sha256log} does not exists. Preparing to store log content")
file = pathlib.Path('/var/www/html')
if file.exists():
@@ -183,7 +183,7 @@ while True:
for pod in api_response.items:
if re.search(f"{pod_re}", pod.metadata.name) and re.search(f"{namespace_re}", pod.metadata.namespace) and re.search(f"{labels_re}", str(pod.metadata.labels)) and re.search(f"{annotations_re}", str(pod.metadata.annotations)):
webtail_pods.append(pod)
logging.info(f"[logid:{logid}] Taking log of {pod.metadata.name} because it is compliant with the regex {log_pod_regex}")
#logging.info(f"[logid:{logid}] Taking log of {pod.metadata.name} because it is compliant with the regex {log_pod_regex}")
try:
api_response = api_instance.list_namespaced_pod(namespace="kubeinvaders")
@@ -203,17 +203,17 @@ while True:
if webtail_switch or (pod.metadata.labels.get('approle') != None and pod.metadata.labels['approle'] == 'chaosnode' and pod.status.phase != "Pending"):
try:
latest_log_tail = r.get(f"log_time:{pod.metadata.name}")
logging.info(f"[logid:{logid}] Reading logs of {pod.metadata.name} on {pod.metadata.namespace}")
#logging.info(f"[logid:{logid}] Reading logs of {pod.metadata.name} on {pod.metadata.namespace}")
if r.exists(f"log_time:{logid}:{pod.metadata.name}"):
latest_log_tail_time = r.get(f"log_time:{logid}:{pod.metadata.name}")
else:
latest_log_tail_time = time.time()
logging.info(f"[logid:{logid}] Latest latest_log_tail for {pod.metadata.name} is {latest_log_tail_time}. Current Unix Time is {time.time()}")
#logging.info(f"[logid:{logid}] Latest latest_log_tail for {pod.metadata.name} is {latest_log_tail_time}. Current Unix Time is {time.time()}")
since = int(time.time() - float(latest_log_tail_time))
since = int(time.time() - float(latest_log_tail_time)) + 1
logging.info(f"[logid:{logid}] Diff from time.time() and latest_log_tail_time for {pod.metadata.name} is {since}")
#logging.info(f"[logid:{logid}] Diff from time.time() and latest_log_tail_time for {pod.metadata.name} is {since}")
if since == 0:
since = 1
@@ -224,12 +224,13 @@ while True:
if api_response == "":
continue
if api_response.__class__.__name__ == "list":
if type(api_response) is list:
for api_response_line in api_response:
compute_line(api_response_line, api_instance)
else:
compute_line(api_response, api_instance)
for api_response_line in api_response.splitlines():
compute_line(api_response_line, api_instance)
except ApiException as e:
logging.info(e)
time.sleep(0.5)
time.sleep(1)