Struct EPScan 

pub struct EPScan {
    pub partition: PartitionSelector,
    pub start_sequence: RangeValue,
    pub end_sequence: RangeValue,
    pub count: Option<u64>,
}

Scan events in a partition by sequence number range.

Syntax

EPSCAN <partition> <start_sequence> <end_sequence> [COUNT <count>]

Parameters

• partition: Partition selector (partition ID 0-65535 or UUID key)
• start_sequence: Starting sequence number (use “-” for beginning)
• end_sequence: Ending sequence number (use “+” for end, or specific number)
• count (optional): Maximum number of events to return

Examples

EPSCAN 42 100 200 COUNT 50
EPSCAN 550e8400-e29b-41d4-a716-446655440000 - + COUNT 100

Fields

partition: PartitionSelector

start_sequence: RangeValue

end_sequence: RangeValue

count: Option<u64>

Implementations

impl EPScan

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

Trait Implementations

impl HandleRequest for EPScan

type Error = String

type Ok = EPScanResp

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