Class TrackingSlotSupplier<SI extends SlotInfo>

java.lang.Object

io.temporal.internal.worker.TrackingSlotSupplier<SI>

Type Parameters:

SI - The slot info type

public class TrackingSlotSupplier<SI extends SlotInfo>
extends Object

Wraps a slot supplier and supplements it with additional tracking information that is useful to provide to all implementations. This type is used internally rather than SlotSupplier directly.

Constructor Summary

Constructors

Constructor	Description
TrackingSlotSupplier(SlotSupplier<SI> inner, com.uber.m3.tally.Scope metricsScope)

Method Summary

Modifier and Type	Method	Description
int	getIssuedSlots()
String	getSupplierKind()
int	getUsedSlotCount()
void	markSlotUsed(SI slotInfo, SlotPermit permit)
Optional<Integer>	maximumSlots()
void	releaseSlot(SlotReleaseReason reason, SlotPermit permit)
SlotSupplierFuture	reserveSlot(SlotReservationData data)
Optional<SlotPermit>	tryReserveSlot(SlotReservationData data)

Methods inherited from class java.lang.Object

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

Constructor Details

TrackingSlotSupplier

public TrackingSlotSupplier(SlotSupplier<SI> inner,
 com.uber.m3.tally.Scope metricsScope)

Method Details

getSupplierKind

public String getSupplierKind()

getUsedSlotCount

public int getUsedSlotCount()

reserveSlot

public SlotSupplierFuture reserveSlot(SlotReservationData data)

tryReserveSlot

public Optional<SlotPermit> tryReserveSlot(SlotReservationData data)

markSlotUsed

public void markSlotUsed(SI slotInfo,
 SlotPermit permit)

releaseSlot

public void releaseSlot(SlotReleaseReason reason,
 SlotPermit permit)

maximumSlots

public Optional<Integer> maximumSlots()

getIssuedSlots

public int getIssuedSlots()