@Test public void testSetNodeAvailable() { final MemcachedNodesManager cut = createFor( "n1:localhost:11211,n2:localhost:11212", null, null, _mcc ); assertTrue(cut.isNodeAvailable("n1")); assertTrue(cut.isNodeAvailable("n2")); cut.setNodeAvailable("n1", false); assertFalse(cut.isNodeAvailable("n1")); assertTrue(cut.isNodeAvailable("n2")); }
public void setNodeAvailable(@Nullable final String nodeId, final boolean available) { if ( _nodeIdService != null ) { _nodeIdService.setNodeAvailable(nodeId, available); } }
MemcachedNodesManager { public void setNodeAvailable(@Nullable final String nodeId, final boolean available) { if ( _nodeIdService != null ) { _nodeIdService.setNodeAvailable(nodeId, available); } } }
MemcachedNodesManager { public void setNodeAvailable(@Nullable final String nodeId, final boolean available) { if ( _nodeIdService != null ) { _nodeIdService.setNodeAvailable(nodeId, available); } } MemcachedNodesManager(final String memcachedNodes, @Nonnull final NodeIdList primaryNodeIds, @Nonnull final List<String> failoverNodeIds,
			@Nonnull final LinkedHashMap<InetSocketAddress, String> address2Ids,
			@Nullable final StorageKeyFormat storageKeyFormat, @Nullable final StorageClientCallback storageClientCallback); }
MemcachedNodesManager { public void setNodeAvailable(@Nullable final String nodeId, final boolean available) { if ( _nodeIdService != null ) { _nodeIdService.setNodeAvailable(nodeId, available); } } MemcachedNodesManager(final String memcachedNodes, @Nonnull final NodeIdList primaryNodeIds, @Nonnull final List<String> failoverNodeIds,
			@Nonnull final LinkedHashMap<InetSocketAddress, String> address2Ids,
			@Nullable final StorageKeyFormat storageKeyFormat, @Nullable final StorageClientCallback storageClientCallback); @Nonnull static MemcachedNodesManager createFor(final String memcachedNodes, final String failoverNodes, final StorageKeyFormat storageKeyFormat,
            final StorageClientCallback storageClientCallback); String getMemcachedNodes(); int getCountNodes(); @Nonnull NodeIdList getPrimaryNodeIds(); @Nonnull List<String> getFailoverNodeIds(); boolean isEncodeNodeIdInSessionId(); @Nonnull String getNodeId(final InetSocketAddress socketAddress); @CheckForNull String getNextPrimaryNodeId(final String nodeId); String getNextAvailableNodeId(final String nodeId); @Nonnull SessionIdFormat getSessionIdFormat(); @Nonnull StorageKeyFormat getStorageKeyFormat(); @Nonnull List<InetSocketAddress> getAllMemcachedAddresses(); @Nonnull String createSessionId( @Nonnull final String sessionId ); void setNodeAvailable(@Nullable final String nodeId, final boolean available); boolean isNodeAvailable(final String nodeId); boolean isValidForMemcached(final String sessionId); boolean canHitMemcached(final String sessionId); void onLoadFromMemcachedSuccess(final String sessionId); void onLoadFromMemcachedFailure(final String sessionId); String setNodeAvailableForSessionId(final String sessionId, final boolean available); String getNewSessionIdIfNodeFromSessionIdUnavailable( @Nonnull final String sessionId ); String changeSessionIdForTomcatFailover( @Nonnull final String sessionId, final String jvmRoute ); boolean isCouchbaseBucketConfig(); boolean isRedisConfig(); List<URI> getCouchbaseBucketURIs(); }
MemcachedNodesManager { public void setNodeAvailable(@Nullable final String nodeId, final boolean available) { if ( _nodeIdService != null ) { _nodeIdService.setNodeAvailable(nodeId, available); } } MemcachedNodesManager(final String memcachedNodes, @Nonnull final NodeIdList primaryNodeIds, @Nonnull final List<String> failoverNodeIds,
			@Nonnull final LinkedHashMap<InetSocketAddress, String> address2Ids,
			@Nullable final StorageKeyFormat storageKeyFormat, @Nullable final StorageClientCallback storageClientCallback); @Nonnull static MemcachedNodesManager createFor(final String memcachedNodes, final String failoverNodes, final StorageKeyFormat storageKeyFormat,
            final StorageClientCallback storageClientCallback); String getMemcachedNodes(); int getCountNodes(); @Nonnull NodeIdList getPrimaryNodeIds(); @Nonnull List<String> getFailoverNodeIds(); boolean isEncodeNodeIdInSessionId(); @Nonnull String getNodeId(final InetSocketAddress socketAddress); @CheckForNull String getNextPrimaryNodeId(final String nodeId); String getNextAvailableNodeId(final String nodeId); @Nonnull SessionIdFormat getSessionIdFormat(); @Nonnull StorageKeyFormat getStorageKeyFormat(); @Nonnull List<InetSocketAddress> getAllMemcachedAddresses(); @Nonnull String createSessionId( @Nonnull final String sessionId ); void setNodeAvailable(@Nullable final String nodeId, final boolean available); boolean isNodeAvailable(final String nodeId); boolean isValidForMemcached(final String sessionId); boolean canHitMemcached(final String sessionId); void onLoadFromMemcachedSuccess(final String sessionId); void onLoadFromMemcachedFailure(final String sessionId); String setNodeAvailableForSessionId(final String sessionId, final boolean available); String getNewSessionIdIfNodeFromSessionIdUnavailable( @Nonnull final String sessionId ); String changeSessionIdForTomcatFailover( @Nonnull final String sessionId, final String jvmRoute ); boolean isCouchbaseBucketConfig(); boolean isRedisConfig(); List<URI> getCouchbaseBucketURIs();  }