Type Alias fluvio_spu_schema::server::stream_fetch::DefaultStreamFetchRequest

source · 
pub type DefaultStreamFetchRequest = StreamFetchRequest<RecordSet<RawRecords>>;

Aliased Type§

struct DefaultStreamFetchRequest {
    pub topic: String,
    pub partition: u32,
    pub fetch_offset: i64,
    pub max_bytes: i32,
    pub isolation: Isolation,
    pub smartmodules: Vec<SmartModuleInvocation>,
    pub consumer_id: Option<String>,
    /* private fields */
}

Fields§

§topic: String§partition: u32§fetch_offset: i64§max_bytes: i32§isolation: Isolation§smartmodules: Vec<SmartModuleInvocation>§consumer_id: Option<String>