@Test public void getEvaluatorDescriptorTest() throws InjectionException { final EvaluatorDescriptor evaluatorDescriptor = injector.getInstance(MockEvaluatorDescriptor.class); reefEventStateManager.put("1234", evaluatorDescriptor); final EvaluatorDescriptor evaluatorDescriptor1 = reefEventStateManager.getEvaluatorDescriptor("1234"); Assert.assertEquals(evaluatorDescriptor, evaluatorDescriptor1); }
public EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId); }
ReefEventStateManager { public EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId); } }
ReefEventStateManager { public EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId); } @Inject  ReefEventStateManager(final RemoteManager remoteManager, final DriverStatusManager driverStatusManager); }
ReefEventStateManager { public EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId); } @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 EvaluatorDescriptor getEvaluatorDescriptor(final String evaluatorId) { return evaluators.get(evaluatorId); } @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();  }