risingwave_common::session_config

Struct SessionConfig

source 
pub struct SessionConfig {
Show 49 fields
    implicit_flush: bool,
    create_compaction_group_for_mv: bool,
    query_mode: QueryMode,
    extra_float_digits: i32,
    application_name: String,
    date_style: String,
    batch_enable_lookup_join: bool,
    batch_enable_sort_agg: bool,
    batch_enable_distributed_dml: bool,
    max_split_range_gap: i32,
    search_path: SearchPath,
    visibility_mode: VisibilityMode,
    transaction_isolation: IsolationLevel,
    query_epoch: ConfigNonZeroU64,
    timezone: String,
    streaming_parallelism: ConfigNonZeroU64,
    streaming_enable_delta_join: bool,
    streaming_enable_bushy_join: bool,
    streaming_use_arrangement_backfill: bool,
    streaming_use_snapshot_backfill: bool,
    streaming_allow_jsonb_in_stream_key: bool,
    enable_join_ordering: bool,
    enable_two_phase_agg: bool,
    force_two_phase_agg: bool,
    enable_share_plan: bool,
    force_split_distinct_agg: bool,
    interval_style: String,
    batch_parallelism: ConfigNonZeroU64,
    server_version: String,
    server_version_num: i32,
    client_min_messages: String,
    client_encoding: String,
    sink_decouple: SinkDecouple,
    synchronize_seqscans: bool,
    statement_timeout: u32,
    idle_in_transaction_session_timeout: u32,
    lock_timeout: i32,
    cdc_source_wait_streaming_start_timeout: i32,
    row_security: bool,
    standard_conforming_strings: String,
    backfill_rate_limit: i32,
    source_rate_limit: i32,
    streaming_over_window_cache_policy: OverWindowCachePolicy,
    background_ddl: bool,
    streaming_use_shared_source: bool,
    server_encoding: String,
    bytea_output: String,
    bypass_cluster_limits: bool,
    streaming_max_parallelism: usize,

}
Expand description

This is the Session Config of RisingWave.

Fields§

§implicit_flush: bool

If RW_IMPLICIT_FLUSH is on, then every INSERT/UPDATE/DELETE statement will block until the entire dataflow is refreshed. In other words, every related table & MV will be able to see the write.

§create_compaction_group_for_mv: bool

If CREATE_COMPACTION_GROUP_FOR_MV is on, dedicated compaction groups will be created in MV creation.

§query_mode: QueryMode

A temporary config variable to force query running in either local or distributed mode. The default value is auto which means let the system decide to run batch queries in local or distributed mode automatically.

§extra_float_digits: i32

Sets the number of digits displayed for floating-point values. See https://www.postgresql.org/docs/current/runtime-config-client.html#:~:text=for%20more%20information.-,extra_float_digits,-(integer)

§application_name: String

Sets the application name to be reported in statistics and logs. See https://www.postgresql.org/docs/14/runtime-config-logging.html#:~:text=What%20to%20Log-,application_name,-(string)

§date_style: String

It is typically set by an application upon connection to the server. see https://www.postgresql.org/docs/current/runtime-config-client.html#GUC-DATESTYLE

§batch_enable_lookup_join: bool

Force the use of lookup join instead of hash join when possible for local batch execution.

§batch_enable_sort_agg: bool

Enable usage of sortAgg instead of hash agg when order property is satisfied in batch execution

§batch_enable_distributed_dml: bool

Enable distributed DML, so an insert, delete, and update statement can be executed in a distributed way (e.g. running in multiple compute nodes). No atomicity guarantee in this mode. Its goal is to gain the best ingestion performance for initial batch ingestion where users always can drop their table when failure happens.

§max_split_range_gap: i32

The max gap allowed to transform small range scan into multi point lookup.

§search_path: SearchPath

Sets the order in which schemas are searched when an object (table, data type, function, etc.) is referenced by a simple name with no schema specified. See https://www.postgresql.org/docs/14/runtime-config-client.html#GUC-SEARCH-PATH

§visibility_mode: VisibilityMode

If VISIBILITY_MODE is all, we will support querying data without checkpoint.

§transaction_isolation: IsolationLevel

See https://www.postgresql.org/docs/current/transaction-iso.html

§query_epoch: ConfigNonZeroU64

Select as of specific epoch. Sets the historical epoch for querying data. If 0, querying latest data.

§timezone: String

Session timezone. Defaults to UTC.

§streaming_parallelism: ConfigNonZeroU64

The execution parallelism for streaming queries, including tables, materialized views, indexes, and sinks. Defaults to 0, which means they will be scheduled adaptively based on the cluster size.

