synwire-core 0.1.0

Core traits and types for the Synwire AI framework
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

//! Runnable configuration.

use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::collections::HashMap;
use std::sync::Arc;
use uuid::Uuid;

/// Configuration passed through a runnable chain.
#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct RunnableConfig {
    /// Tags for filtering and categorization.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub tags: Option<Vec<String>>,
    /// Metadata key-value pairs.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub metadata: Option<HashMap<String, Value>>,
    /// Maximum concurrency for batch operations.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub max_concurrency: Option<usize>,
    /// Name for this run.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub run_name: Option<String>,
    /// Unique identifier for this run.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub run_id: Option<Uuid>,
    /// Configurable key-value pairs.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub configurable: Option<HashMap<String, Value>>,
    /// Callback handlers (not serialized).
    #[serde(skip)]
    pub callbacks: Option<Vec<Arc<dyn CallbackHandlerDyn>>>,
    /// Tracing configuration (only available with the `tracing` feature).
    #[cfg(feature = "tracing")]
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub tracing_config: Option<crate::observability::TracingConfig>,
}

/// Marker trait for callback handlers (placeholder until callbacks module exists).
pub trait CallbackHandlerDyn: Send + Sync + std::fmt::Debug {}