Package io.micronaut.kubernetes.client.openapi.operator.workqueue

Interface DelayingQueue<T>

Type Parameters:
T - item type
All Superinterfaces:
WorkQueue<T>
All Known Subinterfaces:
RateLimitingQueue<T>
All Known Implementing Classes:
DefaultDelayingQueue, DefaultRateLimitingQueue
public interface DelayingQueue<T> extends WorkQueue<T>
Defines a queue that can add an item at a later time. This makes it easier to requeue items after failures without ending up in a hot-loop.

The code has been copied from the official client and modified: DelayingQueue

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addAfter(T item, @NonNull Duration duration)
    Adds an item to the workqueue after the indicated duration has passed.

    Methods inherited from interface io.micronaut.kubernetes.client.openapi.operator.workqueue.WorkQueue

    add, done, get, isShutdown, length, shutdown, start

  • Method Details

    • addAfter

      void addAfter(@NonNull T item, @NonNull @NonNull Duration duration)
      Adds an item to the workqueue after the indicated duration has passed.
      Parameters:
      item - item to add
      duration - specific duration