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 data: PhantomData<R>, }
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>
data: PhantomData<R>
Trait Implementations
impl<R> Decoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> Decoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]impl<R: Default> Default for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R: Default> Default for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]fn default() -> StreamFetchRequest<R>
[src]
impl<R> Encoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> Encoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]impl<R> Request for StreamFetchRequest<R> where
R: Debug + Decoder + Encoder,
[src]
impl<R> Request for StreamFetchRequest<R> where
R: Debug + Decoder + Encoder,
[src]const API_KEY: u16
[src]
const DEFAULT_API_VERSION: i16
[src]
type Response = StreamFetchResponse<R>
pub const MIN_API_VERSION: i16
pub const MAX_API_VERSION: i16
Auto Trait Implementations
impl<R> RefUnwindSafe for StreamFetchRequest<R> where
R: RefUnwindSafe,
impl<R> RefUnwindSafe for StreamFetchRequest<R> where
R: RefUnwindSafe,
impl<R> Send for StreamFetchRequest<R> where
R: Send,
impl<R> Send for StreamFetchRequest<R> where
R: Send,
impl<R> Sync for StreamFetchRequest<R> where
R: Sync,
impl<R> Sync for StreamFetchRequest<R> where
R: Sync,
impl<R> Unpin for StreamFetchRequest<R> where
R: Unpin,
impl<R> Unpin for StreamFetchRequest<R> where
R: Unpin,
impl<R> UnwindSafe for StreamFetchRequest<R> where
R: UnwindSafe,
impl<R> UnwindSafe for StreamFetchRequest<R> where
R: UnwindSafe,
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]