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
use structopt::StructOpt;
mod error;
pub use error::RunnerError;
use error::Result;
use fluvio_spu::SpuOpt;
use fluvio_sc::cli::ScOpt;
#[derive(Debug, StructOpt)]
pub enum RunCmd {
#[structopt(name = "spu")]
SPU(SpuOpt),
#[structopt(name = "sc")]
SC(ScOpt),
}
impl RunCmd {
pub async fn process(self) -> Result<()> {
match self {
Self::SPU(opt) => {
fluvio_spu::main_loop(opt);
}
Self::SC(opt) => {
fluvio_sc::k8::main_k8_loop(opt);
}
}
Ok(())
}
}