FetchConfigurationsTask.java

package cloud.eppo;

import java.util.Timer;
import java.util.TimerTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

class FetchConfigurationsTask extends TimerTask {
  private static final Logger log = LoggerFactory.getLogger(FetchConfigurationsTask.class);
  private final Runnable runnable;
  private final Timer timer;
  private final long intervalInMillis;
  private final long jitterInMillis;

  FetchConfigurationsTask(
      Runnable runnable, Timer timer, long intervalInMillis, long jitterInMillis) {
    this.runnable = runnable;
    this.timer = timer;
    this.intervalInMillis = intervalInMillis;
    this.jitterInMillis = jitterInMillis;
  }

  @Override
  public void run() {
    // TODO: retry on failed fetches
    try {
      runnable.run();
    } catch (Exception e) {
      log.error("[Eppo SDK] Error fetching experiment configuration", e);
    }

    long delay = this.intervalInMillis - (long) (Math.random() * this.jitterInMillis);
    FetchConfigurationsTask nextTask =
        new FetchConfigurationsTask(runnable, timer, intervalInMillis, jitterInMillis);
    timer.schedule(nextTask, delay);
  }
}