INNER CODE UNIT · Java
cleanExpiredDocumentsBefore
PlaytikaOSS/testcontainers-spring-boot · embedded-aerospike/src/main/java/com/playtika/testcontainer/aerospike/AerospikeExpiredDocumentsCleaner.java:49
public void cleanExpiredDocumentsBefore(Instant expireTime) {
cleanExpiredDocumentsBefore(expireTime.toEpochMilli());
}
@Override
public void cleanExpiredDocumentsBefore(long expireTimeMillis) {
long duration = expireTimeMillis - System.currentTimeMillis();
int expiration = (int) TimeUnit.MILLISECONDS.toSeconds(duration);
Value value = Value.get(expiration);
Statement statement = new Statement();
statement.setNamespace(namespace);
WritePolicy writePolicy = new WritePolicy(client.getWritePolicyDefault());
writePolicy.durableDelete = durableDelete;
ExecuteTask executeTask = client.execute(writePolicy, statement, PACKAGE_NAME, FUNC_NAME, value);
executeTask.waitTillComplete(SLEEP_INTERVAL, TIMEOUT);
}
}