paladin-ai-core 0.4.2

Pure domain types for the Paladin framework — zero infrastructure dependencies
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

//! Orchestration context for workflow sessions.
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use uuid::Uuid;

/// Orchestrator execution context.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct OrchestrationContext {
    /// Unique identifier for the orchestration session
    pub session_id: Uuid,
    /// User or system that initiated the orchestration
    pub initiator: String,
    /// Environment context (dev, staging, prod)
    pub environment: String,
    /// Correlation ID for tracking related operations
    pub correlation_id: Option<Uuid>,
    /// Session metadata
    pub metadata: HashMap<String, serde_json::Value>,
    /// Session start time
    pub started_at: DateTime<Utc>,
}

impl OrchestrationContext {
    /// Create a new orchestration context.
    pub fn new(initiator: String, environment: String) -> Self {
        Self {
            session_id: Uuid::new_v4(),
            initiator,
            environment,
            correlation_id: None,
            metadata: HashMap::new(),
            started_at: Utc::now(),
        }
    }

    /// Set the correlation ID.
    pub fn with_correlation(mut self, correlation_id: Uuid) -> Self {
        self.correlation_id = Some(correlation_id);
        self
    }

    /// Add typed metadata to the context.
    pub fn add_metadata<T: Serialize>(
        &mut self,
        key: String,
        value: T,
    ) -> Result<(), serde_json::Error> {
        let json_value = serde_json::to_value(value)?;
        self.metadata.insert(key, json_value);
        Ok(())
    }
}