Failure returns the first Failure that shouldFailTest considered a test-failing log, or nil if no such log has been observed. Sticky: first failure wi

FireAfter check will the timer get fired after a certain time

GetCassandraAddress return the cassandra address

GetCassandraPort return the cassandra port

GetMethodMetadata gets metadata for a given API method in one of the services exported by frontend (WorkflowService, OperatorService, AdminService).

GetPostgreSQLAddress return the Postgres address

GetPostgreSQLPort return the Postgres port

GetResetReapplyExcludeTypes computes the set of requested exclude types. It uses the reset_reapply_exclude_types request field (a set of event types t

nolint:staticcheck

IsLocked returns true if already locked

IsPersistenceTransientError checks if the error is a transient persistence error

IsTimeExpired checks if the testing time is equal or before the reference time. The precision of the comparison is millisecond. This function takes ta

MapSlice given slice xs []T and f(T) S produces slice []S by applying f to every element of xs

MarkAsWrapperError adds the "unwrap-error" metadata to the original failure of the given OperationError, which signals the Temporal codebase to unwrap

MergeCustomMemo merges the provided custom memo fields into the existing ones. - If a key in `customMemo` already exists, the value in `customMemo` re

NewCLILogger returns a logger at debug level and log into STDERR for logging from within CLI tools

NewMockCache creates a new mock instance.

NewMockClientFactory creates a new mock instance.

NewMockClusterMetadataManager creates a new mock instance.

NewRedirection creates DC redirection interceptor

NewServer starts and returns a new TestServer. If not specifying the WithT option, the caller should execute Stop when finished to close the server a

NewWithMetrics creates a new cache that will emit capacity and ttl metrics. handler should be tagged with metrics.CacheTypeTag.

NormalizeAndValidateUserDefined is like NormalizeAndValidate, but specifically for external user-defined task queues, disallowing use of internal per-

Offer offers a task to a potential consumer (poller) If the task is successfully matched with a consumer, this method will return true and no error. I

OperationID returns tag for a nexus operation ID

Parse converts maps of search attribute strings to search attributes. typeMap can be nil (values will be parsed with strconv and MetadataType field wo

ProcessInput validates the input, and returns routing information for processing this operation. The method may mutate the input to set default values

Prompt the user for confirmation. If the user does not respond with "y" or "yes" (case-insensitive and without leading or trailing space), the process

Propagate propagates version headers from incoming context to outgoing context. It copies all headers to outgoing context only if they are exist in in

RangeSelectFromReplicationDLQTasks returns one or more rows from replication_tasks_dlq table