refactoring
Nikita Koksharov
4 years ago
parent
f4c5111691
commit
588669d62f
@ -0,0 +1,167 @@
|
||||
/**
|
||||
* Copyright (c) 2013-2021 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.micronaut.cache;
|
||||
|
||||
import edu.umd.cs.findbugs.annotations.NonNull;
|
||||
import io.micronaut.core.naming.Named;
|
||||
import org.redisson.api.MapOptions;
|
||||
import org.redisson.api.map.MapLoader;
|
||||
import org.redisson.api.map.MapWriter;
|
||||
import org.redisson.client.codec.Codec;
|
||||
|
||||
import java.time.Duration;
|
||||
|
||||
/**
|
||||
* Micronaut Cache settings.
|
||||
*
|
||||
* @author Nikita Koksharov
|
||||
*
|
||||
*/
|
||||
public class BaseCacheConfiguration implements Named {
|
||||
|
||||
MapOptions<Object, Object> mapOptions = MapOptions.defaults();
|
||||
|
||||
private final String name;
|
||||
|
||||
private Codec codec;
|
||||
private Duration expireAfterWrite;
|
||||
private Duration expireAfterAccess;
|
||||
private int maxSize;
|
||||
|
||||
public BaseCacheConfiguration(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
@NonNull
|
||||
@Override
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public Codec getCodec() {
|
||||
return codec;
|
||||
}
|
||||
|
||||
/**
|
||||
* Redis data codec applied to cache entries.
|
||||
* Default is MarshallingCodec codec
|
||||
*
|
||||
* @see Codec
|
||||
* @see org.redisson.codec.MarshallingCodec
|
||||
*
|
||||
* @param codec - data codec
|
||||
* @return config
|
||||
*/
|
||||
public void setCodec(Codec codec) {
|
||||
this.codec = codec;
|
||||
}
|
||||
|
||||
public Duration getExpireAfterWrite() {
|
||||
return expireAfterWrite;
|
||||
}
|
||||
|
||||
/**
|
||||
* Cache entry time to live duration applied after each write operation.
|
||||
*
|
||||
* @param expireAfterWrite - time to live duration
|
||||
*/
|
||||
public void setExpireAfterWrite(Duration expireAfterWrite) {
|
||||
this.expireAfterWrite = expireAfterWrite;
|
||||
}
|
||||
|
||||
public Duration getExpireAfterAccess() {
|
||||
return expireAfterAccess;
|
||||
}
|
||||
|
||||
/**
|
||||
* Cache entry time to live duration applied after each read operation.
|
||||
*
|
||||
* @param expireAfterAccess - time to live duration
|
||||
*/
|
||||
public void setExpireAfterAccess(Duration expireAfterAccess) {
|
||||
this.expireAfterAccess = expireAfterAccess;
|
||||
}
|
||||
|
||||
public int getMaxSize() {
|
||||
return maxSize;
|
||||
}
|
||||
|
||||
/**
|
||||
* Max size of this cache. Superfluous elements are evicted using LRU algorithm.
|
||||
*
|
||||
* @param maxSize - max size
|
||||
* If <code>0</code> the cache is unbounded (default).
|
||||
*/
|
||||
public void setMaxSize(int maxSize) {
|
||||
this.maxSize = maxSize;
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets write behind tasks batch size.
|
||||
* During MapWriter methods execution all updates accumulated into a batch of specified size.
|
||||
* <p>
|
||||
* Default is <code>50</code>
|
||||
*
|
||||
* @param writeBehindBatchSize - size of batch
|
||||
*/
|
||||
public void setWriteBehindBatchSize(int writeBehindBatchSize) {
|
||||
mapOptions.writeBehindBatchSize(writeBehindBatchSize);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets write behind tasks execution delay. All updates would be applied with lag not more than specified delay.
|
||||
* <p>
|
||||
* Default is <code>1000</code> milliseconds
|
||||
*
|
||||
* @param writeBehindDelay - delay in milliseconds
|
||||
*/
|
||||
public void setWriteBehindDelay(int writeBehindDelay) {
|
||||
mapOptions.writeBehindDelay(writeBehindDelay);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets {@link MapWriter} object used for write-through operations.
|
||||
*
|
||||
* @param writer object
|
||||
*/
|
||||
public void setWriter(MapWriter<Object, Object> writer) {
|
||||
mapOptions.writer(writer);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets write mode.
|
||||
* <p>
|
||||
* Default is <code>{@link MapOptions.WriteMode#WRITE_THROUGH}</code>
|
||||
*
|
||||
* @param writeMode - write mode
|
||||
*/
|
||||
public void setWriteMode(MapOptions.WriteMode writeMode) {
|
||||
mapOptions.writeMode(writeMode);
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets {@link MapLoader} object used to load entries during read-operations execution.
|
||||
*
|
||||
* @param loader object
|
||||
*/
|
||||
public void setLoader(MapLoader<Object, Object> loader) {
|
||||
mapOptions.loader(loader);
|
||||
}
|
||||
|
||||
public MapOptions<Object, Object> getMapOptions() {
|
||||
return mapOptions;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue