holon 0.14.1

A headless, event-driven runtime for long-lived agents
Documentation 
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

use anyhow::Result;
use async_trait::async_trait;
use tokio::io::AsyncRead;

use super::{
    types::{RunningProcessExitStatus, StopSignal},
    EffectiveExecution, ProcessRequest, ProcessResult,
};

pub trait ProcessOutput: AsyncRead + Unpin + Send {}

impl<T> ProcessOutput for T where T: AsyncRead + Unpin + Send {}

#[async_trait]
pub trait RunningProcess: Send {
    fn id(&self) -> String;
    fn take_stdout(&mut self) -> Option<Box<dyn ProcessOutput>>;
    fn take_stderr(&mut self) -> Option<Box<dyn ProcessOutput>>;
    async fn write_stdin(&mut self, data: &[u8]) -> Result<()>;
    async fn wait(&mut self) -> Result<RunningProcessExitStatus>;
    async fn try_status(&mut self) -> Result<Option<RunningProcessExitStatus>>;
    async fn stop(&mut self, signal: StopSignal) -> Result<()>;
}

#[async_trait]
pub trait ProcessHost: Send + Sync {
    async fn run(
        &self,
        execution: &EffectiveExecution,
        req: ProcessRequest,
    ) -> Result<ProcessResult>;
    async fn spawn(
        &self,
        execution: &EffectiveExecution,
        req: ProcessRequest,
    ) -> Result<Box<dyn RunningProcess>>;
}