If a non-zero value is set, streaming queries will be scheduled to use a fixed number of parallelism. Note that the value will be bounded at STREAMING_MAX_PARALLELISM.

§streaming_enable_delta_join: bool

Enable delta join for streaming queries. Defaults to false.

§streaming_enable_bushy_join: bool

Enable bushy join for streaming queries. Defaults to true.

§streaming_use_arrangement_backfill: bool

Enable arrangement backfill for streaming queries. Defaults to true. When set to true, the parallelism of the upstream fragment will be decoupled from the parallelism of the downstream scan fragment. Or more generally, the parallelism of the upstream table / index / mv will be decoupled from the parallelism of the downstream table / index / mv / sink.

§streaming_use_snapshot_backfill: bool§streaming_allow_jsonb_in_stream_key: bool

Allow jsonb in stream key

§enable_join_ordering: bool

Enable join ordering for streaming and batch queries. Defaults to true.

§enable_two_phase_agg: bool

Enable two phase agg optimization. Defaults to true. Setting this to true will always set FORCE_TWO_PHASE_AGG to false.

§force_two_phase_agg: bool

Force two phase agg optimization whenever there’s a choice between optimizations. Defaults to false. Setting this to true will always set ENABLE_TWO_PHASE_AGG to false.

§enable_share_plan: bool

Enable sharing of common sub-plans. This means that DAG structured query plans can be constructed, rather than only tree structured query plans.

§force_split_distinct_agg: bool

Enable split distinct agg

§interval_style: String

See https://www.postgresql.org/docs/current/runtime-config-client.html#GUC-INTERVALSTYLE

§batch_parallelism: ConfigNonZeroU64

If BATCH_PARALLELISM is non-zero, batch queries will use this parallelism.

§server_version: String

The version of PostgreSQL that Risingwave claims to be.

§server_version_num: i32

The version of PostgreSQL that Risingwave claims to be.

§client_min_messages: String

see https://www.postgresql.org/docs/15/runtime-config-client.html#GUC-CLIENT-MIN-MESSAGES

§client_encoding: String

see https://www.postgresql.org/docs/15/runtime-config-client.html#GUC-CLIENT-ENCODING

§sink_decouple: SinkDecouple

Enable decoupling sink and internal streaming graph or not

§synchronize_seqscans: bool

See https://www.postgresql.org/docs/current/runtime-config-compatible.html#RUNTIME-CONFIG-COMPATIBLE-VERSION Unused in RisingWave, support for compatibility.

§statement_timeout: u32

Abort query statement that takes more than the specified amount of time in sec. If log_min_error_statement is set to ERROR or lower, the statement that timed out will also be logged. If this value is specified without units, it is taken as milliseconds. A value of zero (the default) disables the timeout.

§idle_in_transaction_session_timeout: u32

Terminate any session that has been idle (that is, waiting for a client query) within an open transaction for longer than the specified amount of time in milliseconds.

§lock_timeout: i32

See https://www.postgresql.org/docs/current/runtime-config-client.html#GUC-LOCK-TIMEOUT Unused in RisingWave, support for compatibility.

§cdc_source_wait_streaming_start_timeout: i32

For limiting the startup time of a shareable CDC streaming source when the source is being created. Unit: seconds.

§row_security: bool

see https://www.postgresql.org/docs/current/runtime-config-client.html#GUC-ROW-SECURITY. Unused in RisingWave, support for compatibility.

§standard_conforming_strings: String

see https://www.postgresql.org/docs/current/runtime-config-client.html#GUC-STANDARD-CONFORMING-STRINGS

§backfill_rate_limit: i32

Set streaming rate limit (rows per second) for each parallelism for mv / source / sink backfilling If set to -1, disable rate limit. If set to 0, this pauses the snapshot read / source read.

§source_rate_limit: i32

Set streaming rate limit (rows per second) for each parallelism for mv / source backfilling, source reads. If set to -1, disable rate limit. If set to 0, this pauses the snapshot read / source read.

§streaming_over_window_cache_policy: OverWindowCachePolicy

Cache policy for partition cache in streaming over window. Can be “full”, “recent”, “recent_first_n” or “recent_last_n”.

§background_ddl: bool

Run DDL statements in background

§streaming_use_shared_source: bool

Enable shared source. Currently only for Kafka.

When enabled, CREATE SOURCE will create a source streaming job, and CREATE MATERIALIZED VIEWS from the source will forward the data from the same source streaming job, and also backfill prior data from the external source.

§server_encoding: String

