Enum StreamResponse 

pub enum StreamResponse {
    BucketCreated {
        bucket_id: String,
    },
    BucketAlreadyExists {
        bucket_id: String,
    },
    BucketDeleted {
        bucket_id: String,
    },
    BucketQuotaSet {
        bucket_id: String,
    },
    Created {
        stream_id: BucketStreamId,
        next_offset: u64,
        closed: bool,
    },
    AlreadyExists {
        next_offset: u64,
        closed: bool,
        content_type: String,
        stream_ttl_seconds: Option<u64>,
        stream_expires_at_ms: Option<u64>,
    },
    Appended {
        offset: u64,
        next_offset: u64,
        closed: bool,
        deduplicated: bool,
        producer: Option<ProducerRequest>,
    },
    Closed {
        next_offset: u64,
        deduplicated: bool,
        producer: Option<ProducerRequest>,
    },
    Deleted,
    ColdFlushed {
        hot_start_offset: u64,
    },
    ColdCompacted {
        compacted_chunks: u64,
        compacted_bytes: u64,
    },
    SnapshotPublished {
        snapshot_offset: u64,
        snapshot_digest: String,
        record_range: Option<StreamRecordRange>,
    },
    RetentionAdvanced {
        retained_offset: u64,
        record_range: Option<StreamRecordRange>,
    },
    Accessed {
        changed: bool,
        expired: bool,
    },
    AttrsUpdated {
        changed: bool,
    },
    ColdGcAcked {
        removed: u64,
    },
    BucketPurged {
        bucket_id: String,
        removed_streams: u64,
        pending_cold_gc_entries: u64,
    },
    SnapshotImported {
        buckets: u64,
        streams: u64,
    },
    Error {
        code: StreamErrorCode,
        message: String,
        next_offset: Option<u64>,
        context: Vec<StreamErrorContext>,
    },
}

Variants

BucketCreated

Fields

bucket_id: String

BucketAlreadyExists

Fields

bucket_id: String

BucketDeleted

Fields

bucket_id: String

BucketQuotaSet

Fields

bucket_id: String

Created

Fields

stream_id: BucketStreamId

next_offset: u64

closed: bool

AlreadyExists

Fields

next_offset: u64

closed: bool

content_type: String

stream_ttl_seconds: Option<u64>

stream_expires_at_ms: Option<u64>

Appended

Fields

offset: u64

next_offset: u64

closed: bool

deduplicated: bool

producer: Option<ProducerRequest>

Closed

Fields

next_offset: u64

deduplicated: bool

producer: Option<ProducerRequest>

Deleted

ColdFlushed

Fields

hot_start_offset: u64

ColdCompacted

Fields

compacted_chunks: u64

compacted_bytes: u64

SnapshotPublished

Fields

snapshot_offset: u64

snapshot_digest: String

record_range: Option<StreamRecordRange>

RetentionAdvanced

Fields

retained_offset: u64

record_range: Option<StreamRecordRange>

Accessed

Fields

changed: bool

expired: bool

AttrsUpdated

Fields

changed: bool

ColdGcAcked

Fields

removed: u64

BucketPurged

A whole-bucket purge accepted by StreamCommand::PurgeBucket.

Fields

bucket_id: String

removed_streams: u64

pending_cold_gc_entries: u64

SnapshotImported

A whole-group state import accepted by StreamCommand::ImportSnapshot.

Fields

buckets: u64

streams: u64

Error

Fields

code: StreamErrorCode

message: String

next_offset: Option<u64>

context: Vec<StreamErrorContext>

Trait Implementations

impl Clone for StreamResponse

fn clone(&self) -> StreamResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamResponse

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

Formats the value using the given formatter.

impl Eq for StreamResponse

impl PartialEq for StreamResponse

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamResponse