Enum StreamResponse 

pub enum StreamResponse {
    BucketCreated {
        bucket_id: String,
    },
    BucketAlreadyExists {
        bucket_id: String,
    },
    BucketDeleted {
        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 {
        hard_deleted: bool,
        parent_to_release: Option<BucketStreamId>,
    },
    ForkRefAdded {
        fork_ref_count: u64,
    },
    ForkRefReleased {
        hard_deleted: bool,
        fork_ref_count: u64,
        parent_to_release: Option<BucketStreamId>,
    },
    ColdFlushed {
        hot_start_offset: u64,
    },
    SnapshotPublished {
        snapshot_offset: u64,
    },
    Accessed {
        changed: bool,
        expired: bool,
    },
    AttrsUpdated {
        changed: bool,
    },
    ColdGcAcked {
        removed: 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

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

Fields

hard_deleted: bool

parent_to_release: Option<BucketStreamId>

ForkRefAdded

Fields

fork_ref_count: u64

ForkRefReleased

Fields

hard_deleted: bool

fork_ref_count: u64

parent_to_release: Option<BucketStreamId>

ColdFlushed

Fields

hot_start_offset: u64

SnapshotPublished

Fields

snapshot_offset: u64

Accessed

Fields

changed: bool

expired: bool

AttrsUpdated

Fields

changed: bool

ColdGcAcked

Fields

removed: 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

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 StructuralPartialEq for StreamResponse