Skip to content

Commit

Permalink
[regression](metrics) add a regression for version metrics (#45593)
Browse files Browse the repository at this point in the history
Related PR: #45490
  • Loading branch information
yagagagaga authored Dec 24, 2024
1 parent 2b365e5 commit 95608bb
Showing 1 changed file with 75 additions and 0 deletions.
75 changes: 75 additions & 0 deletions regression-test/suites/metrics_p0/test_version_metrics.groovy
Original file line number Diff line number Diff line change
@@ -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)
}
}
}
}
}
}

0 comments on commit 95608bb

Please sign in to comment.