Struct fluvio_spu_schema::server::stream_fetch::StreamFetchRequest
source · pub struct StreamFetchRequest<R> {
pub topic: String,
pub partition: PartitionId,
pub fetch_offset: i64,
pub max_bytes: i32,
pub isolation: Isolation,
pub smartmodules: Vec<SmartModuleInvocation>,
pub consumer_id: Option<String>,
/* private fields */
}
Expand description
Fetch records continuously Output will be send back as stream
Fields§
§topic: String
§partition: PartitionId
§fetch_offset: i64
§max_bytes: i32
§isolation: Isolation
§smartmodules: Vec<SmartModuleInvocation>
§consumer_id: Option<String>
Implementations§
source§impl<R> StreamFetchRequest<R>where
R: Clone,
impl<R> StreamFetchRequest<R>where
R: Clone,
pub fn builder() -> StreamFetchRequestBuilder<R>
Trait Implementations§
source§impl<R> Debug for StreamFetchRequest<R>
impl<R> Debug for StreamFetchRequest<R>
source§impl<R: Decoder> Decoder for StreamFetchRequest<R>
impl<R: Decoder> Decoder for StreamFetchRequest<R>
source§impl<R: Default> Default for StreamFetchRequest<R>
impl<R: Default> Default for StreamFetchRequest<R>
source§fn default() -> StreamFetchRequest<R>
fn default() -> StreamFetchRequest<R>
Returns the “default value” for a type. Read more
source§impl<R: Encoder> Encoder for StreamFetchRequest<R>
impl<R: Encoder> Encoder for StreamFetchRequest<R>
source§impl<R> Request for StreamFetchRequest<R>
impl<R> Request for StreamFetchRequest<R>
const API_KEY: u16 = 1_003u16
const DEFAULT_API_VERSION: i16 = 23i16
type Response = StreamFetchResponse<R>
const MIN_API_VERSION: i16 = _
const MAX_API_VERSION: i16 = Self::DEFAULT_API_VERSION
Auto Trait Implementations§
impl<R> Freeze for StreamFetchRequest<R>
impl<R> RefUnwindSafe for StreamFetchRequest<R>where
R: RefUnwindSafe,
impl<R> Send for StreamFetchRequest<R>where
R: Send,
impl<R> Sync for StreamFetchRequest<R>where
R: Sync,
impl<R> Unpin for StreamFetchRequest<R>where
R: Unpin,
impl<R> UnwindSafe for StreamFetchRequest<R>where
R: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more