NewNexusEndpointProcessor creates a new NexusEndpointProcessor.

NewProtoTaskBlobEncoder returns a TaskBlobEncoder that uses a TaskBlobProtoDeserializer to deserialize the blob.

NewRegistry creates a new instance of Registry for accessing and caching namespace information to reduce the load on persistence.

NewRemoteGate create a new timer gate instance

NewRequestErrorHandler creates a new RequestErrorHandler

NewRetryableClient creates a new instance of historyservice.HistoryServiceClient with retry policy

NewServerMetricsContextInjectorInterceptor returns grpc server interceptor that adds metrics context to golang context.

NewShardStore returns a new shard store

TODO (alex): use it by default SdkCleint everywhere?

Caller must call UpdateSettings once before using this object.

PartialRefresh refresh tasks for all sub state machines that have been updated since the given minVersionedTransition (inclusive). If a sub state mach

Patch applies a patch to the schedule for PatchSchedule requests.

PollComponent waits until the predicate is true when evaluated against the component identified by the supplied component reference. If this times out

ProtoElementsMatch behaves like require.ElementsMatch except in that it works for protobuf-generated structs. Both arguments must be slices or arrays.

ProtoSliceEqual compares elements in a slice of proto.Message. This is not a method on the suite type because methods cannot have generic parameters a

PutIfNotExist records the mapping, if there is no mapping for this key already Returns true if the mapping was recorded, false otherwise

PutOrDo put the key value in the map, if key does not exists, otherwise, call fn with existing key and value return (value, fn evaluated or not, error

QueryID returns tag for QueryID

RecordTaskAdd records the outcome of a task add to this physical queue using the queue's tagged metrics handler, so all per-physical-queue labels are

RegisterActivities registers remote Activity types provided by this worker component. Local Activities should be registered in RegisterWorkflow

RegisterImmediateExecutor registers an [ImmediateExecutor] for the given task type. Returns an [ErrDuplicateRegistration] if an executor for the type

RegisterPlugin will register a SQL plugin

RegisterServiceProcessor adds a service-level processor to the endpoint keyed by its name. Returns an error if a processor with the same name is alrea

RemoveIf deletes the given key from the map if fn return true return whether the key is removed or not

ReplaceCustomMemo replaces the existing custom memo fields with the provided ones. If `customMemo` is empty, the underlying memo node is deleted.

RequestLinks returns the links attached to the given component for the specific requestID. Returns nil if no entry exists for that requestID. Empty re

Reset cleans up all the internal states and reset to a brand new generator

SelectFromTasks retrieves one or more rows from the tasks table Required filter params - {namespaceID, taskqueueName, taskType, inclusiveMinTaskID, ex

SetDefaultWorkflowIDPolicies migrates and applies defaults to both Workflow ID policies.

Sets the value of the future, if it has not been set already. Returns true if this call set the value.

SetVisibilityEnabledByDefault sets the default visibility archival config to be enabled.

ShallowCopyClusterInformation returns a shallow copy of the given ClusterInformation. The [ClusterInformation.Tags] field is not deep-copied, so you m

ShardID returns the target shard ID for this routing key given the total number of shards.

Size returns the size of the object, in bytes, once serialized

SourceClusterTag returns a new source cluster tag.

StartScaleManager is called by backlog manager after it's loaded metadata from the default queue. (New matcher only.)

implements heap.Interface, do not call directly

Take finds a value in this set by its key and removes it, returning the value.