MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 1 callersMethodRelease
(n int)
common/locks/priority_semaphore_impl.go:175
↓ 1 callersMethodRemoveFromBuildIdToTaskQueueMapping
(ctx context.Context, request RemoveFromBuildIdToTaskQueueMapping)
common/persistence/sql/sqlplugin/matching_task_queue_user_data.go:50
↓ 1 callersMethodRemovePayload
( mutableContext chasm.MutableContext, key string, )
chasm/lib/tests/payload.go:182
↓ 1 callersMethodRemoveReportedProblemsSearchAttribute
()
service/history/workflow/mutable_state_impl.go:7053
↓ 1 callersMethodRemoveSpeculativeWorkflowTaskTimeoutTask
()
service/history/workflow/mutable_state_impl.go:7370
↓ 1 callersMethodReplicationConfig
()
common/namespace/replication_resolver.go:32
↓ 1 callersMethodReplicationConfig
ReplicationConfig returns the underlying NamespaceReplicationConfig proto. The returned value is the registry's own copy and must not be mutated.
common/namespace/namespace.go:244
↓ 1 callersMethodReprocessAllTasks
()
service/matching/physical_task_queue_manager.go:107
↓ 1 callersMethodRequestCancelInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:86
↓ 1 callersFunctionRequestCount
RequestCount returns tag for RequestCount
common/log/tag/tags.go:516
↓ 1 callersMethodRequireNoHistoryEvent
RequireNoHistoryEvent fails the test if any event matches the given event type.
common/testing/historyrequire/history_require.go:76
↓ 1 callersMethodRequireTransportSecurity
RequireTransportSecurity returns true so the bearer never attaches to plaintext dials, per RFC 9700.
common/rpc/auth/token_credentials.go:44
↓ 1 callersMethodReschedule
()
service/history/replication/batchable_task.go:120
↓ 1 callersMethodReschedule
Reschedule marks the task for retry
common/tasks/task.go:37
↓ 1 callersMethodReserve
()
common/quotas/clocked_rate_limiter.go:70
↓ 1 callersMethodReserve
(now time.Time, request Request)
common/quotas/multi_request_rate_limiter_impl.go:51
↓ 1 callersMethodReserve
( now time.Time, request Request, )
common/quotas/priority_rate_limiter_impl.go:96
↓ 1 callersMethodReserveN
(now time.Time, token int)
common/quotas/clocked_rate_limiter.go:74
↓ 1 callersMethodReset
()
common/backoff/retrypolicy.go:43
↓ 1 callersMethodResolvePendingTaskIDs
ResolvePendingTaskIDs replaces PendingMaxReplicationTaskID sentinel watermarks with real values. Called when shard state transitions to acquired.
service/history/shard/handover_tracker.go:38
↓ 1 callersFunctionResolveWorkflowIDConflictPolicy
( shardContext historyi.ShardContext, workflowKey definition.WorkflowKey, namespaceEntry *namespace.Namespa
service/history/api/workflow_id_dedup.go:83
↓ 1 callersMethodRetryBehavior
()
common/nexus/nexusrpc/failure_converter.go:32
↓ 1 callersMethodRetryPolicy
()
service/history/replication/executable_task.go:66
↓ 1 callersMethodRollback
()
common/persistence/sql/sqlplugin/tests/queue_v2.go:157
↓ 1 callersMethodRoute
(p tqid.Partition)
client/matching/client.go:505
↓ 1 callersMethodRsaKey
(alg string, kid string)
common/authorization/token_key_provider.go:16
↓ 1 callersMethodRun
Run runs the scavenger
service/worker/scanner/history/scavenger.go:119
↓ 1 callersFunctionRunHistoryTaskQueueManagerTestSuite
RunHistoryTaskQueueManagerTestSuite runs all tests for the history task queue manager against a given queue provided by a particular database. This te
common/persistence/tests/history_task_queue_manager_test_suite.go:87
↓ 1 callersMethodRunID
RunID is different from other getters. By default, it returns an empty string. This is to simplify the usage of WorkflowExecution() which most of the
common/testing/testvars/test_vars.go:199
↓ 1 callersMethodRunIndexCreation
RunIndexCreation runs only index creation
tools/elasticsearch/tasks.go:127
↓ 1 callersMethodRunIndexUpdate
RunIndexUpdate updates the mappings of an existing index
tools/elasticsearch/tasks.go:140
↓ 1 callersFunctionRunSQLQueueV2TestSuite
(t *testing.T, baseDB sqlplugin.DB)
common/persistence/sql/sqlplugin/tests/queue_v2.go:180
↓ 1 callersMethodRunSchemaSetup
RunSchemaSetup runs only cluster settings and template setup (no index creation)
tools/elasticsearch/tasks.go:96
↓ 1 callersMethodRunTemplateUpgrade
RunTemplateUpgrade runs only template upgrade
tools/elasticsearch/tasks.go:114
↓ 1 callersFunctionRunTool
(args []string)
tools/fairsim/sim.go:87
↓ 1 callersFunctionRunTool
RunTool runs the temporal-elasticsearch-tool command line tool
tools/elasticsearch/main.go:26
↓ 1 callersMethodRunning
()
service/worker/pernamespaceworker.go:131
↓ 1 callersMethodSATypeMap
SATypeMap returns the type map for the CHASM search attributes.
chasm/visibility.go:113
↓ 1 callersMethodSLog
()
common/log/slog.go:25
↓ 1 callersFunctionSanitizeMutableStateMutation
( mutableStateMutation *persistencespb.WorkflowMutableStateMutation, )
service/history/workflow/mutable_state_util.go:51
↓ 1 callersMethodScanCAS
(...any)
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:29
↓ 1 callersFunctionScheduleAttempt
ScheduleAttempt returns tag for ScheduleAttempt
common/log/tag/tags.go:705
↓ 1 callersMethodSelectFromQueueV2Metadata
(ctx context.Context, filter sqlplugin.QueueV2MetadataFilter)
common/persistence/sql/sqlplugin/sqlite/queue_v2.go:33
↓ 1 callersMethodSendMsg
(m any)
tests/testcore/replication_stream_recorder.go:228
↓ 1 callersFunctionSequentialTaskQueueCompareLess
(this TrackableExecutableTask, that TrackableExecutableTask)
service/history/replication/sequential_queue.go:75
↓ 1 callersMethodSerialize
Serialize implements nexus.Serializer.
common/nexus/payload_serializer.go:100
↓ 1 callersMethodSerialize
( registry *Registry, )
chasm/ref.go:99
↓ 1 callersMethodSerializeClusterMetadata
(icm *persistencespb.ClusterMetadata)
common/persistence/serialization/serializer.go:37
↓ 1 callersMethodSerializeNexusTaskToken
(taskToken *tokenspb.NexusTask)
common/tasktoken/serializer.go:41
↓ 1 callersMethodSerializeOutput
SerializeOutput serializes output of the invocation to a byte array that is suitable for transport.
service/history/hsm/remote_methods.go:9
↓ 1 callersMethodSerializeQueryTaskToken
(taskToken *tokenspb.QueryTask)
common/tasktoken/serializer.go:28
↓ 1 callersMethodSerializeReplicationTask
(task tasks.Task)
service/history/replication/fx.go:37
↓ 1 callersFunctionSerializeToken
(token any)
common/archiver/s3store/util.go:46
↓ 1 callersMethodSetAdminRateForTesting
(rps float64)
service/matching/ratelimit_manager_test.go:72
↓ 1 callersMethodSetBatchGenerationRule
SetBatchGenerationRule sets a function to determine next generated batch of history events
common/testing/event_generator.go:183
↓ 1 callersMethodSetBurst
(burst int)
common/quotas/rate_burst.go:156
↓ 1 callersMethodSetBurstAt
(t time.Time, newBurst int)
common/quotas/clocked_rate_limiter.go:148
↓ 1 callersMethodSetContextMetadata
( ctx context.Context, )
service/history/workflow/mutable_state_impl.go:7628
↓ 1 callersMethodSetCurrentBranchToken
( branchToken []byte, )
service/history/workflow/mutable_state_impl.go:1059
↓ 1 callersFunctionSetCurrentVersionHistoryIndex
SetCurrentVersionHistoryIndex set the current VersionHistory index.
common/persistence/versionhistory/version_histories.go:171
↓ 1 callersFunctionSetDefaultContinueAsNewInitiator
(f *enumspb.ContinueAsNewInitiator)
common/enums/defaults.go:59
↓ 1 callersFunctionSetDefaultHistoryEventFilterType
(f *enumspb.HistoryEventFilterType)
common/enums/defaults.go:35
↓ 1 callersFunctionSetDefaultParentClosePolicy
(f *enumspb.ParentClosePolicy)
common/enums/defaults.go:47
↓ 1 callersFunctionSetDefaultQueryRejectCondition
(f *enumspb.QueryRejectCondition)
common/enums/defaults.go:53
↓ 1 callersFunctionSetDefaultResetReapplyType
(f *enumspb.ResetReapplyType)
common/enums/defaults.go:65
↓ 1 callersFunctionSetDefaultUpdateWorkflowExecutionLifecycleStage
(f *enumspb.UpdateWorkflowExecutionLifecycleStage)
common/enums/defaults.go:71
↓ 1 callersMethodSetDeleteAfterClose
SetDeleteAfterClose suppresses the close visibility task when an execution is being terminated as part of a delete operation. Must be called before a
chasm/tree.go:2863
↓ 1 callersFunctionSetEventRegistryOnContext
SetEventRegistryOnContext injects the event registry into a CHASM context. This is primarily useful for tests that construct MockMutableContext direct
chasm/lib/workflow/library.go:76
↓ 1 callersMethodSetGlobalFlag
Mutation methods for modifying resolver state
common/namespace/replication_resolver.go:35
↓ 1 callersMethodSetHistoryClientForTesting
SetHistoryClientForTesting sets history client. Only used by tests.
service/history/shard/context_testutil.go:212
↓ 1 callersMethodSetInitializedError
(err error)
service/matching/backlog_manager.go:150
↓ 1 callersMethodSetLimitAt
(t time.Time, newLimit rate.Limit)
common/quotas/clocked_rate_limiter.go:144
↓ 1 callersMethodSetLoggers
SetLoggers sets both s.throttledLogger and s.contextTaggedLogger. Only used by tests.
service/history/shard/context_testutil.go:201
↓ 1 callersMethodSetManager
( ctx context.Context, namespaceEntry *namespace.Namespace, request *workflowservice.SetWorkerDeployment
service/worker/workerdeployment/client.go:149
↓ 1 callersMethodSetMaxNextVertex
SetMaxNextVertex sets the max concurrent path can be generated from this vertex
common/testing/event_generator.go:461
↓ 1 callersMethodSetMetricsHandler
SetMetricsHandler sets s.metricsHandler. Only used by tests.
service/history/shard/context_testutil.go:207
↓ 1 callersMethodSetOtherHasTasks
SetOtherHasTasks updates the otherHasTasks flag and attempts to persist immediately. The in-memory state is updated regardless of whether persistence
service/matching/db.go:488
↓ 1 callersMethodSetOutboundTaskGroup
(taskgroup string)
service/history/tasks/chasm_task.go:124
↓ 1 callersMethodSetRPS
SetRPS sets the rate of the rate limiter
common/quotas/rate_limiter_impl.go:40
↓ 1 callersMethodSetRPS
(rate float64)
common/quotas/rate_burst.go:152
↓ 1 callersMethodSetSpeculativeExecutionPolicy
(SpeculativeExecutionPolicy)
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:40
↓ 1 callersMethodSetStateMachineState
(status callbackspb.CallbackStatus)
chasm/lib/callback/component.go:66
↓ 1 callersMethodSetSuccessorRunID
(runID string)
service/history/interfaces/mutable_state.go:416
↓ 1 callersMethodSetTimeSource
(timeSource clock.TimeSource)
service/history/historybuilder/history_builder.go:96
↓ 1 callersMethodSetTrailer
(ctx context.Context)
client/matching/partition_counts.go:51
↓ 1 callersFunctionSetUpCassandraDatabase
(t *testing.T, cfg *config.Cassandra, logger log.Logger)
common/persistence/tests/cassandra_test_util.go:76
↓ 1 callersFunctionSetUpCassandraSchema
(t *testing.T, cfg *config.Cassandra, logger log.Logger)
common/persistence/tests/cassandra_test_util.go:104
↓ 1 callersMethodSetVersion
SetVersion sets the event version
common/testing/event_generator.go:191
↓ 1 callersMethodSetVersioningRevisionNumber
(revisionNumber int64)
service/history/interfaces/mutable_state.go:404
↓ 1 callersMethodSetWeight
(newWeight int)
common/tasks/weighted_channel.go:44
↓ 1 callersMethodSetWorkerDeploymentManager
( ctx context.Context, request *workflowservice.SetWorkerDeploymentManagerRequest, opts ...grpc.CallOption,
client/frontend/client_gen.go:932
↓ 1 callersMethodSetWorkerDeploymentManager
(ctx context.Context, request *workflowservice.SetWorkerDeploymentManagerRequest)
service/frontend/workflow_handler.go:4229
↓ 1 callersFunctionSetupSchema
SetupSchema initializes the SQLite schema in an empty database. Note: this function may receive breaking changes or be removed in the future.
schema/sqlite/setup.go:36
↓ 1 callersFunctionSetupSchemaOnDB
SetupSchemaOnDB initializes the SQLite schema in an empty database using existing DB connection. Note: this function may receive breaking changes or
schema/sqlite/setup.go:49
↓ 1 callersMethodSetupTest
()
service/frontend/operator_handler_test.go:61
↓ 1 callersMethodSetupTest
()
service/history/history_engine2_test.go:120
↓ 1 callersMethodSetupTest
()
service/history/history_engine_test.go:132
↓ 1 callersFunctionShardContextState
ShardContextState returns tag for ShardContextState
common/log/tag/tags.go:575
↓ 1 callersFunctionShardContextStateRequest
ShardContextStateRequest returns tag for ShardContextStateRequest
common/log/tag/tags.go:580
↓ 1 callersMethodShouldResetActivityTimerTaskMask
(current, incoming *persistencespb.ActivityInfo)
service/history/workflow/mutable_state_impl.go:9208
← previousnext →10,501–10,600 of 43,335, ranked by callers