HandleWorkflowTask invokes the provided handler with the provided task, and completes/fails the task accordingly. Is it a blocking call. Any unspecifi

HasNextVertex checks if there is accessible history event vertex

ImportWorkflowExecution attempts to import workflow according to persisted history events. NOTE: this is experimental API

ImportWorkflowExecution attempts to import workflow according to persisted history events. NOTE: this is experimental API

IncomingVersion returns tag for IncomingVersion

InstanceTag returns a new instance tag

InternalStatusToAPIStatus converts internal activity execution status to API status.

Invoke is the implementation of the history service's AddTasks API. This exposes the [shard.Context.AddTasks] API via the history service. This method

nolint:revive // cyclomatic complexity

IsActivityTaskValid is called by matching service checking whether the workflow task is valid.

IsEqualVersionHistoryItems checks whether version history items are equal

IsImmediate reports whether the task is scheduled for immediate execution (zero or unset scheduled time).

IsInternalPerNsTaskQueue returns true if the task queue name belongs to a per-namespace internal system worker

IsResetRun returns true if this run is result of a reset operation.

IsSystem returns true if name is system search attribute

IsUnversionedOrAssignedBuildIdSearchAttribute returns the value is "unversioned" or "assigned:<bld>"

IsValidPayloadSize validates that a payload size is within the configured limits.

IsWorkflowTaskValid is called by matching service checking whether the workflow task is valid.

LifecycleState maps the operation's status to a CHASM lifecycle state.

ListGeneratedVertices lists the pasted generated vertices

ListInfo returns the ScheduleListInfo, used as the visibility memo, and to answer List queries.

ListMatchingTimes returns the upcoming times that the schedule will trigger within the given time range.

List all registered services.

ListOpenWorkflow mocks base method.

ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.

ListTaskQueuePartitions returns a map of partitionKey and hostAddress for a task queue.

ListWorkers retrieves a list of workers in the specified namespace that match the provided filters. Supports pagination for large result sets. Returns

ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.

ListenIP returns the IP to bind to in Listen. It tries to find an IP that can be used by other machines to reach this machine.

LoadAndMergeWithStaticConfig loads cluster metadata from the database and merges it with the static config.

LoadAndSplitQuery loads and split cql / sql query into one statement per string. Comments are removed from the query.

LoadSchema from PersistenceTestCluster interface

MakeBackoffAlgorithm creates a BackoffCalculatorAlgorithmFunc that returns a fixed delay if requestedDelay is non-nil, otherwise falls back to exponen

MapConcurrent concurrently maps a function over input and fails fast on error.

Marshal an object of type HistoryTask to the protobuf v3 wire format

MaskYaml replace password values with mask and returns copy of the string. Does recursive replacement for entire yamlStr.

Max returns the maximum of two Clocks

MergeDLQMessages merges messages from DLQ.

MergeDLQMessages merges messages from DLQ.

MetricsHandlerFromConfig is used at startup to construct a MetricsHandler

Min returns the minimum of two Clocks

TODO: this is invoked for non-ES validation code flow. Needs refactoring

NewAdminHandler creates a gRPC handler for the adminservice

NewAllAPIsForwardingPolicy creates a forwarding policy for all APIs based on namespace