Struct arpx::LogMonitor

pub struct LogMonitor {
    pub buffer: RollingBuffer,
    pub buffer_size: usize,
    pub ctx: Ctx,
    pub name: String,
    pub ontrigger: String,
    pub test: String,
}

Represents and contains a given runtime job task log monitor.

This object contains all of the data necessary to run a given log monitor. This data includes the log monitor name, the size of its rolling buffer, the rolling buffer instance itself, the test command which should be executed on each push to the buffer, and the ontrigger action which should run if test returns with a 0 exit code.

Fields

buffer: RollingBuffer

buffer_size: usize

ctx: Ctx

name: String

ontrigger: String

test: String

Implementations

impl LogMonitor

pub fn new(name: String) -> Self

Constructs a new, empty LogMonitor.

pub fn buffer_size(self, b: usize) -> Self

Builds LogMonitor with the specified rolling buffer size.

pub fn ontrigger(self, o: String) -> Self

Builds LogMonitor with the name of the action to execute if the test succeeds.

pub fn test(self, t: String) -> Self

Builds LogMonitor with the specified test.

pub fn run(
    self,
    ontrigger: Option<Box<dyn Fn() + Send>>
) -> Result<(JoinHandle<()>, Sender<LogMonitorMessage>)>

Executes the log monitor using the provided action.

pub fn push(&mut self, line: String, ontrigger: &Option<Box<dyn Fn() + Send>>)

Pushes a line of text to the rolling buffer and executes the test command on the new buffer state.

pub fn exec_test(&self, ontrigger: &Option<Box<dyn Fn() + Send>>) -> Result<()>

Executes the current test command and, if successful, performs the ontrigger action.

Trait Implementations

impl Clone for LogMonitor

fn clone(&self) -> LogMonitor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LogMonitor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.