kaish-kernel 0.8.0

Core kernel for kaish: lexer, parser, interpreter, and runtime
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
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

//! Scheduler module for kaish — pipelines, background jobs, and scatter/gather.
//!
//! This module provides:
//! - **Pipeline execution**: Run commands connected by pipes, where stdout
//!   of one command flows to stdin of the next.
//! - **Background jobs**: Run commands in the background with `&`, track them,
//!   and wait for completion.
//! - **Scatter/Gather**: Parallel fan-out and collection for pipelines.
//!
//! # Architecture
//!
//! ```text
//! ┌─────────────────────────────────────────────────────────────┐
//! │                     PipelineRunner                          │
//! │  ┌─────────┐   channel   ┌─────────┐   channel   ┌────────┐│
//! │  │ cmd1    │────────────▶│ cmd2    │────────────▶│ cmd3   ││
//! │  │ (spawn) │   stdout    │ (spawn) │   stdout    │ (spawn)││
//! │  └─────────┘             └─────────┘             └────────┘│
//! └─────────────────────────────────────────────────────────────┘
//!
//! ┌─────────────────────────────────────────────────────────────┐
//! │                    ScatterGatherRunner                        │
//! │  ┌────────────┐         ┌─────────────────────────┐        │
//! │  │ pre_scatter│────────▶│  scatter (fan-out)      │        │
//! │  └────────────┘         │  ┌───┐ ┌───┐ ┌───┐      │        │
//! │                         │  │ 1 │ │ 2 │ │ 3 │ ...  │        │
//! │                         │  └───┘ └───┘ └───┘      │        │
//! │                         │         │               │        │
//! │                         │         ▼               │        │
//! │                         │  gather (collect)       │        │
//! │                         └─────────────────────────┘        │
//! │                                    │                       │
//! │                                    ▼                       │
//! │                         ┌────────────┐                     │
//! │                         │ post_gather│                     │
//! │                         └────────────┘                     │
//! └─────────────────────────────────────────────────────────────┘
//!
//! ┌─────────────────────────────────────────────────────────────┐
//! │                      JobManager                             │
//! │  jobs: HashMap<JobId, Job>                                  │
//! │  - spawn(pipeline) → JobId                                  │
//! │  - wait(JobId) → ExecResult                                 │
//! │  - wait_all() → Vec<ExecResult>                             │
//! │  - list() → Vec<JobInfo>                                    │
//! └─────────────────────────────────────────────────────────────┘
//! ```

mod job;
mod pipe_stream;
pub(crate) mod pipeline;
mod scatter;
mod stderr_stream;
mod stream;

pub use job::{Job, JobId, JobInfo, JobManager, JobStatus};
pub use pipe_stream::{pipe_stream, pipe_stream_default, PipeReader, PipeWriter, PIPE_BUFFER_SIZE};
pub use stderr_stream::{stderr_stream, StderrReceiver, StderrStream};
pub use stream::{drain_to_stream, BoundedStream, StreamStats, DEFAULT_STREAM_MAX_SIZE};
pub use pipeline::{build_tool_args, is_bool_type, schema_param_lookup, select_leaf, PipelineRunner};
pub use scatter::{
    extract_items, parse_gather_options, parse_scatter_options, GatherOptions,
    ScatterGatherRunner, ScatterOptions, ScatterResult,
};