MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 1 callersMethodApplyWorkflowExecutionTerminatedEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:6093
↓ 1 callersMethodApplyWorkflowExecutionTimeSkippingTransitionedEvent
ApplyWorkflowExecutionTimeSkippingTransitionedEvent applies the WorkflowExecutionTimeSkippingTransitionedEvent to the mutable state.
service/history/workflow/mutable_state_impl.go:4167
↓ 1 callersMethodApplyWorkflowExecutionTimedoutEvent
( batchID int64, event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:4957
↓ 1 callersMethodApplyWorkflowExecutionUnpausedEvent
(event *historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:233
↓ 1 callersMethodApplyWorkflowExecutionUnpausedEvent
ApplyWorkflowExecutionUnpausedEvent applies the unpaused event to the mutable state. It updates the workflow execution status to running and clears th
service/history/workflow/mutable_state_impl.go:3273
↓ 1 callersMethodApplyWorkflowExecutionUpdateAcceptedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5680
↓ 1 callersMethodApplyWorkflowExecutionUpdateAdmittedEvent
(event *historypb.HistoryEvent, batchId int64)
service/history/interfaces/mutable_state.go:139
↓ 1 callersMethodApplyWorkflowExecutionUpdateAdmittedEvent
ApplyWorkflowExecutionUpdateAdmittedEvent applies a WorkflowExecutionUpdateAdmittedEvent to mutable state.
service/history/workflow/mutable_state_impl.go:5610
↓ 1 callersMethodApplyWorkflowExecutionUpdateCompletedEvent
( event *historypb.HistoryEvent, batchID int64, )
service/history/workflow/mutable_state_impl.go:5752
↓ 1 callersMethodApplyWorkflowPropertiesModifiedEvent
( event *historypb.HistoryEvent, )
service/history/workflow/mutable_state_impl.go:5289
↓ 1 callersMethodApplyWorkflowTaskFailedEvent
()
service/history/workflow/workflow_task_state_machine.go:256
↓ 1 callersMethodApplyWorkflowTaskScheduledEvent
( version int64, scheduledEventID int64, taskQueue *taskqueuepb.TaskQueue, startToCloseTimeout *durationpb
service/history/workflow/workflow_task_state_machine.go:62
↓ 1 callersMethodApplyWorkflowTaskStartedEvent
( workflowTask *historyi.WorkflowTaskInfo, version int64, scheduledEventID int64, startedEventID int64, r
service/history/workflow/workflow_task_state_machine.go:169
↓ 1 callersMethodArchetypeID
( registry *Registry, )
chasm/ref.go:83
↓ 1 callersFunctionArchetypeIDToUUID
( archetypeID chasm.ArchetypeID, )
common/persistence/nosql/nosqlplugin/cassandra/gocql/uuid.go:27
↓ 1 callersFunctionArchivalCallerServiceName
========== Archival tags defined here: archival- ========== archival request tags ArchivalCallerServiceName returns tag for the service name calling
common/log/tag/tags.go:841
↓ 1 callersFunctionArchivalRequestCloseTimestamp
ArchivalRequestCloseTimestamp returns tag for RequestCloseTimestamp
common/log/tag/tags.go:886
↓ 1 callersFunctionArchivalRequestNextEventID
ArchivalRequestNextEventID returns tag for RequestNextEventID
common/log/tag/tags.go:876
↓ 1 callersFunctionArchivalRequestStatus
ArchivalRequestStatus returns tag for RequestStatus
common/log/tag/tags.go:891
↓ 1 callersMethodArchivalTaskInfoToBlob
(info *persistencespb.ArchivalTaskInfo)
common/persistence/serialization/serializer.go:64
↓ 1 callersFunctionArchvialRequestWorkflowType
ArchvialRequestWorkflowType returns tag for RequestWorkflowType
common/log/tag/tags.go:861
↓ 1 callersMethodAssertFired
AssertFired asserts that the callback was triggered a certain number of times.
common/clock/event_time_source_test.go:31
↓ 1 callersFunctionAssets
Assets returns a file system with the contents of the schema directory
schema/embed.go:16
↓ 1 callersMethodAttempt
()
service/history/queues/executable.go:48
↓ 1 callersFunctionAttemptCount
AttemptCount returns tag for AttemptCount
common/log/tag/tags.go:690
↓ 1 callersFunctionAttemptEnd
AttemptEnd returns tag for AttemptEnd
common/log/tag/tags.go:700
↓ 1 callersMethodAudience
Audience returns the configured audience string.
common/authorization/audience_mapper.go:16
↓ 1 callersMethodAuthInfoRequired
()
common/authorization/claim_mapper.go:39
↓ 1 callersMethodAvailableMemberCount
()
common/quotas/calculator/cluster_aware_quota_calculator.go:11
↓ 1 callersMethodAvailableMembers
()
common/membership/ringpop/service_resolver.go:235
↓ 1 callersMethodAverage
()
common/aggregate/moving_window_average.go:60
↓ 1 callersMethodBackfillHistoryEvents
(ctx context.Context, request *historyi.BackfillHistoryEventsRequest)
service/history/ndc/history_replicator.go:96
↓ 1 callersMethodBacklogStatus
()
service/matching/backlog_manager.go:47
↓ 1 callersFunctionBlobSize
size limit BlobSize returns tag for BlobSize
common/log/tag/tags.go:320
↓ 1 callersFunctionBootstrapHostPorts
BootstrapHostPorts returns tag for bootstrap host ports
common/log/tag/tags.go:956
↓ 1 callersMethodBufferSize
Dynamic buffer size limiter. Evaluated at submit time.
common/tasks/dynamic_worker_pool_scheduler.go:17
↓ 1 callersMethodBuildAndExpr
(exprs ...sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter.go:100
↓ 1 callersMethodBuildAndExpr
(exprs ...any)
common/persistence/visibility/store/query/nil_converter.go:28
↓ 1 callersMethodBuildAndExpr
(exprs ...elastic.Query)
common/persistence/visibility/store/elasticsearch/query_converter.go:40
↓ 1 callersMethodBuildCountStmt
( queryParams *query.QueryParams[sqlparser.Expr], )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:183
↓ 1 callersMethodBuildCountStmt
( queryParams *query.QueryParams[sqlparser.Expr], )
common/persistence/sql/sqlplugin/mysql/query_converter.go:200
↓ 1 callersMethodBuildCountStmt
( queryParams *query.QueryParams[sqlparser.Expr], )
common/persistence/sql/sqlplugin/sqlite/query_converter.go:207
↓ 1 callersFunctionBuildDigest
BuildDigest builds a digest report for the specified time range
tools/ci-notify/github.go:200
↓ 1 callersFunctionBuildFailureReport
BuildFailureReport aggregates all failure information
tools/ci-notify/github.go:55
↓ 1 callersFunctionBuildIdTaskReachabilityTag
BuildIdTaskReachabilityTag returns tag for build id task reachability
common/log/tag/tags.go:313
↓ 1 callersMethodBuildNotExpr
(expr sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter.go:95
↓ 1 callersMethodBuildNotExpr
(expr any)
common/persistence/visibility/store/query/nil_converter.go:24
↓ 1 callersMethodBuildOrExpr
(exprs ...sqlparser.Expr)
common/persistence/visibility/store/sql/query_converter.go:125
↓ 1 callersMethodBuildOrExpr
(exprs ...any)
common/persistence/visibility/store/query/nil_converter.go:32
↓ 1 callersMethodBuildOrExpr
(exprs ...elastic.Query)
common/persistence/visibility/store/elasticsearch/query_converter.go:68
↓ 1 callersMethodBuildParenExpr
(expr any)
common/persistence/visibility/store/query/nil_converter.go:20
↓ 1 callersMethodBuildParenExpr
(expr elastic.Query)
common/persistence/visibility/store/elasticsearch/query_converter.go:20
↓ 1 callersMethodBuildPendingNexusOperationInfos
BuildPendingNexusOperationInfos reads nexus operations from the workflow and converts them to API format.
chasm/lib/workflow/nexus_methods.go:277
↓ 1 callersMethodBuildSelectStmt
( queryParams *query.QueryParams[sqlparser.Expr], pageSize int, token *sqlplugin.VisibilityPageToken, )
common/persistence/sql/sqlplugin/postgresql/query_converter.go:127
↓ 1 callersMethodBuildSelectStmt
( queryParams *query.QueryParams[sqlparser.Expr], pageSize int, token *sqlplugin.VisibilityPageToken, )
common/persistence/sql/sqlplugin/mysql/query_converter.go:131
↓ 1 callersMethodBuildSelectStmt
( queryParams *query.QueryParams[sqlparser.Expr], pageSize int, token *sqlplugin.VisibilityPageToken, )
common/persistence/sql/sqlplugin/sqlite/query_converter.go:151
↓ 1 callersMethodBuildSelectStmt
( pageSize int, nextPageToken []byte, )
common/persistence/visibility/store/sql/query_converter_legacy.go:122
↓ 1 callersFunctionCalculateExponentialRetryInterval
CalculateExponentialRetryInterval calculates the retry interval using exponential backoff algorithm
common/backoff/retry.go:195
↓ 1 callersMethodCallerType
()
common/tasks/priority.go:69
↓ 1 callersFunctionCamelCaseToSnakeCase
(s string)
cmd/tools/codegen/helpers.go:66
↓ 1 callersMethodCanMerge
(iter Iterator)
service/history/queues/iterator.go:92
↓ 1 callersMethodCanMergeWithSlice
(slice Slice)
service/history/queues/slice.go:157
↓ 1 callersMethodCanSplit
( key tasks.Key, )
service/history/queues/range.go:48
↓ 1 callersMethodCanSplit
(key tasks.Key)
service/history/queues/iterator.go:71
↓ 1 callersMethodCanSplitByRange
(key tasks.Key)
service/history/queues/slice.go:94
↓ 1 callersMethodCancel
()
service/history/replication/executable_task_tracker.go:38
↓ 1 callersMethodCancel
()
service/history/replication/batchable_task.go:107
↓ 1 callersMethodCancel
Cancel requests that this goroutine stop by cancelling the associated context object. This function is threadsafe and idempotent. Note that this funct
common/goro/goro.go:58
↓ 1 callersMethodCancel
Cancel indicates that the reservation holder will not perform the reserved action and reverses the effects of this Reservation on the rate limit as mu
common/quotas/reservation.go:17
↓ 1 callersMethodCancelAll
CancelAll cancels all pollers for a worker and removes the worker entry. Returns cancelled count. Thread-safe.
service/matching/matching_engine.go:224
↓ 1 callersMethodCancelAt
(t time.Time)
common/quotas/clocked_rate_limiter.go:66
↓ 1 callersMethodCancelAt
CancelAt indicates that the reservation holder will not perform the reserved action and reverses the effects of this Reservation on the rate limit as
common/quotas/multi_reservation_impl.go:42
↓ 1 callersMethodCancelAt
CancelAt indicates that the reservation holder will not perform the reserved action and reverses the effects of this Reservation on the rate limit as
common/quotas/priority_reservation_impl.go:39
↓ 1 callersMethodCancelJob
(c *cli.Context)
tools/tdbg/dlq_job_service.go:51
↓ 1 callersMethodCancelOperation
(ctx context.Context, service, operation, token string, options nexus.CancelOperationOptions)
service/frontend/nexus_handler.go:632
↓ 1 callersMethodCancelOperation
(ctx context.Context, service, operation, token string, options nexus.CancelOperationOptions)
common/nexus/nexusrpc/cancel_test.go:24
↓ 1 callersMethodCanonicalForm
()
service/worker/scheduler/spec.go:265
↓ 1 callersMethodCapturedHeaders
()
common/testing/rpctest/transport_stream.go:70
↓ 1 callersMethodCatIndices
(ctx context.Context, target string)
common/persistence/visibility/store/elasticsearch/client/client.go:34
↓ 1 callersMethodCategory
Category mocks base method.
service/history/queues/queue_mock.go:44
↓ 1 callersFunctionCertThumbprint
CertThumbprint returns tag for CertThumbprint
common/log/tag/tags.go:541
↓ 1 callersFunctionChasmEngineInterceptorProvider
( engine Engine, logger log.Logger, metricsHandler metrics.Handler, )
chasm/interceptors.go:35
↓ 1 callersMethodChasmNodeFromBlob
(blob *commonpb.DataBlob)
common/persistence/serialization/serializer.go:95
↓ 1 callersMethodChasmNodeFromBlobs
(metadata *commonpb.DataBlob, data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:96
↓ 1 callersMethodChasmNodeToBlob
ChasmNodeToBlob returns a single encoded blob for the node.
common/persistence/serialization/serializer.go:57
↓ 1 callersMethodChasmNodeToBlobs
ChasmNodeToBlobs returns the metadata blob first, followed by the data blob.
common/persistence/serialization/serializer.go:59
↓ 1 callersMethodChasmRegistry
ChasmRegistry mocks base method.
service/history/interfaces/shard_context_mock.go:140
↓ 1 callersMethodChasmSignalBacklinksEnabled
()
service/history/interfaces/mutable_state.go:362
↓ 1 callersFunctionChasmTaskTypeTag
(value string)
common/metrics/tags.go:295
↓ 1 callersFunctionChasmVisibilityInterceptorProvider
(visibilityMgr VisibilityManager)
chasm/interceptors.go:63
↓ 1 callersFunctionCheckCompatibleVersion
CheckCompatibleVersion check the version compatibility
common/persistence/cassandra/version_checker.go:40
↓ 1 callersMethodCheckResettable
TODO: we will release the restriction when reset API allow those pending CheckResettable check if workflow can be reset
service/history/workflow/mutable_state_impl.go:4070
↓ 1 callersMethodChecksumFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:91
↓ 1 callersMethodChildExecutionInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:84
↓ 1 callersMethodClearSlices
(SlicePredicate)
service/history/queues/reader.go:33
↓ 1 callersFunctionClientNameTag
ClientNameTag returns a new client_name tag for the SDK client name.
common/metrics/tags.go:575
↓ 1 callersMethodClose
()
service/history/replication/bi_direction_stream.go:111
↓ 1 callersMethodClose
Close closes the iterator and releases any allocated resources
common/collection/interface.go:60
↓ 1 callersMethodClose
()
common/persistence/cassandra/shard_store.go:174
↓ 1 callersMethodClose
( chasmContext chasm.MutableContext, _ chasm.NoValue, )
chasm/lib/tests/payload.go:104
← previousnext →9,301–9,400 of 43,335, ranked by callers