Package io.temporal.internal.worker
package io.temporal.internal.worker
-
ClassDescriptionInterface of an activity task handler.A simple implementation of an adjustable semaphore.Manages periodic worker heartbeat RPCs.Holds namespace-level capabilities discovered from the server's DescribeNamespace response.Options for component that polls Temporal task queues for tasks.Tracks in-flight poll count and last successful poll time for heartbeat reporting.PollScaleReportHandle<T extends ScalingTask>PollScaleReportHandle is responsible for managing the scaling of pollers based on the scaling feedback attached to the task by the server.Encapsulates a special query implementation for replaying workflow histories to support
Worker.replayWorkflowExecution(io.temporal.internal.common.WorkflowExecutionHistory)Interface for tasks that can provide scaling feedback from the server.Represents a scaling decision made by the task.Specialization ofTaskExecutorthat can be shutdown.Activity worker that supports POJO activity implementations.Facade that supports a lifecycle and maintains an assembly ofWorkflowWorkerthat performing execution of workflow taskLocalActivityWorkerthat performs execution of local activities scheduled by the workflow tasks and exposing additional management helper methods for the assembly.Tracks total processed and failed task counts for a worker.TrackingSlotSupplier<SI extends SlotInfo>Wraps a slot supplier and supplements it with additional tracking information that is useful to provide to all implementations.Internal.Handles server-to-worker commands delivered on the worker command Nexus task queue.Contains old and new worker versioning options together.Internal.Interface of workflow task handlers.