Shows the server-side character set encoding. At present, this parameter can be shown but not set, because the encoding is determined at database creation time.

§bytea_output: String§bypass_cluster_limits: bool

Bypass checks on cluster limits

When enabled, CREATE MATERIALIZED VIEW will not fail if the cluster limit is hit.

§streaming_max_parallelism: usize

The maximum number of parallelism a streaming query can use. Defaults to 256.

Compared to STREAMING_PARALLELISM, which configures the initial parallelism, this configures the maximum parallelism a streaming query can use in the future, if the cluster size changes or users manually change the parallelism with ALTER .. SET PARALLELISM.

It’s not always a good idea to set this to a very large number, as it may cause performance degradation when performing range scans on the table or the materialized view.

Implementations§

source§

impl SessionConfig

source

fn new() -> Self

source

pub fn alias_to_entry_name(key_name: &str) -> String

source

pub fn implicit_flush_str(&self) -> String

Get a value string of parameter stringify! (implicit_flush)

source

pub fn implicit_flush(&self) -> bool

Get a typed value of parameter stringify! (implicit_flush)

source

pub fn create_compaction_group_for_mv_str(&self) -> String

Get a value string of parameter stringify! (create_compaction_group_for_mv)

source

pub fn create_compaction_group_for_mv(&self) -> bool

Get a typed value of parameter stringify! (create_compaction_group_for_mv)

source

pub fn query_mode_str(&self) -> String

Get a value string of parameter stringify! (query_mode)

source

pub fn query_mode(&self) -> QueryMode

Get a typed value of parameter stringify! (query_mode)

source

pub fn extra_float_digits_str(&self) -> String

Get a value string of parameter stringify! (extra_float_digits)

source

pub fn extra_float_digits(&self) -> i32

Get a typed value of parameter stringify! (extra_float_digits)

source

pub fn application_name_str(&self) -> String

Get a value string of parameter stringify! (application_name)

source

pub fn application_name(&self) -> String

Get a typed value of parameter stringify! (application_name)

source

pub fn date_style_str(&self) -> String

Get a value string of parameter “datestyle”

source

pub fn date_style(&self) -> String

Get a typed value of parameter “datestyle”

source

pub fn batch_enable_lookup_join_str(&self) -> String

Get a value string of parameter stringify! (batch_enable_lookup_join)

source

pub fn batch_enable_lookup_join(&self) -> bool

Get a typed value of parameter stringify! (batch_enable_lookup_join)

source

pub fn batch_enable_sort_agg_str(&self) -> String

Get a value string of parameter stringify! (batch_enable_sort_agg)

source

pub fn batch_enable_sort_agg(&self) -> bool

Get a typed value of parameter stringify! (batch_enable_sort_agg)

source

pub fn batch_enable_distributed_dml_str(&self) -> String

Get a value string of parameter “batch_enable_distributed_dml”

source

pub fn batch_enable_distributed_dml(&self) -> bool

Get a typed value of parameter “batch_enable_distributed_dml”

source

pub fn max_split_range_gap_str(&self) -> String

Get a value string of parameter stringify! (max_split_range_gap)

source

pub fn max_split_range_gap(&self) -> i32

Get a typed value of parameter stringify! (max_split_range_gap)

source

pub fn search_path_str(&self) -> String

Get a value string of parameter stringify! (search_path)

source

pub fn search_path(&self) -> SearchPath

Get a typed value of parameter stringify! (search_path)

source

pub fn visibility_mode_str(&self) -> String

Get a value string of parameter stringify! (visibility_mode)

source

pub fn visibility_mode(&self) -> VisibilityMode

Get a typed value of parameter stringify! (visibility_mode)

source

pub fn transaction_isolation_str(&self) -> String

Get a value string of parameter stringify! (transaction_isolation)

source

pub fn transaction_isolation(&self) -> IsolationLevel

Get a typed value of parameter stringify! (transaction_isolation)

source

pub fn query_epoch_str(&self) -> String

Get a value string of parameter stringify! (query_epoch)

source

pub fn query_epoch(&self) -> ConfigNonZeroU64

Get a typed value of parameter stringify! (query_epoch)

source

pub fn timezone_str(&self) -> String

Get a value string of parameter stringify! (timezone)

source

pub fn timezone(&self) -> String

Get a typed value of parameter stringify! (timezone)

source

pub fn streaming_parallelism_str(&self) -> String

Get a value string of parameter stringify! (streaming_parallelism)

source

pub fn streaming_parallelism(&self) -> ConfigNonZeroU64

Get a typed value of parameter stringify! (streaming_parallelism)

