tryEvictUntilCacheSizeUnderLimit tries to evict entries until c.currSize is less than c.maxSize.

tryParseDataRace parses a data race alert at position i if present.

tryParseFatal parses a runtime fatal error alert at position i if present.

tryParsePanic parses a non-timeout panic alert at position i if present.

trySetRPSFromUserDataLocked sets the apiConfigRPS from user data. Called exclusively in response to updates in user data.

tryVisibilityMapper might find a successful match in which case we return it otherwise we continue with the fallback logic.

tweakablesFromContext returns the scheduler Tweakables for the context's namespace, falling back to DefaultTweakables when no config is registered.

nolint:staticcheck // SA1019

nolint:staticcheck // SA1019

updateIndexMappings updates the mappings of an existing index using raw HTTP request

updateRatelimitLocked checks and updates the overall queue rate limit if changed.

updateResult returns the update result sent by the worker in this cluster.

UpdateUserData allows callers to update user data (such as worker build IDs) for this task queue. The pointer passed to the update function is guarant

nolint:revive // cyclomatic complexity

upsertHeartbeat records or refreshes a WorkerHeartbeat under the given namespace. New entries increment the global counter.

Generate new uuid for every new n.

validateAccessHelper is a helper method that validates both the current node's lifecycle state AND its ancestors recursively. Do not call this method

Receiver mode can only be set once for the lifetime of the receiver. Receiver mode is set when receiver receive the first task. If the first task is p

nolint:revive // cyclomatic complexity

validateCachedState clears cached fields whenever the Scheduler's ConflictToken doesn't match its cacheConflictToken field. Validation is only as effe