feldera_types/preprocess.rs
1//! Configuration describing a preprocessor
2
3use serde::{Deserialize, Serialize};
4use serde_json::Value;
5use utoipa::ToSchema;
6
7/// Configuration for describing a preprocessor
8#[derive(Debug, Deserialize, Clone, Eq, PartialEq, Serialize, ToSchema)]
9pub struct PreprocessorConfig {
10 /// Name of the preprocessor.
11 /// All preprocessors with the same name will perform the same task.
12 pub name: String,
13 /// True if the preprocessor is message-oriented: true if each preprocessor
14 /// output record corresponds to a whole number of of parser records.
15 pub message_oriented: bool,
16 /// Arbitrary additional configuration.
17 pub config: Value,
18}