Struct LogIngesterQueryParams 

pub struct LogIngesterQueryParams {
    pub db: Option<String>,
    pub table: Option<String>,
    pub pipeline_name: Option<String>,
    pub version: Option<String>,
    pub ignore_errors: Option<bool>,
    pub source: Option<String>,
    pub msg_field: Option<String>,
    pub custom_time_index: Option<String>,
    pub skip_error: Option<bool>,
}

LogIngesterQueryParams is used for query params of log ingester API.

Fields

db: Option<String>

The database where log data will be written to.

table: Option<String>

The table where log data will be written to.

pipeline_name: Option<String>

The pipeline that will be used for log ingestion.

version: Option<String>

The version of the pipeline to be used for log ingestion.

ignore_errors: Option<bool>

Whether to ignore errors during log ingestion.

source: Option<String>

The source of the log data.

msg_field: Option<String>

The JSON field name of the log message. If not provided, it will take the whole log as the message. The field must be at the top level of the JSON structure.

custom_time_index: Option<String>

Specify a custom time index from the input data rather than server’s arrival time. Valid formats:

• <field_name>;epoch;
• <field_name>;datestr;

If an error occurs while parsing the config, the error will be returned in the response. If an error occurs while ingesting the data, the ignore_errors will be used to determine if the error should be ignored. If so, use the current server’s timestamp as the event time.

skip_error: Option<bool>

Whether to skip errors during log ingestion. If set to true, the ingestion will continue even if there are errors in the data. If set to false, the ingestion will stop at the first error. This is different from ignore_errors, which is used to ignore errors during the pipeline execution. The priority of query params is lower than that headers of x-greptime-pipeline-params.

Trait Implementations

impl Debug for LogIngesterQueryParams

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

Formats the value using the given formatter.

impl Default for LogIngesterQueryParams

fn default() -> LogIngesterQueryParams

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for LogIngesterQueryParams

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LogIngesterQueryParams

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.