GracefulStop stops the HTTP server. This will first attempt a graceful stop with a drain time, then will hard-stop. This will not return until stopped

HandlePartialWorkflowTask for workflow task

Host returns tag for Host

Intercept extracts routing key from the request and adds it to the context. It tries each extractor in order until one returns a non-empty routing key

InverseMap creates the inverse map, ie., for a key-value map, it builds the value-key map.

IsSentinel returns true if this is a sentinel scheduler.

IsServiceTransientError checks if the error is a retryable error.

IsValidContext checks that the thrift context is not expired on cancelled. Returns nil if the context is still valid. Otherwise, returns the result of

Less implements sort.Interface

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

ListClusterMembers returns information about Temporal cluster members.

LockHigh try to lock with high priority, use LockHigh / UnlockHigh pair to lock / unlock

Machine returns a [StateMachineDefinition] for a given type and a boolean indicating whether it was found.

* MatchActivity matches the given query with the given activity info. The query should be a valid SQL query with WHERE clause. The supported fields ar

MergeCustomSearchAttributes merges the provided custom search attribute fields into the existing ones. - If a key in `customSearchAttributes` already

MergeProtoExcludingFields merges fields from source into target, excluding specific fields. The fields to exclude are specified as pointers to fields

Name of the remote method. Must be unique per state machine.

NewBackgroundHighCallerInfo creates a new CallerInfo with BackgroundHigh callerType and empty callOrigin. This is equivalent to NewCallerInfo(callerNa

NewBatcher creates a Batcher. `fn` is the processing function, `opts` are the timing options. `clock` is usually clock.NewRealTimeSource but can be a

NewChasmNotifier creates a new instance of ChasmNotifier.

NewCompletionHTTPHandler constructs an [http.Handler] from given options for handling operation completion requests.

NewExecutionPersistenceMetricsClient creates a client to manage executions

NewExecutionStore returns a new ExecutionStore

NewHistoryEventModel initials new history event model

NewMSPointer creates a new MSPointer instance.

NewMockBucketHandleWrapper creates a new mock instance.

NewMockHistoryPaginatedFetcher creates a new mock instance.

NewMockHostInfoProvider creates a new mock instance.

NewMockMapperProvider creates a new mock instance.

NewMockMonitor creates a new mock instance.

NewMockNexusEndpointManager creates a new mock instance.

NewMockProvider creates a new mock instance.

NewMockRunnable creates a new mock instance.

NewMockScheduler creates a new mock instance.

NewMockStreamSender creates a new mock instance.

NewNamespaceTypedSetting creates a setting that uses mapstructure to handle complex structured values. The value from dynamic config will be _merged_

NewNexusEndpointStore returns a new nexus service store

NewOtelMetricsHandler returns a new Handler that uses the provided OpenTelemetry [metric.Meter] to record metrics. This OTel handler supports metric d

NewSearchAttributeDateTime creates a new date time search attribute given a predefined chasm field

NewShardManager returns a new shard manager

NewStringerTag returns a tag that will lazily generate the string representation of the provided fmt.Stringer value. Note that it does **not** cache t

NewTaskExecutor creates a new instance of namespace replicator

NewTaskStore returns a new task store

Now returns the current time, with the location set to UTC.