Struct GreptimePipelineParams 

pub struct GreptimePipelineParams {
    options: HashMap<String, String>,
    pub skip_error: OnceCell<bool>,
    pub max_nested_levels: OnceCell<usize>,
}

Parameters that can be used to configure the greptime pipelines.

Fields

options: HashMap<String, String>

The original options for configuring the greptime pipelines. This should not be used directly, instead, use the parsed shortcut option values.

skip_error: OnceCell<bool>

Whether to skip error when processing the pipeline.

max_nested_levels: OnceCell<usize>

Max nested levels when flattening JSON object. Defaults to DEFAULT_MAX_NESTED_LEVELS_FOR_JSON_FLATTENING when not provided.

Implementations

impl GreptimePipelineParams

pub fn from_params(params: Option<&str>) -> Self

Create a GreptimePipelineParams from params string which is from the http header with key x-greptime-pipeline-params The params is in the format of key1=value1&key2=value2,for example: x-greptime-pipeline-params: max_nested_levels=5

pub fn from_map(options: HashMap<String, String>) -> Self

pub fn parse_header_str_to_map(params: Option<&str>) -> HashMap<String, String>

pub fn skip_error(&self) -> bool

Whether to skip error when processing the pipeline.

pub fn max_nested_levels(&self) -> usize

Max nested levels for JSON flattening. If not provided or invalid, falls back to DEFAULT_MAX_NESTED_LEVELS_FOR_JSON_FLATTENING.

Trait Implementations

impl Debug for GreptimePipelineParams

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GreptimePipelineParams

fn default() -> GreptimePipelineParams

Returns the “default value” for a type.