@load base/frameworks/cluster @load base/frameworks/broker module Dop; export { global manager_to_workers: event(mystring: string); global bourbon: set[string]; } event manager_to_workers(mystring: string){ add Dop::bourbon[mystring]; } event bro_init() { Broker::auto_publish(Cluster::worker_topic, Dop::manager_to_workers); add Dop::bourbon["Eagle Rare"]; @if ( ! Cluster::is_enabled() || Cluster::local_node_type() == Cluster::MANAGER ) when ( local hostname = lookup_addr(198.128.153.23) ){ #don't actually care about the hostname, testing when() event manager_to_workers("Woodford"); } # test schedule schedule 1min {manager_to_workers("Elijah Craig")}; # test direct publish Broker::publish(Cluster::worker_topic, manager_to_workers, "Buffalo Trace"); # test direct auto publish event manager_to_workers("High West"); @endif }