Jack Wills
1060 lines
31 KiB
Rust
1060 lines
31 KiB
Rust
use std::{
|
|
cmp::Ordering,
|
|
collections::{HashSet, VecDeque},
|
|
fmt,
|
|
net::IpAddr,
|
|
};
|
|
|
|
use bollard::service::Port;
|
|
use jiff::{Timestamp, tz::TimeZone};
|
|
use ratatui::{
|
|
style::Color,
|
|
widgets::{ListItem, ListState},
|
|
};
|
|
|
|
use crate::config::AppColors;
|
|
|
|
use super::Header;
|
|
|
|
const ONE_KB: f64 = 1000.0;
|
|
const ONE_MB: f64 = ONE_KB * 1000.0;
|
|
const ONE_GB: f64 = ONE_MB * 1000.0;
|
|
|
|
#[derive(Debug, Clone, Eq, Hash, PartialEq)]
|
|
pub struct ContainerId(String);
|
|
|
|
impl From<&str> for ContainerId {
|
|
fn from(x: &str) -> Self {
|
|
Self(x.to_owned())
|
|
}
|
|
}
|
|
|
|
impl ContainerId {
|
|
// TODO remove this once zigbuild uses Rust v1.87.0
|
|
#[cfg(target_os = "macos")]
|
|
#[allow(clippy::missing_const_for_fn)]
|
|
pub fn get(&self) -> &str {
|
|
self.0.as_str()
|
|
}
|
|
|
|
#[cfg(not(target_os = "macos"))]
|
|
pub const fn get(&self) -> &str {
|
|
self.0.as_str()
|
|
}
|
|
|
|
/// Only return first 8 chars of id, is usually more than enough for uniqueness
|
|
/// need to update tests to use real ids, or atleast strings of the correct-ish length
|
|
pub fn get_short(&self) -> String {
|
|
self.0.chars().take(8).collect::<String>()
|
|
}
|
|
}
|
|
|
|
impl Ord for ContainerId {
|
|
fn cmp(&self, other: &Self) -> Ordering {
|
|
self.0.cmp(&other.0)
|
|
}
|
|
}
|
|
|
|
impl PartialOrd for ContainerId {
|
|
fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
|
|
Some(self.cmp(other))
|
|
}
|
|
}
|
|
|
|
pub trait Contains {
|
|
fn contains(&self, input: &str) -> bool;
|
|
}
|
|
/// ContainerName and ContainerImage are simple structs, used so can implement custom fmt functions to them
|
|
macro_rules! unit_struct {
|
|
($name:ident) => {
|
|
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord)]
|
|
pub struct $name(String);
|
|
|
|
impl From<String> for $name {
|
|
fn from(value: String) -> Self {
|
|
Self(value)
|
|
}
|
|
}
|
|
|
|
#[cfg(test)]
|
|
impl From<&str> for $name {
|
|
fn from(value: &str) -> Self {
|
|
Self(value.to_owned())
|
|
}
|
|
}
|
|
|
|
impl $name {
|
|
#[cfg(target_os = "macos")]
|
|
#[allow(clippy::missing_const_for_fn)]
|
|
// TODO remove this once zigbuild uses Rust v1.87.0
|
|
pub fn get(&self) -> &str {
|
|
self.0.as_str()
|
|
}
|
|
|
|
#[cfg(not(target_os = "macos"))]
|
|
pub const fn get(&self) -> &str {
|
|
self.0.as_str()
|
|
}
|
|
|
|
pub fn set(&mut self, value: String) {
|
|
self.0 = value;
|
|
}
|
|
}
|
|
|
|
impl Contains for $name {
|
|
fn contains(&self, input: &str) -> bool {
|
|
self.0.to_lowercase().contains(input)
|
|
}
|
|
}
|
|
|
|
impl std::fmt::Display for $name {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
|
|
if self.0.chars().count() >= 30 {
|
|
write!(f, "{}…", self.0.chars().take(29).collect::<String>())
|
|
} else {
|
|
write!(f, "{}", self.0)
|
|
}
|
|
}
|
|
}
|
|
};
|
|
}
|
|
|
|
unit_struct!(ContainerName);
|
|
unit_struct!(ContainerImage);
|
|
|
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
|
pub struct ContainerPorts {
|
|
pub ip: Option<IpAddr>,
|
|
pub private: u16,
|
|
pub public: Option<u16>,
|
|
}
|
|
|
|
impl From<Port> for ContainerPorts {
|
|
fn from(value: Port) -> Self {
|
|
Self {
|
|
ip: value.ip.and_then(|i| i.parse::<IpAddr>().ok()),
|
|
private: value.private_port,
|
|
public: value.public_port,
|
|
}
|
|
}
|
|
}
|
|
|
|
impl ContainerPorts {
|
|
pub fn len_ip(&self) -> usize {
|
|
self.ip
|
|
.as_ref()
|
|
.map_or(0, |i| i.to_string().chars().count())
|
|
}
|
|
pub fn len_private(&self) -> usize {
|
|
format!("{}", self.private).chars().count()
|
|
}
|
|
pub fn len_public(&self) -> usize {
|
|
format!("{}", self.public.unwrap_or_default())
|
|
.chars()
|
|
.count()
|
|
}
|
|
|
|
/// Return as tuple of Strings, ip address, private port, and public port
|
|
pub fn get_all(&self) -> (String, String, String) {
|
|
(
|
|
self.ip
|
|
.as_ref()
|
|
.map_or(String::new(), std::string::ToString::to_string),
|
|
format!("{}", self.private),
|
|
self.public.map_or(String::new(), |s| s.to_string()),
|
|
)
|
|
}
|
|
}
|
|
|
|
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
pub struct StatefulList<T> {
|
|
pub state: ListState,
|
|
pub items: Vec<T>,
|
|
}
|
|
|
|
impl<T> StatefulList<T> {
|
|
pub fn new(items: Vec<T>) -> Self {
|
|
Self {
|
|
state: ListState::default(),
|
|
items,
|
|
}
|
|
}
|
|
|
|
pub fn end(&mut self) {
|
|
let len = self.items.len();
|
|
if len > 0 {
|
|
self.state.select(Some(self.items.len() - 1));
|
|
}
|
|
}
|
|
|
|
pub fn start(&mut self) {
|
|
self.state.select(Some(0));
|
|
}
|
|
|
|
pub fn next(&mut self) {
|
|
if !self.items.is_empty() {
|
|
self.state.select(Some(
|
|
self.state.selected().map_or(
|
|
0,
|
|
|i| {
|
|
if i < self.items.len() - 1 { i + 1 } else { i }
|
|
},
|
|
),
|
|
));
|
|
}
|
|
}
|
|
|
|
pub fn previous(&mut self) {
|
|
if !self.items.is_empty() {
|
|
self.state.select(Some(
|
|
self.state
|
|
.selected()
|
|
.map_or(0, |i| if i == 0 { 0 } else { i - 1 }),
|
|
));
|
|
}
|
|
}
|
|
|
|
/// Return the current status of the select list, e.g. 2/5,
|
|
pub fn get_state_title(&self) -> String {
|
|
if self.items.is_empty() {
|
|
String::new()
|
|
} else {
|
|
let len = self.items.len();
|
|
let count = self
|
|
.state
|
|
.selected()
|
|
.map_or(0, |value| if len > 0 { value + 1 } else { value });
|
|
format!(" {count}/{len}")
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Store the containers status in a struct, so can then check for healthy/unhealthy status
|
|
/// It's usually something like "Up 1 hour", "Exited (0) 10 hours ago", "Up 10 minutes (unhealthy)"
|
|
#[derive(Debug, Clone, Eq, PartialEq, PartialOrd)]
|
|
pub struct ContainerStatus(String);
|
|
|
|
impl From<String> for ContainerStatus {
|
|
fn from(value: String) -> Self {
|
|
Self(value)
|
|
}
|
|
}
|
|
|
|
impl ContainerStatus {
|
|
/// Check if a container is unhealthy
|
|
pub fn unhealthy(&self) -> bool {
|
|
self.contains("(unhealthy)")
|
|
}
|
|
|
|
/// Get a reference to the source string
|
|
pub const fn get(&self) -> &String {
|
|
&self.0
|
|
}
|
|
}
|
|
|
|
impl Contains for ContainerStatus {
|
|
/// Check if the state contains a specific string
|
|
fn contains(&self, item: &str) -> bool {
|
|
self.0.to_lowercase().contains(item)
|
|
}
|
|
}
|
|
|
|
/// By default a container's running status will be healthy
|
|
#[derive(Debug, Clone, Copy, Eq, PartialEq, PartialOrd)]
|
|
pub enum RunningState {
|
|
Healthy,
|
|
Unhealthy,
|
|
}
|
|
/// States of the container
|
|
#[derive(Debug, Clone, Copy, Eq, PartialEq)]
|
|
pub enum State {
|
|
Dead,
|
|
Exited,
|
|
Paused,
|
|
Removing,
|
|
Restarting,
|
|
Running(RunningState),
|
|
Unknown,
|
|
}
|
|
|
|
impl State {
|
|
/// The container is alive if the start is Running, either healthy or unhealthy
|
|
pub const fn is_alive(self) -> bool {
|
|
matches!(self, Self::Running(_))
|
|
}
|
|
|
|
/// Check if state is running & healthy
|
|
pub const fn is_healthy(self) -> bool {
|
|
match self {
|
|
Self::Running(x) => match x {
|
|
RunningState::Healthy => true,
|
|
RunningState::Unhealthy => false,
|
|
},
|
|
_ => false,
|
|
}
|
|
}
|
|
/// Color of the state for the containers section
|
|
pub const fn get_color(self, colors: AppColors) -> Color {
|
|
match self {
|
|
Self::Dead => colors.container_state.dead,
|
|
Self::Exited => colors.container_state.exited,
|
|
Self::Paused => colors.container_state.paused,
|
|
Self::Removing => colors.container_state.removing,
|
|
Self::Restarting => colors.container_state.restarting,
|
|
Self::Running(RunningState::Healthy) => colors.container_state.running_healthy,
|
|
Self::Running(RunningState::Unhealthy) => colors.container_state.running_unhealthy,
|
|
Self::Unknown => colors.container_state.unknown,
|
|
}
|
|
}
|
|
/// Dirty way to create order for the state, rather than impl Ord
|
|
pub const fn order(self) -> u8 {
|
|
match self {
|
|
Self::Running(RunningState::Healthy) => 0,
|
|
Self::Running(RunningState::Unhealthy) => 1,
|
|
Self::Paused => 2,
|
|
Self::Restarting => 3,
|
|
Self::Removing => 4,
|
|
Self::Exited => 5,
|
|
Self::Dead => 6,
|
|
Self::Unknown => 7,
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Need status, to check if container is unhealthy or not
|
|
impl From<(&str, &ContainerStatus)> for State {
|
|
fn from((input, status): (&str, &ContainerStatus)) -> Self {
|
|
match input {
|
|
"dead" => Self::Dead,
|
|
"exited" => Self::Exited,
|
|
"paused" => Self::Paused,
|
|
"removing" => Self::Removing,
|
|
"restarting" => Self::Restarting,
|
|
"running" => {
|
|
if status.unhealthy() {
|
|
Self::Running(RunningState::Unhealthy)
|
|
} else {
|
|
Self::Running(RunningState::Healthy)
|
|
}
|
|
}
|
|
_ => Self::Unknown,
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Need status, to check if container is unhealthy or not
|
|
impl
|
|
From<(
|
|
&bollard::secret::ContainerSummaryStateEnum,
|
|
&ContainerStatus,
|
|
)> for State
|
|
{
|
|
fn from(
|
|
(input, status): (
|
|
&bollard::secret::ContainerSummaryStateEnum,
|
|
&ContainerStatus,
|
|
),
|
|
) -> Self {
|
|
match input {
|
|
bollard::secret::ContainerSummaryStateEnum::DEAD => Self::Dead,
|
|
bollard::secret::ContainerSummaryStateEnum::EXITED => Self::Exited,
|
|
bollard::secret::ContainerSummaryStateEnum::PAUSED => Self::Paused,
|
|
bollard::secret::ContainerSummaryStateEnum::REMOVING => Self::Removing,
|
|
bollard::secret::ContainerSummaryStateEnum::RESTARTING => Self::Restarting,
|
|
bollard::secret::ContainerSummaryStateEnum::RUNNING => {
|
|
if status.unhealthy() {
|
|
Self::Running(RunningState::Unhealthy)
|
|
} else {
|
|
Self::Running(RunningState::Healthy)
|
|
}
|
|
}
|
|
_ => Self::Unknown,
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Again, need status, to check if container is unhealthy or not
|
|
impl
|
|
From<(
|
|
Option<&bollard::secret::ContainerSummaryStateEnum>,
|
|
&ContainerStatus,
|
|
)> for State
|
|
{
|
|
fn from(
|
|
(input, status): (
|
|
Option<&bollard::secret::ContainerSummaryStateEnum>,
|
|
&ContainerStatus,
|
|
),
|
|
) -> Self {
|
|
input.map_or(Self::Unknown, |input| Self::from((input, status)))
|
|
}
|
|
}
|
|
|
|
/// Again, need status, to check if container is unhealthy or not
|
|
impl From<(Option<String>, &ContainerStatus)> for State {
|
|
fn from((input, status): (Option<String>, &ContainerStatus)) -> Self {
|
|
input.map_or(Self::Unknown, |input| Self::from((input.as_str(), status)))
|
|
}
|
|
}
|
|
|
|
impl fmt::Display for State {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
let disp = match self {
|
|
Self::Dead => "✖ dead",
|
|
Self::Exited => "✖ exited",
|
|
Self::Paused => "॥ paused",
|
|
Self::Removing => "removing",
|
|
Self::Restarting => "↻ restarting",
|
|
Self::Running(RunningState::Healthy) => "✓ running",
|
|
Self::Running(RunningState::Unhealthy) => "! running",
|
|
Self::Unknown => "? unknown",
|
|
};
|
|
write!(f, "{disp}")
|
|
}
|
|
}
|
|
|
|
/// Items for the container control list
|
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
|
pub enum DockerCommand {
|
|
Pause,
|
|
Restart,
|
|
Start,
|
|
Stop,
|
|
Resume,
|
|
Delete,
|
|
}
|
|
|
|
impl DockerCommand {
|
|
pub const fn get_color(self, colors: AppColors) -> Color {
|
|
match self {
|
|
Self::Pause => colors.commands.pause,
|
|
Self::Restart => colors.commands.restart,
|
|
Self::Start => colors.commands.start,
|
|
Self::Stop => colors.commands.stop,
|
|
Self::Delete => colors.commands.delete,
|
|
Self::Resume => colors.commands.resume,
|
|
}
|
|
}
|
|
|
|
/// Docker commands available depending on the containers state
|
|
pub fn gen_vec(state: State) -> Vec<Self> {
|
|
match state {
|
|
State::Dead | State::Exited => vec![Self::Start, Self::Restart, Self::Delete],
|
|
State::Paused => vec![Self::Resume, Self::Stop, Self::Delete],
|
|
State::Restarting => vec![Self::Stop, Self::Delete],
|
|
State::Running(_) => vec![Self::Pause, Self::Restart, Self::Stop, Self::Delete],
|
|
_ => vec![Self::Delete],
|
|
}
|
|
}
|
|
}
|
|
|
|
impl fmt::Display for DockerCommand {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
let disp = match self {
|
|
Self::Pause => "pause",
|
|
Self::Delete => "delete",
|
|
Self::Restart => "restart",
|
|
Self::Start => "start",
|
|
Self::Stop => "stop",
|
|
Self::Resume => "resume",
|
|
};
|
|
write!(f, "{disp}")
|
|
}
|
|
}
|
|
|
|
pub trait Stats {
|
|
fn get_value(&self) -> f64;
|
|
}
|
|
|
|
/// Struct for frequently updated CPU stats
|
|
/// So can use custom display formatter
|
|
/// Use trait Stats for use as generic in draw_chart function
|
|
#[derive(Debug, Default, Clone, Copy)]
|
|
pub struct CpuStats(f64);
|
|
|
|
impl CpuStats {
|
|
pub const fn new(value: f64) -> Self {
|
|
Self(value)
|
|
}
|
|
}
|
|
|
|
impl Eq for CpuStats {}
|
|
|
|
impl PartialEq for CpuStats {
|
|
fn eq(&self, other: &Self) -> bool {
|
|
self.0 == other.0
|
|
}
|
|
}
|
|
|
|
impl PartialOrd for CpuStats {
|
|
fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
|
|
Some(self.cmp(other))
|
|
}
|
|
}
|
|
|
|
impl Ord for CpuStats {
|
|
fn cmp(&self, other: &Self) -> Ordering {
|
|
if self.0 > other.0 {
|
|
Ordering::Greater
|
|
} else if (self.0 - other.0).abs() < 0.01 {
|
|
Ordering::Equal
|
|
} else {
|
|
Ordering::Less
|
|
}
|
|
}
|
|
}
|
|
|
|
impl Stats for CpuStats {
|
|
fn get_value(&self) -> f64 {
|
|
self.0
|
|
}
|
|
}
|
|
|
|
impl fmt::Display for CpuStats {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
let disp = format!("{:05.2}%", self.0);
|
|
write!(f, "{disp:>x$}", x = f.width().unwrap_or(1))
|
|
}
|
|
}
|
|
|
|
/// Struct for frequently updated memory usage stats
|
|
/// So can use custom display formatter
|
|
/// Use trait Stats for use as generic in draw_chart function
|
|
#[derive(Debug, Default, Clone, Copy, Eq)]
|
|
pub struct ByteStats(u64);
|
|
|
|
impl PartialEq for ByteStats {
|
|
fn eq(&self, other: &Self) -> bool {
|
|
self.0 == other.0
|
|
}
|
|
}
|
|
|
|
impl PartialOrd for ByteStats {
|
|
fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
|
|
Some(self.cmp(other))
|
|
}
|
|
}
|
|
|
|
impl Ord for ByteStats {
|
|
fn cmp(&self, other: &Self) -> Ordering {
|
|
self.0.cmp(&other.0)
|
|
}
|
|
}
|
|
|
|
impl ByteStats {
|
|
pub const fn new(value: u64) -> Self {
|
|
Self(value)
|
|
}
|
|
pub const fn update(&mut self, value: u64) {
|
|
self.0 = value;
|
|
}
|
|
}
|
|
|
|
#[allow(clippy::cast_precision_loss)]
|
|
impl Stats for ByteStats {
|
|
fn get_value(&self) -> f64 {
|
|
self.0 as f64
|
|
}
|
|
}
|
|
|
|
/// convert from bytes to kB, MB, GB etc
|
|
impl fmt::Display for ByteStats {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
let as_f64 = self.get_value();
|
|
let p = match as_f64 {
|
|
x if x >= ONE_GB => format!("{y:.2} GB", y = as_f64 / ONE_GB),
|
|
x if x >= ONE_MB => format!("{y:.2} MB", y = as_f64 / ONE_MB),
|
|
_ => format!("{y:.2} kB", y = as_f64 / ONE_KB),
|
|
};
|
|
write!(f, "{p:>x$}", x = f.width().unwrap_or(1))
|
|
}
|
|
}
|
|
|
|
pub type MemTuple = (Vec<(f64, f64)>, ByteStats, State);
|
|
pub type CpuTuple = (Vec<(f64, f64)>, CpuStats, State);
|
|
|
|
/// Used to make sure that each log entry, for each container, is unique,
|
|
/// will only push a log entry into the logs vec if timestamp of said log entry isn't in the hashset
|
|
#[derive(Debug, Clone, Hash, PartialEq, Eq)]
|
|
pub struct LogsTz(String);
|
|
|
|
impl fmt::Display for LogsTz {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
write!(f, "{}", self.0)
|
|
}
|
|
}
|
|
|
|
impl LogsTz {
|
|
/// With a given &str, split into a logtz and content, so that we only need to `use split_once()` once
|
|
/// The docker log, which should always contain a timestamp, is in the format `2023-01-14T19:13:30.783138328Z Lorem ipsum dolor sit amet`
|
|
pub fn splitter(input: &str) -> (Self, String) {
|
|
let (tz, content) = input.split_once(' ').unwrap_or_default();
|
|
(Self(tz.to_owned()), content.to_owned())
|
|
}
|
|
|
|
/// Display the timestamp in a given format, and if provided, with a timezone offset
|
|
pub fn display_with_formatter(&self, tz: Option<&TimeZone>, format: &str) -> Option<String> {
|
|
self.0.parse::<Timestamp>().map_or(None, |t| {
|
|
if let Some(tz) = tz.as_ref() {
|
|
let tz = tz.iana_name()?;
|
|
let z = t.in_tz(tz).ok()?;
|
|
Some(z.strftime(format).to_string())
|
|
} else {
|
|
Some(t.strftime(format).to_string())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
/// Store the logs alongside a HashSet, each log *should* generate a unique timestamp,
|
|
/// so if we store the timestamp separately in a HashSet, we can then check if we should insert a log line into the
|
|
/// stateful list dependent on whether the timestamp is in the HashSet or not
|
|
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
pub struct Logs {
|
|
logs: StatefulList<ListItem<'static>>,
|
|
tz: HashSet<LogsTz>,
|
|
}
|
|
|
|
impl Default for Logs {
|
|
fn default() -> Self {
|
|
let mut logs = StatefulList::new(vec![]);
|
|
logs.end();
|
|
Self {
|
|
logs,
|
|
tz: HashSet::new(),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl Logs {
|
|
/// Only allow a new log line to be inserted if the log timestamp isn't in the tz HashSet
|
|
pub fn insert(&mut self, line: ListItem<'static>, tz: LogsTz) {
|
|
if self.tz.insert(tz) {
|
|
self.logs.items.push(line);
|
|
}
|
|
}
|
|
|
|
/// Get the logs vec, but instead of cloning to whole vec, only clone items with x of the currently selected index
|
|
/// Where x is the abs different of the index plus the panel height & a padding
|
|
/// The rest can be just empty list items
|
|
pub fn to_vec(&self, height: usize, padding: usize) -> Vec<ListItem<'static>> {
|
|
let current_index = self.logs.state.selected().unwrap_or_default();
|
|
self.logs
|
|
.items
|
|
.iter()
|
|
.enumerate()
|
|
.map(|(index, item)| {
|
|
if current_index.abs_diff(index) <= height + padding {
|
|
item.clone()
|
|
} else {
|
|
ListItem::from("")
|
|
}
|
|
})
|
|
.collect()
|
|
}
|
|
/// The rest of the methods are basically forwarding from the underlying StatefulList
|
|
pub fn get_state_title(&self) -> String {
|
|
self.logs.get_state_title()
|
|
}
|
|
|
|
pub fn next(&mut self) {
|
|
self.logs.next();
|
|
}
|
|
|
|
pub fn previous(&mut self) {
|
|
self.logs.previous();
|
|
}
|
|
|
|
pub fn end(&mut self) {
|
|
self.logs.end();
|
|
}
|
|
pub fn start(&mut self) {
|
|
self.logs.start();
|
|
}
|
|
|
|
// TODO remove this once zigbuild uses Rust v1.87.0
|
|
#[cfg(target_os = "macos")]
|
|
#[allow(clippy::missing_const_for_fn)]
|
|
pub fn len(&self) -> usize {
|
|
self.logs.items.len()
|
|
}
|
|
|
|
#[cfg(not(target_os = "macos"))]
|
|
pub const fn len(&self) -> usize {
|
|
self.logs.items.len()
|
|
}
|
|
|
|
pub const fn state(&mut self) -> &mut ListState {
|
|
&mut self.logs.state
|
|
}
|
|
}
|
|
|
|
/// Info for each container
|
|
#[derive(Debug, Clone, PartialEq, Eq)]
|
|
pub struct ContainerItem {
|
|
pub cpu_stats: VecDeque<CpuStats>,
|
|
pub created: u64,
|
|
pub docker_controls: StatefulList<DockerCommand>,
|
|
pub id: ContainerId,
|
|
pub image: ContainerImage,
|
|
pub is_oxker: bool,
|
|
pub last_updated: u64,
|
|
pub logs: Logs,
|
|
pub mem_limit: ByteStats,
|
|
pub mem_stats: VecDeque<ByteStats>,
|
|
pub name: ContainerName,
|
|
pub ports: Vec<ContainerPorts>,
|
|
pub rx: ByteStats,
|
|
pub state: State,
|
|
pub status: ContainerStatus,
|
|
pub tx: ByteStats,
|
|
}
|
|
|
|
/// Basic display information, for when running in debug mode
|
|
impl fmt::Display for ContainerItem {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
write!(
|
|
f,
|
|
"{}, {}, {}, {}",
|
|
self.id.get_short(),
|
|
self.name,
|
|
self.cpu_stats.back().unwrap_or(&CpuStats::new(0.0)),
|
|
self.mem_stats.back().unwrap_or(&ByteStats::new(0))
|
|
)
|
|
}
|
|
}
|
|
|
|
impl ContainerItem {
|
|
#[allow(clippy::too_many_arguments)]
|
|
/// Create a new container item
|
|
pub fn new(
|
|
created: u64,
|
|
id: ContainerId,
|
|
image: String,
|
|
is_oxker: bool,
|
|
name: String,
|
|
ports: Vec<ContainerPorts>,
|
|
state: State,
|
|
status: ContainerStatus,
|
|
) -> Self {
|
|
let mut docker_controls = StatefulList::new(DockerCommand::gen_vec(state));
|
|
docker_controls.start();
|
|
|
|
Self {
|
|
cpu_stats: VecDeque::with_capacity(60),
|
|
created,
|
|
docker_controls,
|
|
id,
|
|
image: image.into(),
|
|
is_oxker,
|
|
last_updated: 0,
|
|
logs: Logs::default(),
|
|
mem_limit: ByteStats::default(),
|
|
mem_stats: VecDeque::with_capacity(60),
|
|
name: name.into(),
|
|
ports,
|
|
rx: ByteStats::default(),
|
|
state,
|
|
status,
|
|
tx: ByteStats::default(),
|
|
}
|
|
}
|
|
|
|
/// Find the max value in the cpu stats VecDeque
|
|
fn max_cpu_stats(&self) -> CpuStats {
|
|
self.cpu_stats
|
|
.iter()
|
|
.max()
|
|
.map_or_else(CpuStats::default, |value| *value)
|
|
}
|
|
|
|
/// Find the max value in the mem stats VecDeque
|
|
fn max_mem_stats(&self) -> ByteStats {
|
|
self.mem_stats
|
|
.iter()
|
|
.max()
|
|
.map_or_else(ByteStats::default, |value| *value)
|
|
}
|
|
|
|
/// Convert cpu stats into a vec for the charts function
|
|
#[allow(clippy::cast_precision_loss)]
|
|
fn get_cpu_dataset(&self) -> Vec<(f64, f64)> {
|
|
self.cpu_stats
|
|
.iter()
|
|
.enumerate()
|
|
.map(|i| (i.0 as f64, i.1.0))
|
|
.collect::<Vec<_>>()
|
|
}
|
|
|
|
/// Convert mem stats into a Vec for the charts function
|
|
#[allow(clippy::cast_precision_loss)]
|
|
fn get_mem_dataset(&self) -> Vec<(f64, f64)> {
|
|
self.mem_stats
|
|
.iter()
|
|
.enumerate()
|
|
.map(|i| (i.0 as f64, i.1.0 as f64))
|
|
.collect::<Vec<_>>()
|
|
}
|
|
|
|
/// Get all cpu chart data
|
|
fn get_cpu_chart_data(&self) -> CpuTuple {
|
|
(self.get_cpu_dataset(), self.max_cpu_stats(), self.state)
|
|
}
|
|
|
|
/// Get all mem chart data
|
|
fn get_mem_chart_data(&self) -> MemTuple {
|
|
(self.get_mem_dataset(), self.max_mem_stats(), self.state)
|
|
}
|
|
|
|
/// Get chart info for cpu & memory in one function
|
|
/// So only need to call .lock() once
|
|
pub fn get_chart_data(&self) -> (CpuTuple, MemTuple) {
|
|
(self.get_cpu_chart_data(), self.get_mem_chart_data())
|
|
}
|
|
}
|
|
|
|
/// Container information panel headings + widths, for nice pretty formatting
|
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
|
pub struct Columns {
|
|
pub name: (Header, u8),
|
|
pub state: (Header, u8),
|
|
pub status: (Header, u8),
|
|
pub cpu: (Header, u8),
|
|
pub mem: (Header, u8, u8),
|
|
pub id: (Header, u8),
|
|
pub image: (Header, u8),
|
|
pub net_rx: (Header, u8),
|
|
pub net_tx: (Header, u8),
|
|
}
|
|
|
|
impl Columns {
|
|
/// (Column titles, minimum header string length)
|
|
pub const fn new() -> Self {
|
|
Self {
|
|
name: (Header::Name, 4),
|
|
state: (Header::State, 5),
|
|
status: (Header::Status, 6),
|
|
cpu: (Header::Cpu, 3),
|
|
mem: (Header::Memory, 7, 7),
|
|
id: (Header::Id, 8),
|
|
image: (Header::Image, 5),
|
|
net_rx: (Header::Rx, 4),
|
|
net_tx: (Header::Tx, 4),
|
|
}
|
|
}
|
|
}
|
|
|
|
#[cfg(test)]
|
|
#[allow(clippy::unwrap_used)]
|
|
mod tests {
|
|
|
|
use jiff::tz::TimeZone;
|
|
use ratatui::widgets::ListItem;
|
|
|
|
use crate::{
|
|
app_data::{ContainerImage, Logs, LogsTz, RunningState},
|
|
ui::log_sanitizer,
|
|
};
|
|
|
|
use super::{ByteStats, ContainerName, ContainerStatus, CpuStats, State};
|
|
|
|
#[test]
|
|
/// Display CpuStats as a string
|
|
fn test_container_state_cpustats_to_string() {
|
|
let test = |f: f64, s: &str| {
|
|
assert_eq!(CpuStats::new(f).to_string(), s);
|
|
};
|
|
|
|
test(0.0, "00.00%");
|
|
test(1.5, "01.50%");
|
|
test(15.15, "15.15%");
|
|
test(150.15, "150.15%");
|
|
}
|
|
|
|
#[test]
|
|
/// Display bytestats as a string, convert into correct data unit (Kb, MB, GB)
|
|
fn test_container_state_bytestats_to_string() {
|
|
let test = |u: u64, s: &str| {
|
|
assert_eq!(ByteStats::new(u).to_string(), s);
|
|
};
|
|
|
|
test(0, "0.00 kB");
|
|
test(150, "0.15 kB");
|
|
test(1500, "1.50 kB");
|
|
test(150_000, "150.00 kB");
|
|
test(1_500_000, "1.50 MB");
|
|
test(15_000_000, "15.00 MB");
|
|
test(150_000_000, "150.00 MB");
|
|
test(1_500_000_000, "1.50 GB");
|
|
test(15_000_000_000, "15.00 GB");
|
|
test(150_000_000_000, "150.00 GB");
|
|
}
|
|
|
|
#[test]
|
|
/// ContainerName as string truncated correctly
|
|
fn test_container_state_container_name_to_string() {
|
|
let result = ContainerName::from("name_01");
|
|
assert_eq!(result.to_string(), "name_01");
|
|
|
|
let result = ContainerName::from("name_01_name_01_name_01_name_01_");
|
|
assert_eq!(result.to_string(), "name_01_name_01_name_01_name_…");
|
|
|
|
let result = result.get();
|
|
assert_eq!(result, "name_01_name_01_name_01_name_01_");
|
|
}
|
|
|
|
#[test]
|
|
/// ContainerImage as string truncated correctly
|
|
fn test_container_state_container_image() {
|
|
let result = ContainerImage::from("name_01");
|
|
assert_eq!(result.to_string(), "name_01");
|
|
|
|
let result = ContainerImage::from("name_01_name_01_name_01_name_01_");
|
|
assert_eq!(result.to_string(), "name_01_name_01_name_01_name_…");
|
|
|
|
let result = result.get();
|
|
assert_eq!(result, "name_01_name_01_name_01_name_01_");
|
|
}
|
|
|
|
#[test]
|
|
/// LogzTz correctly splits a line by timestamp
|
|
fn test_container_state_logz_splitter() {
|
|
let input = "2023-01-14T12:01:20.012345678Z Lorem ipsum dolor sit amet";
|
|
let log_tz = LogsTz::splitter(input);
|
|
|
|
assert_eq!(
|
|
log_tz.0,
|
|
super::LogsTz("2023-01-14T12:01:20.012345678Z".to_owned())
|
|
);
|
|
assert_eq!(log_tz.1, "Lorem ipsum dolor sit amet");
|
|
}
|
|
|
|
#[test]
|
|
/// LogsTz display correctly formats with a given timestamp string
|
|
fn test_container_state_logz_display() {
|
|
let input = "2023-01-14T12:01:20.012345678Z Lorem ipsum dolor sit amet";
|
|
let log_tz = LogsTz::splitter(input);
|
|
|
|
let result = log_tz
|
|
.0
|
|
.display_with_formatter(None, "%Y-%m-%dT%H:%M:%S.%8f");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
assert_eq!(result, "2023-01-14T12:01:20.01234567");
|
|
|
|
let result = log_tz.0.display_with_formatter(None, "%Y-%m-%d %H:%M:%S");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
assert_eq!(result, "2023-01-14 12:01:20");
|
|
|
|
let result = log_tz.0.display_with_formatter(None, "%Y-%j");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
|
|
assert_eq!(result, "2023-014");
|
|
}
|
|
|
|
#[test]
|
|
/// LogsTz display correctly formats with a given timestamp string & timezone
|
|
fn test_container_state_logz_display_with_timezone() {
|
|
let input = "2023-01-14T12:01:20.012345678Z Lorem ipsum dolor sit amet";
|
|
let log_tz = LogsTz::splitter(input);
|
|
|
|
let timezone = Some(TimeZone::get("Asia/Tokyo").unwrap());
|
|
let result = log_tz
|
|
.0
|
|
.display_with_formatter(timezone.as_ref(), "%Y-%m-%dT%H:%M:%S.%8f");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
assert_eq!(result, "2023-01-14T21:01:20.01234567");
|
|
|
|
let result = log_tz
|
|
.0
|
|
.display_with_formatter(timezone.as_ref(), "%Y-%m-%d %H:%M:%S");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
assert_eq!(result, "2023-01-14 21:01:20");
|
|
|
|
let result = log_tz.0.display_with_formatter(timezone.as_ref(), "%Y-%j");
|
|
assert!(result.is_some());
|
|
let result = result.unwrap();
|
|
assert_eq!(result, "2023-014");
|
|
}
|
|
|
|
#[test]
|
|
/// Logs can only contain 1 entry per LogzTz
|
|
fn test_container_state_logz() {
|
|
let input = "2023-01-14T19:13:30.783138328Z Lorem ipsum dolor sit amet";
|
|
let (tz, _) = LogsTz::splitter(input);
|
|
let mut logs = Logs::default();
|
|
let line = log_sanitizer::remove_ansi(input);
|
|
|
|
logs.insert(ListItem::new(line.clone()), tz.clone());
|
|
logs.insert(ListItem::new(line.clone()), tz.clone());
|
|
logs.insert(ListItem::new(line), tz);
|
|
|
|
assert_eq!(logs.logs.items.len(), 1);
|
|
|
|
let input = "2023-01-15T19:13:30.783138328Z Lorem ipsum dolor sit amet";
|
|
let (tz, _) = LogsTz::splitter(input);
|
|
let line = log_sanitizer::remove_ansi(input);
|
|
|
|
logs.insert(ListItem::new(line.clone()), tz.clone());
|
|
logs.insert(ListItem::new(line.clone()), tz.clone());
|
|
logs.insert(ListItem::new(line), tz);
|
|
|
|
assert_eq!(logs.logs.items.len(), 2);
|
|
}
|
|
|
|
#[test]
|
|
/// check ContainerStatus unhealthy state
|
|
fn test_container_state_unhealthy() {
|
|
let input = ContainerStatus::from("Up 1 hour".to_owned());
|
|
|
|
assert!(!input.unhealthy());
|
|
|
|
let input = ContainerStatus::from("Up 1 hour (unhealthy)".to_owned());
|
|
|
|
assert!(input.unhealthy());
|
|
}
|
|
|
|
#[test]
|
|
/// Generate container State from a &str and &ContainerStatus
|
|
fn test_container_status_unhealthy() {
|
|
let healthy = ContainerStatus::from("Up 1 hour".to_owned());
|
|
let unhealthy = ContainerStatus::from("Up 1 hour (unhealthy)".to_owned());
|
|
|
|
// Running and healthy
|
|
let input = State::from(("running", &healthy));
|
|
assert_eq!(input, State::Running(RunningState::Healthy));
|
|
|
|
// Running and unhealthy
|
|
let input = State::from(("running", &unhealthy));
|
|
assert_eq!(input, State::Running(RunningState::Unhealthy));
|
|
|
|
// Dead
|
|
let input = State::from(("dead", &healthy));
|
|
assert_eq!(input, State::Dead);
|
|
|
|
// Exited
|
|
let input = State::from(("exited", &healthy));
|
|
assert_eq!(input, State::Exited);
|
|
|
|
// Paused
|
|
let input = State::from(("paused", &healthy));
|
|
assert_eq!(input, State::Paused);
|
|
|
|
// Removing
|
|
let input = State::from(("removing", &healthy));
|
|
assert_eq!(input, State::Removing);
|
|
|
|
// Restarting
|
|
let input = State::from(("restarting", &healthy));
|
|
assert_eq!(input, State::Restarting);
|
|
|
|
// Unknown
|
|
let input = State::from(("oxker", &healthy));
|
|
assert_eq!(input, State::Unknown);
|
|
}
|
|
}
|