-
Notifications
You must be signed in to change notification settings - Fork 14
Expand file tree
/
Copy pathcluster-node.tsx
More file actions
142 lines (132 loc) · 5.51 KB
/
cluster-node.tsx
File metadata and controls
142 lines (132 loc) · 5.51 KB
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
import { Dot, LayoutDashboard, Terminal, PowerIcon } from "lucide-react"
import { useNavigate } from "react-router"
import { useSelector } from "react-redux"
import { CONNECTED } from "@common/src/constants.ts"
import { TooltipProvider } from "@radix-ui/react-tooltip"
import { Card } from "./card"
import { CustomTooltip } from "./custom-tooltip"
import type { RootState } from "@/store.ts"
import { connectPending } from "@/state/valkey-features/connection/connectionSlice.ts"
import { useAppDispatch } from "@/hooks/hooks"
interface ReplicaNode {
id: string
host: string
port: number
}
interface PrimaryNode {
host: string
port: number
replicas: ReplicaNode[]
}
interface ParsedNodeInfo {
server_name: string | null
uptime_in_days: string | null
tcp_port: string | null
used_memory_human: string | null
used_cpu_sys: string | null
instantaneous_ops_per_sec: string | null
total_commands_processed: string | null
role: string | null
connected_clients: string | null
}
interface ClusterNodeProps {
primaryKey: string
primary: PrimaryNode
primaryData: ParsedNodeInfo
allNodeData: Record<string, ParsedNodeInfo>
clusterId: string
}
export default function ClusterNode({ primaryKey, primary, primaryData, allNodeData, clusterId }: ClusterNodeProps) {
const navigate = useNavigate()
const dispatch = useAppDispatch()
// to check if cluster node is connected
const connectionId = `localhost-${primary.port}`
const connectionStatus = useSelector((state: RootState) =>
state.valkeyConnection?.connections?.[connectionId]?.status,
)
const isConnected = connectionStatus === CONNECTED
const formatRole = (role: string | null) => {
if (!role) return "UNKNOWN"
const normalized = role.toLowerCase()
if (normalized === "master") return "PRIMARY"
if (normalized === "slave") return "REPLICA"
return role.toUpperCase()
}
const handleNodeConnect = () => {
if (!isConnected) {
dispatch(connectPending({
connectionId,
host: primary.host,
port: primary.port.toString(),
}))
}
}
return (
<Card className="dark:bg-gray-800">
{/* for primary */}
<TooltipProvider>
<div className="flex items-center justify-between">
<span className="font-bold">{formatRole(primaryData?.role)}</span>
<CustomTooltip content={`${isConnected ? "Connected" : "Not Connected"}`}>
<PowerIcon
className={`${isConnected ? "text-green-500 bg-green-100" : "text-gray-400 cursor-pointer bg-gray-100 hover:text-gray-600"} rounded-full p-0.5`}
onClick={handleNodeConnect}
size={18}
/>
</CustomTooltip>
</div>
</TooltipProvider>
<div className="flex flex-col text-xs text-tw-dark-border"><span>{primaryData?.server_name}</span><span>{primaryKey}</span></div>
<div className="text-xs space-y-1.5">
<div className="flex justify-between">
<span className="text-tw-dark-border">Memory:</span>
<span>{primaryData?.used_memory_human ?? "N/A"}</span>
</div>
<div className="flex justify-between">
<span className="text-tw-dark-border">CPU (sys):</span>
<span>{primaryData?.used_cpu_sys ?? "N/A"}</span>
</div>
<div className="flex justify-between">
<span className="text-tw-dark-border">Commands:</span>
<span>{primaryData?.total_commands_processed ?? "N/A"}</span>
</div>
<div className="flex justify-between">
<span className="text-tw-dark-border">Clients:</span>
<span>{primaryData?.connected_clients ?? "N/A"}</span>
</div>
</div>
<div className="border-b mt-0"></div>
{/* for replicas */}
{primary.replicas.length > 0 && (
<div className="mt-0">
<span className="text-xs text-tw-dark-border">REPLICAS ({primary.replicas.length})</span>
{primary.replicas.map((replica) => (
<div className="bg-tw-primary/10 rounded-sm p-2 text-xs text-tw-dark-border" key={replica.id}>
<div className="flex items-center justify-between space-y-1">
<div className="">
<span>{`${replica.host}:${replica.port}`}</span>
<div className="flex gap-4">
<span>Mem: {allNodeData[`${replica.host}:${replica.port}`]?.used_memory_human}</span>
<span>Clients: {allNodeData[`${replica.host}:${replica.port}`]?.connected_clients}</span>
</div>
</div>
<Dot className="text-tw-primary" size={30} />
</div>
</div>
))}
</div>
)}
{/* primary buttons */}
<div className="mt-2 flex gap-2 text-xs items-center justify-center">
<button className={`w-1/2 flex items-center justify-center gap-1.5 border px-2 py-1 rounded
${isConnected ? "cursor-pointer hover:bg-tw-primary hover:text-white" : "cursor-not-allowed opacity-50"}`}
disabled={!isConnected}
onClick={() => { navigate(`/${clusterId}/localhost-${primary.port}/dashboard`) }}><LayoutDashboard size={12} /> Dashboard</button>
<button className={`w-1/2 flex items-center justify-center gap-1.5 border px-2 py-1 rounded
${isConnected ? "cursor-pointer hover:bg-tw-primary hover:text-white" : "cursor-not-allowed opacity-50"}`}
disabled={!isConnected}
onClick={() => { navigate(`/${clusterId}/localhost-${primary.port}/sendcommand`) }}><Terminal size={12} /> Command</button>
</div>
</Card>
)
}