llm-optimizer-processor 0.1.1

Data processing and transformation pipeline
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

//! Decision Engine error types

use thiserror::Error;

/// Result type for Decision Engine operations
pub type DecisionResult<T> = Result<T, DecisionError>;

/// Error types for the Decision Engine
#[derive(Error, Debug, Clone, PartialEq)]
pub enum DecisionError {
    /// Strategy not found
    #[error("Strategy not found: {0}")]
    StrategyNotFound(String),

    /// Invalid decision criteria
    #[error("Invalid decision criteria: {0}")]
    InvalidCriteria(String),

    /// Decision validation failed
    #[error("Decision validation failed: {0}")]
    ValidationFailed(String),

    /// Insufficient data for decision
    #[error("Insufficient data: {0}")]
    InsufficientData(String),

    /// Constraint violation
    #[error("Constraint violation: {0}")]
    ConstraintViolation(String),

    /// Configuration error
    #[error("Configuration error: {0}")]
    ConfigError(String),

    /// Execution error
    #[error("Execution error: {0}")]
    ExecutionError(String),

    /// Rollback failed
    #[error("Rollback failed: {0}")]
    RollbackFailed(String),

    /// Strategy conflict
    #[error("Strategy conflict: {0}")]
    StrategyConflict(String),

    /// Timeout
    #[error("Decision timeout after {0}ms")]
    Timeout(u64),

    /// Not running
    #[error("Decision engine is not running")]
    NotRunning,

    /// Invalid state transition
    #[error("Invalid state transition from {from:?} to {to:?}")]
    InvalidStateTransition {
        from: DecisionState,
        to: DecisionState,
    },

    /// Internal error
    #[error("Internal error: {0}")]
    Internal(String),
}

/// Decision Engine state
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub enum DecisionState {
    /// Initialized but not started
    Initialized,
    /// Starting up
    Starting,
    /// Running and processing decisions
    Running,
    /// Draining before shutdown
    Draining,
    /// Stopped
    Stopped,
    /// Failed state
    Failed,
}

impl DecisionState {
    /// Check if the state allows processing decisions
    pub fn can_process(&self) -> bool {
        matches!(self, DecisionState::Running)
    }

    /// Check if transition to another state is valid
    pub fn can_transition_to(&self, to: DecisionState) -> bool {
        use DecisionState::*;
        matches!(
            (self, to),
            (Initialized, Starting)
                | (Starting, Running)
                | (Starting, Failed)
                | (Running, Draining)
                | (Running, Failed)
                | (Draining, Stopped)
                | (Draining, Failed)
                | (Failed, Initialized)
        )
    }
}