GetClusterID return the cluster ID, which is also the initial failover version

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

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

WithMetadataContext adds a metadata context to the given context.

Build returns a read-only [Route].

Close gracefully closes the client object

EXPECT returns an object that allows the caller to indicate expected use.

Add a per test prefix to avoid hitting the namespace limit of mapped task queue per build ID

GetPass tracks a value per key, which may be lossy or approximate. It increments the value by inc and returns the new value. The value returned must b

Put adds an element to the cache, returning the previous element

Marshal an object of type Task to the protobuf v3 wire format

NewRealTimeSource returns a timeSource that uses the real wall timeSource time.

State returns the current task state

GetUserData returns the user data for this task queue. Do not mutate the returned pointer, as doing so will cause cache inconsistency.

Value returns the value associated with this context for key. The behavior is the same as context.Context.Value(). Use WithContextValues RegistrableCo

ContextMetadataGet retrieves a metadata value from the context.

Value represents the value

ClusterNameForFailoverVersion return the corresponding cluster name for a given failover version

Update the timer gate, return true if update is a success. Success means timer is idle or timer is set with a sooner time to fire

GetSqlDbColName maps system and reserved search attributes to column names for SQL tables. If the input is not a system or reserved search attribute,

Timer obtains a timer for the given name.

NewURI constructs a new archiver URI from string.

HandleErr handle the error returned by Execute

ProtoEqual compares two proto.Message objects for equality

Allow attempts to allow a request to go through. The method returns immediately with a true or false indicating if the request can make progress

EXPECT returns an object that allows the caller to indicate expected use.

IsGlobalNamespaceEnabled whether the global namespace is enabled, this attr should be discarded when cross DC is made public

newGlobalNamespaceForTest returns an entry with test data

CloseTransactionAsMutation closes the mutable state transaction (different from DB transaction) and prepares the whole state mutation to be persisted

GetCurrentVersionHistory gets the current VersionHistory.

EXPECT returns an object that allows the caller to indicate expected use.

EXPECT returns an object that allows the caller to indicate expected use.

RpcName returns the mangled name of the task queue partition, to be used in RPCs. RPC names look like this: sticky partition: <sticky name> root

SetCallerInfo sets callerName, callerType and CallOrigin in the context. Existing values will be overwritten if new value is not empty. TODO: consider