source

pub fn streaming_enable_delta_join_str(&self) -> String

Get a value string of parameter stringify! (streaming_enable_delta_join)

source

pub fn streaming_enable_delta_join(&self) -> bool

Get a typed value of parameter stringify! (streaming_enable_delta_join)

source

pub fn streaming_enable_bushy_join_str(&self) -> String

Get a value string of parameter stringify! (streaming_enable_bushy_join)

source

pub fn streaming_enable_bushy_join(&self) -> bool

Get a typed value of parameter stringify! (streaming_enable_bushy_join)

source

pub fn streaming_use_arrangement_backfill_str(&self) -> String

Get a value string of parameter stringify! (streaming_use_arrangement_backfill)

source

pub fn streaming_use_arrangement_backfill(&self) -> bool

Get a typed value of parameter stringify! (streaming_use_arrangement_backfill)

source

pub fn streaming_use_snapshot_backfill_str(&self) -> String

Get a value string of parameter stringify! (streaming_use_snapshot_backfill)

source

pub fn streaming_use_snapshot_backfill(&self) -> bool

Get a typed value of parameter stringify! (streaming_use_snapshot_backfill)

source

pub fn streaming_allow_jsonb_in_stream_key_str(&self) -> String

Get a value string of parameter stringify! (streaming_allow_jsonb_in_stream_key)

source

pub fn streaming_allow_jsonb_in_stream_key(&self) -> bool

Get a typed value of parameter stringify! (streaming_allow_jsonb_in_stream_key)

source

pub fn enable_join_ordering_str(&self) -> String

Get a value string of parameter stringify! (enable_join_ordering)

source

pub fn enable_join_ordering(&self) -> bool

Get a typed value of parameter stringify! (enable_join_ordering)

source

pub fn enable_two_phase_agg_str(&self) -> String

Get a value string of parameter stringify! (enable_two_phase_agg)

source

pub fn enable_two_phase_agg(&self) -> bool

Get a typed value of parameter stringify! (enable_two_phase_agg)

source

pub fn force_two_phase_agg_str(&self) -> String

Get a value string of parameter stringify! (force_two_phase_agg)

source

pub fn force_two_phase_agg(&self) -> bool

Get a typed value of parameter stringify! (force_two_phase_agg)

source

pub fn enable_share_plan_str(&self) -> String

Get a value string of parameter stringify! (enable_share_plan)

source

pub fn enable_share_plan(&self) -> bool

Get a typed value of parameter stringify! (enable_share_plan)

source

pub fn force_split_distinct_agg_str(&self) -> String

Get a value string of parameter stringify! (force_split_distinct_agg)

source

pub fn force_split_distinct_agg(&self) -> bool

Get a typed value of parameter stringify! (force_split_distinct_agg)

source

pub fn interval_style_str(&self) -> String

Get a value string of parameter “intervalstyle”

source

pub fn interval_style(&self) -> String

Get a typed value of parameter “intervalstyle”

source

pub fn batch_parallelism_str(&self) -> String

Get a value string of parameter stringify! (batch_parallelism)

source

pub fn batch_parallelism(&self) -> ConfigNonZeroU64

Get a typed value of parameter stringify! (batch_parallelism)

source

pub fn server_version_str(&self) -> String

Get a value string of parameter stringify! (server_version)

source

pub fn server_version(&self) -> String

Get a typed value of parameter stringify! (server_version)

source

pub fn server_version_num_str(&self) -> String

Get a value string of parameter stringify! (server_version_num)

source

pub fn server_version_num(&self) -> i32

Get a typed value of parameter stringify! (server_version_num)

source

pub fn client_min_messages_str(&self) -> String

Get a value string of parameter stringify! (client_min_messages)

source

pub fn client_min_messages(&self) -> String

Get a typed value of parameter stringify! (client_min_messages)

source

pub fn client_encoding_str(&self) -> String

Get a value string of parameter stringify! (client_encoding)

source

pub fn client_encoding(&self) -> String

Get a typed value of parameter stringify! (client_encoding)

source

pub fn sink_decouple_str(&self) -> String

Get a value string of parameter stringify! (sink_decouple)

source

pub fn sink_decouple(&self) -> SinkDecouple

Get a typed value of parameter stringify! (sink_decouple)

source

pub fn synchronize_seqscans_str(&self) -> String

Get a value string of parameter stringify! (synchronize_seqscans)

source

pub fn synchronize_seqscans(&self) -> bool

Get a typed value of parameter stringify! (synchronize_seqscans)

source

pub fn statement_timeout_str(&self) -> String

