pub struct SystemConfig {Show 18 fields
pub barrier_interval_ms: Option<u32>,
pub checkpoint_frequency: Option<u64>,
pub sstable_size_mb: Option<u32>,
pub parallel_compact_size_mb: Option<u32>,
pub block_size_kb: Option<u32>,
pub bloom_false_positive: Option<f64>,
pub state_store: Option<String>,
pub data_directory: Option<String>,
pub backup_storage_url: Option<String>,
pub backup_storage_directory: Option<String>,
pub max_concurrent_creating_streaming_jobs: Option<u32>,
pub pause_on_next_bootstrap: Option<bool>,
pub enable_tracing: Option<bool>,
pub use_new_object_prefix_strategy: Option<bool>,
pub license_key: Option<LicenseKey>,
pub time_travel_retention_ms: Option<u64>,
pub per_database_isolation: Option<bool>,
pub enforce_secret: Option<bool>,
}Expand description
The section [system] in risingwave.toml. All these fields are used to initialize the system
parameters persisted in Meta store. Most fields are for testing purpose only and should not be
documented.
Fields§
§barrier_interval_ms: Option<u32>The interval of periodic barrier.
checkpoint_frequency: Option<u64>There will be a checkpoint for every n barriers.
sstable_size_mb: Option<u32>Target size of the Sstable.
parallel_compact_size_mb: Option<u32>The size of parallel task for one compact/flush job.
block_size_kb: Option<u32>Size of each block in bytes in SST.
bloom_false_positive: Option<f64>DEPRECATED: Bloom filter is no longer a supported SST filter implementation. This field is kept for backward compatibility and no longer controls whether SST filters are emitted.
state_store: Option<String>URL for the state store
data_directory: Option<String>Remote directory for storing data and metadata objects.
backup_storage_url: Option<String>Remote storage url for storing snapshots.
backup_storage_directory: Option<String>Remote directory for storing snapshots.
max_concurrent_creating_streaming_jobs: Option<u32>Max number of concurrent creating streaming jobs.
pause_on_next_bootstrap: Option<bool>Whether to pause all data sources on next bootstrap.
enable_tracing: Option<bool>Whether to enable distributed tracing.
use_new_object_prefix_strategy: Option<bool>Whether to split object prefix.
license_key: Option<LicenseKey>The license key to activate enterprise features.
time_travel_retention_ms: Option<u64>The data retention period for time travel.
per_database_isolation: Option<bool>Whether per database isolation is enabled
enforce_secret: Option<bool>Whether to enforce secret on cloud.
Implementations§
Source§impl SystemConfig
impl SystemConfig
Source§impl SystemConfig
impl SystemConfig
pub fn into_init_system_params(self) -> SystemParams
Trait Implementations§
Source§impl Clone for SystemConfig
impl Clone for SystemConfig
Source§fn clone(&self) -> SystemConfig
fn clone(&self) -> SystemConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for SystemConfig
impl Debug for SystemConfig
Source§impl Default for SystemConfig
impl Default for SystemConfig
Source§impl<'de> Deserialize<'de> for SystemConfig
impl<'de> Deserialize<'de> for SystemConfig
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Auto Trait Implementations§
impl Freeze for SystemConfig
impl RefUnwindSafe for SystemConfig
impl Send for SystemConfig
impl Sync for SystemConfig
impl Unpin for SystemConfig
impl UnsafeUnpin for SystemConfig
impl UnwindSafe for SystemConfig
Blanket Implementations§
impl<T> Allocation for T
§impl<U> As for U
impl<U> As for U
§fn as_<T>(self) -> Twhere
T: CastFrom<U>,
U: Sized,
fn as_<T>(self) -> Twhere
T: CastFrom<U>,
U: Sized,
self to type T. The semantics of numeric casting with the as operator are followed, so <T as As>::as_::<U> can be used in the same way as T as U for numeric conversions. Read moreSource§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Code for Twhere
T: Serialize + DeserializeOwned,
impl<T> Code for Twhere
T: Serialize + DeserializeOwned,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
§impl<T> Downcast for Twhere
T: AsAny + ?Sized,
impl<T> Downcast for Twhere
T: AsAny + ?Sized,
§fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
Any.§fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
Any.§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Layered].impl<T> LruValue for T
impl<T> MaybeSend for Twhere
T: Send,
Source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
Source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level.Source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n.Source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
RelabeledMetricVec::with_metric_level_relabel_n with metric_level set to
MetricLevel::Debug and relabel_num set to 1.