Skip to content

Commit 552ca05

Browse files
[multicast] Add omdb multicast support
1 parent 52ad8d8 commit 552ca05

9 files changed

Lines changed: 1862 additions & 2 deletions

File tree

dev-tools/omdb/Cargo.toml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,9 @@ version = "0.1.0"
44
edition.workspace = true
55
license = "MPL-2.0"
66

7+
[features]
8+
multicast = []
9+
710
[lints]
811
workspace = true
912

dev-tools/omdb/src/bin/omdb/db.rs

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,7 @@ mod alert;
187187
mod blueprints;
188188
mod db_metadata;
189189
mod ereport;
190+
mod multicast;
190191
mod saga;
191192
mod sitrep;
192193
mod user_data_export;
@@ -411,6 +412,8 @@ enum DbCommands {
411412
/// Print information about migrations
412413
#[clap(alias = "migration")]
413414
Migrations(MigrationsArgs),
415+
/// Print information about multicast groups
416+
Multicast(multicast::MulticastArgs),
414417
/// Print information about snapshots
415418
Snapshots(SnapshotArgs),
416419
/// Validate the contents of the database
@@ -1420,6 +1423,33 @@ impl DbArgs {
14201423
}) => {
14211424
cmd_db_migrations_list(&datastore, &fetch_opts, args).await
14221425
}
1426+
DbCommands::Multicast(multicast::MulticastArgs {
1427+
command: multicast::MulticastCommands::Groups(args),
1428+
}) => {
1429+
multicast::cmd_db_multicast_groups(
1430+
&datastore, &fetch_opts, &args,
1431+
)
1432+
.await
1433+
}
1434+
DbCommands::Multicast(multicast::MulticastArgs {
1435+
command: multicast::MulticastCommands::Members(args),
1436+
}) => {
1437+
multicast::cmd_db_multicast_members(&datastore, &fetch_opts, &args)
1438+
.await
1439+
}
1440+
DbCommands::Multicast(multicast::MulticastArgs {
1441+
command: multicast::MulticastCommands::Pools,
1442+
}) => {
1443+
multicast::cmd_db_multicast_pools(&datastore, &fetch_opts).await
1444+
}
1445+
DbCommands::Multicast(multicast::MulticastArgs {
1446+
command: multicast::MulticastCommands::Info(args),
1447+
}) => {
1448+
multicast::cmd_db_multicast_info(
1449+
&datastore, &fetch_opts, &args,
1450+
)
1451+
.await
1452+
}
14231453
DbCommands::Snapshots(SnapshotArgs {
14241454
command: SnapshotCommands::Info(uuid),
14251455
}) => cmd_db_snapshot_info(&opctx, &datastore, uuid).await,

0 commit comments

Comments
 (0)