ddth-cache-adapter-core/src/main/java/com/github/ddth/cacheadapter/cacheimpl/redis/ClusteredRedisCache.java
@Override
    public void deleteAll() {
        switch (keyMode) {
        case NAMESPACE:
            throw new CacheException.OperationNotSupportedException(
                    "Key mode[" + keyMode + "] does not support 'deleteAll' operation.");
        case MONOPOLISTIC:
            try {
                getJedis().getClusterNodes().forEach((name, pool) -> {
                    try (Jedis jedis = pool.getResource()) {
                        jedis.flushAll();
                    }
                });
            } catch (Exception e) {
                throw e instanceof CacheException ? (CacheException) e : new CacheException(e);
            }
            break;
        case HASH:
            try {
                getJedis().del(getName());
            } catch (Exception e) {
                throw e instanceof CacheException ? (CacheException) e : new CacheException(e);
            }
            break;
        default:
            throw new IllegalStateException("Invalid key mode: " + keyMode);
        }
    }
@Override
    public void deleteAll() {
        switch (keyMode) {
        case NAMESPACE:
            throw new CacheException.OperationNotSupportedException(
                    "Key mode[" + keyMode + "] does not support 'deleteAll' operation.");
        case MONOPOLISTIC:
            try {
                getJedis().getClusterNodes().forEach((name, pool) -> {
                    try (Jedis jedis = pool.getResource()) {
                        jedis.flushAll();
                    }
                });
            } catch (Exception e) {
                throw e instanceof CacheException ? (CacheException) e : new CacheException(e);
            }
            break;
        case HASH:
            try {
                getJedis().del(getName());
            } catch (Exception e) {
                throw e instanceof CacheException ? (CacheException) e : new CacheException(e);
            }
            break;
        default:
            throw new IllegalStateException("Invalid key mode: " + keyMode);
        }
    }
@ Override public void deleteAll ( ) { switch ( keyMode ) { case NAMESPACE : throw new CacheException . OperationNotSupportedException ( "Key mode[" + keyMode + "] does not support 'deleteAll' operation." ) ; case MONOPOLISTIC : try { getJedis ( ) . getClusterNodes ( ) . forEach ( ( name , pool ) -> { try ( Jedis jedis = pool . getResource ( ) ) { jedis . flushAll ( ) ; } } ) ; } catch ( Exception e ) { throw e instanceof CacheException ? ( CacheException ) e : new CacheException ( e ) ; } break ; case HASH : try { getJedis ( ) . del ( getName ( ) ) ; } catch ( Exception e ) { throw e instanceof CacheException ? ( CacheException ) e : new CacheException ( e ) ; } break ; default : throw new IllegalStateException ( "Invalid key mode: " + keyMode ) ; } }
{@inheritDoc}
{