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

testing/btest/Files: Add broker/cluster-layout.zeek

Browse source 
This is a cluster-layout.zeek template that can be copied into a testing
directory if needed. The idea is that a developer sets environment
variables within their btest and the Cluster::nodes variable is
implicitly extended by appropriate nodes.

For example, using @TEST-PORT BROKER_LOGGER1_PORT will add an appropriate
logger-1 node to Cluster::nodes, based on the existence of the
BROKER_LOGGER1_PORT environment variable.

(cherry picked from commit a56744a2679c3bd42b4046f2687ccc8fb8442485)
This commit is contained in:
Arne Welzel 2025-05-14 11:16:11 +02:00
parent 4027c70e2b
commit a444a9cc4a
1 changed files with 85 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

85
testing/btest/Files/broker/cluster-layout.zeek Normal file
View file

@ -0,0 +1,85 @@
#
# Use this file in a test by copying it into the tests directory:
#
# @TEST-EXEC: cp $FILES/broker/cluster-layout.zeek .
#
# Then specify @TEST-PORT using the following:
#
# BROKER_MANAGER_PORT
# BROKER_LOGGER1_PORT
# BROKER_LOGGER2_PORT
# BROKER_PROXY1_PORT
# BROKER_PROXY2_PORT
# BROKER_WORKER1_PORT
# BROKER_WORKER2_PORT
# BROKER_WORKER3_PORT
# BROKER_WORKER4_PORT
#
# The existence of the environment variable will add a corresponding node
# to Cluster::nodes.
# Redef'ed to F if logger-1 or logger-2 are active.
redef Cluster::manager_is_logger = T;
# Minimal cluster-layout for two nodes.
redef Cluster::nodes = {
["manager"] = [$node_type=Cluster::MANAGER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_MANAGER_PORT"))],
};
# Depending on what environment variables are set, extend the Cluster::nodes table
# with more nodes. This allows tests to control the contents of Cluster::nodes
# just by using TEST-PORT accordingly to the used environment variables.
### Loggers
@if ( getenv("BROKER_LOGGER1_PORT") != "" )
redef Cluster::manager_is_logger = F;
redef Cluster::nodes += {
["logger-1"] = [$node_type=Cluster::LOGGER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_LOGGER1_PORT")), $manager="manager"],
};
@endif
@if ( getenv("BROKER_LOGGER2_PORT") != "" )
redef Cluster::manager_is_logger = F;
redef Cluster::nodes += {
["logger-2"] = [$node_type=Cluster::LOGGER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_LOGGER2_PORT")), $manager="manager"],
};
@endif
### Proxies
@if ( getenv("BROKER_PROXY1_PORT") != "" )
redef Cluster::nodes += {
["proxy-1"] = [$node_type=Cluster::PROXY, $ip=127.0.0.1, $p=to_port(getenv("BROKER_PROXY1_PORT")), $manager="manager"],
};
@endif
@if ( getenv("BROKER_PROXY2_PORT") != "" )
redef Cluster::nodes += {
["proxy-2"] = [$node_type=Cluster::PROXY, $ip=127.0.0.1, $p=to_port(getenv("BROKER_PROXY2_PORT")), $manager="manager"],
};
@endif
### Workers
@if ( getenv("BROKER_WORKER1_PORT") != "" )
redef Cluster::nodes += {
["worker-1"] = [$node_type=Cluster::WORKER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_WORKER1_PORT")), $manager="manager"],
};
@endif
@if ( getenv("BROKER_WORKER2_PORT") != "" )
redef Cluster::nodes += {
["worker-2"] = [$node_type=Cluster::WORKER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_WORKER2_PORT")), $manager="manager"],
};
@endif
@if ( getenv("BROKER_WORKER3_PORT") != "" )
redef Cluster::nodes += {
["worker-3"] = [$node_type=Cluster::WORKER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_WORKER3_PORT")), $manager="manager"],
};
@endif
@if ( getenv("BROKER_WORKER4_PORT") != "" )
redef Cluster::nodes += {
["worker-4"] = [$node_type=Cluster::WORKER, $ip=127.0.0.1, $p=to_port(getenv("BROKER_WORKER4_PORT")), $manager="manager"],
};
@endif