rustfs-cli 0.1.13

A Rust S3 CLI client for S3-compatible object storage
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

//! bucket command group - Noun-first bucket workflows.
//!
//! Provides an agent-friendly bucket-oriented entrypoint while delegating to the
//! existing command implementations.

use clap::{Args, Subcommand};

use crate::exit_code::ExitCode;
use crate::output::OutputConfig;

use super::{anonymous, cors, event, ilm, ls, mb, quota, rb, replicate, version};

const BUCKET_AFTER_HELP: &str = "\
Examples:
  rc bucket list local/
  rc bucket create local/my-bucket
  rc bucket remove local/my-bucket
  rc bucket event list local/my-bucket
  rc bucket cors list local/my-bucket
  rc bucket replication status local/my-bucket";

/// Manage bucket-oriented workflows
#[derive(Args, Debug)]
#[command(after_help = BUCKET_AFTER_HELP)]
pub struct BucketArgs {
    #[command(subcommand)]
    pub command: BucketCommands,
}

#[derive(Subcommand, Debug)]
pub enum BucketCommands {
    /// List buckets for an alias, or objects within a bucket path
    #[command(alias = "ls")]
    List(ls::LsArgs),

    /// Create a bucket
    Create(mb::MbArgs),

    /// Remove a bucket
    Remove(rb::RbArgs),

    /// Manage bucket notification rules
    #[command(subcommand)]
    Event(event::EventCommands),

    /// Manage bucket CORS rules
    #[command(subcommand)]
    Cors(cors::CorsCommands),

    /// Manage bucket versioning
    #[command(subcommand)]
    Version(version::VersionCommands),

    /// Manage bucket quota
    #[command(subcommand)]
    Quota(quota::QuotaCommands),

    /// Manage anonymous bucket access
    #[command(subcommand)]
    Anonymous(anonymous::AnonymousCommands),

    /// Manage bucket lifecycle rules, tiers, and restores
    #[command(name = "lifecycle")]
    Lifecycle(ilm::IlmArgs),

    /// Manage bucket replication rules and status
    #[command(name = "replication")]
    Replication(replicate::ReplicateArgs),
}

/// Execute the bucket command group
pub async fn execute(args: BucketArgs, output_config: OutputConfig) -> ExitCode {
    match args.command {
        BucketCommands::List(args) => ls::execute(args, output_config).await,
        BucketCommands::Create(args) => mb::execute(args, output_config).await,
        BucketCommands::Remove(args) => rb::execute(args, output_config).await,
        BucketCommands::Event(cmd) => {
            event::execute(event::EventArgs { command: cmd }, output_config).await
        }
        BucketCommands::Cors(cmd) => {
            cors::execute(cors::CorsArgs { command: cmd }, output_config).await
        }
        BucketCommands::Version(cmd) => {
            version::execute(version::VersionArgs { command: cmd }, output_config).await
        }
        BucketCommands::Quota(cmd) => {
            quota::execute(quota::QuotaArgs { command: cmd }, output_config).await
        }
        BucketCommands::Anonymous(cmd) => {
            anonymous::execute(anonymous::AnonymousArgs { command: cmd }, output_config).await
        }
        BucketCommands::Lifecycle(args) => ilm::execute(args, output_config).await,
        BucketCommands::Replication(args) => replicate::execute(args, output_config).await,
    }
}