SelectFromTasks retrieves one or more rows from the tasks_v2 table Required filter params - {RangeHash, TaskQueueID, InclusiveMinLevel, PageSize} Retu

Serialize a state machine into bytes.

SetHistoryEnabledByDefault sets the default history archival config to be enabled.

SetMetricsHandler sets the metrics handler for the client. This is useful when the metricsHandler is not available at the time of initialization due t

SetSpeculativeWorkflowTaskTimeoutTask submits the task to the shard's in-memory scheduled queue, replacing any prior speculative timeout. VisibilityTi

Deprecated: SetT is managed internally by [Run]. Do not call directly.

Helpers for creating new retry/cron workflows:

ShouldSkipReactivation reports whether a reactivation signal to the given version would be redundant. Returns true when the version's status is CURREN

SignalWithStartWorkflow mocks base method.

SliceTail returns the last n elements of s. n may be greater than len(s).

SplitHistoryGarbageCleanupInfo returns workflow identity information

StampIfUsingVersioning returns the given WorkerVersionStamp if it is using versioning, otherwise returns nil.

Start causes this service to join the membership ring. Services should not call Start until they are ready to receive requests from other cluster memb

Stop stops the scavenger

SubscribeShardCount returns a ShardCountSubscription for receiving shard count updates.

T returns the *testing.T, panicking if the guard has been sealed.

TLSInfoFromContext extracts TLS information from the context's peer value.

TagLoggerWithArchiveHistoryRequestAndURI tags logger with fields in the archive history request and the URI

TagLoggerWithArchiveVisibilityRequestAndURI tags logger with fields in the archive visibility request and the URI

TakeRemaining removes all remaining values from this set and returns them.

TaskGroup returns the side-effect task group for the task.

TaskKey returns tag for TaskKey

TaskPriority returns tag for TaskPriority

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

Terminate method is invoked by the chasm framework on an execution's root component when the execution needs to be forcefully terminated. Some example

Timeout returns tag for timeout

ToAPICallback converts a CHASM callback to API callback proto.

TokenLastEventVersion returns tag for TokenLastEventVersion

TokenizeTextQueryString tokenizes the string by spaces It's a temporary solution as it doesn't cover tokenizer used by PostgreSQL or SQLite.

TrailerToContextMetadataInterceptor reads metadata from gRPC response trailers and propagates it to the calling context using contextutil.ContextMetad

TryLockHigh try to lock with high priority, return true if lock acquired use TryLockHigh / UnlockHigh pair to lock / unlock

TryLockLow try to lock with high priority, return true if lock acquired use TryLockLow / UnlockLow pair to lock / unlock

Unmarshal an object of type ListChasmExecutionsRequest from the protobuf v3 wire format

Unmarshal an object of type Baggage from the protobuf v3 wire format

Unmarshal an object of type NexusEndpoint from the protobuf v3 wire format

Unmarshal an object of type HistoryBranch from the protobuf v3 wire format

Unmarshal an object of type UpdateInfo from the protobuf v3 wire format

Unmarshal an object of type HistoryTask from the protobuf v3 wire format

Unmarshal an object of type HostInfo from the protobuf v3 wire format

UnpackNexusCallbackToken decodes a callback token produced by GenerateNexusCallback, returning the component ref and request ID. It accepts both token

UpdateBuildIdAssignment based on initial assignment or a redirect

UpdateHistoryBranchInfo updates the history branch with branch information

Additions to rateLimitManager for use by other unit tests:

nolint:revive

ValidateAndNormalizeStandaloneActivity validates and normalizes the attributes for a standalone activity.

ValidateClusterInformation checks the invariants that NewMetadata and the runtime refresh both depend on. It is also used at admin/operator RPC bounda

NOTE: when modifying this file, plz make each case clear, do not combine cases together. The idea for this file is to test whether current record poin

ValidateDeploymentVersionFields is a helper that verifies if the fields within a Worker Deployment Version are valid

ValidateGetRequest validates the get archived history request

ValidateHistoryArchiveRequest validates the archive history request

ValidateLongPollContextTimeout checks if the context timeout for a long poll handler is too short or below a normal value. If the timeout is not set o