Struct BatchingModeOptions

pub struct BatchingModeOptions {
    pub query_timeout: Duration,
    pub slow_query_threshold: Duration,
    pub experimental_min_refresh_duration: Duration,
    pub grpc_conn_timeout: Duration,
    pub experimental_grpc_max_retries: u32,
    pub experimental_frontend_scan_timeout: Duration,
    pub experimental_frontend_activity_timeout: Duration,
    pub experimental_max_filter_num_per_query: usize,
    pub experimental_time_window_merge_threshold: usize,
    pub read_preference: ReadPreference,
    pub frontend_tls: Option<ClientTlsOption>,
}

Fields

query_timeout: Duration

The default batching engine query timeout is 10 minutes

slow_query_threshold: Duration

will output a warn log for any query that runs for more that this threshold

experimental_min_refresh_duration: Duration

The minimum duration between two queries execution by batching mode task

grpc_conn_timeout: Duration

The gRPC connection timeout

experimental_grpc_max_retries: u32

The gRPC max retry number

experimental_frontend_scan_timeout: Duration

Flow wait for available frontend timeout, if failed to find available frontend after frontend_scan_timeout elapsed, return error which prevent flownode from starting

experimental_frontend_activity_timeout: Duration

Frontend activity timeout if frontend is down(not sending heartbeat) for more than frontend_activity_timeout, it will be removed from the list that flownode use to connect

experimental_max_filter_num_per_query: usize

Maximum number of filters allowed in a single query

experimental_time_window_merge_threshold: usize

Time window merge distance

read_preference: ReadPreference

Read preference of the Frontend client.

frontend_tls: Option<ClientTlsOption>

TLS option for client connections to frontends.

Trait Implementations

impl Clone for BatchingModeOptions

fn clone(&self) -> BatchingModeOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BatchingModeOptions

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

Formats the value using the given formatter.

impl Default for BatchingModeOptions

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BatchingModeOptions

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for BatchingModeOptions

fn eq(&self, other: &BatchingModeOptions) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for BatchingModeOptions

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BatchingModeOptions