Add cluster_started and node_fully_connected events.

scripts/policy/frameworks/cluster/experimental.zeek

@@ -0,0 +1,89 @@
+##! Experimental features of the Cluster framework.
+
+@load base/frameworks/cluster
+
+module Cluster::Experimental;
+
+export {
+	## When using broker-enabled cluster framework, this event will be sent to
+	## the manager and raised locally, once a cluster node has successfully
+	## conducted cluster-level handshakes for all its outgoing connections to
+	## other cluster nodes based on the given cluster layout.
+	##
+	## name: The name of the now fully connected node.
+	##
+	## id: The identifier of the now fully connected node.
+	##
+	## resending: If true, the node has previously signaled that it is fully
+	##            connected. This may happen in case the manager restarts.
+	##
+	## .. warning::
+	##
+	##     There is no tracking of cluster node connectivity. Thus, there is
+	##     no guarantee that all peerings still exist at the time of this event
+	##     being raised.
+	global node_fully_connected: event(name: string, id: string, resending: bool);
+
+	## When using broker-enabled cluster framework, this event will be
+	## broadcasted from the manager once all nodes reported that they have set
+	## up all their outgoing connections to other cluster nodes based on the
+	## given cluster layout.
+	##
+	## .. warning::
+	##
+	##     There is no tracking of cluster node connectivity. Thus, there is
+	##     no guarantee that all peerings still exist at the time of this event
+	##     being raised.
+	global cluster_started: event();
+}
+
+# Track the names of cluster nodes, the local node sets up connections to.
+global connectees_pending: set[string];
+# Track whether the cluster reached the fully connected state.
+global is_cluster_started = F;
+
+@if ( Cluster::is_enabled() )
+
+@if ( Cluster::local_node_type() == Cluster::MANAGER )
+@load ./nodes-experimental/manager
+@endif
+
+event zeek_init() &priority=4
+	{
+	Broker::auto_publish(Cluster::manager_topic, Cluster::Experimental::node_fully_connected);
+	}
+
+hook Cluster::connect_node_hook(connectee: Cluster::NamedNode)
+	{
+	add connectees_pending[connectee$name];
+	}
+
+event Cluster::node_up(name: string, id: string) &priority=-10
+	{
+	# Track pending connectees to trigger node_fully_connected, which will be
+	# auto published to the manager once available.
+	local mgr = Cluster::nodes[Cluster::node]?$manager ? Cluster::nodes[Cluster::node]$manager : "";
+	if ( name !in connectees_pending && name != mgr )
+		return;
+
+	# At this point we are either awaiting the started node or see our manager
+	# for the first time. Hence, we can trigger node_fully_connected if no
+	# pending connectee is left.
+	delete connectees_pending[name];
+	if ( |connectees_pending| == 0 )
+		event Cluster::Experimental::node_fully_connected(Cluster::node, Broker::node_id(),
+			is_cluster_started);
+	}
+
+event Cluster::Experimental::node_fully_connected(name: string, id: string, resending: bool)
+	{
+	if ( ! is_remote_event() )
+		Cluster::log("fully connected");
+	}
+
+event Cluster::Experimental::cluster_started()
+	{
+	is_cluster_started = T;
+	}
+
+@endif

scripts/policy/frameworks/cluster/nodes-experimental/manager.zeek

@@ -0,0 +1,57 @@
+##! This script is loaded on the cluster manager to cover manager-related
+##! parts of experimental features.
+
+@load base/frameworks/cluster
+@load policy/frameworks/cluster/experimental
+
+module Cluster::Experimental;
+
+global fully_connected_nodes_pending: set[string];
+
+event zeek_init()
+	{
+	fully_connected_nodes_pending = table_keys(Cluster::nodes);
+	}
+
+event node_fully_connected(name: string, id: string, resending: bool)
+	{
+	# If a node resends this event, it has already seen the cluster connected.
+	# That is, the manager most likely restarted. Adopt the view of the other
+	# nodes.
+	is_cluster_started = is_cluster_started || resending;
+
+	delete fully_connected_nodes_pending[name];
+	if ( !is_cluster_started && |fully_connected_nodes_pending| == 0 )
+		{
+		event cluster_started();
+
+		for ( topic in Cluster::broadcast_topics )
+			Broker::publish(topic, Cluster::Experimental::cluster_started);
+		}
+	}
+
+event cluster_started()
+	{
+	Cluster::log("cluster connected");
+	}
+
+# Handle some special cases for tracking connected nodes:
+
+event zeek_init() &priority=-15
+	{
+	# Make sure the manager recognizes itself as ready if no
+	# connections have to be initiated.
+	if ( |connectees_pending| == 0 )
+		event node_fully_connected(Cluster::node, Broker::node_id(), F);
+	}
+
+event Cluster::node_up(name: string, id: string)
+	{
+	# Loggers may not know any manager and would thus be unable to
+	# report successful setup. As they do not establish connections
+	# we can consider this case here.
+
+	local n = Cluster::nodes[name];
+	if ( n$node_type == Cluster::LOGGER && ! n?$manager )
+		event node_fully_connected(name, id, F);
+	}

scripts/test-all-policy.zeek

@@ -11,6 +11,8 @@
 
 # @load frameworks/control/controllee.zeek
 # @load frameworks/control/controller.zeek
+@load frameworks/cluster/experimental.zeek
+@load frameworks/cluster/nodes-experimental/manager.zeek
 @load frameworks/management/agent/__load__.zeek
 @load frameworks/management/agent/api.zeek
 @load frameworks/management/agent/boot.zeek