1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
"""The Nodes cog helps with managing Kubernetes nodes."""
from textwrap import dedent
from discord.ext import commands
from tabulate import tabulate
from arthur.apis.kubernetes import nodes
from arthur.bot import KingArthur
class Nodes(commands.Cog):
"""Commands for working with Kubernetes nodes."""
def __init__(self, bot: KingArthur) -> None:
self.bot = bot
@commands.group(name="nodes", aliases=["node"], invoke_without_command=True)
async def nodes(self, ctx: commands.Context) -> None:
"""Commands for working with Kubernetes nodes."""
await ctx.send_help(ctx.command)
@nodes.command(name="list", aliases=["ls"])
async def nodes_list(self, ctx: commands.Context) -> None:
"""List Kubernetes nodes in the cluster."""
cluster_nodes = await nodes.list_nodes()
table_data = []
for node in cluster_nodes.items:
statuses = []
for condition in node.status.conditions:
if condition.type == "Ready" and condition.status == "True":
statuses.append("Ready")
break
else:
statuses.append("Unready")
for condition in node.status.conditions:
if condition.type == "Ready":
pass
if condition.status is True:
statuses.append(condition.type)
if node.spec.taints:
for taint in node.spec.taints:
statuses.append(taint.effect)
node_creation = node.metadata.creation_timestamp
table_data.append(
[
node.metadata.name,
", ".join(statuses),
node.status.node_info.kubelet_version,
node_creation,
]
)
table = tabulate(
table_data, headers=["Name", "Status", "Kubernetes Version", "Created"], tablefmt="psql"
)
return_message = dedent(
"""
**Cluster nodes**
```
{0}
```
"""
)
await ctx.send(return_message.format(table))
@nodes.command(name="cordon")
async def nodes_cordon(self, ctx: commands.Context, *, node: str) -> None:
"""
Cordon a node in the cluster.
Cordoning a node has the effect of preventing any new deployments from being scheduled.
"""
await nodes.cordon_node(node)
await ctx.send(
f":construction: **Cordoned {node}** Node is now "
"cordoned and no pods will be scheduled to it."
)
@nodes.command(name="uncordon")
async def nodes_uncordon(self, ctx: commands.Context, *, node: str) -> None:
"""
Uncordon a node in the cluster.
Cordoning a node has the effect of preventing any new deployments from being scheduled.
"""
await nodes.uncordon_node(node)
await ctx.send(
f":construction: **Uncordoned {node}** Node is now "
"uncordoned, future pods may be scheduled to it."
)
async def setup(bot: KingArthur) -> None:
"""Add the extension to the bot."""
await bot.add_cog(Nodes(bot))
|
