INNER CODE UNIT · Java
duration
PlaytikaOSS/testcontainers-spring-boot · embedded-aerospike/src/main/java/com/playtika/testcontainer/aerospike/AerospikeExpiredDocumentsCleaner.java:55
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);
}
}