risingwave_common/util/
query_log.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use std::sync::LazyLock;
16use std::time::Duration;
17
18/// The target name for the root span while pgwire is handling a query.
19pub const PGWIRE_ROOT_SPAN_TARGET: &str = "pgwire_root_span";
20/// The target name for the event when pgwire finishes handling a query.
21pub const PGWIRE_QUERY_LOG: &str = "pgwire_query_log";
22/// The target name for the event when pgwire does not finish handling a query in time.
23pub const PGWIRE_SLOW_QUERY_LOG: &str = "pgwire_slow_query_log";
24
25/// The period of logging ongoing slow queries.
26pub static SLOW_QUERY_LOG_PERIOD: LazyLock<Duration> = LazyLock::new(|| {
27    std::env::var("RW_SLOW_QUERY_LOG_PERIOD_MS")
28        .ok()
29        .and_then(|s| s.parse().ok())
30        .map(Duration::from_millis)
31        .unwrap_or(Duration::from_secs(60))
32});
risingwave_common/util/query_log.rs

risingwave_common/util/
query_log.rs
