Struct StreamingConfig

pub struct StreamingConfig {
    pub in_flight_barrier_nums: usize,
    pub actor_runtime_worker_threads_num: Option<usize>,
    pub async_stack_trace: AsyncStackTraceOption,
    pub developer: StreamingDeveloperConfig,
    pub unique_user_stream_errors: usize,
    pub unsafe_enable_strict_consistency: bool,
    pub unrecognized: Unrecognized<Self>,
}

The section [streaming] in risingwave.toml.

Fields

in_flight_barrier_nums: usize

The maximum number of barriers in-flight in the compute nodes.

actor_runtime_worker_threads_num: Option<usize>

The thread number of the streaming actor runtime in the compute node. The default value is decided by tokio.

async_stack_trace: AsyncStackTraceOption

Enable async stack tracing through await-tree for risectl.

developer: StreamingDeveloperConfig

unique_user_stream_errors: usize

Max unique user stream errors per actor

unsafe_enable_strict_consistency: bool

Control the strictness of stream consistency.

unrecognized: Unrecognized<Self>

Implementations

impl StreamingConfig

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

Trait Implementations

impl Clone for StreamingConfig

fn clone(&self) -> StreamingConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingConfig

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

Formats the value using the given formatter.

impl Default for StreamingConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamingConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamingConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.