mirror of
https://github.com/fankes/beszel.git
synced 2025-10-20 02:09:28 +08:00
add bandwidth chart
This commit is contained in:
98
site/src/components/charts/bandwidth-chart.tsx
Normal file
98
site/src/components/charts/bandwidth-chart.tsx
Normal file
@@ -0,0 +1,98 @@
|
|||||||
|
import { Area, AreaChart, CartesianGrid, XAxis, YAxis } from 'recharts'
|
||||||
|
|
||||||
|
import {
|
||||||
|
ChartConfig,
|
||||||
|
ChartContainer,
|
||||||
|
ChartTooltip,
|
||||||
|
ChartTooltipContent,
|
||||||
|
} from '@/components/ui/chart'
|
||||||
|
import { formatShortDate, hourWithMinutes } from '@/lib/utils'
|
||||||
|
import Spinner from '../spinner'
|
||||||
|
|
||||||
|
const chartConfig = {
|
||||||
|
recv: {
|
||||||
|
label: 'Received',
|
||||||
|
color: 'hsl(var(--chart-2))',
|
||||||
|
},
|
||||||
|
sent: {
|
||||||
|
label: 'Sent',
|
||||||
|
color: 'hsl(var(--chart-1))',
|
||||||
|
},
|
||||||
|
} satisfies ChartConfig
|
||||||
|
|
||||||
|
export default function BandwidthChart({
|
||||||
|
chartData,
|
||||||
|
ticks,
|
||||||
|
}: {
|
||||||
|
chartData: { time: number; sent: number; recv: number }[]
|
||||||
|
ticks: number[]
|
||||||
|
}) {
|
||||||
|
if (!chartData.length || !ticks.length) {
|
||||||
|
return <Spinner />
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<ChartContainer config={chartConfig} className="h-full w-full absolute aspect-auto">
|
||||||
|
<AreaChart
|
||||||
|
accessibilityLayer
|
||||||
|
data={chartData}
|
||||||
|
margin={{
|
||||||
|
left: 0,
|
||||||
|
right: 0,
|
||||||
|
top: 10,
|
||||||
|
bottom: 0,
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<CartesianGrid vertical={false} />
|
||||||
|
<YAxis
|
||||||
|
className="tracking-tighter"
|
||||||
|
width={80}
|
||||||
|
domain={[0, 'auto']}
|
||||||
|
// ticks={ticks}
|
||||||
|
tickCount={9}
|
||||||
|
minTickGap={8}
|
||||||
|
tickLine={false}
|
||||||
|
axisLine={false}
|
||||||
|
unit={' MB/s'}
|
||||||
|
/>
|
||||||
|
{/* todo: short time if first date is same day, otherwise short date */}
|
||||||
|
<XAxis
|
||||||
|
dataKey="time"
|
||||||
|
domain={[ticks[0], ticks.at(-1)!]}
|
||||||
|
ticks={ticks}
|
||||||
|
type="number"
|
||||||
|
scale={'time'}
|
||||||
|
tickLine={true}
|
||||||
|
axisLine={false}
|
||||||
|
tickMargin={8}
|
||||||
|
minTickGap={30}
|
||||||
|
tickFormatter={hourWithMinutes}
|
||||||
|
/>
|
||||||
|
<ChartTooltip
|
||||||
|
// cursor={false}
|
||||||
|
content={
|
||||||
|
<ChartTooltipContent
|
||||||
|
unit=" MB/s"
|
||||||
|
labelFormatter={(_, data) => formatShortDate(data[0].payload.time)}
|
||||||
|
indicator="line"
|
||||||
|
/>
|
||||||
|
}
|
||||||
|
/>
|
||||||
|
<Area
|
||||||
|
dataKey="sent"
|
||||||
|
type="monotoneX"
|
||||||
|
fill="var(--color-sent)"
|
||||||
|
fillOpacity={0.4}
|
||||||
|
stroke="var(--color-sent)"
|
||||||
|
/>
|
||||||
|
<Area
|
||||||
|
dataKey="recv"
|
||||||
|
type="monotoneX"
|
||||||
|
fill="var(--color-recv)"
|
||||||
|
fillOpacity={0.4}
|
||||||
|
stroke="var(--color-recv)"
|
||||||
|
/>
|
||||||
|
</AreaChart>
|
||||||
|
</ChartContainer>
|
||||||
|
)
|
||||||
|
}
|
@@ -9,7 +9,6 @@ import ChartTimeSelect from '../charts/chart-time-select'
|
|||||||
import { chartTimeData, cn, getPbTimestamp } from '@/lib/utils'
|
import { chartTimeData, cn, getPbTimestamp } from '@/lib/utils'
|
||||||
import { Separator } from '../ui/separator'
|
import { Separator } from '../ui/separator'
|
||||||
import { scaleTime } from 'd3-scale'
|
import { scaleTime } from 'd3-scale'
|
||||||
import DiskIoChart from '../charts/disk-io-chart'
|
|
||||||
import { Tooltip, TooltipContent, TooltipProvider, TooltipTrigger } from '../ui/tooltip'
|
import { Tooltip, TooltipContent, TooltipProvider, TooltipTrigger } from '../ui/tooltip'
|
||||||
|
|
||||||
const CpuChart = lazy(() => import('../charts/cpu-chart'))
|
const CpuChart = lazy(() => import('../charts/cpu-chart'))
|
||||||
@@ -17,6 +16,8 @@ const ContainerCpuChart = lazy(() => import('../charts/container-cpu-chart'))
|
|||||||
const MemChart = lazy(() => import('../charts/mem-chart'))
|
const MemChart = lazy(() => import('../charts/mem-chart'))
|
||||||
const ContainerMemChart = lazy(() => import('../charts/container-mem-chart'))
|
const ContainerMemChart = lazy(() => import('../charts/container-mem-chart'))
|
||||||
const DiskChart = lazy(() => import('../charts/disk-chart'))
|
const DiskChart = lazy(() => import('../charts/disk-chart'))
|
||||||
|
const DiskIoChart = lazy(() => import('../charts/disk-io-chart'))
|
||||||
|
const BandwidthChart = lazy(() => import('../charts/bandwidth-chart'))
|
||||||
|
|
||||||
function timestampToBrowserTime(timestamp: string) {
|
function timestampToBrowserTime(timestamp: string) {
|
||||||
const date = new Date(timestamp)
|
const date = new Date(timestamp)
|
||||||
@@ -42,6 +43,9 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
const [diskIoChartData, setDiskIoChartData] = useState(
|
const [diskIoChartData, setDiskIoChartData] = useState(
|
||||||
[] as { time: number; read: number; write: number }[]
|
[] as { time: number; read: number; write: number }[]
|
||||||
)
|
)
|
||||||
|
const [bandwidthChartData, setBandwidthChartData] = useState(
|
||||||
|
[] as { time: number; sent: number; recv: number }[]
|
||||||
|
)
|
||||||
const [dockerCpuChartData, setDockerCpuChartData] = useState(
|
const [dockerCpuChartData, setDockerCpuChartData] = useState(
|
||||||
[] as Record<string, number | string>[]
|
[] as Record<string, number | string>[]
|
||||||
)
|
)
|
||||||
@@ -56,6 +60,7 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
setCpuChartData([])
|
setCpuChartData([])
|
||||||
setMemChartData([])
|
setMemChartData([])
|
||||||
setDiskChartData([])
|
setDiskChartData([])
|
||||||
|
setBandwidthChartData([])
|
||||||
setDockerCpuChartData([])
|
setDockerCpuChartData([])
|
||||||
setDockerMemChartData([])
|
setDockerMemChartData([])
|
||||||
}
|
}
|
||||||
@@ -71,17 +76,6 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
}
|
}
|
||||||
}, [name, server, servers])
|
}, [name, server, servers])
|
||||||
|
|
||||||
// if visiting directly, make sure server gets set when servers are loaded
|
|
||||||
// useEffect(() => {
|
|
||||||
// if (!('id' in server)) {
|
|
||||||
// const matchingServer = servers.find((s) => s.name === name) as SystemRecord
|
|
||||||
// if (matchingServer) {
|
|
||||||
// console.log('setting server')
|
|
||||||
// setServer(matchingServer)
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// }, [servers])
|
|
||||||
|
|
||||||
// get stats
|
// get stats
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (!server.id) {
|
if (!server.id) {
|
||||||
@@ -114,6 +108,7 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
const memData = [] as typeof memChartData
|
const memData = [] as typeof memChartData
|
||||||
const diskData = [] as typeof diskChartData
|
const diskData = [] as typeof diskChartData
|
||||||
const diskIoData = [] as typeof diskIoChartData
|
const diskIoData = [] as typeof diskIoChartData
|
||||||
|
const networkData = [] as typeof bandwidthChartData
|
||||||
for (let { created, stats } of serverStats) {
|
for (let { created, stats } of serverStats) {
|
||||||
const time = new Date(created).getTime()
|
const time = new Date(created).getTime()
|
||||||
cpuData.push({ time, cpu: stats.cpu })
|
cpuData.push({ time, cpu: stats.cpu })
|
||||||
@@ -125,11 +120,13 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
})
|
})
|
||||||
diskData.push({ time, disk: stats.d, diskUsed: stats.du })
|
diskData.push({ time, disk: stats.d, diskUsed: stats.du })
|
||||||
diskIoData.push({ time, read: stats.dr, write: stats.dw })
|
diskIoData.push({ time, read: stats.dr, write: stats.dw })
|
||||||
|
networkData.push({ time, sent: stats.ns, recv: stats.nr })
|
||||||
}
|
}
|
||||||
setCpuChartData(cpuData)
|
setCpuChartData(cpuData)
|
||||||
setMemChartData(memData)
|
setMemChartData(memData)
|
||||||
setDiskChartData(diskData)
|
setDiskChartData(diskData)
|
||||||
setDiskIoChartData(diskIoData)
|
setDiskIoChartData(diskIoData)
|
||||||
|
setBandwidthChartData(networkData)
|
||||||
}, [serverStats])
|
}, [serverStats])
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
@@ -278,6 +275,11 @@ export default function ServerDetail({ name }: { name: string }) {
|
|||||||
>
|
>
|
||||||
<DiskIoChart chartData={diskIoChartData} ticks={ticks} />
|
<DiskIoChart chartData={diskIoChartData} ticks={ticks} />
|
||||||
</ChartCard>
|
</ChartCard>
|
||||||
|
|
||||||
|
<ChartCard title="Bandwidth" description="Throughput of network interfaces">
|
||||||
|
<BandwidthChart chartData={bandwidthChartData} ticks={ticks} />
|
||||||
|
</ChartCard>
|
||||||
|
|
||||||
<Card>
|
<Card>
|
||||||
<CardHeader>
|
<CardHeader>
|
||||||
<CardTitle className={'mb-3'}>{server.name}</CardTitle>
|
<CardTitle className={'mb-3'}>{server.name}</CardTitle>
|
||||||
|
@@ -44,8 +44,9 @@ import {
|
|||||||
} from './components/ui/dropdown-menu.tsx'
|
} from './components/ui/dropdown-menu.tsx'
|
||||||
import { AlertRecord, SystemRecord } from './types'
|
import { AlertRecord, SystemRecord } from './types'
|
||||||
import { $router, Link, navigate } from './components/router.tsx'
|
import { $router, Link, navigate } from './components/router.tsx'
|
||||||
|
import ServerDetail from './components/routes/server.tsx'
|
||||||
|
|
||||||
const ServerDetail = lazy(() => import('./components/routes/server.tsx'))
|
// const ServerDetail = lazy(() => import('./components/routes/server.tsx'))
|
||||||
const CommandPalette = lazy(() => import('./components/command-palette.tsx'))
|
const CommandPalette = lazy(() => import('./components/command-palette.tsx'))
|
||||||
const LoginPage = lazy(() => import('./components/login/login.tsx'))
|
const LoginPage = lazy(() => import('./components/login/login.tsx'))
|
||||||
|
|
||||||
@@ -103,11 +104,7 @@ const App = () => {
|
|||||||
} else if (page.path === '/') {
|
} else if (page.path === '/') {
|
||||||
return <Home />
|
return <Home />
|
||||||
} else if (page.route === 'server') {
|
} else if (page.route === 'server') {
|
||||||
return (
|
return <ServerDetail name={page.params.name} />
|
||||||
<Suspense>
|
|
||||||
<ServerDetail name={page.params.name} />
|
|
||||||
</Suspense>
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
6
site/src/types.d.ts
vendored
6
site/src/types.d.ts
vendored
@@ -48,6 +48,10 @@ export interface SystemStats {
|
|||||||
dr: number
|
dr: number
|
||||||
/** disk write (mb) */
|
/** disk write (mb) */
|
||||||
dw: number
|
dw: number
|
||||||
|
/** network sent (mb) */
|
||||||
|
ns: number
|
||||||
|
/** network received (mb) */
|
||||||
|
nr: number
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface ContainerStatsRecord extends RecordModel {
|
export interface ContainerStatsRecord extends RecordModel {
|
||||||
@@ -66,7 +70,7 @@ interface ContainerStats {
|
|||||||
|
|
||||||
export interface SystemStatsRecord extends RecordModel {
|
export interface SystemStatsRecord extends RecordModel {
|
||||||
system: string
|
system: string
|
||||||
info: SystemStats
|
stats: SystemStats
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface AlertRecord extends RecordModel {
|
export interface AlertRecord extends RecordModel {
|
||||||
|
2
types.go
2
types.go
@@ -39,6 +39,8 @@ type SystemStats struct {
|
|||||||
DiskPct float64 `json:"dp"`
|
DiskPct float64 `json:"dp"`
|
||||||
DiskRead float64 `json:"dr"`
|
DiskRead float64 `json:"dr"`
|
||||||
DiskWrite float64 `json:"dw"`
|
DiskWrite float64 `json:"dw"`
|
||||||
|
NetworkSent float64 `json:"ns"`
|
||||||
|
NetworkRecv float64 `json:"nr"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type ContainerStats struct {
|
type ContainerStats struct {
|
||||||
|
Reference in New Issue
Block a user