Skip to main content

write_segment

Function write_segment 

Source
pub async fn write_segment(
    args: &RestoreArgs,
    partition: &TopicIdPartition,
    segment: &VerifiedSegment,
    predicates: &Predicates,
) -> Result<SegmentOutcome, RestoreError>
Expand description

Write one verified segment into its target partition, under the bound.

ยงErrors

Returns RestoreError::Records when a batch will not re-encode, and RestoreError::Log or RestoreError::Io when the target rejects the write.