Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 1 callers
Method
ImportWorkflow
( ctx context.Context, workflowKey definition.WorkflowKey, versionHistoryItems []*historyspb.VersionH
service/history/ndc/history_importer.go:25
↓ 1 callers
Method
IndexPutMapping
(ctx context.Context, indexName string, bodyString string)
common/persistence/visibility/store/elasticsearch/client/client.go:41
↓ 1 callers
Method
IndexPutTemplate
(ctx context.Context, templateName string, bodyString string)
common/persistence/visibility/store/elasticsearch/client/client.go:48
↓ 1 callers
Method
Info
Info returns the underlying NamespaceInfo proto. The returned value is the registry's own copy and must not be mutated.
common/namespace/namespace.go:232
↓ 1 callers
Method
Info
(msg string, keyvals ...any)
common/log/sdk_logger.go:61
↓ 1 callers
Method
Initialize
( ctx context.Context, workflowKey definition.WorkflowKey, token []byte, )
service/history/ndc/mutable_state_initializer.go:42
↓ 1 callers
Method
InitializeFromDB
( ctx context.Context, namespaceEntry *namespace.Namespace, workflowKey definition.WorkflowKey, )
service/history/ndc/mutable_state_initializer.go:85
↓ 1 callers
Method
InitializeFromToken
( _ context.Context, namespaceEntry *namespace.Namespace, workflowKey definition.WorkflowKey, token []byte
service/history/ndc/mutable_state_initializer.go:151
↓ 1 callers
Function
InitializeHistoryEventGenerator
InitializeHistoryEventGenerator initializes the history event generator
common/testing/history_event_util.go:38
↓ 1 callers
Method
InitializeNexusEndpointsTableVersion
(ctx context.Context)
common/persistence/sql/sqlplugin/nexus_endpoints.go:23
↓ 1 callers
Method
InitiateShutdown
InitiateShutdown signals the scheduler to stop without waiting for shutdown to complete.
common/tasks/runnable_scheduler.go:14
↓ 1 callers
Method
InitiateShutdown
InitiateShutdown aborts all buffered tasks and empties the buffer.
common/tasks/dynamic_worker_pool_scheduler.go:64
↓ 1 callers
Method
InjectWorkerRPS
Lazy injection of poll metadata. Called whenever a new poll request comes in. This allows the rate limit manager to adjust its rate limits based on an
service/matching/ratelimit_manager.go:180
↓ 1 callers
Method
InsertIntoHistoryImmediateTasks
InsertIntoHistoryImmediateTasks inserts rows that into history_immediate_tasks table.
common/persistence/sql/sqlplugin/history_immediate_tasks.go:39
↓ 1 callers
Method
InsertIntoHistoryScheduledTasks
InsertIntoHistoryScheduledTasks inserts rows that into history_scheduled_tasks table.
common/persistence/sql/sqlplugin/history_scheduled_tasks.go:43
↓ 1 callers
Method
InsertIntoNexusEndpoints
(ctx context.Context, row *NexusEndpointsRow)
common/persistence/sql/sqlplugin/nexus_endpoints.go:27
↓ 1 callers
Method
Intercept
Intercept wraps the request context with metadata storage and invokes the handler. When setTrailer is enabled, accumulated metadata is written to gRPC
common/rpc/interceptor/context_metadata_interceptor.go:48
↓ 1 callers
Function
InterruptCh
()
temporal/interrupt.go:9
↓ 1 callers
Function
InterruptOn
InterruptOn interrupts server on the signal from server. If channel is nil Start() will block forever.
temporal/server_option.go:75
↓ 1 callers
Method
InvalidateCache
()
service/history/hsm/tree.go:344
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RecordActivityTaskHeartbeatRequest, shard historyi.ShardContext,
service/history/api/recordactivitytaskheartbeat/api.go:17
↓ 1 callers
Function
Invoke
( ctx context.Context, resetRequest *historyservice.ResetWorkflowExecutionRequest, shardContext historyi.Sh
service/history/api/resetworkflow/api.go:27
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.VerifyChildExecutionCompletionRecordedRequest, workflowConsi
service/history/api/verifychildworkflowcompletionrecorded/api.go:87
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.QueryWorkflowRequest, shardContext historyi.ShardContext, w
service/history/api/queryworkflow/api.go:33
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RequestCancelWorkflowExecutionRequest, shard historyi.ShardConte
service/history/api/requestcancelworkflow/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.UnpauseActivityRequest, shardContext historyi.ShardContext,
service/history/api/unpauseactivity/api.go:18
↓ 1 callers
Function
Invoke
( ctx context.Context, namespaceUUID namespace.ID, workflowID string, runID string, reapplyEvents []*hist
service/history/api/reapplyevents/api.go:21
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.IsActivityTaskValidRequest, shardContext historyi.ShardContext,
service/history/api/isactivitytaskvalid/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RespondWorkflowTaskFailedRequest, shardContext historyi.ShardCon
service/history/api/respondworkflowtaskfailed/api.go:21
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.UnpauseWorkflowExecutionRequest, shard historyi.ShardContext, w
service/history/api/unpauseworkflow/api.go:17
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.IsWorkflowTaskValidRequest, shardContext historyi.ShardContext,
service/history/api/isworkflowtaskvalid/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.ScheduleWorkflowTaskRequest, shardContext historyi.ShardContext,
service/history/api/scheduleworkflowtask/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.RecordActivityTaskStartedRequest, shardContext historyi.Shar
service/history/api/recordactivitytaskstarted/api.go:38
↓ 1 callers
Function
Invoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionrawhistoryv2/api.go:25
↓ 1 callers
Function
Invoke
( ctx context.Context, workflowKey definition.WorkflowKey, archetypeID chasm.ArchetypeID, shardContext his
service/history/api/refreshworkflow/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.ExecuteMultiOperationRequest, shardContext historyi.ShardContext
service/history/api/multioperation/api.go:55
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.DescribeWorkflowExecutionRequest, shard historyi.ShardContext,
service/history/api/describeworkflow/api.go:63
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RemoveSignalMutableStateRequest, shard historyi.ShardContext, w
service/history/api/removesignalmutablestate/api.go:14
↓ 1 callers
Function
Invoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionrawhistory/api.go:25
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RespondActivityTaskCanceledRequest, shard historyi.ShardContext,
service/history/api/respondactivitytaskcanceled/api.go:21
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.DescribeMutableStateRequest, shardContext historyi.ShardContext,
service/history/api/describemutablestate/api.go:16
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.PauseWorkflowExecutionRequest, shard historyi.ShardContext, wor
service/history/api/pauseworkflow/api.go:17
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.DeleteWorkflowExecutionRequest, shardContext historyi.ShardC
service/history/api/deleteworkflow/api.go:18
↓ 1 callers
Function
Invoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionhistoryreverse/api.go:23
↓ 1 callers
Function
Invoke
( ctx context.Context, shardContext historyi.ShardContext, workflowConsistencyChecker api.WorkflowConsisten
service/history/api/getworkflowexecutionhistory/api.go:119
↓ 1 callers
Function
Invoke
( ctx context.Context, chasmEngine chasm.Engine, request *historyservice.DeleteExecutionRequest, )
service/history/api/deleteexecution/api.go:10
↓ 1 callers
Function
Invoke
( ctx context.Context, signalWithStartRequest *historyservice.SignalWithStartWorkflowExecutionRequest, shar
service/history/api/signalwithstartworkflow/api.go:19
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.ResetActivityRequest, shardContext historyi.ShardContext, workf
service/history/api/resetactivity/api.go:17
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.RespondActivityTaskCompletedRequest, shard historyi.ShardContext
service/history/api/respondactivitytaskcompleted/api.go:21
↓ 1 callers
Function
Invoke
( ctx context.Context, request *historyservice.PauseActivityRequest, shardContext historyi.ShardContext, w
service/history/api/pauseactivity/api.go:19
↓ 1 callers
Function
Invoke
( ctx context.Context, req *historyservice.TerminateWorkflowExecutionRequest, shardContext historyi.ShardCo
service/history/api/terminateworkflow/api.go:15
↓ 1 callers
Method
Invoke
( ctx context.Context, )
service/history/api/updateworkflow/api.go:74
↓ 1 callers
Method
Invoke
Invoke starts a new workflow execution. NOTE: `beforeCreateHook` might be invoked more than once in the case where the workflow policy requires termin
service/history/api/startworkflow/api.go:180
↓ 1 callers
Method
Invoke
nolint:revive // cyclomatic complexity
service/history/api/respondworkflowtaskcompleted/api.go:110
↓ 1 callers
Function
IsAPIOperation
(apiFullName string)
service/frontend/configs/quotas.go:388
↓ 1 callers
Function
IsASCIIUpper
(c rune)
cmd/tools/codegen/helpers.go:94
↓ 1 callers
Method
IsCurrentWorkflowGuaranteed
()
service/history/workflow/mutable_state_impl.go:1308
↓ 1 callers
Method
IsDirty
IsDirty is used for sanity check that mutable state is "clean" after mutable state lock is released. However, certain in-memory changes (e.g. speculat
service/history/workflow/mutable_state_impl.go:7417
↓ 1 callers
Method
IsDirty
()
service/history/historybuilder/history_builder.go:155
↓ 1 callers
Method
IsDupDatabaseError
(err error)
common/persistence/sql/sqlplugin/postgresql/db.go:22
↓ 1 callers
Method
IsDupDatabaseError
(error)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:26
↓ 1 callers
Method
IsDupEntryError
(error)
common/persistence/sql/sqlplugin/postgresql/driver/interface.go:25
↓ 1 callers
Method
IsEmpty
IsEmpty indicate if the priority queue is empty
common/collection/priority_queue.go:59
↓ 1 callers
Method
IsEmpty
()
common/namespace/namespace.go:343
↓ 1 callers
Function
IsEnabled
(t trace.Tracer)
common/telemetry/config.go:419
↓ 1 callers
Method
IsForceTerminated
( workflowID string, runID string, )
tests/ndc/ndc_test.go:2425
↓ 1 callers
Method
IsGlobalNamespace
()
common/namespace/replication_resolver.go:98
↓ 1 callers
Method
IsGlobalNamespace
IsGlobalNamespace returns whether the namespace is a global namespace. Being a global namespace doesn't necessarily mean that there are multiple regis
common/namespace/namespace.go:221
↓ 1 callers
Function
IsHealthCheckAPI
(fullApi string)
common/authorization/frontend_api.go:25
↓ 1 callers
Method
IsInHandover
IsInHandover returns true if operations for this namespace+workflowID should be blocked due to handover.
service/history/shard/handover_tracker.go:30
↓ 1 callers
Function
IsInternalTag
(internal bool)
common/metrics/tags.go:582
↓ 1 callers
Function
IsInternalTaskQueue
IsInternalTaskQueue returns true if the task queue name belongs to an internal system task queue.
common/primitives/task_queues.go:41
↓ 1 callers
Function
IsInternalTaskQueueKind
IsInternalTaskQueueKind returns true if the task queue kind identifies a server-internal task queue (e.g. worker commands queues). All kinds are liste
common/primitives/task_queues.go:28
↓ 1 callers
Function
IsLongPollDescribeActivityExecutionRequest
( req any, )
common/rpc/interceptor/namespace_rate_limit.go:171
↓ 1 callers
Function
IsLongPollGetWorkflowExecutionHistoryRequest
( req any, )
common/rpc/interceptor/namespace_rate_limit.go:161
↓ 1 callers
Function
IsNamespaceHandoverError
(err error)
common/util.go:374
↓ 1 callers
Function
IsNegativeScheduleIDOperator
IsNegativeScheduleIDOperator returns true for operators that express exclusion. Negative operators require AND when combining V1 and V2 WorkflowId con
service/worker/scheduler/schedule_id_query_rewriter.go:146
↓ 1 callers
Method
IsNonCurrentWorkflowGuaranteed
()
service/history/interfaces/mutable_state.go:219
↓ 1 callers
Function
IsNoopAuthorizer
(authorizer Authorizer)
common/authorization/authorizer.go:75
↓ 1 callers
Function
IsRetryableError
(err error)
service/history/api/retry_util.go:12
↓ 1 callers
Method
IsStateDirty
IsStateDirty returns true if any node in the tree has USER DATA modified, which need to be persisted to DB AND replicated to other clusters. The resul
chasm/tree.go:2806
↓ 1 callers
Method
IsStickyTaskQueueSet
()
service/history/workflow/mutable_state_impl.go:1449
↓ 1 callers
Function
IsStickyWorkerUnavailable
(err error)
common/util.go:378
↓ 1 callers
Method
IsStrictOnNextVertex
IsStrictOnNextVertex returns the isStrict flag
common/testing/event_generator.go:455
↓ 1 callers
Method
IsStrictOnNextVertex
()
common/testing/generator_interface.go:54
↓ 1 callers
Method
IsSubStateMachineDeleted
()
service/history/interfaces/mutable_state.go:413
↓ 1 callers
Method
IsTerminalTaskError
()
service/history/queues/executable.go:76
↓ 1 callers
Function
IsUserDefinedSearchAttribute
IsUserDefinedSearchAttribute returns true if alias refers to a user-defined custom search attribute rather than a synthetic one (e.g. the synthetic Sc
common/searchattribute/mapper.go:235
↓ 1 callers
Method
IsValid
()
service/history/replication/stream_receiver.go:36
↓ 1 callers
Method
IsVersionMissingTaskQueues
Used internally by the Worker Deployment workflow in its IsVersionMissingTaskQueues Activity to verify if there are missing task queues in the new cur
service/worker/workerdeployment/client.go:192
↓ 1 callers
Method
IsWorkflow
()
service/history/workflow/mutable_state_impl.go:664
↓ 1 callers
Method
IsWorkflow
()
chasm/tree.go:225
↓ 1 callers
Method
IsWorkflowExecutionRunning
()
service/history/interfaces/mutable_state.go:229
↓ 1 callers
Method
IsWorkflowTaskTrigger
IsWorkflowTaskTrigger returns a boolean indicating whether this event type should trigger a workflow task.
chasm/lib/workflow/events.go:18
↓ 1 callers
Method
Iter
Iter returns an iterator to the map. This map does not use re-entrant locks, so access or modification to the map during iteration can cause a dead lo
common/collection/concurrent_tx_map.go:192
↓ 1 callers
Method
Key
(task tasks.Task)
service/history/queues/grouper.go:19
↓ 1 callers
Method
Key
(task tasks.Task)
service/history/queues/grouper.go:37
↓ 1 callers
Function
KeyExists
(ctx context.Context, s3cli S3API, URI archiver.URI, key string)
common/archiver/s3store/util.go:93
↓ 1 callers
Method
KillHost
KillHost kills the given host within the cluster
common/membership/ringpop/test_cluster.go:177
↓ 1 callers
Method
LastActiveTime
()
common/tasks/weighted_channel.go:48
← previous
next →
10,001–10,100 of 43,335, ranked by callers