# everruns-sdk
Rust SDK for the Everruns API.
## Installation
\`\`\`bash
cargo add everruns-sdk
\`\`\`
## Quick Start
\`\`\`rust
use everruns_sdk::{CreateSessionRequest, Everruns};
#[tokio::main]
async fn main() -> Result<(), everruns_sdk::Error> {
// Uses EVERRUNS_API_KEY environment variable
let client = Everruns::from_env()?;
// Create an agent
let agent = client.agents().create(
"Assistant",
"You are a helpful assistant."
).await?;
// Create a session
let session = client
.sessions()
.create_with_options(CreateSessionRequest::new().agent_id(&agent.id))
.await?;
// Send a message
client.messages().create(&session.id, "Hello!").await?;
Ok(())
}
\`\`\`
## Initial Files
\`\`\`rust
use everruns_sdk::{CreateSessionRequest, InitialFile};
let session = client
.sessions()
.create_with_options(
CreateSessionRequest::new()
.agent_id(&agent.id)
.initial_files(vec![
InitialFile::new("/workspace/README.md", "# Demo Project\n")
.encoding("text")
.is_readonly(true),
InitialFile::new("/workspace/src/app.py", "print(\"hello\")\n")
.encoding("text"),
]),
)
.await?;
\`\`\`
Runnable example: [`examples/initial_files.rs`](examples/initial_files.rs)
## Authentication
The SDK uses API key authentication. Set the \`EVERRUNS_API_KEY\` environment variable or pass the key explicitly:
\`\`\`rust
// From environment variable
let client = Everruns::from_env()?;
// Explicit key
let client = Everruns::new("evr_...")?;
\`\`\`
## Streaming Events
The SDK supports SSE streaming with automatic reconnection:
\`\`\`rust
use futures::StreamExt;
use everruns_sdk::StreamOptions;
let stream = client.events().stream(
&session.id,
StreamOptions::default().exclude(vec!["output.message.delta".into()])
).await?;
while let Some(event) = stream.next().await {
match event?.event_type.as_str() {
"output.message.completed" => {
println!("Message: {:?}", event.data);
}
"turn.completed" => {
println!("Turn completed");
break;
}
"turn.failed" => {
eprintln!("Turn failed: {:?}", event.data);
break;
}
_ => {}
}
}
\`\`\`
## Error Handling
\`\`\`rust
use everruns_sdk::Error;
match client.agents().get("invalid-id").await {
Ok(agent) => println!("Agent: {:?}", agent),
Err(Error::Authentication(_)) => eprintln!("Invalid API key"),
Err(Error::NotFound(_)) => eprintln!("Agent not found"),
Err(Error::RateLimit { retry_after }) => {
eprintln!("Rate limited, retry after {:?}", retry_after);
}
Err(e) => eprintln!("Error: {}", e),
}
\`\`\`
## License
MIT