EndpointByName resolves a nexus endpoint entry.

Entries returns a channel of MapEntry objects that can be used in a range loop

EqualTimesWithPrecision assertion that two times are equal within precision

Evict removes the cached entry for the given key and runs its release fn.

Execute toggles the callback status from BACKING_OFF to SCHEDULED to trigger a new invocation attempt.

ExecuteRemoteMethod gets an [RemoteExecutor] from the registry and invokes it. Returns [ErrNotRegistered] if an executor is not registered for the giv

Exists returns nil if the namespace exists, otherwise an error.

ExpectedVersion returns expected version.

ExpectedVersion returns expected version.

Export implements metric.Exporter

Extract extracts routing key from the request using the specified pattern. Returns a zero-value namespace.RoutingKey if not found.

FailoverVersion returns tag for Version

FailoverVersion return the namespace failover version

FinalGC does a final gc pass before unloading. Used when unloading a draining queue that won't be reloaded.

FindRedirectBuildId follows chain of redirect rules starting from the given sourceBuildId and returns the final target build ID that should be used fo

FoldSlice folds left a slice using given reducer function and initial value.

ForEachTask calls pred on each non-forwarder task. If pred returns true, calls post and removes the task. pred and post must not call back into taskBT

ForceClose ignores reference counts and shutsdown the underlying connection pool

ForceLoadAllChildPartitions force-loads known child (read) partitions in new goroutines. TODO(dp): consider moving this into scaleManager.backgroundWo

Forget removes a previously registered expectation. A forgotten expectation will no longer be evaluated when logs are encountered.

FormatReportForDebug formats the success report for console output

ForwardNexusTask forwards a nexus task to parent task queue partition, if it exists.

FromStatus converts gRPC status to service error.

FromStatus converts gRPC Status to service error.

FrontendHostPort returns the host:port for this server. When constructing a Temporalite client from within the same process, NewClient or NewClientWi

GenerateDeleteHistoryEventTask adds a task to delete all history events for a workflow execution. This method only adds the task to the mutable state

replication tasks

NOTE: DO NOT MODIFY UNLESS ALSO APPLIED TO ./service/frontend/token_deprecated.go

GenerateWorkflowID generates a deterministic workflow ID for a buffered action by combining the base workflow ID with the truncated nominal time.

Get a single value from the underlying gRPC metadata. Returns an empty string if the metadata key is unset.

GetAddress returns the ip:port address

GetAllPollerInfo returns all pollers that polled from this taskqueue in last few minutes