Package org.apache.s4.comm.topology

Clusters configurations and partitions assignments to cluster nodes through Zookeeper.

See:
          Description

Interface Summary
Assignment Upon startup an S4 process in a cluster must be assigned one and only one of the available cluster nodes.
Cluster Represents a logical cluster
ClusterChangeListener Entities interested in changes occurring in topologies implement this listener and should register through the Cluster interface
Clusters Represents clusters related to the current node (clusters to which this node belongs, and connected clusters that may receive messages from this node)
RemoteCluster Represents a logical cluster external to the current cluster
 

Class Summary
AssignmentFromZK Handles partition assignment through Zookeeper.
ClusterFromZK Represents a logical cluster definition fetched from Zookeeper.
ClusterNode Represents an node.
ClustersFromZK Monitors all clusters
PhysicalCluster The S4 physical cluster implementation.
RemoteStreams Monitors streams available in the S4 cluster.
StreamConsumer A subscriber to a published stream.
ZkClient Overwriting the ZKclient since the org.I0Itec.zkclient.ZkClient does not expose some important methods
ZNRecord ZooKeeper's custom znode data structure.
ZNRecordSerializer Utility to serialize/deserialize data in ZK.
 

Enum Summary
RemoteStreams.StreamType  
 

Package org.apache.s4.comm.topology Description

Clusters configurations and partitions assignments to cluster nodes through Zookeeper.