Struct StreamBuilder 

pub struct StreamBuilder<C: CodecType> { /* private fields */ }

Builder for creating JetStream streams.

Implementations

impl<C: CodecType> StreamBuilder<C>

pub fn subjects(self, subjects: Vec<String>) -> Self

Set the subjects for this stream.

pub fn subject(self, subject: impl Into<String>) -> Self

Add a single subject to this stream.

pub fn description(self, description: impl Into<String>) -> Self

Set the description for this stream.

pub fn retention(self, retention: RetentionPolicy) -> Self

Set the retention policy.

pub fn max_messages(self, max: i64) -> Self

Set the maximum number of messages.

pub fn max_messages_per_subject(self, max: i64) -> Self

Set the maximum number of messages per subject.

pub fn max_bytes(self, max: i64) -> Self

Set the maximum bytes.

pub fn max_message_size(self, max: i32) -> Self

Set the maximum message size.

pub fn max_age(self, age: Duration) -> Self

Set the maximum age for messages.

pub fn max_consumers(self, max: i32) -> Self

Set the maximum number of consumers.

pub fn replicas(self, replicas: usize) -> Self

Set the number of replicas.

pub fn storage(self, storage: StorageType) -> Self

Set the storage type.

pub fn discard_policy(self, policy: DiscardPolicy) -> Self

Set the discard policy.

pub fn duplicate_window(self, window: Duration) -> Self

Enable or disable duplicate detection window.

pub fn allow_direct(self, allow: bool) -> Self

Allow direct gets.

pub fn mirror(self, source: StreamSource) -> Self

Enable mirroring from another stream.

pub fn add_source(self, source: StreamSource) -> Self

Add a source stream.

pub fn sealed(self, sealed: bool) -> Self

Set whether this is a sealed stream.

pub fn deny_delete(self, deny: bool) -> Self

Set whether to deny delete.

pub fn deny_purge(self, deny: bool) -> Self

Set whether to deny purge.

pub fn allow_rollup(self, allow: bool) -> Self

Set whether to allow rollup headers.

pub fn compression(self, compression: Compression) -> Self

Set the compression type.

pub fn first_sequence(self, seq: u64) -> Self

Set the first sequence number.

pub fn subject_transform(self, source: &str, destination: &str) -> Self

Set a subject transform.

pub async fn create(self) -> Result<Stream<C>>

Create the stream.

pub async fn create_or_update(self) -> Result<Stream<C>>

Create or update the stream.