Struct StreamReconfiguration 

#[non_exhaustive]
pub struct StreamReconfiguration {
    pub storage_class: Maybe<Option<StorageClass>>,
    pub retention_policy: Maybe<Option<RetentionPolicy>>,
    pub timestamping: Maybe<Option<TimestampingReconfiguration>>,
    pub delete_on_empty: Maybe<Option<DeleteOnEmptyReconfiguration>>,
}

Reconfiguration for StreamConfig.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

storage_class: Maybe<Option<StorageClass>>

Override for the existing storage_class.

retention_policy: Maybe<Option<RetentionPolicy>>

Override for the existing retention_policy.

timestamping: Maybe<Option<TimestampingReconfiguration>>

Override for the existing timestamping.

delete_on_empty: Maybe<Option<DeleteOnEmptyReconfiguration>>

Override for the existing delete_on_empty.

Implementations

impl StreamReconfiguration

pub fn new() -> Self

Create a new StreamReconfiguration.

Examples found in repository

examples/reconfigure_stream.rs (line 25)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let access_token =
        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
    let basin_name: BasinName = std::env::var("S2_BASIN")
        .map_err(|_| "S2_BASIN env var not set")?
        .parse()?;
    let stream_name: StreamName = std::env::var("S2_STREAM")
        .map_err(|_| "S2_STREAM env var not set")?
        .parse()?;

    let s2 = S2::new(S2Config::new(access_token))?;
    let basin = s2.basin(basin_name);

    let input = ReconfigureStreamInput::new(
        stream_name,
        StreamReconfiguration::new().with_retention_policy(RetentionPolicy::Age(10 * 24 * 60 * 60)),
    );
    let config = basin.reconfigure_stream(input).await?;
    println!("{config:#?}");

    Ok(())
}

examples/reconfigure_basin.rs (line 24)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let access_token =
        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
    let basin_name: BasinName = std::env::var("S2_BASIN")
        .map_err(|_| "S2_BASIN env var not set")?
        .parse()?;

    let config = S2Config::new(access_token);
    let s2 = S2::new(config)?;

    let input = ReconfigureBasinInput::new(
        basin_name,
        BasinReconfiguration::new()
            .with_default_stream_config(
                StreamReconfiguration::new()
                    .with_storage_class(StorageClass::Standard)
                    .with_timestamping(TimestampingReconfiguration::new().with_uncapped(true)),
            )
            .with_create_stream_on_read(true),
    );
    let config = s2.reconfigure_basin(input).await?;
    println!("{config:#?}");

    Ok(())
}

pub fn with_storage_class(self, storage_class: StorageClass) -> Self

Set the override for the existing storage_class.

Examples found in repository

examples/reconfigure_basin.rs (line 25)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let access_token =
        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
    let basin_name: BasinName = std::env::var("S2_BASIN")
        .map_err(|_| "S2_BASIN env var not set")?
        .parse()?;

    let config = S2Config::new(access_token);
    let s2 = S2::new(config)?;

    let input = ReconfigureBasinInput::new(
        basin_name,
        BasinReconfiguration::new()
            .with_default_stream_config(
                StreamReconfiguration::new()
                    .with_storage_class(StorageClass::Standard)
                    .with_timestamping(TimestampingReconfiguration::new().with_uncapped(true)),
            )
            .with_create_stream_on_read(true),
    );
    let config = s2.reconfigure_basin(input).await?;
    println!("{config:#?}");

    Ok(())
}

pub fn with_retention_policy(self, retention_policy: RetentionPolicy) -> Self

Set the override for the existing retention_policy.

Examples found in repository

examples/reconfigure_stream.rs (line 25)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let access_token =
        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
    let basin_name: BasinName = std::env::var("S2_BASIN")
        .map_err(|_| "S2_BASIN env var not set")?
        .parse()?;
    let stream_name: StreamName = std::env::var("S2_STREAM")
        .map_err(|_| "S2_STREAM env var not set")?
        .parse()?;

    let s2 = S2::new(S2Config::new(access_token))?;
    let basin = s2.basin(basin_name);

    let input = ReconfigureStreamInput::new(
        stream_name,
        StreamReconfiguration::new().with_retention_policy(RetentionPolicy::Age(10 * 24 * 60 * 60)),
    );
    let config = basin.reconfigure_stream(input).await?;
    println!("{config:#?}");

    Ok(())
}

pub fn with_timestamping( self, timestamping: TimestampingReconfiguration, ) -> Self

Set the override for the existing timestamping.

Examples found in repository

examples/reconfigure_basin.rs (line 26)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let access_token =
        std::env::var("S2_ACCESS_TOKEN").map_err(|_| "S2_ACCESS_TOKEN env var not set")?;
    let basin_name: BasinName = std::env::var("S2_BASIN")
        .map_err(|_| "S2_BASIN env var not set")?
        .parse()?;

    let config = S2Config::new(access_token);
    let s2 = S2::new(config)?;

    let input = ReconfigureBasinInput::new(
        basin_name,
        BasinReconfiguration::new()
            .with_default_stream_config(
                StreamReconfiguration::new()
                    .with_storage_class(StorageClass::Standard)
                    .with_timestamping(TimestampingReconfiguration::new().with_uncapped(true)),
            )
            .with_create_stream_on_read(true),
    );
    let config = s2.reconfigure_basin(input).await?;
    println!("{config:#?}");

    Ok(())
}

pub fn with_delete_on_empty( self, delete_on_empty: DeleteOnEmptyReconfiguration, ) -> Self

Set the override for the existing delete_on_empty.

Trait Implementations

impl Clone for StreamReconfiguration

fn clone(&self) -> StreamReconfiguration

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamReconfiguration

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamReconfiguration

fn default() -> StreamReconfiguration

Returns the “default value” for a type.

impl From<StreamReconfiguration> for StreamReconfiguration

fn from(value: StreamReconfiguration) -> Self

Converts to this type from the input type.