TrimHistoryBranch trims a branch

TrimStateMachineTimers returns of copy of trimmed the StateMachineTimers slice by removing any timer tasks that are associated with an HSM node that h

TryGet returns the parent component and a boolean indicating if the value was found, deserializing if necessary. Panics rather than returning an error

TrySubmit submits a task for processing. If called after the scheduler is shut down, the task will be accepted and aborted.

TrySyncMatch tries to match task to a local or remote poller. Returns a syncMatchOutcome indicating success or the reason the match failed.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

UpdateHandoverState processes a namespace state change.

UpdateIncomingSignalEvent updates the eventID for an existing signal requestID in the map. If the requestID is not in the map, this is a no-op (e.g. w

UpdateResetRunID saves the runID that resulted when this execution was reset.

Validate checks if a given task queue name is valid. It verifies the name is not empty, does not exceed the maximum length, and is a valid UTF-8 strin

ValidateAndLowercaseNexusHeaders validates headers and returns a new map with lower-cased keys.

nolint:revive,cognitive-complexity

ValidateComponentTotal checks that adding addingCount links to a component already holding existingCount links would not exceed the per-component cap.

ValidateDeploymentVersion returns error if the deployment version is not a valid entity.

ValidateDeploymentVersionStringV31 returns error if the deployment version is nil or it has empty version or deployment name.

ValidateOperationName checks that the operation name does not exceed the configured limit.

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

ValidateServiceName checks that the service name does not exceed the configured limit.

ValueType returns tag for ValueType

VerifyCompatibleVersion ensures that the installed version of temporal and visibility is greater than or equal to the expected version.

VersionStampToBuildIdSearchAttribute returns the search attribute value for a version stamp

VersionedTag represents whether a loaded task queue manager represents a specific version set or build ID or not.

WaitN waits up till maximum deadline for n rate limit tokens

WaitShutdown waits for the scheduler to complete shutdown. Must be called after InitiateShutdown().

WaitShutdown waits for all worker goroutines to complete.

WaitUntilInitialized blocks until initialization is completed and returns the result of initialization. The current implementation does log.Fatal if i

WithArchival enables archival on the test's cluster. This implies a dedicated cluster because archival is configured at the cluster level.

WithAudienceGetter configures JWT audience getter for authorization

WithBadBinary adds a bad binary checksum to a Namespace during a Clone operation.

WithBaseClientOptions configures options for the default clients and workers connected to the test server.

WithBaseServerOptions enables configuring additional server options not directly exposed via temporaltest.