BacklogCountHint returns the number of backlog tasks loaded in memory now. It's returned as a hint to the SDK to influence polling behavior (sticky vs

BlockWithTimeout invokes fn and waits for it to complete until the timeout. Returns true if the call completed before the timeout, otherwise returns f

BuildSuccessReportMessage creates a Slack message for success report

CHASMToLegacyStartScheduleArgs converts CHASM scheduler state to V1 StartScheduleArgs. This is the primary V2-to-V1 migration function. The migrationT

CLIFlags returns the CLI flags for the connection parameters.

CanAddEvent returns true if an event can be added to the EventStore.

Cancel stops the timer that triggers the rate limiter to delegate to the underlying rate limiter. It returns true if the timer was stopped before it e

CancelOutstandingPoll is called by frontend to unblock long polls on matching for zombie pollers. Our rpc stack does not support context propagation,

CancelOutstandingWorkerPolls cancels any outstanding polls for a given worker instance key. These polls could be waiting on different partitions of th

CancelWorkflow mocks base method.

Deprecated: metric capture is cluster-global. Use (*TestEnv).StartGlobalMetricCapture() or (*TestEnv).StartNamespaceMetricCapture() instead.

CapturePanic is used to capture panic, it will emit the service panic metric, log the panic and also return the error through pointer. If the panic va

Check settles GC, then returns a full retained-object report and an error for retained objects not covered by expected patterns, expected patterns tha

CheckInternalPerNsTaskQueueAllowed tries to block the usage of internal per-namespace task queue for illegal cases. Parameters: - targetTaskQueue: The

Blocks on user data propagation to all loaded partitions. If successful, all loaded workflow + activity partitions have the requested version or highe

CheckTaskQueueVersionMembership checks if a task queue is part of a specific deployment version.

CleanupOldDeletedVersions removes versions deleted more than 7 days ago. Also removes more deleted versions if the limit is being exceeded. Never remo

CloseShard close the shard.

ClusterNames observes the names of the clusters to which this namespace is replicated.

CompleteActivity mocks base method.

ConvertSql transforms SQL to Elasticsearch query. nolint:staticcheck

CountWorkers counts workers in the specified namespace that match the provided query.

CreateCassandraKeyspace creates the keyspace using this session for given replica count

CreateFrontendClientRetryPolicy creates a retry policy for calls to frontend service

CreateMatchingPollWorkflowTaskQueueResponse create response for matching's PollWorkflowTaskQueue

Create a Nexus endpoint. (-- api-linter: core::0133::method-signature=disabled aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google

CreateUnaryMetricsHandlerLogTags creates metrics handler and log tags for unary RPC calls

CurrentSuspected returns the number of currently unresolved suspected deadlocks.

CursorTimestamp returns tag for CursorTimestamp

DPanic implements log.Logger.

DedicatedActivityWorkerOptions returns a DedicatedWorkerOptions for this worker component. Return nil to use default worker instance.

DedicatedWorkflowWorkerOptions returns a DedicatedWorkerOptions for this worker component. Return nil to use default worker instance.

Deep health check history service dependencies health status

DefaultStoreType returns the storeType for the default persistence store

DeleteAllFromChasmNodeMaps deletes all rows related to a particular workflow in the chasm_node_maps table.

DeleteFromChasmNodeMaps deletes one or more rows in the chasm_node_maps table.

DeleteFromTasks deletes multiple rows from tasks table Required filter params: - {RangeHash, TaskQueueID, ExclusiveMaxLevel, Limit} - this will delete

Delete a service by its name.

DeleteWorkflowExecution force deletes a workflow's visibility record, current & concrete execution record and history if possible

DeleteWorkflowExecution asynchronously deletes a specific Workflow Execution (when WorkflowExecution.run_id is provided) or the latest Workflow Execut

DeploymentIfValid returns the deployment back if is both of its fields have value.

DeploymentQueueKey returns a PhysicalTaskQueueKey of a task queue partition for a deployment.

DescribeHistoryHost returns information about the internal states of a history host

DescribeHistoryHost returns information about the internal states of a history host.

DescribeWorkflowExecution returns information about the internal states of workflow execution.

DescribeMutableState returns information about the internal states of workflow mutable state.

DescribeTaskQueue returns information about the target task queue, right now this API returns the pollers which polled this task queue in last few min

DescribeTaskQueuePartition returns information about the target task queue partition.