Added getLocalCachedMapCache method

dependabot/maven/io.reactivex.rxjava3-rxjava-3.1.10
Nikita Koksharov 2 months ago
parent 8fc04158d8
commit 724ac33f2b

@ -345,12 +345,12 @@ public final class Redisson implements RedissonClient {
@Override
public <K, V> RLocalCachedMapCache<K, V> getLocalCachedMapCache(String name, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version -> https://redisson.pro");
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override
public <K, V> RLocalCachedMapCache<K, V> getLocalCachedMapCache(String name, Codec codec, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version -> https://redisson.pro");
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override

@ -1188,6 +1188,16 @@ public class RedissonReactive implements RedissonReactiveClient {
new RedissonMapReactive<>(map, ca), RLocalCachedMapReactive.class);
}
@Override
public <K, V> RLocalCachedMapCacheReactive<K, V> getLocalCachedMapCache(String name, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override
public <K, V> RLocalCachedMapCacheReactive<K, V> getLocalCachedMapCache(String name, Codec codec, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override
public RTransactionReactive createTransaction(TransactionOptions options) {
return new RedissonTransactionReactive(commandExecutor, options);

@ -1166,6 +1166,16 @@ public class RedissonRx implements RedissonRxClient {
new RedissonMapRx<>(map, ce), RLocalCachedMapRx.class);
}
@Override
public <K, V> RLocalCachedMapCacheRx<K, V> getLocalCachedMapCache(String name, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override
public <K, V> RLocalCachedMapCacheRx<K, V> getLocalCachedMapCache(String name, Codec codec, LocalCachedMapCacheOptions<K, V> options) {
throw new UnsupportedOperationException("This feature is implemented in the Redisson PRO version. Visit https://redisson.pro");
}
@Override
public RTransactionRx createTransaction(TransactionOptions options) {
return new RedissonTransactionRx(commandExecutor, options);

@ -0,0 +1,31 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
/**
* Map object with local entry cache support.
* <p>
* Each instance maintains local cache to achieve fast read operations.
* Suitable for maps which used mostly for read operations and network roundtrip delays are undesirable.
*
* @author Nikita Koksharov
*
* @param <K> map key
* @param <V> map value
*/
public interface RLocalCachedMapCacheReactive<K, V> extends RMapCacheReactive<K, V>, RLocalCachedMapReactive<K, V> {
}

@ -0,0 +1,31 @@
/**
* Copyright (c) 2013-2024 Nikita Koksharov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.redisson.api;
/**
* Map object with local entry cache support.
* <p>
* Each instance maintains local cache to achieve fast read operations.
* Suitable for maps which used mostly for read operations and network roundtrip delays are undesirable.
*
* @author Nikita Koksharov
*
* @param <K> map key
* @param <V> map value
*/
public interface RLocalCachedMapCacheRx<K, V> extends RMapCacheRx<K, V>, RLocalCachedMapRx<K, V> {
}

@ -1029,6 +1029,31 @@ public interface RedissonReactiveClient {
*/
<K, V> RLocalCachedMapReactive<K, V> getLocalCachedMap(org.redisson.api.options.LocalCachedMapOptions<K, V> options);
/**
* Returns local cached map cache instance by name.
* Configured by parameters of options-object.
*
* @param <K> type of key
* @param <V> type of value
* @param name - name of object
* @param options - local map options
* @return LocalCachedMapCache object
*/
<K, V> RLocalCachedMapCacheReactive<K, V> getLocalCachedMapCache(String name, LocalCachedMapCacheOptions<K, V> options);
/**
* Returns local cached map cache instance by name using provided codec.
* Configured by parameters of options-object.
*
* @param <K> type of key
* @param <V> type of value
* @param name - name of object
* @param codec - codec for keys and values
* @param options - local map options
* @return LocalCachedMap object
*/
<K, V> RLocalCachedMapCacheReactive<K, V> getLocalCachedMapCache(String name, Codec codec, LocalCachedMapCacheOptions<K, V> options);
/**
* Returns set instance by name.
*

@ -1020,6 +1020,31 @@ public interface RedissonRxClient {
*/
<K, V> RLocalCachedMapRx<K, V> getLocalCachedMap(org.redisson.api.options.LocalCachedMapOptions<K, V> options);
/**
* Returns local cached map cache instance by name.
* Configured by parameters of options-object.
*
* @param <K> type of key
* @param <V> type of value
* @param name - name of object
* @param options - local map options
* @return LocalCachedMapCache object
*/
<K, V> RLocalCachedMapCacheRx<K, V> getLocalCachedMapCache(String name, LocalCachedMapCacheOptions<K, V> options);
/**
* Returns local cached map cache instance by name using provided codec.
* Configured by parameters of options-object.
*
* @param <K> type of key
* @param <V> type of value
* @param name - name of object
* @param codec - codec for keys and values
* @param options - local map options
* @return LocalCachedMap object
*/
<K, V> RLocalCachedMapCacheRx<K, V> getLocalCachedMapCache(String name, Codec codec, LocalCachedMapCacheOptions<K, V> options);
/**
* Returns set instance by name.
*

Loading…
Cancel
Save