pmdaopentelemetry: new pmda for opentelemetry metrics

Addition of OpenTelemetry PMDA - domain num 88. Supports
ingestion of OpenTelemetry data and conversion to PCP
metrics. PMDA supports dynamic metric addition and
removal congruent to source entries in the configuration
directory. Relevent QA tests were added. Addition
and update of new pmdaopentelemetry manpage.

Author: lmchilton

build/rpm/GNUmakefile

@@ -76,6 +76,7 @@ pcp.spec: pcp.spec.in
 	    -e's|@pmda_infiniband@|$(PMDA_INFINIBAND)|g' \
 	    -e's|@pmda_perfevent@|$(PMDA_PERFEVENT)|g' \
 	    -e's|@pmda_openmetrics@|$(PMDA_OPENMETRICS)|g' \
+	    -e's|@pmda_opentelemetry@|$(PMDA_OPENTELEMETRY)|g' \
 	    -e's|@pmda_libvirt@|$(PMDA_LIBVIRT)|g' \
 	    -e's|@pmda_lio@|$(PMDA_LIO)|g' \
 	    -e's|@pmda_json@|$(PMDA_JSON)|g' \

configure

@@ -827,6 +827,7 @@ QMAKE
 PMDA_RESCTRL
 PMDA_LIBVIRT
 PMDA_MSSQL
+PMDA_OPENTELEMETRY
 PMDA_OPENMETRICS
 PMDA_LIO
 PMDA_NUTCRACKER
@@ -9720,6 +9721,19 @@ if $pmda_openmetrics; then { printf "%s\n" "$as_me:${as_lineno-$LINENO}: result:
 printf "%s\n" "yes" >&6; }; else { printf "%s\n" "$as_me:${as_lineno-$LINENO}: result: no" >&5
 printf "%s\n" "no" >&6; }; fi
 
+{ printf "%s\n" "$as_me:${as_lineno-$LINENO}: checking if the OpenTelemetry PMDA should be included" >&5
+printf %s "checking if the OpenTelemetry PMDA should be included... " >&6; }
+pmda_opentelemetry=false
+if test "$have_python" = true
+then
+    $have_python_requests && $have_python_OrderedDict && pmda_opentelemetry=true
+fi
+PMDA_OPENTELEMETRY=$pmda_opentelemetry
+
+if $pmda_opentelemetry; then { printf "%s\n" "$as_me:${as_lineno-$LINENO}: result: yes" >&5
+printf "%s\n" "yes" >&6; }; else { printf "%s\n" "$as_me:${as_lineno-$LINENO}: result: no" >&5
+printf "%s\n" "no" >&6; }; fi
+
 { printf "%s\n" "$as_me:${as_lineno-$LINENO}: checking if the SQL Server PMDA should be included" >&5
 printf %s "checking if the SQL Server PMDA should be included... " >&6; }
 pmda_mssql=false

configure.ac

@@ -14,6 +14,8 @@ dnl or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 dnl for more details.
 dnl
 
+configopts="`rpmbuild --eval '--exec-prefix=%{_exec_prefix} --bindir=%{_bindir} --sbindir=%{_sbindir} --sysconfdir=%{_sysconfdir} --datadir=%{_datadir} --includedir=%{_includedir} --libdir=%{_libdir} --libexecdir=%{_libexecdir} --localstatedir=%{_localstatedir} --sharedstatedir=%{_sharedstatedir} --mandir=%{_mandir} --prefix=%{_prefix}' 2>/dev/null`"
+
 dnl unpacking check - this file must exist
 AC_INIT
 AC_CONFIG_SRCDIR([src/include/pcp/pmapi.h])
@@ -1522,6 +1524,15 @@ fi
 AC_SUBST(PMDA_OPENMETRICS, $pmda_openmetrics)
 if $pmda_openmetrics; then AC_MSG_RESULT(yes); else AC_MSG_RESULT(no); fi
 
