GetLocalhostIP returns the ip address of the localhost domain

InsertIntoReplicationDLQTasks puts the replication task into DLQ

InsertIntoReplicationTasks inserts rows that into replication_tasks table.

InsertIntoTimerTasks inserts rows that into timer_tasks table.

InsertIntoTransferTasks inserts rows that into transfer_tasks table.

InsertIntoVisibilityTasks inserts rows that into visibility_tasks table.

IsResourceExhausted checks if the error is a service busy error.

IsRetryableError check whether to retry after HandleErr(Execute())

Iterator returns the iterator of the cache

Len returns the number of items in the map

Less implements sort.Interface

MachineCollection creates a new typed [statemachines.Collection] for callbacks.

MarkAlive updates the liveness timer to keep this physicalTaskQueueManager alive.

MustValidateUUID parses and validates UUID contents from the given string representation returns empty string if the input is empty string panics if t

NewDynamicRateLimiter returns a rate limiter which handles dynamic config

NewEventLog returns an initialized EventLog component, intended to be parented under any component that wants to record events.

NewFakeMemberCounter returns a new fake quotas.MemberCounter that always returns numInstances.

NewMockTaskRefresher creates a new mock instance.

NewRegisterableNexusOperationProcessor wraps a typed NexusOperationProcessor and returns a registerable adapter.

NewShardedConcurrentTxMap returns an instance of ShardedConcurrentMap ShardedConcurrentMap is a thread safe map that maintains upto nShards number of

NewTestClusterMetadataConfig return an cluster metadata config

NormalizeAndValidate validates a TaskQueue proto object as a top-level task queue or a sticky queue and normalizes its fields. Note that a TaskQueue p

RemoveSearchAttributes removes custom search attributes and returns comprehensive information about them. Deprecated. Use operatorservice instead.

Retention returns retention duration for this namespace.

Task returns tag for Task

Get the counts for a small number of top keys (the maximum keys returned will be limited by the Counter's configuration). Not guaranteed to return the

Type implements hsm.StateMachineDefinition.

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

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

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

ValidateCreateWorkflowStateStatus validate workflow state and close status

WaitN waits till the deadline for n rate limit token to allow the request to go through.

WithConfigDir sets the directory path where configuration files are located. If empty, defaults to "config".