kowalski-core 1.2.0

Kowalski Core Module: A Rust-based agent for interacting with Ollama models
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

use thiserror::Error;

#[derive(Error, Debug)]
pub enum KowalskiError {
    #[error("Tool execution error: {0}")]
    ToolExecution(String),

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

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

    #[error("Content processing error: {0}")]
    ContentProcessing(String),

    #[error("Invalid input: {0}")]
    ToolInvalidInput(String),

    #[error("Resource not found: {0}")]
    NotFound(String),

    #[error("Permission denied: {0}")]
    PermissionDenied(String),

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

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

    #[error("IO error: {0}")]
    Io(#[from] std::io::Error),

    #[error("JSON error: {0}")]
    Json(#[from] serde_json::Error),

    #[error("URL error: {0}")]
    Url(#[from] url::ParseError),

    #[error("Config error: {0}")]
    Config(#[from] config::ConfigError),

    #[error("Template agent error: {0}")]
    TemplateAgent(String),

    #[error("Web agent error: {0}")]
    WebAgent(String),

    #[error("Academic agent error: {0}")]
    AcademicAgent(String),

    #[error("Tool chain error: {0}")]
    ToolChain(String),

    #[error("Task handler error: {0}")]
    TaskHandler(String),

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

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

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

    #[error("Rate limit error: {0}")]
    RateLimit(String),

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

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

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

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

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

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

    #[error("File system error: {0}")]
    FileSystem(String),

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

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

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

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

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

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

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

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

    #[error("Request error: {0}")]
    Request(#[from] reqwest::Error),

    #[error("Conversation not found: {0}")]
    ConversationNotFound(String),

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

    #[error("Network error: {0}")]
    ToolNetwork(String),

    #[error("Config error: {0}")]
    ToolConfig(String),

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

impl From<String> for KowalskiError {
    fn from(err: String) -> Self {
        KowalskiError::Agent(err)
    }
}

impl From<&str> for KowalskiError {
    fn from(err: &str) -> Self {
        KowalskiError::Agent(err.to_string())
    }
}