Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 06:38:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add basic btest to verify that Broker peering telemetry is available.

Browse source
This commit is contained in:
Christian Kreibich 2025-04-23 23:46:43 -07:00
parent 88a0cda8ca
commit 35ab9d5c80
3 changed files with 63 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
testing/btest/Baseline/broker.telemetry/manager.out Normal file
View file

@ -0,0 +1,4 @@
### BTest baseline data generated by btest-diff. Do not edit. Use "btest -U/-u" to update. Requires BTest >= 0.63.
Telemetry::COUNTER, zeek, zeek_broker_peer_buffer_overflows_total, [endpoint, peer], [manager, worker]
Telemetry::GAUGE, zeek, zeek_broker_peer_buffer_messages, [endpoint, peer], [manager, worker]
Telemetry::GAUGE, zeek, zeek_broker_peer_buffer_recent_max_messages, [endpoint, peer], [manager, worker]

4
testing/btest/Baseline/broker.telemetry/worker.out Normal file
View file

@ -0,0 +1,4 @@
### BTest baseline data generated by btest-diff. Do not edit. Use "btest -U/-u" to update. Requires BTest >= 0.63.
Telemetry::COUNTER, zeek, zeek_broker_peer_buffer_overflows_total, [endpoint, peer], [worker, manager]
Telemetry::GAUGE, zeek, zeek_broker_peer_buffer_messages, [endpoint, peer], [worker, manager]
Telemetry::GAUGE, zeek, zeek_broker_peer_buffer_recent_max_messages, [endpoint, peer], [worker, manager]

55
testing/btest/broker/telemetry.zeek Normal file
View file

@ -0,0 +1,55 @@
# @TEST-DOC: run a mini two-node cluster and check that Broker's peering telemetry is available.
#
# @TEST-PORT: BROKER_PORT
#
# @TEST-EXEC: btest-bg-run manager ZEEKPATH=$ZEEKPATH:.. CLUSTER_NODE=manager zeek -b manager.zeek
# @TEST-EXEC: btest-bg-run worker ZEEKPATH=$ZEEKPATH:.. CLUSTER_NODE=worker zeek -b worker.zeek
# @TEST-EXEC: btest-bg-wait 15
#
# @TEST-EXEC: btest-diff manager/out
# @TEST-EXEC: btest-diff worker/out
# @TEST-START-FILE cluster-layout.zeek
redef Cluster::nodes = {
["manager"] = [$node_type=Cluster::MANAGER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_PORT"))],
["worker"] = [$node_type=Cluster::WORKER, $ip=127.0.0.1, $manager="manager"],
};
# @TEST-END-FILE
# @TEST-START-FILE common.zeek
@load base/frameworks/cluster
@load policy/frameworks/cluster/experimental
redef exit_only_after_terminate = T;
redef Log::enable_local_logging = T;
redef Log::default_rotation_interval = 0secs;
redef Cluster::retry_interval = 1sec;
function print_metrics(metrics: vector of Telemetry::Metric)
{
local f = open("out");
for (i in metrics)
{
local m = metrics[i];
print f, m$opts$metric_type, m$opts$prefix, m$opts$name, m$label_names, m?$label_values ? m$label_values : vector();
}
close(f);
}
event Cluster::Experimental::cluster_started()
{
local broker_metrics = Telemetry::collect_metrics("zeek_broker_peer_buffer*", "*");
print_metrics(broker_metrics);
terminate();
}
# @TEST-END-FILE
# @TEST-START-FILE manager.zeek
@load ./common.zeek
# @TEST-END-FILE
# @TEST-START-FILE worker.zeek
@load ./common.zeek
# @TEST-END-FILE