Struct StreamConfig 

pub struct StreamConfig {
    pub content_type: String,
    pub ttl_seconds: Option<u64>,
    pub expires_at: Option<DateTime<Utc>>,
    pub created_closed: bool,
}

Immutable stream configuration captured at create time.

This is the durable metadata returned by HEAD and used for idempotent create checks. The server treats it as part of the stream identity: recreating an existing stream with a different configuration is a conflict.

Custom PartialEq: when ttl_seconds is Some, expires_at is derived from Utc::now() and will drift between requests. The comparison therefore ignores expires_at in that case. When ttl_seconds is None and expires_at was set directly (via Expires-At header), the parsed timestamp is stable so we compare it.

Fields

content_type: String

Content-Type header value (normalized, lowercase)

ttl_seconds: Option<u64>

Time-to-live in seconds (optional)

expires_at: Option<DateTime<Utc>>

Absolute expiration time (optional)

created_closed: bool

Whether the stream was created closed

Implementations

impl StreamConfig

pub fn new(content_type: String) -> Self

Create a config with a normalized content type and default flags.

pub fn with_ttl(self, ttl_seconds: u64) -> Self

Set a relative time-to-live in seconds.

pub fn with_expires_at(self, expires_at: DateTime<Utc>) -> Self

Set an absolute expiration timestamp.

pub fn with_created_closed(self, created_closed: bool) -> Self

Record that the stream should be considered created in the closed state.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamConfig

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for StreamConfig