Skip to main content

create_error_batch

kinetic_core::error_payload

Function create_error_batch 

Source 
pub fn create_error_batch(
    pipeline_name: &str,
    stage: &str,
    xids: Vec<String>,
    error_messages: Vec<String>,
    raw_payloads: Vec<Vec<u8>>,
    metadata: ArcEventMetadata,
) -> Result<EventBatch>