GetReachableMembers returns addresses of all members of the ring.

GetRecordedTasksByCategoryFiltered returns recorded tasks WITH metadata for a specific category, filtered by namespace (required) and optionally by wo

GetValues returns header values for passed header names. It always returns slice of the same size as number of passed header names.

Handles the maybe-long-poll GetUserData RPC.

HasExecutionQueue returns true if the task's execution has an active queue in the executionQueueScheduler.

InjectHooks injects the test hooks for this matching behavior.

Intercept a grpc request

Invoke the GetDLQTasks API. All errors returned from this function are already translated into the appropriate type from the [serviceerror] package.

IsMappable returns true if name can be mapped to the alias. Mappable search attributes are those that can be defined by the user.

IsOnCluster returns true is namespace is registered on cluster otherwise false.

IsReserved returns true if name is system reserved and can't be used as custom search attribute name.

Iter returns an iterator to the map

LifecycleState implements the chasm.Component interface.

Links returns the union of links attached to the given component across all requests. Returns nil for components that are not (yet) registered as tree

LockLow try to lock with low priority, use LockLow / UnlockLow pair to lock / unlock

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

MaskStruct replace password values with mask and returns copy of the strct. Original strct value is not modified. Doesn't go recursively through strct

MatchTaskImmediately attempts a non-blocking sync match.

MinTime returns the earlier of two given time.Time

NewCallback creates a new callback in the STANDBY state from given params.

NewCliApp instantiates a new instance of the CLI application.

NewCliApp is a wrapper around [tdbg.NewCliApp] that sets the [cli.App.ExitErrHandler] to a no-op function.

NewConnection creates a new connection to database

NewDefaultRateLimiter returns a default rate limiter with a dynamic burst ratio and fixed 1 minute refresh interval

NewDelayedRequestRateLimiter returns a DelayedRequestRateLimiter that delegates to the given rate limiter after a delay. The timeSource is used to cre

NewFrontendServiceErrorInterceptor returns a gRPC interceptor that has two responsibilities: 1. Mask certain internal service error details. 2. Propag

NewMockArchivalMetadata creates a new mock instance.

NewMockDataStoreFactory creates a new mock instance.

NewMockHistogramIface creates a new mock instance.

NewMockRequestRateLimiter creates a new mock instance.

NewMockTaskManager creates a new mock instance.

NewMockWorkflowRun creates a new mock instance.

NewNoopDataMerger creates a new NoopDataMerger.

NewOnceMap creates a [OnceMap] from a given construct function. construct should be kept light as it is called while holding a lock on the entire map.

NewOperation creates a new Operation component with the given persisted state.

NewRangeBackfiller returns an intialized Backfiller component, which should be parented under a Scheduler root node.

NewScope builds a new tally scope for this metrics configuration If the underlying configuration is valid for multiple reporter types, only one of th

NewSimple creates a new simple cache with given options. Simple cache will never evict entries and it will never reorder the elements. Simple cache al

NewSlogLogger creates an slog.Logger from a given logger.