Get a value string of parameter stringify! (statement_timeout)

source

pub fn statement_timeout(&self) -> u32

Get a typed value of parameter stringify! (statement_timeout)

source

pub fn idle_in_transaction_session_timeout_str(&self) -> String

Get a value string of parameter stringify! (idle_in_transaction_session_timeout)

source

pub fn idle_in_transaction_session_timeout(&self) -> u32

Get a typed value of parameter stringify! (idle_in_transaction_session_timeout)

source

pub fn lock_timeout_str(&self) -> String

Get a value string of parameter stringify! (lock_timeout)

source

pub fn lock_timeout(&self) -> i32

Get a typed value of parameter stringify! (lock_timeout)

source

pub fn cdc_source_wait_streaming_start_timeout_str(&self) -> String

Get a value string of parameter stringify! (cdc_source_wait_streaming_start_timeout)

source

pub fn cdc_source_wait_streaming_start_timeout(&self) -> i32

Get a typed value of parameter stringify! (cdc_source_wait_streaming_start_timeout)

source

pub fn row_security_str(&self) -> String

Get a value string of parameter stringify! (row_security)

source

pub fn row_security(&self) -> bool

Get a typed value of parameter stringify! (row_security)

source

pub fn standard_conforming_strings_str(&self) -> String

Get a value string of parameter stringify! (standard_conforming_strings)

source

pub fn standard_conforming_strings(&self) -> String

Get a typed value of parameter stringify! (standard_conforming_strings)

source

pub fn backfill_rate_limit_str(&self) -> String

Get a value string of parameter stringify! (backfill_rate_limit)

source

pub fn backfill_rate_limit(&self) -> i32

Get a typed value of parameter stringify! (backfill_rate_limit)

source

pub fn source_rate_limit_str(&self) -> String

Get a value string of parameter stringify! (source_rate_limit)

source

pub fn source_rate_limit(&self) -> i32

Get a typed value of parameter stringify! (source_rate_limit)

source

pub fn streaming_over_window_cache_policy_str(&self) -> String

Get a value string of parameter stringify! (streaming_over_window_cache_policy)

source

pub fn streaming_over_window_cache_policy(&self) -> OverWindowCachePolicy

Get a typed value of parameter stringify! (streaming_over_window_cache_policy)

source

pub fn background_ddl_str(&self) -> String

Get a value string of parameter stringify! (background_ddl)

source

pub fn background_ddl(&self) -> bool

Get a typed value of parameter stringify! (background_ddl)

source

pub fn streaming_use_shared_source_str(&self) -> String

Get a value string of parameter stringify! (streaming_use_shared_source)

source

pub fn streaming_use_shared_source(&self) -> bool

Get a typed value of parameter stringify! (streaming_use_shared_source)

source

pub fn server_encoding_str(&self) -> String

Get a value string of parameter stringify! (server_encoding)

source

pub fn server_encoding(&self) -> String

Get a typed value of parameter stringify! (server_encoding)

source

pub fn bytea_output_str(&self) -> String

Get a value string of parameter stringify! (bytea_output)

source

pub fn bytea_output(&self) -> String

Get a typed value of parameter stringify! (bytea_output)

source

pub fn bypass_cluster_limits_str(&self) -> String

Get a value string of parameter stringify! (bypass_cluster_limits)

source

pub fn bypass_cluster_limits(&self) -> bool

Get a typed value of parameter stringify! (bypass_cluster_limits)

source

pub fn streaming_max_parallelism_str(&self) -> String

Get a value string of parameter stringify! (streaming_max_parallelism)

source

pub fn streaming_max_parallelism(&self) -> usize

Get a typed value of parameter stringify! (streaming_max_parallelism)

source

pub fn set_implicit_flush_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (implicit_flush) by a string.

source

