mirror of
https://github.com/zeek/zeek.git
synced 2025-10-02 14:48:21 +00:00
33 lines
633 B
Text
33 lines
633 B
Text
redef exit_only_after_terminate = T;
|
|
|
|
global event_count = 0;
|
|
|
|
global event_1: event(val: count);
|
|
|
|
event event_1(value: count)
|
|
{
|
|
++event_count;
|
|
}
|
|
|
|
event bye_bye()
|
|
{
|
|
print "received bye-bye event";
|
|
terminate();
|
|
}
|
|
|
|
event print_stats()
|
|
{
|
|
print "received ", event_count, " events/s";
|
|
event_count = 0;
|
|
schedule 1sec { print_stats() };
|
|
}
|
|
|
|
event zeek_init()
|
|
{
|
|
local broker_port = to_port(getenv("BROKER_PORT"));
|
|
print "trying to connect to port ", broker_port;
|
|
Broker::subscribe("benchmark/terminate");
|
|
Broker::subscribe("benchmark/events");
|
|
Broker::peer("127.0.0.1", broker_port);
|
|
schedule 1sec { print_stats() };
|
|
}
|