@Test public void getEvaluatorNodeDescriptorTest() throws InjectionException { final EvaluatorDescriptor evaluatorDescriptor = injector.getInstance(MockEvaluatorDescriptor.class); reefEventStateManager.put("1234", evaluatorDescriptor); final NodeDescriptor nodeDescriptor = reefEventStateManager.getEvaluatorNodeDescriptor("1234"); Assert.assertEquals("myKey", nodeDescriptor.getId()); }
public NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId).getNodeDescriptor(); }
ReefEventStateManager { public NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId).getNodeDescriptor(); } }
ReefEventStateManager { public NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId).getNodeDescriptor(); } @Inject  ReefEventStateManager(final RemoteManager remoteManager, final DriverStatusManager driverStatusManager); }
ReefEventStateManager { public NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId).getNodeDescriptor(); } @Inject  ReefEventStateManager(final RemoteManager remoteManager, final DriverStatusManager driverStatusManager); String getStartTime(); String getStopTime(); Map<String, EvaluatorDescriptor> getEvaluators(); String getDriverEndpointIdentifier(); List<AvroReefServiceInfo> getServicesInfo(); void registerServiceInfo(final AvroReefServiceInfo serviceInfo); Map<String, ActiveContext> getContexts(); void put(final String key, final EvaluatorDescriptor value); EvaluatorDescriptor get(final String key); EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId); NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId); void onClientKill(); }
ReefEventStateManager { public NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId).getNodeDescriptor(); } @Inject  ReefEventStateManager(final RemoteManager remoteManager, final DriverStatusManager driverStatusManager); String getStartTime(); String getStopTime(); Map<String, EvaluatorDescriptor> getEvaluators(); String getDriverEndpointIdentifier(); List<AvroReefServiceInfo> getServicesInfo(); void registerServiceInfo(final AvroReefServiceInfo serviceInfo); Map<String, ActiveContext> getContexts(); void put(final String key, final EvaluatorDescriptor value); EvaluatorDescriptor get(final String key); EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId); NodeDescriptor getEvaluatorNodeDescriptor(final String evaluatorId); void onClientKill();  }