ParseDuration is like time.ParseDuration, but supports unit "d" for days (always interpreted as exactly 24 hours).

ParseValue returns a string, int64 or float64 if the parsing succeeds.

PathsByDir returns a list of paths to directories within the schema subdirectory that have versioned schemas in them

Peek returns the first item of the queue

PollActivityTask creates an activity task poller that uses the given PollActivityTaskQueueRequest.

Put records the given key value mapping. Overwrites previous values

RangeID returns the current persistence view of rangeID

ReadMessages returns messages in order of increasing message ID.

RegisterServiceNameToServiceTypeEnum must be called from a static init().

ReplicationPolicy return the derived workflow replication policy

Resolve implementation should return list of addresses for the service (not necessary IP addresses but addresses that service dependency library accep

RunTool runs the temporal-sql-tool command line tool

SearchAttributesMapper returns the search attributes mapper for this component.

SetupSuiteBase sets up the test suite

SliceHead returns the first n elements of s. n may be greater than len(s).

Only validates the scheme and buckets are passed

SortSlice sorts the given slice of an ordered type. Sort is not guaranteed to be stable.

StateMachinePath gets the state machine path for from this reference.

TearDownCluster tears down the test cluster

TearDownSuiteBase tears down the test suite

TODO (alex): remove this method. Replace usages with concrete methods.

TokenLastEventID returns tag for TokenLastEventID

UnaryInterceptor returns a gRPC unary client interceptor that captures messages

UnixMilliseconds returns t as a Unix time, the number of milliseconds elapsed since January 1, 1970 UTC. It should be used for all CQL timestamp.

UnlockHigh unlock with high priority, use LockHigh / UnlockHigh pair to lock / unlock

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

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

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

Validate validates a retry policy

ValidateAndNormalizeEmbeddedActivity validates and normalizes the attributes for an embedded activity.

ValidateState returns a [consts.ErrStaleReference] if the machine is not in the expected state.

WithBusinessIDAlias allows specifying the business ID alias of the component. This option must be specified if the archetype uses the Visibility compo

history tree WorkflowBranchToken returns tag for WorkflowBranchToken

WorkflowNewRunID returns tag for WorkflowNewRunID

WorkflowNextEventID returns tag for WorkflowNextEventID

abort set Update futures with error or failure (which is passed to all waiters) and set state to stateAborted. It is a terminal state. Update can't be

add applies sizeDiff to stats.HistorySize and remembers it so it can be reverted.

appendAlertsSuite adds a synthetic JUnit suite summarizing high-priority alerts (data races, panics, fatals) so that CI surfaces them prominently.

awaitUpdateAccepted polls the workflow history until a WorkflowExecutionUpdateAccepted event is found, failing the test if it does not appear within 1

calcRampThreshold returns a number in [0, 100) that is deterministically calculated based on the passed id