Skip to content

Commit 34ba50e

Browse files
committed
Add streaming commands to svix CLI
1 parent 6ae259b commit 34ba50e

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

svix-cli/src/cmds/api/mod.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,3 +12,8 @@ pub mod message_attempt;
1212
pub mod message_poller;
1313
pub mod operational_webhook;
1414
pub mod operational_webhook_endpoint;
15+
pub mod streaming;
16+
pub mod streaming_event_type;
17+
pub mod streaming_events;
18+
pub mod streaming_sink;
19+
pub mod streaming_stream;

svix-cli/src/main.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ use self::{
1212
endpoint::EndpointArgs, environment::EnvironmentArgs, event_type::EventTypeArgs,
1313
ingest::IngestArgs, integration::IntegrationArgs, message::MessageArgs,
1414
message_attempt::MessageAttemptArgs, operational_webhook::OperationalWebhookArgs,
15+
streaming::StreamingArgs,
1516
},
1617
listen::ListenArgs,
1718
open::OpenArgs,
@@ -84,6 +85,8 @@ enum RootCommands {
8485
Open(OpenArgs),
8586
/// List, create & modify operational webhook endpoints
8687
OperationalWebhook(OperationalWebhookArgs),
88+
/// List, create & modify Svix Stream resources
89+
Streaming(StreamingArgs),
8790
/// Generate a test application with sample endpoints and event types
8891
Seed(SeedArgs),
8992
/// Verifying and signing webhooks with the Svix signature scheme
@@ -148,6 +151,10 @@ async fn main() -> Result<()> {
148151
let client = get_client(&cfg?)?;
149152
args.command.exec(&client, color_mode).await?;
150153
}
154+
RootCommands::Streaming(args) => {
155+
let client = get_client(&cfg?)?;
156+
args.command.exec(&client, color_mode).await?;
157+
}
151158

152159
RootCommands::Listen(args) => args.exec(&cfg?).await?,
153160
RootCommands::Login => cmds::login::prompt(&cfg?).await?,

0 commit comments

Comments
 (0)