<p align="center">
<b>Secure, typed, async Rust SDK for OpenBao.</b><br>
Memory-safe by default. Minimal dependency surface. Built for audited secret workflows.
</p>
<div align="center">
<a href="https://openbao.org/">OpenBao</a>
·
<a href="docs/OPENBAO_API_COVERAGE.md">API Coverage</a>
·
<a href="docs/RELEASE_PLAN.md">Release Plan</a>
·
<a href="SECURITY.md">Security</a>
</div>
<br>
<p align="center">
<img src="https://raw.githubusercontent.com/valkyoth/openbao-rust-crate/main/.github/images/openbao_rust_crate.webp" alt="OpenBao Rust crate overview">
</p>
# OpenBao Rust SDK
`openbao` is a secure, typed, async Rust SDK for
[OpenBao](https://openbao.org/), the community-driven open source fork of
Vault. It is designed for audited secret workflows: HTTPS by default, no
redirect forwarding, strict path validation, secret-aware token types, and a
small reviewed dependency surface.
The crate name on crates.io is `openbao`; Rust imports are lowercase:
```rust
use openbao::Client;
```
This README documents the `0.5.0` release line. `0.5.0` builds on `0.4.0`
with Userpass auth, JWT auth, database secrets, and typed Transit signing/JWS
ergonomics.
The crate is dual-licensed under MIT or Apache-2.0.
## Current Status
Implemented now:
- Async client with typestate authentication.
- Direct token authentication with re-exported `openbao::SecretString`.
- AppRole login with secret-aware role ID, secret ID, token, and accessor
handling.
- Kubernetes auth login plus config and role administration helpers.
- TLS certificate auth login, method config, CA role, and CRL administration
helpers.
- JWT login plus JWT/OIDC auth method config and role administration helpers.
- Userpass login plus user create/read/list/delete, password update, and
policy update helpers.
- Token create, lookup, accessor lookup/list, renew, revoke, and revoke-self
helpers.
- KV v2 read, write, CAS write, patch, list, latest delete, version read,
version delete, undelete, destroy, metadata, backend config, typed data, and
secret-aware service config helpers.
- KV v1 read, write, delete, and list helpers.
- Database connection config, dynamic roles, static roles, root/static
rotation, and credential helpers.
- PKI URL and CRL config, root/intermediate generation, intermediate signing
and install, role write/read/list/delete, issue, sign, revoke, certificate
list/read, issuer/key list/read/delete/update, issuer revoke, CA/key import,
ACME config/EAB/directory URL, CRL rotate, and tidy helpers.
- Transit key create, read, list, delete, encrypt, decrypt, rewrap, data key,
random, hash, HMAC, sign, verify, typed RSA/JWS signing options, and
optional raw-byte helpers.
- System health, seal status, and loopback-only dev bootstrap helpers.
- Secret and auth mount enable, list, read, tune, and disable helpers.
- Response wrapping lookup, wrap, unwrap, and rewrap helpers.
- ACL policy list, read, write, delete, and prefix list helpers.
- Capability checks for the caller token, an explicit token, or a token
accessor.
- Audit device list, enable, disable, and hash helpers.
- Safe exact lease lookup, renew, and revoke helpers.
- Plugin catalog list, type-list, register, read, delete, and backend reload
helpers.
- Environment-based client construction from common OpenBao/Vault variables.
- Raw JSON request escape hatch for endpoints that are not typed yet.
- Local TLS OpenBao Podman stack on `9940` and `9941`.
- Real OpenBao integration test gate using the pinned OpenBao image.
Planned next:
- `0.6.0`: SSH, TOTP, and explicitly gated production init/unseal/rekey/rotate APIs.
- `0.7.0`: cubbyhole, identity, Kubernetes secrets, LDAP secrets, and
RabbitMQ.
- `0.8.0`: remaining auth methods and broader system backend automation.
See [API Coverage](docs/OPENBAO_API_COVERAGE.md) and
[Release Plan](docs/RELEASE_PLAN.md) for the road to `1.0.0`.
## Trust Dashboard
| License | `MIT OR Apache-2.0` |
| Rust edition | 2024 |
| MSRV | Rust `1.90.0` |
| Async runtime | Runtime-agnostic client; examples use Tokio |
| HTTP transport | `reqwest` with redirects disabled |
| Default TLS backend | Rustls |
| TLS floor | TLS 1.3 by default; TLS 1.2 requires explicit opt-in |
| Plain HTTP | Rejected by default; sensitive requests still require HTTPS |
| Token storage | `openbao::SecretString` (`secrecy::SecretString`) |
| Unsafe policy | `unsafe_code = "forbid"` |
| Path validation | Rejects traversal, query/fragment injection, empty segments, controls, and trailing periods |
| Error posture | API error strings are bounded and sanitized before formatting |
| Dependency policy | `cargo deny` plus RustSec audit in the release gate |
| Release evidence | fmt, clippy, tests, docs, deny, audit, SBOM, and real OpenBao integration |
| Pentest gate | Required before tagging a release |
Security details live in [SECURITY.md](SECURITY.md). Release evidence and
release sequencing live in [release-notes](release-notes) and
[docs/RELEASE_PLAN.md](docs/RELEASE_PLAN.md).
## Rust Version Support
The minimum supported Rust version is Rust `1.90.0`. New deployments should
prefer the latest stable Rust; as of May 30, 2026, that is Rust `1.96.0`.
The `0.5.0` release gate will refresh compatibility evidence across this
range before tagging:
| `1.90.0` | Full test suite and clippy. |
| `1.91.0` | `cargo check --all-features`. |
| `1.92.0` | `cargo check --all-features`. |
| `1.93.0` | `cargo check --all-features`. |
| `1.94.0` | `cargo check --all-features`. |
| `1.95.0` | `cargo check --all-features`. |
| `1.96.0` | `cargo check --all-features`. |
## Install
```toml
[dependencies]
openbao = "0.5"
serde = { version = "1.0.228", features = ["derive"] }
tokio = { version = "1.52.3", features = ["macros", "rt-multi-thread"] }
```
Some advanced examples below use JSON helper types directly:
```toml
[dependencies]
serde_json = "1.0.150"
```
The crate defaults to the common SDK surface:
```toml
[dependencies]
openbao = { version = "0.5", features = ["approle", "cert-auth", "database", "jwt-auth", "kubernetes-auth", "userpass", "token", "kv1", "kv2", "pki", "transit", "sys", "rustls-tls"] }
```
For a smaller build, disable defaults and opt into only what the application
uses:
```toml
[dependencies]
openbao = { version = "0.5", default-features = false, features = ["kv2", "sys", "rustls-tls"] }
```
## Features
| `approle` | yes | AppRole authentication helpers. |
| `cert-auth` | yes | TLS certificate auth login/config/role/CRL helpers. |
| `database` | yes | Database secrets engine config, role, credential, and rotation helpers. |
| `jwt-auth` | yes | JWT login plus JWT/OIDC config and role administration helpers. |
| `kubernetes-auth` | yes | Kubernetes auth login/config/role helpers. |
| `userpass` | yes | Userpass login and user administration helpers. |
| `token` | yes | Token lifecycle helpers. |
| `kv1` | yes | KV v1 secrets engine helpers. |
| `kv2` | yes | KV v2 secrets engine helpers. |
| `pki` | yes | PKI authority, issuer/key metadata/import, role, issue/sign, revoke, cert read/list, ACME config/EAB/directory URL, CRL config/rotate, and tidy helpers. |
| `transit` | yes | Transit cryptography helpers. |
| `transit-bytes` | no | Raw-byte Transit convenience helpers using `base64-ng` for OpenBao's base64 request/response fields. |
| `sys` | yes | System backend helpers. |
| `allow-sha1` | no | Explicit opt-in for legacy Transit SHA-1 selection. Disabled by default. |
| `rustls-tls` | yes | Rustls transport configuration. |
| `native-tls` | no | Legacy native TLS support. Requires `native-tls-acknowledged` after audit. |
| `native-tls-acknowledged` | no | Explicit acknowledgment for audited native TLS builds. |
## Support Matrix
### Client, Transport, And TLS
| Async client | Yes | Built on `reqwest` with a small public API surface. |
| Typestate auth | Yes | Separate unauthenticated and authenticated client states. |
| HTTPS by default | Yes | Plain HTTP is rejected unless loopback HTTP is explicitly enabled. |
| Redirect protection | Yes | Redirect following is disabled to avoid forwarding token headers. |
| Response size cap | Yes | 32 MiB default with per-client lowering for small-response workflows. |
| TLS floor | Yes | TLS 1.3 minimum by default; audited legacy deployments can opt down to TLS 1.2. |
| Custom CA roots | Yes | Extra root certificates can be merged with the platform trust store. |
| Root-only trust stores | Yes | System roots can be bypassed by using only configured root certificates. |
| Client TLS identity | Yes | Optional mutual TLS client identity for TLS certificate auth. |
| Connection timeout | Yes | 5-second connection timeout by default; caller overrides are bounded. |
| User agent fingerprinting | Yes | Default user agent omits the exact crate version. |
| Namespace header | Yes | `X-Vault-Namespace` support for namespace-aware deployments. |
| Environment construction | Yes | Reads `OPENBAO_*`, `BAO_*`, and `VAULT_*` aliases with secure defaults. |
| Raw JSON requests | Yes | Escape hatch for endpoints that are not typed yet. |
### Authentication
| Direct token auth | Yes | Tokens are accepted as `SecretString`. |
| `X-Vault-Token` | Yes | Default documented OpenBao-compatible token header. |
| Bearer auth | Yes | Optional `Authorization: Bearer` header mode. |
| AppRole login | Yes | Role ID and secret ID are secret-aware; returned token is wrapped. |
| Token accessor handling | Yes | Accessors are treated as secret material. |
| Token lifecycle helpers | Yes | Lookup, accessor lookup/list, renew, revoke, revoke-self, and create helpers. |
| Kubernetes auth | Yes | Login, auth method config, and role administration helpers. |
| TLS certificate auth | Yes | Login, auth method config, CA role administration, and CRL helpers. |
| JWT/OIDC | Yes | JWT login plus JWT/OIDC auth method config and role administration helpers. Browser OIDC callback helpers are still planned. |
| Userpass auth | Yes | Login and user create/read/list/delete, password update, and policy update helpers. |
### Secret Engines
| KV v2 read/write | Yes | Typed serialization and deserialization. |
| KV v2 CAS write | Yes | Optional check-and-set version support. |
| KV v2 patch | Yes | JSON merge patch content type. |
| KV v2 list/delete versions | Yes | Metadata list, latest delete, soft delete, undelete, and destroy. |
| KV v2 metadata/config | Yes | Backend, per-key metadata, typed data, and secret-aware service config helpers. |
| KV v1 | Yes | Read, write, delete, and list helpers. |
| Database credentials | Yes | Connection config/list/read/delete, dynamic roles/credentials, static roles/credentials, and root/static rotation helpers. |
| Transit | Yes | Key create/read/list/delete, encrypt, decrypt, rewrap, data key, random, hash, HMAC, sign, verify, typed RSA/JWS signing options, and optional raw-byte helpers. |
| PKI | Partial | Authority generation/signing/install, URL/CRL config, roles, issue, sign, revoke, certificate list/read, issuer/key list/read/delete/update, issuer revoke, CA/key import, ACME config/EAB/directory URL, CRL rotate, and tidy are implemented. |
| SSH and TOTP | Planned | Planned for `0.6.0`. |
| Identity and remaining engines | Planned | Planned for `0.7.0`. |
### System Backend And Operations
| Health | Yes | Accepts OpenBao active, standby, sealed, and uninitialized health statuses. |
| Init status | Yes | Typed `/sys/init` status helper. |
| Seal status | Yes | Typed `/sys/seal-status` helper. |
| Dev bootstrap | Yes | Fresh numeric-loopback dev instances only; not for production or HSM/KMS deployments. |
| Mount management | Yes | Secret and auth mount enable/list/read/tune/disable helpers. |
| Response wrapping | Yes | Lookup, wrap, unwrap, and rewrap helpers. |
| Policies and capabilities | Yes | ACL policy helpers plus self/token/accessor capability checks. |
| Audit devices | Yes | Enable, list, disable, and audit hash helpers. |
| Lease helpers | Yes | Safe exact lookup, renew, and revoke; prefix/force/tidy operations are intentionally not exposed. |
| Plugin catalog | Yes | List, type-list, register, read, delete, and mounted backend reload helpers. |
| Production init, unseal, rekey, rotate | Planned | Explicit safety documentation in `0.6.0`. |
| Quotas, metrics, namespaces | Planned | Planned in the `0.8.0` operations line. |
## Examples
Create a client from an existing token:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let health = client.sys().health().await?;
println!("openbao version: {}", health.version);
Ok(())
}
```
Create an authenticated client from environment variables:
```rust,no_run
use openbao::{Client, Result};
#[tokio::main]
async fn main() -> Result<()> {
// Reads OPENBAO_ADDR/BAO_ADDR/VAULT_ADDR plus token, namespace, and CA aliases.
let client = Client::from_env_with_token()?;
let health = client.sys().health().await?;
println!("openbao version: {}", health.version);
Ok(())
}
```
Configure a stricter client with a namespace and root-only trust store:
```rust,no_run
use openbao::{Client, OpenBaoConfig, Result};
use openbao::Certificate;
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let ca_pem = std::fs::read("openbao-ca.pem").map_err(|_| {
openbao::Error::InvalidTlsConfig(
"failed to read the configured CA certificate file".into(),
)
})?;
let ca = Certificate::from_pem(&ca_pem)?;
let config = OpenBaoConfig::new("https://bao.example.com:8200")?
.namespace("admin/team-a")?
.only_root_certificates(vec![ca])?;
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::from_config(config)?.try_with_token(token)?;
let seal = client.sys().seal_status().await?;
println!("sealed: {}", seal.sealed);
Ok(())
}
```
Authenticate with AppRole:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let client = Client::new("https://bao.example.com:8200")?;
let role_id = SecretString::from(std::env::var("APPROLE_ROLE_ID").unwrap_or_default());
let secret_id = SecretString::from(std::env::var("APPROLE_SECRET_ID").unwrap_or_default());
let (client, login) = client.login_approle(role_id, secret_id).await?;
let health = client.sys().health().await?;
let _token_accessor = login.accessor;
println!("openbao version: {}", health.version);
Ok(())
}
```
Authenticate with Userpass:
```rust,no_run
use openbao::{Client, Result, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let client = Client::new("https://bao.example.com:8200")?;
let password = SecretString::from(std::env::var("BAO_USERPASS_PASSWORD").unwrap_or_default());
let (client, login) = client.login_userpass("alice", password).await?;
let health = client.sys().health().await?;
let _token_accessor = login.accessor;
println!("openbao version: {}", health.version);
Ok(())
}
```
Authenticate with JWT:
```rust,no_run
use openbao::{Client, Result, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let client = Client::new("https://bao.example.com:8200")?;
let jwt = SecretString::from(std::env::var("SERVICE_JWT").unwrap_or_default());
let (client, login) = client.login_jwt(Some("web"), jwt).await?;
let health = client.sys().health().await?;
let _token_accessor = login.accessor;
println!("openbao version: {}", health.version);
Ok(())
}
```
Write and read KV v2 data:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
use serde::{Deserialize, Serialize};
#[derive(Deserialize, Serialize)]
struct DatabaseCredentials {
username: String,
password: SecretString,
}
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let kv = client.kv2("secret")?;
kv.write(
"production/database",
DatabaseCredentials {
username: "app".to_owned(),
password: SecretString::from("change-me"),
},
)
.await?;
let secret = kv
.read::<DatabaseCredentials>("production/database")
.await?;
let _username = secret.data.username;
let _password = secret.data.password;
println!("database credentials loaded");
Ok(())
}
```
Use KV v2 check-and-set, patch, and version operations:
```rust,no_run
use openbao::secrets::kv2::{Kv2MetadataOptions, Kv2WriteOptions};
use openbao::{Client, Result};
use openbao::SecretString;
use serde::Serialize;
#[derive(Serialize)]
struct Patch {
password: SecretString,
}
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let kv = client.kv2("secret")?;
kv.write_with_options(
"app/config",
serde_json::json!({ "username": "app", "password": "first" }),
Some(Kv2WriteOptions { cas: Some(0) }),
)
.await?;
let second = kv
.patch("app/config", Patch {
password: SecretString::from("rotated"),
})
.await?;
let _previous = kv
.read_version::<serde_json::Value>("app/config", second.version - 1)
.await?;
kv.delete_versions("app/config", &[second.version - 1]).await?;
kv.undelete_versions("app/config", &[second.version - 1]).await?;
kv.destroy_versions("app/config", &[second.version - 1]).await?;
kv.patch_metadata(
"app/config",
&Kv2MetadataOptions {
max_versions: Some(10),
cas_required: Some(true),
delete_version_after: Some("24h".to_owned()),
custom_metadata: None,
},
)
.await?;
Ok(())
}
```
Load service configuration from KV v2:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
use serde::Deserialize;
#[derive(Deserialize)]
struct AppConfig {
database_url: SecretString,
listen_addr: String,
}
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let kv = client.kv2("secret")?;
let typed = kv.read_data::<AppConfig>("services/api").await?;
let env_map = kv.read_service_config("services/api-env").await?;
println!("listen: {}", typed.listen_addr);
println!("loaded {} secret config keys", env_map.len());
let _database_url_is_not_logged = typed.database_url;
Ok(())
}
```
Read dynamic database credentials:
```rust,no_run
use openbao::{Client, Result, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let database = client.database("database")?;
let credentials = database.credentials("readonly").await?;
let _password = credentials.password;
println!(
"database user {} leased for {} seconds",
credentials.username, credentials.lease_duration
);
Ok(())
}
```
Use a KV v1 mount:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
use serde::{Deserialize, Serialize};
#[derive(Deserialize, Serialize)]
struct Config {
endpoint: String,
}
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let kv = client.kv1("legacy-secret")?;
kv.write("app/config", Config {
endpoint: "https://api.example.com".to_owned(),
})
.await?;
let config = kv.read::<Config>("app/config").await?;
let keys = kv.list("app").await?;
println!("endpoint: {}", config.endpoint);
println!("keys: {}", keys.keys.len());
Ok(())
}
```
Encrypt and decrypt through Transit:
```rust,no_run
use openbao::secrets::transit::{TransitDecryptRequest, TransitEncryptRequest};
use openbao::{Client, Result};
use openbao::{ExposeSecret, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let transit = client.transit("transit")?;
let encrypted = transit
.encrypt(
"app-key",
&TransitEncryptRequest::new(SecretString::from("c2VjcmV0")),
)
.await?;
let decrypted = transit
.decrypt(
"app-key",
&TransitDecryptRequest::new(encrypted.ciphertext),
)
.await?;
println!("plaintext length: {}", decrypted.plaintext.expose_secret().len());
Ok(())
}
```
Encrypt and decrypt raw bytes with the optional `transit-bytes` feature:
```rust,no_run
use openbao::secrets::transit::{TransitDecryptRequest, TransitEncryptRequest};
use openbao::{Client, Result, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let transit = client.transit("transit")?;
let request = TransitEncryptRequest::from_plaintext_bytes(b"secret")?;
let encrypted = transit.encrypt("app-key", &request).await?;
let decrypted = transit
.decrypt("app-key", &TransitDecryptRequest::new(encrypted.ciphertext))
.await?;
let plaintext = decrypted.plaintext_bytes()?;
println!("plaintext length: {}", plaintext.len());
Ok(())
}
```
Sign data for JWS/JWT-style ECDSA workflows:
```rust,no_run
use openbao::secrets::transit::{
TransitHashAlgorithm, TransitSignRequest, TransitVerifyRequest,
};
use openbao::{Client, Result, SecretString};
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let transit = client.transit("transit")?;
let input = SecretString::from("ZXhhbXBsZS1wYXlsb2Fk");
let signed = transit
.sign(
"jwt-signing-key",
Some(TransitHashAlgorithm::Sha2_256),
&TransitSignRequest::jws(input.clone()),
)
.await?;
let verified = transit
.verify(
"jwt-signing-key",
Some(TransitHashAlgorithm::Sha2_256),
&TransitVerifyRequest::jws_with_signature(input, signed.signature),
)
.await?;
println!("signature valid: {}", verified.valid);
Ok(())
}
```
Create, inspect, renew, and revoke a child token:
```rust,no_run
use openbao::auth::token::TokenCreateRequest;
use openbao::{Client, Result};
use openbao::SecretString;
use std::collections::BTreeMap;
#[tokio::main]
async fn main() -> Result<()> {
let root_or_parent = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(root_or_parent)?;
let child = client
.token()
.create(&TokenCreateRequest {
policies: vec!["default".to_owned()],
meta: BTreeMap::from([("owner".to_owned(), "example".to_owned())]),
display_name: Some("example-child".to_owned()),
ttl: Some("30m".to_owned()),
explicit_max_ttl: Some("1h".to_owned()),
renewable: Some(true),
..TokenCreateRequest::default()
})
.await?;
let info = client.token().lookup(&child.client_token).await?;
println!("renewable: {}", info.renewable);
let _renewed = client.token().renew(&child.client_token, Some("15m")).await?;
client.token().revoke_accessor(&child.accessor).await?;
Ok(())
}
```
Enable a KV v2 mount:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
client
.sys()
.enable_kv2("apps", Some("application secrets"))
.await?;
let mounts = client.sys().list_mounts().await?;
println!("mount count: {}", mounts.len());
Ok(())
}
```
Wrap and unwrap JSON data:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
use serde::{Deserialize, Serialize};
#[derive(Deserialize, Serialize)]
struct WrappedPayload {
nonce: String,
}
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let wrap = client
.sys()
.wrapping_wrap("5m", &WrappedPayload {
nonce: "one-time".to_owned(),
})
.await?;
let payload = client
.sys()
.wrapping_unwrap::<WrappedPayload>(Some(&wrap.token))
.await?;
println!("payload nonce length: {}", payload.nonce.len());
Ok(())
}
```
Write an ACL policy and check capabilities:
```rust,no_run
use openbao::{Client, Result, SecretString};
use openbao::sys::PolicyWriteRequest;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
client
.sys()
.write_policy(
"app-read",
&PolicyWriteRequest::new(r#"path "secret/data/app" { capabilities = ["read"] }"#),
)
.await?;
let capabilities = client.sys().capabilities_self(["secret/data/app"]).await?;
let _for_path = capabilities.by_path.get("secret/data/app");
Ok(())
}
```
Enable an audit device and calculate an audit hash:
```rust,no_run
use openbao::{Client, Result, SecretString};
use openbao::sys::AuditEnableRequest;
use std::collections::BTreeMap;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
client
.sys()
.enable_audit_device(
"file",
&AuditEnableRequest {
options: BTreeMap::from([(
"file_path".to_owned(),
"/var/log/openbao/audit.log".to_owned(),
)]),
..AuditEnableRequest::new("file").with_description("local audit file")
},
)
.await?;
let hash = client
.sys()
.audit_hash("file", &SecretString::from("known-secret-value"))
.await?;
println!("audit hash prefix: {}", hash.hash.split(':').next().unwrap_or(""));
Ok(())
}
```
Look up and renew one exact lease:
```rust,no_run
use openbao::{Client, Result};
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let lease_id = SecretString::from(std::env::var("BAO_LEASE_ID").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let lease = client.sys().lookup_lease(&lease_id).await?;
if lease.renewable {
let renewed = client.sys().renew_lease(&lease_id, Some(1800)).await?;
println!("renewed lease seconds: {}", renewed.lease_duration);
}
Ok(())
}
```
Read and reload a plugin catalog entry:
```rust,no_run
use openbao::sys::{PluginReloadRequest, PluginType};
use openbao::{Client, Result};
use openbao::SecretString;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let plugins = client.sys().list_plugins_by_type(PluginType::Secret).await?;
if plugins.keys.iter().any(|name| name == "transit") {
let _info = client
.sys()
.read_plugin(PluginType::Secret, "transit", None)
.await?;
}
client
.sys()
.reload_plugin_backend(&PluginReloadRequest {
plugin: Some("example-plugin".to_owned()),
mounts: Vec::new(),
scope: None,
})
.await?;
Ok(())
}
```
Call an endpoint that is not typed yet:
```rust,no_run
use openbao::{Client, Result};
use openbao::Method;
use openbao::SecretString;
use serde_json::Value;
#[tokio::main]
async fn main() -> Result<()> {
let token = SecretString::from(std::env::var("BAO_TOKEN").unwrap_or_default());
let client = Client::new("https://bao.example.com:8200")?.try_with_token(token)?;
let response: Value = client
.request_json(Method::GET, "sys/internal/specs/openapi", Option::<&Value>::None)
.await?;
println!("openapi keys: {}", response.as_object().map_or(0, |object| object.len()));
Ok(())
}
```
The raw request layer is intentionally low level. Prefer typed helpers when the
crate supports an endpoint; use raw JSON to bridge missing OpenBao APIs while
coverage grows.
## Local OpenBao Dev Instance
The local dev stack uses Podman, TLS, a private CA, and loopback-only ports in
the requested `994x` range.
Prepare the rootless Podman volume and TLS assets without starting OpenBao:
```bash
scripts/openbao_dev.sh prepare
```
This project does not require a `/srv` directory tree for local development:
raft data lives in a Podman-managed volume, and TLS material lives in the
ignored `deploy/podman/dev-state/` directory.
```bash
scripts/openbao_dev.sh up
```
Endpoints:
- API: `https://127.0.0.1:9940`
- Cluster: `https://127.0.0.1:9941`
- CA certificate: `deploy/podman/dev-state/tls/dev-ca.crt`
Initialize and unseal OpenBao using `bao operator init` and
`bao operator unseal`, then export `BAO_ADDR=https://127.0.0.1:9940` and
`BAO_CACERT=deploy/podman/dev-state/tls/dev-ca.crt`.
For disposable local development, the crate can initialize and unseal a fresh
numeric-loopback instance directly:
```rust,no_run
use openbao::{Client, OpenBaoConfig, Result, sys::DevBootstrapOptions};
use openbao::Certificate;
#[tokio::main]
async fn main() -> Result<()> {
let ca_pem = std::fs::read("deploy/podman/dev-state/tls/dev-ca.crt").map_err(|_| {
openbao::Error::InvalidTlsConfig(
"failed to read the configured CA certificate file".into(),
)
})?;
let ca = Certificate::from_pem(&ca_pem)?;
let config = OpenBaoConfig::new("https://127.0.0.1:9940")?
.only_root_certificates(vec![ca])?;
let client = Client::from_config(config)?;
let bootstrap = client
.sys()
.bootstrap_dev(&DevBootstrapOptions::single_key())
.await?;
let health = bootstrap.client.sys().health().await?;
println!("initialized: {}, sealed: {}", health.initialized, health.sealed);
Ok(())
}
```
`bootstrap_dev` is not a production initialization ceremony. It creates root
and unseal material in process memory, uses Shamir keys, refuses non-loopback
targets, and refuses already initialized servers. Do not use it with HSM/KMS
auto-unseal, shared environments, or any instance that requires operator key
ceremony.
Run the real OpenBao integration flow:
```bash
scripts/openbao_integration.sh
```
The integration script creates a fresh TLS dev instance, initializes and
unseals it, stores the root token in a temporary `0600` file for the test
process, and removes that file when the run exits.
## Release Discipline
Run the normal local checks:
```bash
scripts/checks.sh
```
Run the current release gate:
```bash
scripts/release_0_5_gate.sh
```
Set `OPENBAO_SKIP_INTEGRATION=1` only when Podman is unavailable; release
candidate validation should run the integration gate.
No release tag should be cut unless the matching pentest report status is
reviewed and recorded in the release notes.