Skip to main content

AtomicServer

Atomic-Server services support.

Capabilities​

This service can be used to:

  • stat
  • read
  • write
  • create_dir
  • delete
  • copy
  • rename
  • list
  • scan
  • presign
  • blocking

Configuration​

  • root: Set the working directory of OpenDAL
  • endpoint: Set the server address for Atomicserver
  • private_key: Set the private key for agent used for Atomicserver
  • public_key: Set the public key for agent used for Atomicserver
  • parent_resource_id: Set the parent resource id (url) that Atomicserver uses to store resources under

You can refer to [AtomicserverBuilder]'s docs for more information.

Example​

Via Builder​

use anyhow::Result;
use opendal::services::Atomicserver;
use opendal::Operator;

#[tokio::main]
async fn main() -> Result<()> {
    let mut builder = Atomicserver::default();

    // Set the server address for Atomicserver
    builder.endpoint("http://localhost:9883");
    // Set the public/private key for agent for Atomicserver
    builder.private_key("<private_key>");
    builder.public_key("<public_key>");
    // Set the parent resource id for Atomicserver. In this case
    // We are using the root resource (Drive)
    builder.parent_resource_id("http://localhost:9883");

    let op: Operator = Operator::new(builder)?.finish();
    Ok(())
}

Via Config​

use anyhow::Result;
use opendal::services::Sqlite;
use opendal::Operator;

#[tokio::main]
async fn main() -> Result<()> {
    
    let mut map = HashMap::new();
    map.insert("endpoint".to_string(), "http://localhost:9883".to_string());
    map.insert("private_key".to_string(), "your_private_key".to_string());
    map.insert("public_key".to_string(), "your_public_key".to_string());
    map.insert("parent_resource_id".to_string(), "your_resource_id".to_string());

    let op: Operator = Operator::via_map(Scheme::Atomicserver, map)?;
    Ok(())
}