Struct FrontendConfig 

pub struct FrontendConfig {
    pub max_total_query_size_bytes: u64,
    pub min_single_query_size_bytes: u64,
    pub max_single_query_size_bytes: u64,
    pub stream_flush_threshold_bytes: usize,
    pub hba_config: HbaConfig,
    pub webhook_auth_max_clock_skew_ms: u64,
    pub unsafe_enable_local_fs_connector: bool,
}

The section frontend in risingwave.toml.

Fields

max_total_query_size_bytes: u64

Total memory constraints for running queries.

min_single_query_size_bytes: u64

A query of size under this threshold will never be rejected due to memory constraints.

max_single_query_size_bytes: u64

A query of size exceeding this threshold will always be rejected due to memory constraints.

stream_flush_threshold_bytes: usize

Flush threshold in bytes for streaming pgwire responses. A value of 0 flushes after every row. A single pgwire message can exceed this threshold because messages are encoded atomically.

hba_config: HbaConfig

Host-based authentication configuration

webhook_auth_max_clock_skew_ms: u64

Maximum allowed clock skew in milliseconds for WebSocket ingest init authentication.

unsafe_enable_local_fs_connector: bool

Whether to allow local filesystem connectors such as posix_fs and fs. Disabled by default in release builds because these connectors can access files on the frontend host. Enabled by default in debug builds for local development.

Implementations

impl FrontendConfig

pub fn config_docs( name: String, docs: &mut BTreeMap<String, Vec<(String, String)>>, )

Trait Implementations

impl Clone for FrontendConfig

fn clone(&self) -> FrontendConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FrontendConfig

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

Formats the value using the given formatter.

impl Default for FrontendConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FrontendConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FrontendConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.