This API records the child completion event in the parent's history. It does the following. - Rejects the request if the parent was closed for any rea

IsChasmSearchAttribute checks if a field name matches the pattern for CHASM search attributes. CHASM search attributes follow the pattern: Temporal<Ty

IsCurrentVersionHistoryEmpty checks if the current VersionHistory is empty.

IsDetached returns true if the component type is registered as detached.

IsExperimentAllowed checks if an experiment is enabled for a given namespace in the dynamic config. Returns true if the experiment is explicitly liste

IsExperimentRequested checks if a specific experiment is present in the temporal-experiment header. Returns true if the experiment is explicitly liste

IsReplicationEnabledForCluster checks if replication is enabled for a cluster, considering the feature flag. When enableSeparateReplicationFlag is fal

Label implements ringpop's Membership interface

LastEventVersion returns tag for LastEventVersion

LegacyToCreateFromMigrationStateRequest converts legacy (workflow-backed) scheduler state to a CreateFromMigrationStateRequest proto. This is the prim

below are the functions used by heap.Interface and go internal heap implementation Len implements sort.Interface

ListAllNamespaces returns the names of every namespace active in the current cluster, from the namespace registry's in-memory snapshot. The snapshot m

ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.

MakeDirectiveForWorkflowTask returns a versioning directive based on the following parameters: - inheritedBuildId: build ID inherited from a past/prev

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

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

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

MergeAndApply merges the requested options mentioned in the field mask with the current options in the mutable state and applies the changes to the mu

MetricTag returns a label for this partition kind to be used in metrics. When partitionIDBreakdown is true, partitions that support multiple partition

MetricsHandler returns a metrics handler with namespace tag.

New returns a new instance of scanner daemon Scanner is the background sub-system that does full scans of database tables in an attempt to cleanup res

NewClient creates a new history service gRPC client

NewClient return a Temporal gcloudstorage.Client based on default google service account creadentials (ScopeFullControl required). Bucket must be crea

NewClientFactory creates a new ClientFactory

NewClientMetricsTrailerPropagatorInterceptor returns grpc client interceptor that injects metrics received in trailer into metrics context.

NewClusterMetadataManager returns a new manager for cluster specific metadata

NewComponentRefByArchetypeID creates a new ComponentRef with a known archetype ID. This should only be used by CHASM framework internals. CHASM librar

NewContextFromParentWithTimeoutAndVersionHeaders creates context from parent context with timeout and version headers.

NewDefaultAuthorizer creates a default authorizer

NewForwardingTrace functions the same as NewTrace but forwarded requests do not have an associated attempt count, so all forwarded requests will be tr

NewHTTPHandler constructs an [http.Handler] from given options for handling Nexus service requests.

NewHistoryIteratorFromState returns a new HistoryIterator with specified state

NewIndexedTakeList constructs a new IndexedTakeSet by applying the provided indexer to each of the provided values.

NewJSONPBIndentEncoder creates a new JSONPBEncoder with indent.

NewMetadataManager returns a new metadata manager

NewMockArchiverProvider creates a new mock instance.

NewMockEventsReapplier creates a new mock instance.

NewMockExecutionStore creates a new mock instance.

NewMockExecutor creates a new mock instance.

NewMockParentPtr creates a ParentPtr[T] backed by real Node instances that returns the given parent value when Get or TryGet is called. This is intend

NewMockRescheduler creates a new mock instance.

NewMockServiceResolver creates a new mock instance.

NewMockStateRebuilder creates a new mock instance.

NewMockTaskExecutor creates a new mock instance.

NewMultiRateLimiter returns a new rate limiter that have multiple stage

NewNamespaceTypedSettingWithConverter creates a setting with a custom converter function.

NewNoopRedirectionPolicy is DC redirection policy which does nothing

NewOwnershipBasedQuotaScaler returns an OwnershipBasedQuotaScaler. The updateAppliedCallback field is a channel which is sent to in a blocking fashion

NewPriorityQueueWithItems creats a new priority queue with the provided list of items. PriorityQueue will take ownership of the passed in items, so ca

NewProcessor create new processorImpl