INNER CODE UNIT · Java
AerospikeTestOperations
PlaytikaOSS/testcontainers-spring-boot · embedded-aerospike/src/main/java/com/playtika/testcontainer/aerospike/AerospikeTestOperations.java:24
public class AerospikeTestOperations {
private final ExpiredDocumentsCleaner expiredDocumentsCleaner;
private final GenericContainer<?> aerospikeContainer;
public void addDuration(Duration duration) {
timeTravel(DateTimeUtils.now().plus(duration).plusMinutes(1));
}
public void timeTravelTo(OffsetDateTime futureTime) {
OffsetDateTime now = DateTimeUtils.now();
if (futureTime.isBefore(now)) {
throw new IllegalArgumentException("Time should be in future. Now is: " + now + " time is:" + futureTime);
} else {
timeTravel(futureTime);
}
}