Package com.rpl.rama.cluster

Interface ClusterManagerBase

All Superinterfaces:
AutoCloseable, Closeable
All Known Subinterfaces:
InProcessCluster, RamaClusterManager
public interface ClusterManagerBase extends Closeable
Interface for retrieving depots, PStates, and query topology clients from a real cluster or InProcessCluster
See Also:

  • Method Details

    • clusterPState

      PState clusterPState(String moduleName, String pstateName)
      Retrieve client for a PState
      Parameters:
      moduleName - Owning module of PState
      pstateName - PState name from its declaration

    • clusterDepot

      Depot clusterDepot(String moduleName, String depotName)
      Retrieve client for a Depot
      Parameters:
      moduleName - Owning module of PState
      depotName - Depot name from its declaration

    • clusterQuery

      <T> QueryTopologyClient<T> clusterQuery(String moduleName, String topologyName)
      Retrieve client for a query topology
      Parameters:
      moduleName - Owning module of PState
      topologyName - Name of topology from its declaration

    • getDeployedModuleNames

      Set<String> getDeployedModuleNames()
      Retrieves set of the names of all deployed modules on this cluster.

    • getMicrobatchDepotInfo

      Map<String,Map<String,Map<Integer,MicrobatchParams>>> getMicrobatchDepotInfo(String moduleName, String topologyName)
      Retrieve information about a microbatch topology's latest processed offsets for all depots depended on by the topology.
      Parameters:
      moduleName - Owning module of the topology
      topologyName - Name of topology from its declaration
      Returns:
      a map of moduleName to depotName to partitionIndex to MicrobatchParams