risingwave_stream::executor

Type Alias MessageStreamItem

source
pub type MessageStreamItem = MessageStreamItemInner<BarrierMutationType>;

Aliased Type§

enum MessageStreamItem {
    Ok(MessageInner<Option<Arc<Mutation>>>),
    Err(StreamExecutorError),
}

Variants§

§1.0.0

Ok(MessageInner<Option<Arc<Mutation>>>)

Contains the success value

§1.0.0

Err(StreamExecutorError)

Contains the error value