INNER CODE UNIT · Java
AerospikeExpiredDocumentsCleaner
PlaytikaOSS/testcontainers-spring-boot · embedded-aerospike/src/main/java/com/playtika/testcontainer/aerospike/AerospikeExpiredDocumentsCleaner.java:15
public class AerospikeExpiredDocumentsCleaner implements ExpiredDocumentsCleaner {
private static final String PACKAGE_NAME = "remove_expired";
private static final String FUNC_NAME = "remove_expired";
private static final String RESOURCE_PATH = "udf/remove_expired.lua";
private static final String SERVER_PATH = "remove_expired.lua";
private static final int SLEEP_INTERVAL = 100;
private static final int TIMEOUT = 10_000;
private final IAerospikeClient client;
private final String namespace;
private final boolean durableDelete;
public AerospikeExpiredDocumentsCleaner(IAerospikeClient client, String namespace, boolean durableDelete) {
Assert.notNull(client, "Aerospike client can not be null");
Assert.notNull(namespace, "Namespace can not be null");
this.client = client;
this.namespace = namespace;