Class PollScaleReportHandle<T extends ScalingTask>

java.lang.Object

io.temporal.internal.worker.PollScaleReportHandle<T>

All Implemented Interfaces:

Runnable

@ThreadSafe
public class PollScaleReportHandle<T extends ScalingTask>
extends Object
implements Runnable

PollScaleReportHandle is responsible for managing the scaling of pollers based on the scaling feedback attached to the task by the server.

Constructor Summary

Constructors

Constructor	Description
PollScaleReportHandle(int minPollerCount, int maxPollerCount, int initialPollerCount, boolean serverSupportsAutoscaling, Functions.Proc1<Integer> scaleCallback)

Method Summary

Modifier and Type	Method	Description
void	report(T task, Throwable e)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

PollScaleReportHandle

public PollScaleReportHandle(int minPollerCount,
 int maxPollerCount,
 int initialPollerCount,
 boolean serverSupportsAutoscaling,
 Functions.Proc1<Integer> scaleCallback)

Method Details

report

public void report(T task,
 Throwable e)

run

public void run()

Specified by:

run in interface Runnable