This is an automated email from the ASF dual-hosted git repository. gavinchou pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push: new 95608bb59f2 [regression](metrics) add a regression for version metrics (#45593) 95608bb59f2 is described below commit 95608bb59f23945ce838320cd98741e295214d8f Author: yagagagaga <zhangmi...@selectdb.com> AuthorDate: Tue Dec 24 21:12:02 2024 +0800 [regression](metrics) add a regression for version metrics (#45593) Related PR: #45490 --- .../suites/metrics_p0/test_version_metrics.groovy | 75 ++++++++++++++++++++++ 1 file changed, 75 insertions(+) diff --git a/regression-test/suites/metrics_p0/test_version_metrics.groovy b/regression-test/suites/metrics_p0/test_version_metrics.groovy new file mode 100644 index 00000000000..51f6cc8539d --- /dev/null +++ b/regression-test/suites/metrics_p0/test_version_metrics.groovy @@ -0,0 +1,75 @@ +// Licensed to the Apache Software Foundation (ASF) under one +// or more contributor license agreements. See the NOTICE file +// distributed with this work for additional information +// regarding copyright ownership. The ASF licenses this file +// to you under the Apache License, Version 2.0 (the +// "License"); you may not use this file except in compliance +// with the License. You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, +// software distributed under the License is distributed on an +// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +// KIND, either express or implied. See the License for the +// specific language governing permissions and limitations +// under the License. + +suite("test_version_metrics") { + httpTest { + endpoint context.config.feHttpAddress + uri "/metrics" + op "get" + check { code, body -> + logger.debug("code:${code} body:${body}"); + assertEquals(200, code) + assertTrue(body.contains("doris_fe_version")) + for (final def line in body.split("\n")) { + if (line.contains("doris_fe_version") && !line.contains("#")) { + assertTrue(Long.parseLong(line.split(" ")[1]) >= 0) + } + } + } + } + + def res = sql_return_maparray("show backends") + def beBrpcEndpoint = res[0].Host + ":" + res[0].BrpcPort + + httpTest { + endpoint beBrpcEndpoint + uri "/brpc_metrics" + op "get" + check { code, body -> + logger.debug("code:${code} body:${body}"); + assertEquals(200, code) + assertTrue(body.contains("doris_be_version")) + for (final def line in body.split("\n")) { + if (line.contains("doris_be_version") && !line.contains("#")) { + assertTrue(Long.parseLong(line.split(" ")[1]) >= 0) + } + } + } + } + + if (cluster.isRunning() && cluster.isCloudMode()) { + + def ms = cluster.getAllMetaservices().get(0) + def msEndpoint = ms.host + ":" + ms.httpPort + + httpTest { + endpoint msEndpoint + uri "/brpc_metrics" + op "get" + check { code, body -> + logger.debug("code:${code} body:${body}"); + assertEquals(200, code) + assertTrue(body.contains("doris_cloud_version")) + for (final def line in body.split("\n")) { + if (line.contains("doris_cloud_version") && !line.contains("#")) { + assertTrue(Long.parseLong(line.split(" ")[1]) >= 0) + } + } + } + } + } +} --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org