+AC_MSG_CHECKING([if the OpenTelemetry PMDA should be included])
+pmda_opentelemetry=false
+if test "$have_python" = true
+then
+    $have_python_requests && $have_python_OrderedDict && pmda_opentelemetry=true
+fi
+AC_SUBST(PMDA_OPENTELEMETRY, $pmda_opentelemetry)
+if $pmda_opentelemetry; then AC_MSG_RESULT(yes); else AC_MSG_RESULT(no); fi
+
 AC_MSG_CHECKING([if the SQL Server PMDA should be included])
 pmda_mssql=false
 if test "$have_python" = true

qa/1632

@@ -0,0 +1,98 @@
+#!/bin/sh
+# PCP QA Test No. 1632
+# pmdaopentelemetry scalability testing
+# specifically scaling number of metrics per nodes
+#
+# Copyright (c) 2025 Red Hat.  All Rights Reserved.
+#
+
+seq=`basename $0`
+echo "QA output created by $seq"
+
+# get standard environment, filters and checks
+. ./common.opentelemetry
+
+_pmdaopentelemetry_check || _notrun "opentelemetry pmda and/or load generator not installed"
+_have_python266 && _notrun "python load generator does not currently work with python 2.6.6"
+
+status=1        # failure is the default!
+$sudo rm -rf $tmp $tmp.* $seq.full
+totalendpoints=5 #total queue to work through
+endpoints=5 #opentelemetry endpoints
+iterations=5
+metrics=400
+instances=10
+
+_cleanup()
+{
+    # load generator exits itself for this test
+
+    echo "=== endpoint log ===" >>$here/$seq.full
+    if [ -f $tmp.endpoint ]
+    then
+        cat $tmp.endpoint >>$here/$seq.full
+    else
+        echo "Error: endpoint log file is missing" >>$here/$seq.full
+    fi
+
+    cd $here
+    _pmdaopentelemetry_cleanup
+    $sudo rm -rf $tmp $tmp.*
+}
+
+_prepare_pmda opentelemetry
+trap "_cleanup; exit \$status" 0 1 2 3 15
+_stop_auto_restart pmcd
+
+_pmdaopentelemetry_save_config
+_pmdaopentelemetry_install
+
+port=`_find_free_port 10000`
+echo "port=$port" >>$here/$seq.full
+
+$python $here/opentelemetry/opentelemetry_endpoint.python \
+        --port=$port \
+        --output=$PCP_PMDAS_DIR/opentelemetry/config.d/ \
+        --total $totalendpoints \
+        --endpoints $endpoints \
+        --metrics $metrics \
+        --instances $instances \
+        --limit $iterations >$tmp.endpoint 2>&1 &
+pid=$!
+if ! _pmdaopentelemetry_wait_for_metric opentelemetry.source4
+then
+    status=1
+    exit
+fi
+if pminfo -b 1000000 -v `pminfo opentelemetry.source0 | LC_COLLATE=POSIX sort` > $tmp.info 2> $tmp.err
+then
+    :
+else
+    echo "... failed! ... here is the Install log ..."
+    cat $tmp.out
+fi
+cat $tmp.info $tmp.err
+
+if pminfo -b 1000000 -ftd `pminfo opentelemetry.source1 | LC_COLLATE=POSIX sort` > $tmp.info 2>$tmp.err
+   then
+    echo "Fetch and desc opentelemetry metrics: success"
+    cat $tmp.info
+else
+    echo "Fetch and desc opentelemetry metrics: failed"
+    cat $tmp.err
+fi
+
+for i in `seq 0 1 4`
+do
+    pminfo -b 10000000 -tf `pminfo opentelemetry.source$i | LC_COLLATE=POSIX sort`
+    pminfo -b 10000000 -tf `pminfo opentelemetry.source$i | LC_COLLATE=POSIX sort`
+    pminfo -b 10000000 -tf `pminfo opentelemetry.source$i | LC_COLLATE=POSIX sort`
+    pminfo -b 10000000 -tf `pminfo opentelemetry.source$i | LC_COLLATE=POSIX sort`
+    sleep 0.5
+done
+
+_pmdaopentelemetry_remove
+
+# success, all done
+status=0
+exit