Class TestServerScheduleStore

java.lang.Object
io.fluxzero.testserver.scheduling.TestServerScheduleStore
All Implemented Interfaces:
AutoCloseable
public class TestServerScheduleStore extends Object

  • Constructor Details

    • TestServerScheduleStore

      public TestServerScheduleStore(io.fluxzero.sdk.scheduling.client.InMemoryScheduleStore delegate)

  • Method Details

    • schedule

      public CompletableFuture<Void> schedule(io.fluxzero.common.Guarantee guarantee, io.fluxzero.common.api.scheduling.SerializedSchedule... schedules)

    • getBatch

      public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex, int maxSize)

    • getBatch

      public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex, int maxSize, boolean inclusive)

    • scanBatch

      public io.fluxzero.common.tracking.MessageStoreBatch scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super io.fluxzero.common.api.SerializedMessage> filter)

    • rescheduleNextDeadline

      protected void rescheduleNextDeadline(long nextIndex)

    • truncate

      public void truncate()

    • append

      default CompletableFuture<Void> append(io.fluxzero.common.api.SerializedMessage... arg0)

    • append

      CompletableFuture<Void> append(List<io.fluxzero.common.api.SerializedMessage> arg0)

    • getBatch

      default List<io.fluxzero.common.api.SerializedMessage> getBatch(Long arg0, int arg1, long arg2)

    • getBatch

      default List<io.fluxzero.common.api.SerializedMessage> getBatch(Long arg0, int arg1, boolean arg2, long arg3)

    • setRetentionTime

      void setRetentionTime(Duration arg0)

    • unwrap

      default <T extends io.fluxzero.common.tracking.MessageStore> T unwrap(Class<T> arg0)

    • close

      default void close()
      Specified by:
      close in interface AutoCloseable

    • getMessageStore

      default io.fluxzero.common.tracking.MessageStore getMessageStore()

    • registerMonitor

      io.fluxzero.common.Registration registerMonitor(Consumer<List<io.fluxzero.common.api.SerializedMessage>> arg0)

    • schedule

      default CompletableFuture<Void> schedule(io.fluxzero.common.api.scheduling.SerializedSchedule... arg0)

    • cancelSchedule

      default CompletableFuture<Void> cancelSchedule(String arg0)

    • cancelSchedule

      CompletableFuture<Void> cancelSchedule(String arg0, io.fluxzero.common.Guarantee arg1)

    • hasSchedule

      default boolean hasSchedule(String arg0)

    • getSchedule

      io.fluxzero.common.api.scheduling.SerializedSchedule getSchedule(String arg0)

    • close

      void close()
      Specified by:
      close in interface AutoCloseable