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 callersMethodCreateStartChildWorkflowExecutionFailedEvent
( workflowTaskCompletedEventID int64, initiatedID int64, cause enumspb.StartChildWorkflowExecutionFailedCau
service/history/historybuilder/event_factory.go:906
↓ 1 callersMethodCreateStartChildWorkflowExecutionInitiatedEvent
( workflowTaskCompletedEventID int64, command *commandpb.StartChildWorkflowExecutionCommandAttributes, targ
service/history/historybuilder/event_factory.go:844
↓ 1 callersFunctionCreateTaskNotReadyReschedulePolicy
CreateTaskNotReadyReschedulePolicy creates a retry policy for rescheduling task with ErrTaskRetry
common/util.go:266
↓ 1 callersFunctionCreateTaskReschedulePolicy
CreateTaskReschedulePolicy creates a retry policy for rescheduling task with errors not equal to ErrTaskRetry
common/util.go:249
↓ 1 callersFunctionCreateTaskResourceExhaustedReschedulePolicy
CreateTaskResourceExhaustedReschedulePolicy creates a retry policy for rescheduling task with resource exhausted error
common/util.go:274
↓ 1 callersMethodCreateTime
CreateTime represents the time when the entry is created
common/cache/cache.go:96
↓ 1 callersMethodCreateTimeoutWorkflowEvent
( retryState enumspb.RetryState, newExecutionRunID string, )
service/history/historybuilder/event_factory.go:369
↓ 1 callersMethodCreateTimerCanceledEvent
( workflowTaskCompletedEventID int64, startedEventID int64, timerID string, identity string, )
service/history/historybuilder/event_factory.go:568
↓ 1 callersMethodCreateTimerFiredEvent
(startedEventID int64, timerID string)
service/history/historybuilder/event_factory.go:523
↓ 1 callersMethodCreateTimerStartedEvent
( workflowTaskCompletedEventID int64, command *commandpb.StartTimerCommandAttributes, )
service/history/historybuilder/event_factory.go:508
↓ 1 callersMethodCreateUpsertWorkflowSearchAttributesEvent
( workflowTaskCompletedEventID int64, command *commandpb.UpsertWorkflowSearchAttributesCommandAttributes, )
service/history/historybuilder/event_factory.go:723
↓ 1 callersMethodCreateWorkflowExecution
( ctx context.Context, request *p.InternalCreateWorkflowExecutionRequest, )
common/persistence/cassandra/execution_store.go:97
↓ 1 callersMethodCreateWorkflowExecutionCancelRequestedEvent
(request *historyservice.RequestCancelWorkflowExecutionRequest)
service/history/historybuilder/event_factory.go:586
↓ 1 callersMethodCreateWorkflowExecutionCanceledEvent
( workflowTaskCompletedEventID int64, command *commandpb.CancelWorkflowExecutionCommandAttributes, )
service/history/historybuilder/event_factory.go:600
↓ 1 callersMethodCreateWorkflowExecutionOptionsUpdatedEvent
( versioningOverride *workflowpb.VersioningOverride, unsetVersioningOverride bool, attachRequestID string,
service/history/historybuilder/event_factory.go:401
↓ 1 callersMethodCreateWorkflowExecutionPausedEvent
( identity string, reason string, requestID string, )
service/history/historybuilder/event_factory.go:1052
↓ 1 callersMethodCreateWorkflowExecutionSignaledEvent
( signalName string, input *commonpb.Payloads, identity string, header *commonpb.Header, externalWorkflow
service/history/historybuilder/event_factory.go:820
↓ 1 callersMethodCreateWorkflowExecutionStartedEvent
( startTime time.Time, request *historyservice.StartWorkflowExecutionRequest, resetPoints *workflowpb.Reset
service/history/historybuilder/event_factory.go:31
↓ 1 callersMethodCreateWorkflowExecutionTerminatedEvent
( reason string, details *commonpb.Payloads, identity string, links []*commonpb.Link, )
service/history/historybuilder/event_factory.go:383
↓ 1 callersMethodCreateWorkflowExecutionTimeSkippingTransitionedEvent
CreateWorkflowExecutionTimeSkippingTransitionedEvent creates a workflow execution time skipping transitioned event. If no time needs to be skipped, th
service/history/historybuilder/event_factory.go:1101
↓ 1 callersMethodCreateWorkflowExecutionUnpausedEvent
( identity string, reason string, requestID string, )
service/history/historybuilder/event_factory.go:1068
↓ 1 callersMethodCreateWorkflowExecutionUpdateAcceptedEvent
( protocolInstanceID string, acceptedRequestMessageId string, acceptedRequestSequencingEventId int64, acce
service/history/historybuilder/event_factory.go:432
↓ 1 callersMethodCreateWorkflowExecutionUpdateAdmittedEvent
(request *updatepb.Request, origin enumspb.UpdateAdmittedEventOrigin)
service/history/historybuilder/event_factory.go:465
↓ 1 callersMethodCreateWorkflowExecutionUpdateCompletedEvent
( acceptedEventID int64, updResp *updatepb.Response, )
service/history/historybuilder/event_factory.go:450
↓ 1 callersMethodCreateWorkflowPropertiesModifiedEvent
( workflowTaskCompletedEventID int64, command *commandpb.ModifyWorkflowPropertiesCommandAttributes, )
service/history/historybuilder/event_factory.go:737
↓ 1 callersMethodCreateWorkflowTaskCompletedEvent
( scheduledEventID int64, startedEventID int64, identity string, checksum string, workerVersionStamp *com
service/history/historybuilder/event_factory.go:154
↓ 1 callersMethodCreateWorkflowTaskFailedEvent
( scheduledEventID int64, startedEventID int64, cause enumspb.WorkflowTaskFailedCause, failure *failurepb.
service/history/historybuilder/event_factory.go:202
↓ 1 callersMethodCreateWorkflowTaskScheduledEvent
( taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb.Duration, attempt int32, scheduleTime
service/history/historybuilder/event_factory.go:106
↓ 1 callersMethodCreateWorkflowTaskStartedEvent
( scheduledEventID int64, requestID string, identity string, startTime time.Time, suggestContinueAsNew bo
service/history/historybuilder/event_factory.go:124
↓ 1 callersMethodCreateWorkflowTaskTimedOutEvent
( scheduledEventID int64, startedEventID int64, timeoutType enumspb.TimeoutType, )
service/history/historybuilder/event_factory.go:185
↓ 1 callersMethodCurrentVersionedTransition
()
chasm/tree.go:213
↓ 1 callersMethodCustomSearchAttributesMapper
CustomSearchAttributesMapper is a part of temporary solution. Do not use this method.
common/namespace/namespace.go:295
↓ 1 callersFunctionDataStoreFactoryProvider
( clusterName ClusterName, r resolver.ServiceResolver, cfg *config.Persistence, abstractDataStoreFactory A
common/persistence/client/fx.go:184
↓ 1 callersMethodDbName
()
common/persistence/sql/sqlplugin/interfaces.go:122
↓ 1 callersMethodDecode
( encodedPath string, )
chasm/path_encoder.go:92
↓ 1 callersFunctionDecodeCallbackToken
DecodeCallbackToken unmarshals the given token applying minimal data verification.
common/nexus/callback_token.go:118
↓ 1 callersMethodDecodeHistoryEvents
Decode HistoryEvent slice from bytes.
common/codec/jsonpb.go:63
↓ 1 callersMethodDeepHealthCheck
DeepHealthCheck implements the grpc API from ./proto/internal/temporal/server/api/historyservice/v1/request_response.proto
service/history/deep_health_check.go:31
↓ 1 callersFunctionDefaultFaultInjection
()
common/config/config.go:858
↓ 1 callersMethodDelay
()
common/quotas/clocked_rate_limiter.go:54
↓ 1 callersMethodDelayFrom
(t time.Time)
common/quotas/clocked_rate_limiter.go:58
↓ 1 callersMethodDelayFrom
DelayFrom returns the duration for which the reservation holder must wait before taking the reserved action. Zero duration means act immediately. Mul
common/quotas/multi_reservation_impl.go:61
↓ 1 callersMethodDelayFrom
DelayFrom returns the duration for which the reservation holder must wait before taking the reserved action. Zero duration means act immediately.
common/quotas/priority_reservation_impl.go:54
↓ 1 callersMethodDelete
(ctx context.Context, indexName string, docID string, version int64)
common/persistence/visibility/store/elasticsearch/client/client.go:39
↓ 1 callersMethodDeleteCHASMPureTasks
(maxScheduledTime time.Time)
service/history/interfaces/mutable_state.go:321
↓ 1 callersMethodDeleteEvent
(key EventKey)
service/history/events/cache.go:34
↓ 1 callersMethodDeleteFromHistoryImmediateTasks
DeleteFromHistoryImmediateTasks deletes one rows from history_immediate_tasks table.
common/persistence/sql/sqlplugin/history_immediate_tasks.go:43
↓ 1 callersMethodDeleteFromHistoryScheduledTasks
DeleteFromScheduledTasks deletes one or more rows from history_scheduled_tasks table
common/persistence/sql/sqlplugin/history_scheduled_tasks.go:47
↓ 1 callersMethodDeleteFromNexusEndpoints
(ctx context.Context, id []byte)
common/persistence/sql/sqlplugin/nexus_endpoints.go:31
↓ 1 callersMethodDeleteMessageFromNamespaceDLQ
DeleteMessageFromNamespaceDLQ deletes one message from namespace DLQ
common/persistence/persistence-tests/persistence_test_base.go:423
↓ 1 callersMethodDeleteMessagesBefore
(ctx context.Context, exclusiveMessageID int64)
common/persistence/namespace_replication_queue.go:73
↓ 1 callersMethodDeleteSignalRequested
(requestID string)
service/history/interfaces/mutable_state.go:156
↓ 1 callersMethodDeleteSignalRequested
( requestID string, )
service/history/workflow/mutable_state_impl.go:2558
↓ 1 callersMethodDeleteSubStateMachine
(path *persistencespb.StateMachinePath)
service/history/workflow/mutable_state_impl.go:5586
↓ 1 callersMethodDeleteWorkerControllerInstance
(ctx context.Context, input *deploymentspb.DeleteWorkerControllerInstanceInput)
service/worker/workerdeployment/version_activities.go:215
↓ 1 callersFunctionDeploymentOrVersion
DeploymentOrVersion Temporary helper function to return a Deployment based on passed Deployment or WorkerDeploymentVersion objects, if `v` is not nil,
common/worker_versioning/worker_versioning.go:240
↓ 1 callersMethodDescribe
In order to accommodate the changes brought in by versioning-3.1, `buildIDs` will now also accept versionID's that represent worker-deployment version
service/matching/task_queue_partition_manager.go:1275
↓ 1 callersMethodDescribeJob
(c *cli.Context)
tools/tdbg/dlq_job_service.go:29
↓ 1 callersMethodDescribeWorkerDeployment
( ctx context.Context, namespaceEntry *namespace.Namespace, deploymentName string, )
service/worker/workerdeployment/client.go:574
↓ 1 callersMethodDescribeWorkflowExecution
DescribeWorkflowExecution returns information about the specified workflow execution.
service/frontend/workflow_handler.go:3217
↓ 1 callersMethodDeserialize
Deserialize a state machine from bytes.
service/history/hsm/tree.go:54
↓ 1 callersMethodDeserialize
Deserialize implements nexus.Serializer.
common/nexus/payload_serializer.go:20
↓ 1 callersFunctionDeserializeBlobs
( historySerializer serialization.Serializer, blobs []*commonpb.DataBlob, )
service/history/ndc/replication_task.go:527
↓ 1 callersMethodDeserializeBufferedEvents
( // unexport blobs []*commonpb.DataBlob, )
common/persistence/execution_manager.go:585
↓ 1 callersMethodDeserializeInput
DeserializeInput deserializes input from bytes that is then passed to the handler.
service/history/hsm/remote_methods.go:11
↓ 1 callersMethodDeserializeReplicationTask
(replicationTask *persistencespb.ReplicationTaskInfo)
service/history/replication/fx.go:38
↓ 1 callersFunctionDiffAndLogConfigs
DiffAndLogConfigs computes the difference between two ConfigValueMaps. The result is returned as a ConfigValueMap that can be merged with old to produ
common/dynamicconfig/client_diff.go:16
↓ 1 callersMethodDispatchSpooledTask
DispatchSpooledTask dispatches a task to a poller. When there are no pollers to pick up the task, this method will return error. Task will not be pers
service/matching/physical_task_queue_manager_interface.go:48
↓ 1 callersFunctionDoCreateDatabase
(cfg *config.SQL, defaultDb string, logger log.Logger)
tools/sql/handler.go:75
↓ 1 callersFunctionDoDropDatabase
(cfg *config.SQL, defaultDb string, logger log.Logger)
tools/sql/handler.go:102
↓ 1 callersMethodDrainHost
DrainHost marks the given host draining
common/membership/ringpop/test_cluster.go:168
↓ 1 callersMethodDropDatabase
DropDatabase drops a database
tools/sql/conn.go:93
↓ 1 callersMethodDropDatabase
DropDatabase from PersistenceTestCluster interface
common/persistence/sql/test_sql_persistence.go:141
↓ 1 callersMethodDropDatabase
DropDatabase from PersistenceTestCluster interface
common/persistence/cassandra/test.go:162
↓ 1 callersMethodDropTable
DropTable drops a given table from the database
tools/sql/conn.go:69
↓ 1 callersMethodDropTable
(table string)
common/persistence/sql/sqlplugin/interfaces.go:86
↓ 1 callersMethodDropTable
DropTable drops a given table from the database
common/persistence/sql/sqlplugin/postgresql/admin.go:99
↓ 1 callersMethodDropTable
DropTable drops a given table from the database
common/persistence/sql/sqlplugin/mysql/admin.go:98
↓ 1 callersMethodDropTable
DropTable drops a given table from the database
common/persistence/sql/sqlplugin/sqlite/admin.go:78
↓ 1 callersFunctionDurationFromHours
(h int64)
common/primitives/timestamp/duration.go:45
↓ 1 callersFunctionESClusterStatus
(status string)
common/log/tag/tags.go:750
↓ 1 callersFunctionESKey
ESKey returns tag for ESKey
common/log/tag/tags.go:727
↓ 1 callersFunctionESResponseError
ESResponseError returns tag for ESResponse error
common/log/tag/tags.go:722
↓ 1 callersFunctionESResponseStatus
ESResponseStatus returns tag for ESResponse status
common/log/tag/tags.go:717
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/archival/archiver_mock.go:39
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/workflow/mutable_state_rebuilder_mock.go:43
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/searchattribute/mapper_mock.go:39
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/authorization/audience_mapper_mock.go:40
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/resolver/service_resolver_mock.go:38
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/mock/store_mock.go:212
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/mock/store_mock.go:319
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/visibility/store/elasticsearch/client/bulk_processor_mock.go:38
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/persistence/visibility/manager/visibility_manager_mock.go:41
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/interface_mock.go:41
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/interface_mock.go:113
↓ 1 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/testing/mocksdk/value_mock.go:32
↓ 1 callersMethodEcdsaKey
(alg string, kid string)
common/authorization/token_key_provider.go:14
↓ 1 callersFunctionElasticsearchIndexTemplate
ElasticsearchIndexTemplate returns the embedded index template for Elasticsearch v7 (latest version)
schema/embed.go:60
↓ 1 callersFunctionEncode
encoding & decoding util
common/archiver/s3store/util.go:31
↓ 1 callersMethodEncode
The Encode method encodes node path in a way that the following uses cases can be achieved by doing a simple a range query in DB based on prefixes of
chasm/path_encoder.go:47
← previousnext →9,501–9,600 of 43,335, ranked by callers