Struct fluvio_spu_schema::server::stream_fetch::StreamFetchRequest [−][src]
pub struct StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug, { pub topic: String, pub partition: i32, pub fetch_offset: i64, pub max_bytes: i32, pub isolation: Isolation, pub wasm_module: Vec<u8>, pub wasm_payload: Option<SmartStreamPayload>, pub data: PhantomData<R>, }
Expand description
Fetch records continuously Output will be send back as stream
Fields
topic: String
partition: i32
fetch_offset: i64
max_bytes: i32
isolation: Isolation
wasm_module: Vec<u8>
wasm_payload: Option<SmartStreamPayload>
data: PhantomData<R>
Trait Implementations
Returns the “default value” for a type. Read more