pub fn set_implicit_flush( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (implicit_flush) by a typed value.

source

pub fn set_create_compaction_group_for_mv_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (create_compaction_group_for_mv) by a string.

source

pub fn set_create_compaction_group_for_mv( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (create_compaction_group_for_mv) by a typed value.

source

pub fn set_query_mode_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (query_mode) by a string.

source

pub fn set_query_mode( &mut self, val: QueryMode, reporter: &mut impl ConfigReporter, ) -> Result<QueryMode, SessionConfigError>

Set parameter stringify! (query_mode) by a typed value.

source

pub fn set_extra_float_digits_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (extra_float_digits) by a string.

source

pub fn set_extra_float_digits( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (extra_float_digits) by a typed value.

source

pub fn set_application_name_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (application_name) by a string.

source

pub fn set_application_name( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (application_name) by a typed value.

source

pub fn set_date_style_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter “datestyle” by a string.

source

pub fn set_date_style( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter “datestyle” by a typed value.

source

pub fn set_batch_enable_lookup_join_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (batch_enable_lookup_join) by a string.

source

pub fn set_batch_enable_lookup_join( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (batch_enable_lookup_join) by a typed value.

source

pub fn set_batch_enable_sort_agg_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (batch_enable_sort_agg) by a string.

source

pub fn set_batch_enable_sort_agg( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (batch_enable_sort_agg) by a typed value.

source

pub fn set_batch_enable_distributed_dml_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter “batch_enable_distributed_dml” by a string.

source

pub fn set_batch_enable_distributed_dml( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter “batch_enable_distributed_dml” by a typed value.

source

pub fn set_max_split_range_gap_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (max_split_range_gap) by a string.

source

pub fn set_max_split_range_gap( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (max_split_range_gap) by a typed value.

source

pub fn set_search_path_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (search_path) by a string.

source

pub fn set_search_path( &mut self, val: SearchPath, reporter: &mut impl ConfigReporter, ) -> Result<SearchPath, SessionConfigError>

Set parameter stringify! (search_path) by a typed value.

source

pub fn set_visibility_mode_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (visibility_mode) by a string.

source

pub fn set_visibility_mode( &mut self, val: VisibilityMode, reporter: &mut impl ConfigReporter, ) -> Result<VisibilityMode, SessionConfigError>

Set parameter stringify! (visibility_mode) by a typed value.

source

pub fn set_transaction_isolation_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (transaction_isolation) by a string.

source

pub fn set_transaction_isolation( &mut self, val: IsolationLevel, reporter: &mut impl ConfigReporter, ) -> Result<IsolationLevel, SessionConfigError>

Set parameter stringify! (transaction_isolation) by a typed value.

source

pub fn set_query_epoch_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (query_epoch) by a string.

source

pub fn set_query_epoch( &mut self, val: ConfigNonZeroU64, reporter: &mut impl ConfigReporter, ) -> Result<ConfigNonZeroU64, SessionConfigError>

Set parameter stringify! (query_epoch) by a typed value.

source

pub fn set_timezone_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (timezone) by a string.

source

pub fn set_timezone( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (timezone) by a typed value.

source

pub fn set_streaming_parallelism_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_parallelism) by a string.

source

pub fn set_streaming_parallelism( &mut self, val: ConfigNonZeroU64, reporter: &mut impl ConfigReporter, ) -> Result<ConfigNonZeroU64, SessionConfigError>

Set parameter stringify! (streaming_parallelism) by a typed value.

source

pub fn set_streaming_enable_delta_join_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_enable_delta_join) by a string.

source

pub fn set_streaming_enable_delta_join( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_enable_delta_join) by a typed value.

source

pub fn set_streaming_enable_bushy_join_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_enable_bushy_join) by a string.

source

pub fn set_streaming_enable_bushy_join( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_enable_bushy_join) by a typed value.

source

pub fn set_streaming_use_arrangement_backfill_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_use_arrangement_backfill) by a string.

source

pub fn set_streaming_use_arrangement_backfill( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_use_arrangement_backfill) by a typed value.

source

pub fn set_streaming_use_snapshot_backfill_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_use_snapshot_backfill) by a string.

source

pub fn set_streaming_use_snapshot_backfill( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_use_snapshot_backfill) by a typed value.

source

pub fn set_streaming_allow_jsonb_in_stream_key_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_allow_jsonb_in_stream_key) by a string.

source

pub fn set_streaming_allow_jsonb_in_stream_key( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_allow_jsonb_in_stream_key) by a typed value.

source

pub fn set_enable_join_ordering_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (enable_join_ordering) by a string.

source

pub fn set_enable_join_ordering( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (enable_join_ordering) by a typed value.

source

pub fn set_enable_two_phase_agg_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (enable_two_phase_agg) by a string.

source

pub fn set_enable_two_phase_agg_inner( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (enable_two_phase_agg) by a typed value.

source

pub fn set_force_two_phase_agg_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (force_two_phase_agg) by a string.

source

pub fn set_force_two_phase_agg_inner( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (force_two_phase_agg) by a typed value.

source

pub fn set_enable_share_plan_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (enable_share_plan) by a string.

source

pub fn set_enable_share_plan( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (enable_share_plan) by a typed value.

source

pub fn set_force_split_distinct_agg_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (force_split_distinct_agg) by a string.

source

pub fn set_force_split_distinct_agg( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (force_split_distinct_agg) by a typed value.

source

pub fn set_interval_style_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter “intervalstyle” by a string.

source

pub fn set_interval_style( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter “intervalstyle” by a typed value.

source

pub fn set_batch_parallelism_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (batch_parallelism) by a string.

source

pub fn set_batch_parallelism( &mut self, val: ConfigNonZeroU64, reporter: &mut impl ConfigReporter, ) -> Result<ConfigNonZeroU64, SessionConfigError>

Set parameter stringify! (batch_parallelism) by a typed value.

source

pub fn set_server_version_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (server_version) by a string.

source

pub fn set_server_version( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (server_version) by a typed value.

source

pub fn set_server_version_num_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (server_version_num) by a string.

source

pub fn set_server_version_num( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (server_version_num) by a typed value.

source

pub fn set_client_min_messages_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (client_min_messages) by a string.

source

pub fn set_client_min_messages( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (client_min_messages) by a typed value.

source

pub fn set_client_encoding_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (client_encoding) by a string.

source

pub fn set_client_encoding( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (client_encoding) by a typed value.

source

pub fn set_sink_decouple_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (sink_decouple) by a string.

source

pub fn set_sink_decouple( &mut self, val: SinkDecouple, reporter: &mut impl ConfigReporter, ) -> Result<SinkDecouple, SessionConfigError>

Set parameter stringify! (sink_decouple) by a typed value.

source

pub fn set_synchronize_seqscans_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (synchronize_seqscans) by a string.

source

pub fn set_synchronize_seqscans( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (synchronize_seqscans) by a typed value.

source

pub fn set_statement_timeout_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (statement_timeout) by a string.

source

pub fn set_statement_timeout( &mut self, val: u32, reporter: &mut impl ConfigReporter, ) -> Result<u32, SessionConfigError>

Set parameter stringify! (statement_timeout) by a typed value.

source

pub fn set_idle_in_transaction_session_timeout_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (idle_in_transaction_session_timeout) by a string.

source

pub fn set_idle_in_transaction_session_timeout( &mut self, val: u32, reporter: &mut impl ConfigReporter, ) -> Result<u32, SessionConfigError>

Set parameter stringify! (idle_in_transaction_session_timeout) by a typed value.

source

pub fn set_lock_timeout_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (lock_timeout) by a string.

source

pub fn set_lock_timeout( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (lock_timeout) by a typed value.

source

pub fn set_cdc_source_wait_streaming_start_timeout_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (cdc_source_wait_streaming_start_timeout) by a string.

source

pub fn set_cdc_source_wait_streaming_start_timeout( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (cdc_source_wait_streaming_start_timeout) by a typed value.

source

pub fn set_row_security_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (row_security) by a string.

source

pub fn set_row_security( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (row_security) by a typed value.

source

pub fn set_standard_conforming_strings_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (standard_conforming_strings) by a string.

source

pub fn set_standard_conforming_strings( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (standard_conforming_strings) by a typed value.

source

pub fn set_backfill_rate_limit_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (backfill_rate_limit) by a string.

source

pub fn set_backfill_rate_limit( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (backfill_rate_limit) by a typed value.

source

pub fn set_source_rate_limit_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (source_rate_limit) by a string.

source

pub fn set_source_rate_limit( &mut self, val: i32, reporter: &mut impl ConfigReporter, ) -> Result<i32, SessionConfigError>

Set parameter stringify! (source_rate_limit) by a typed value.

source

pub fn set_streaming_over_window_cache_policy_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_over_window_cache_policy) by a string.

source

pub fn set_streaming_over_window_cache_policy( &mut self, val: OverWindowCachePolicy, reporter: &mut impl ConfigReporter, ) -> Result<OverWindowCachePolicy, SessionConfigError>

Set parameter stringify! (streaming_over_window_cache_policy) by a typed value.

source

pub fn set_background_ddl_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (background_ddl) by a string.

source

pub fn set_background_ddl( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (background_ddl) by a typed value.

source

pub fn set_streaming_use_shared_source_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_use_shared_source) by a string.

source

pub fn set_streaming_use_shared_source( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (streaming_use_shared_source) by a typed value.

source

pub fn set_server_encoding_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (server_encoding) by a string.

source

pub fn set_server_encoding( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (server_encoding) by a typed value.

source

pub fn set_bytea_output_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (bytea_output) by a string.

source

pub fn set_bytea_output( &mut self, val: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (bytea_output) by a typed value.

source

pub fn set_bypass_cluster_limits_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (bypass_cluster_limits) by a string.

source

pub fn set_bypass_cluster_limits( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Set parameter stringify! (bypass_cluster_limits) by a typed value.

source

pub fn set_streaming_max_parallelism_str( &mut self, val: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set parameter stringify! (streaming_max_parallelism) by a string.

source

pub fn set_streaming_max_parallelism( &mut self, val: usize, reporter: &mut impl ConfigReporter, ) -> Result<usize, SessionConfigError>

Set parameter stringify! (streaming_max_parallelism) by a typed value.

source

pub fn reset_implicit_flush( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_create_compaction_group_for_mv( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_query_mode(&mut self, reporter: &mut impl ConfigReporter) -> String

source

pub fn reset_extra_float_digits( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_application_name( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_date_style(&mut self, reporter: &mut impl ConfigReporter) -> String

source

pub fn reset_batch_enable_lookup_join( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_batch_enable_sort_agg( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_batch_enable_distributed_dml( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_max_split_range_gap( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_search_path( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_visibility_mode( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_transaction_isolation( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_query_epoch( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_timezone(&mut self, reporter: &mut impl ConfigReporter) -> String

source

pub fn reset_streaming_parallelism( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_enable_delta_join( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_enable_bushy_join( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_use_arrangement_backfill( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_use_snapshot_backfill( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_allow_jsonb_in_stream_key( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_enable_join_ordering( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_enable_two_phase_agg( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_force_two_phase_agg( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_enable_share_plan( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_force_split_distinct_agg( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_interval_style( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_batch_parallelism( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_server_version( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_server_version_num( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_client_min_messages( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_client_encoding( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_sink_decouple( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_synchronize_seqscans( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_statement_timeout( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_idle_in_transaction_session_timeout( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_lock_timeout( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_cdc_source_wait_streaming_start_timeout( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_row_security( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_standard_conforming_strings( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_backfill_rate_limit( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_source_rate_limit( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_over_window_cache_policy( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_background_ddl( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_use_shared_source( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_server_encoding( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_bytea_output( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_bypass_cluster_limits( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn reset_streaming_max_parallelism( &mut self, reporter: &mut impl ConfigReporter, ) -> String

source

pub fn set( &mut self, key_name: &str, value: String, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Set a parameter given it’s name and value string.

source

pub fn get(&self, key_name: &str) -> Result<String, SessionConfigError>

Get a parameter by it’s name.

source

pub fn reset( &mut self, key_name: &str, reporter: &mut impl ConfigReporter, ) -> Result<String, SessionConfigError>

Reset a parameter by it’s name.

source

pub fn show_all(&self) -> Vec<VariableInfo>

Show all parameters except those specified NO_SHOW_ALL.

source

pub fn list_all(&self) -> Vec<VariableInfo>

List all parameters

source

pub fn contains_param(key_name: &str) -> bool

Check if SessionConfig has a parameter.

source

pub fn check_no_alter_sys(key_name: &str) -> Result<bool, SessionConfigError>

Check if SessionConfig has a parameter.

source§

impl SessionConfig

source

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

source§

impl SessionConfig

source

pub fn set_force_two_phase_agg( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

source

pub fn set_enable_two_phase_agg( &mut self, val: bool, reporter: &mut impl ConfigReporter, ) -> Result<bool, SessionConfigError>

Trait Implementations§

source§

impl Clone for SessionConfig

source§

fn clone(&self) -> SessionConfig

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for SessionConfig

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for SessionConfig

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl<'de> Deserialize<'de> for SessionConfig

source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl PartialEq for SessionConfig

source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

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

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

impl Serialize for SessionConfig

source§

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

Serialize this value into the given Serde serializer. Read more
source§

impl StructuralPartialEq for SessionConfig

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> CloneToUninit for T
where T: Clone,

source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> FromRef<T> for T
where T: Clone,

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

impl<T> FutureExt for T

§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts 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 more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts 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
source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
§

impl<T> IntoResult<T> for T

§

type Err = Infallible

§

fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>

source§

impl<M> MetricVecRelabelExt for M

source§

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level.
source§

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level_relabel_n.
source§

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level_relabel_n with metric_level set to MetricLevel::Debug and relabel_num set to 1.
§

impl<T> Pointable for T

§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same for T

source§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

source§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

§

impl<T> DevConfig for T
where T: Send + Sync + 'static + Debug,

source§

impl<T> LruValue for T
where T: Send + Sync,

§

impl<T> StorageValue for T
where T: Value + Serialize + DeserializeOwned,

§

impl<T> Value for T
where T: Send + Sync + 'static,