kcode-kennedy-orchestration 0.3.3

Typed orchestration and session-control runtime for Kennedy
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

#![forbid(unsafe_code)]

mod prompts;
mod services;
mod worker;

use std::sync::Arc;

pub use kcode_kennedy_sessions::{
    AgentMode, RuntimeModel, Service as SessionService, Session, TurnDeadline, TurnDeadlineKind,
};
pub use kcode_kennedy_stepped_turn_runtime::{
    ControlSignal, DriveFailure, Mailbox, MailboxSender, PendingTurnAdmission, ProcessedAdmission,
    QueuedAdmission, TurnExit,
};
pub use prompts::Manuals;
pub use services::{Api, ApiError, LocalServices, data_url, telegram_caption_for};
pub use worker::{Orchestrator, SessionRuntime, TurnCompletion, persist_record};

#[derive(Clone, Debug)]
pub struct Config {
    pub user_root_node_id: String,
    pub kennedy_root_node_id: String,
    pub telegram_max_media_bytes: usize,
    pub runtime_model: RuntimeModel,
}

pub fn build(config: Config, api: Api, sessions: SessionService) -> Arc<Orchestrator> {
    Arc::new(Orchestrator::new(config, api, sessions))
}

pub async fn run(worker: Arc<Orchestrator>) -> anyhow::Result<()> {
    worker.run().await
}