Package com.netflix.eureka.util.batcher

Class TaskDispatchers

  • public class TaskDispatchers
extends java.lang.Object
    See TaskDispatcher for an overview.

    • Constructor Summary

      Constructors 
      Constructor Description
      TaskDispatchers()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <ID,​T>
      TaskDispatcher<ID,​T>      		 createBatchingTaskDispatcher​(java.lang.String id, int maxBufferSize, int workloadSize, int workerCount, long maxBatchingDelay, long congestionRetryDelayMs, long networkFailureRetryMs, TaskProcessor<T> taskProcessor)  
      static <ID,​T>
      TaskDispatcher<ID,​T>      		 createNonBatchingTaskDispatcher​(java.lang.String id, int maxBufferSize, int workerCount, long maxBatchingDelay, long congestionRetryDelayMs, long networkFailureRetryMs, TaskProcessor<T> taskProcessor)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • TaskDispatchers

        public TaskDispatchers()

    • Method Detail

      • createNonBatchingTaskDispatcher

        public static <ID,​T> TaskDispatcher<ID,​T> createNonBatchingTaskDispatcher​(java.lang.String id,
                                                                                      int maxBufferSize,
                                                                                      int workerCount,
                                                                                      long maxBatchingDelay,
                                                                                      long congestionRetryDelayMs,
                                                                                      long networkFailureRetryMs,
                                                                                      TaskProcessor<T> taskProcessor)

      • createBatchingTaskDispatcher

        public static <ID,​T> TaskDispatcher<ID,​T> createBatchingTaskDispatcher​(java.lang.String id,
                                                                                   int maxBufferSize,
                                                                                   int workloadSize,
                                                                                   int workerCount,
                                                                                   long maxBatchingDelay,
                                                                                   long congestionRetryDelayMs,
                                                                                   long networkFailureRetryMs,
                                                                                   TaskProcessor<T> taskProcessor)