Skip to content

Commit

Permalink
fix(typo): persistance to persistence
Browse files Browse the repository at this point in the history
Signed-off-by: Márk Kővári <[email protected]>
  • Loading branch information
markkovari committed Dec 18, 2024
1 parent 0582e95 commit f49da7c
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ struct Args {
default_value_t = StreamPersistence::File,
hide = true
)]
stream_persistance: StreamPersistence,
stream_persistence: StreamPersistence,
/// Maximum bytes to keep for the command stream
#[arg(
long = "command-stream-max-bytes",
Expand Down Expand Up @@ -305,7 +305,7 @@ async fn main() -> anyhow::Result<()> {
.to_string(),
),
args.max_event_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand All @@ -317,7 +317,7 @@ async fn main() -> anyhow::Result<()> {
vec![DEFAULT_COMMANDS_TOPIC.to_owned()],
Some("A stream that stores all commands for wadm".to_string()),
args.max_command_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand All @@ -326,7 +326,7 @@ async fn main() -> anyhow::Result<()> {
internal_stream_name(STATUS_STREAM_NAME),
vec![DEFAULT_STATUS_TOPIC.to_owned()],
args.max_status_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand Down Expand Up @@ -356,7 +356,7 @@ async fn main() -> anyhow::Result<()> {
.to_string(),
),
args.max_wasmbus_event_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand All @@ -367,7 +367,7 @@ async fn main() -> anyhow::Result<()> {
NOTIFY_STREAM_NAME.to_owned(),
vec![format!("{WADM_NOTIFY_PREFIX}.*")],
args.max_notify_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand All @@ -383,7 +383,7 @@ async fn main() -> anyhow::Result<()> {
.to_string(),
),
args.max_event_consumer_stream_bytes,
args.stream_persistance.into(),
args.stream_persistence.into(),
)
.await?;

Expand Down

0 comments on commit f49da7c

Please sign in to comment.