Struct EScan 

pub struct EScan {
    pub stream_id: StreamId,
    pub start_version: RangeValue,
    pub end_version: RangeValue,
    pub partition_key: Option<Uuid>,
    pub count: Option<u64>,
}

Scan events in a stream by version range.

Syntax

ESCAN <stream_id> <start_version> <end_version> [PARTITION_KEY <partition_key>] [COUNT <count>]

Parameters

• stream_id: Stream identifier to scan
• start_version: Starting version number (use “-” for beginning)
• end_version: Ending version number (use “+” for end, or specific number)
• partition_key (optional): UUID to scan specific partition
• count (optional): Maximum number of events to return

Examples

ESCAN my-stream 0 100 COUNT 50
ESCAN my-stream - + PARTITION_KEY 550e8400-e29b-41d4-a716-446655440000

Fields

stream_id: StreamId

start_version: RangeValue

end_version: RangeValue

partition_key: Option<Uuid>

count: Option<u64>

Implementations

impl EScan

pub fn parser<'a>() -> impl Parser<FrameStream<'a>, Output = EScan> + 'a

Trait Implementations

impl HandleRequest for EScan

type Error = String

type Ok = EScanResp

async fn handle_request( self, conn: &mut Conn, ) -> Result<Option<Self::Ok>, Self::Error>

fn handle_request_failable( self, conn: &mut Conn, ) -> impl Future<Output = Result<Option<BytesFrame>, Error>> + Send