pub struct SourceFetchResponseV1 {
pub batch: SourceBatchV1,
pub high_watermarks: Vec<(SourcePartitionId, SourceHighWatermarkV1)>,
pub retention_floors: Vec<(SourcePartitionId, SourceCursorV1)>,
}Fields§
§batch: SourceBatchV1§high_watermarks: Vec<(SourcePartitionId, SourceHighWatermarkV1)>§retention_floors: Vec<(SourcePartitionId, SourceCursorV1)>Implementations§
Source§impl SourceFetchResponseV1
impl SourceFetchResponseV1
pub fn validate(&self) -> Result<(), SourceContractError>
Trait Implementations§
Source§impl Clone for SourceFetchResponseV1
impl Clone for SourceFetchResponseV1
Source§impl Debug for SourceFetchResponseV1
impl Debug for SourceFetchResponseV1
impl Eq for SourceFetchResponseV1
Source§impl PartialEq for SourceFetchResponseV1
impl PartialEq for SourceFetchResponseV1
impl StructuralPartialEq for SourceFetchResponseV1
Auto Trait Implementations§
impl Freeze for SourceFetchResponseV1
impl RefUnwindSafe for SourceFetchResponseV1
impl Send for SourceFetchResponseV1
impl Sync for SourceFetchResponseV1
impl Unpin for SourceFetchResponseV1
impl UnsafeUnpin for SourceFetchResponseV1
impl UnwindSafe for SourceFetchResponseV1
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