MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 5 callersFunctionvalidate
(vs ...func() error)
service/history/workflow/update/validation.go:34
↓ 5 callersMethodvalidate
validate checks that the guard was satisfied i.e. a dedicated-cluster-only feature was used.
tests/testcore/test_env.go:673
↓ 5 callersFunctionvalidateAndNormalizeStartRequest
( req *workflowservice.StartActivityExecutionRequest, maxIDLengthLimit int, blobSizeLimitError dynamicconfi
chasm/lib/activity/validator.go:351
↓ 5 callersMethodvalidateBaseActivityResponse
( t *testing.T, activityID string, expectedRunID string, response *workflowservice.DescribeActivityExecuti
tests/activity_standalone_test.go:6317
↓ 5 callersMethodvalidateFailure
( ctx context.Context, t *testing.T, activityID string, runID string, expectedHeartbeatDetails *commonpb.
tests/activity_standalone_test.go:6280
↓ 5 callersMethodvalidateID
( eventID int64, lastEventID int64, )
service/worker/scanner/executions/mutable_state_validator.go:224
↓ 5 callersFunctionvalidateMainBranch
( ctx context.Context, modFile *modfile.File, )
cmd/tools/check-dependencies/main.go:113
↓ 5 callersMethodvalidateMergedSlice
( currentSlice *SliceImpl, incomingSlice *SliceImpl, mergedSlices []Slice, expectedTotalExecutables int, )
service/history/queues/slice_test.go:653
↓ 5 callersMethodvalidateNewExecutionResponseRef
( serializedRef []byte, expectedExecutionKey chasm.ExecutionKey, )
service/history/chasm_engine_test.go:615
↓ 5 callersFunctionvalidateStartDelay
(startDelay *durationpb.Duration)
chasm/lib/activity/validator.go:128
↓ 5 callersMethodvalidateTaskQueueStatsByType
( tqName string, tqType enumspb.TaskQueueType, expectation taskQueueExpectations, singlePartition bool, )
tests/task_queue_stats_test.go:1363
↓ 5 callersMethodvalidationError
Generates a validation error with search attribute alias resolution. Input `msg` must contain a single occurrence of `%s` that will be substituted by
common/searchattribute/validator.go:220
↓ 5 callersMethodverifyReplicationTasks
( ctx context.Context, request *verifyReplicationTasksRequest, details *replicationTasksHeartbeatDetails,
service/worker/migration/activities.go:933
↓ 5 callersMethodwaitEvent
(ctx context.Context, sdkClient sdkclient.Client, run sdkclient.WorkflowRun, eventType enumspb.EventType)
tests/xdc/nexus_state_replication_test.go:670
↓ 5 callersMethodwaitForPrune
waitForPrune waits up for the persistence backend to prune all records. Some persistence backends may not remove TTL'd entries at the exact instant th
common/persistence/persistence-tests/cluster_metadata_manager.go:252
↓ 5 callersFunctionwaitLogMatches
(s *ScaleManagerSuite, e *testlogger.Expectation, count int64, msg string)
service/matching/scale_manager_test.go:140
↓ 5 callersMethodwaitUntilRunningWithPendingActivity
waitUntilRunningWithPendingActivity waits until the workflow is RUNNING and has scheduled its activity, so a subsequent pause is applied to a fully in
tests/pause_workflow_execution_test.go:1791
↓ 5 callersFunctionwithInstrumentation
(i *instrumentation)
service/history/workflow/update/update.go:150
↓ 5 callersFunctionwriteProfile
(t *testing.T, outputDir string, profileName string, fileName string, debug int)
tests/leakcheck/leak_test.go:181
↓ 5 callersFunctionwriteTemplatedCode
(w io.Writer, service service, tmpl string)
cmd/tools/genrpcwrappers/main.go:139
↓ 5 callersFunctionwriteTemplatedMethods
(w io.Writer, service service, impl string, tmpl string)
cmd/tools/genrpcwrappers/main.go:451
↓ 4 callersFunctionActivityTargetingMethodTag
ActivityTargetingMethodTag returns a tag indicating how the activity was targeted: "id" or "type".
common/metrics/tags.go:231
↓ 4 callersMethodAdd
(request *BulkableRequest)
common/persistence/visibility/store/elasticsearch/client/bulk_service.go:11
↓ 4 callersMethodAddActivityTaskStartedEvent
( scheduledEventID int64, attempt int32, requestID string, identity string, lastFailure *failurepb.Failur
service/history/historybuilder/history_builder.go:345
↓ 4 callersMethodAddCategory
AddCategory register a Category with the registry or panics if a Category with the same ID has already been registered.
service/history/tasks/task_category_registry.go:43
↓ 4 callersMethodAddContinueAsNewEvent
(context.Context, int64, namespace.Name, *commandpb.ContinueAsNewWorkflowExecutionCommandAttributes, worker_ve
service/history/interfaces/mutable_state.go:75
↓ 4 callersMethodAddFirstWorkflowTaskScheduled
(parentClock *clockspb.VectorClock, event *historypb.HistoryEvent, bypassTaskGeneration bool)
service/history/interfaces/mutable_state.go:79
↓ 4 callersFunctionAddNextStateMachineTimerTask
AddNextStateMachineTimerTask generates a state machine timer task if the first deadline doesn't have a task scheduled yet.
service/history/workflow/state_machine_timers.go:18
↓ 4 callersFunctionAddSearchAttributes
This may mutate saPtr and *saPtr
common/searchattribute/search_attirbute.go:46
↓ 4 callersMethodAddTimerCanceledEvent
(int64, *commandpb.CancelTimerCommandAttributes, string)
service/history/interfaces/mutable_state.go:96
↓ 4 callersMethodAddWorkflowPropertiesModifiedEvent
(int64, *commandpb.ModifyWorkflowPropertiesCommandAttributes)
service/history/interfaces/mutable_state.go:100
↓ 4 callersMethodAddWorkflowTaskScheduledEventAsHeartbeat
(bypassTaskGeneration bool, originalScheduledTimestamp *timestamppb.Timestamp, workflowTaskType enumsspb.Workf
service/history/interfaces/mutable_state.go:81
↓ 4 callersMethodAfterCall
( metricsHandler metrics.Handler, startTime time.Time, targetClusterName string, namespaceName string, re
common/rpc/interceptor/redirection.go:310
↓ 4 callersFunctionAllowListForValidation
( storeNames []string, allowList dynamicconfig.BoolPropertyFnWithNamespaceFilter, )
common/persistence/visibility/defs.go:19
↓ 4 callersMethodAppend
Append combines two executeResults (no deduplication is done).
chasm/lib/scheduler/invoker.go:145
↓ 4 callersMethodApplyRequest
( ctx context.Context, updateReg update.Registry, ms historyi.MutableState, )
service/history/api/updateworkflow/api.go:104
↓ 4 callersMethodApplyWorkflowExecutionOptionsUpdatedEvent
(event *historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:281
↓ 4 callersMethodApplyWorkflowExecutionSignaled
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:278
↓ 4 callersMethodApplyWorkflowTaskCompletedEvent
(*historypb.HistoryEvent)
service/history/interfaces/mutable_state.go:254
↓ 4 callersMethodArchetypeID
ArchetypeID returns the framework's internal ID for the root component's fully qualified name.
chasm/tree.go:2868
↓ 4 callersMethodAudience
(ctx context.Context, req any, info *grpc.UnaryServerInfo)
common/authorization/interceptor.go:34
↓ 4 callersMethodAverage
()
common/aggregate/moving_window_average.go:11
↓ 4 callersMethodBeforeCall
( operation string, )
common/rpc/interceptor/redirection.go:304
↓ 4 callersMethodBroadcast
Broadcast wakes all goroutines waiting on this condition variable.
common/locks/condition_variable.go:9
↓ 4 callersFunctionBuildCLIOptions
BuildCLIOptions builds the options for cli
tools/elasticsearch/main.go:43
↓ 4 callersFunctionBuildFailureMessage
BuildFailureMessage creates a Slack message for CI failure
tools/ci-notify/slack.go:32
↓ 4 callersFunctionBuildIdQueueKey
BuildIdQueueKey returns a PhysicalTaskQueueKey of a task queue partition with the given build ID.
service/matching/physical_task_queue_key.go:83
↓ 4 callersFunctionCall
Call calls a func() hook if present. TestHooks should be used sparingly, see comment on TestHooks.
common/testing/testhooks/test_impl.go:54
↓ 4 callersMethodCancel
Cancel cancels the `context.Context` that was passed to all goroutines spawned via `Go` on this `Group`.
common/goro/group.go:38
↓ 4 callersFunctionClearTombstones
ClearTombstones clears all tombstone build ids (with STATE_DELETED) from versioning data. Clones data to avoid mutating in place.
service/matching/version_sets.go:465
↓ 4 callersFunctionClientSupportsTranOrSpecEvents
ClientSupportsTranOrSpecEvents detects if client supports transient events Default to include transient events for clients, only CLI and UI are explic
service/history/api/get_history_util.go:427
↓ 4 callersMethodClose
Close closes the sql client
tools/sql/conn.go:98
↓ 4 callersMethodClose
()
common/authorization/token_key_provider.go:18
↓ 4 callersMethodClose
()
common/persistence/sql/sqlplugin/mysql/session/session.go:59
↓ 4 callersMethodClose
()
common/persistence/nosql/nosqlplugin/cassandra/gocql/interfaces.go:48
↓ 4 callersFunctionClusterIDToClusterNameShardCount
( allClusterInfo map[string]cluster.ClusterInformation, clusterID int32, )
service/history/replication/stream.go:34
↓ 4 callersMethodCollectMetric
CollectMetric returns the recordings for the named metric that the caller chooses to keep.
tests/testcore/metric_capture.go:31
↓ 4 callersMethodContextMetadata
ContextMetadata returns execution metadata to propagate to the request context. When the ContextMetadataInterceptor is configured with setTrailer=true
chasm/component.go:51
↓ 4 callersMethodContextMetadata
(_ chasm.Context)
chasm/lib/activity/activity.go:127
↓ 4 callersFunctionContextWithValue
ContextWithValue returns a new Context with the given key-value pair added. Added key-value pairs will be accessible via the Value() method on the ret
chasm/context.go:289
↓ 4 callersFunctionConvertClusterReplicationConfigFromProto
( input []*replicationpb.ClusterReplicationConfig, )
common/namespace/nsreplication/replication_task_executor.go:355
↓ 4 callersMethodConvertComparisonExpr
( operator string, col *query.SAColumn, value any, )
common/persistence/visibility/store/sql/query_converter.go:143
↓ 4 callersFunctionConvertFailoverHistoryToPersistenceProto
(failoverHistory []*replicationpb.FailoverStatus)
common/namespace/nsreplication/replication_task_executor.go:366
↓ 4 callersMethodCountExecutions
( context.Context, reflect.Type, *CountExecutionsRequest, )
chasm/visibility_manager.go:24
↓ 4 callersMethodCountFromVisibility
(ctx context.Context, filter VisibilitySelectFilter)
common/persistence/sql/sqlplugin/visibility.go:108
↓ 4 callersMethodCreateContext
(shardID int32, closeCallback CloseCallback)
service/history/shard/context_factory.go:33
↓ 4 callersMethodCreateQueue
CreateQueue must return an ErrQueueAlreadyExists if the queue already exists.
common/persistence/data_interfaces.go:1267
↓ 4 callersMethodCreateSession
CreateSession from PersistenceTestCluster interface
common/persistence/cassandra/test.go:105
↓ 4 callersFunctionCreateTemp
CreateTemp is a helper function which creates a temporary file, and it is automatically closed after test is completed
tests/testutils/io.go:12
↓ 4 callersFunctionDedupPollers
DedupPollers removes duplicate pollers by identity.
common/taskqueue/stats.go:20
↓ 4 callersMethodDeleteAllFromActivityInfoMaps
DeleteAllFromActivityInfoMaps deletes all from activity_info_maps table
common/persistence/sql/sqlplugin/history_activity.go:46
↓ 4 callersMethodDeleteAllFromChildExecutionInfoMaps
DeleteAllFromChildExecutionInfoMaps deletes all rows from child_execution_info_maps table
common/persistence/sql/sqlplugin/history_child_workflow.go:46
↓ 4 callersMethodDeleteAllFromRequestCancelInfoMaps
DeleteAllFromRequestCancelInfoMaps deletes all rows from request_cancel_info_maps table
common/persistence/sql/sqlplugin/history_request_cancel.go:46
↓ 4 callersMethodDeleteAllFromSignalInfoMaps
DeleteFromSignalInfoMaps deletes one or more rows from signal_info_maps table
common/persistence/sql/sqlplugin/history_signal.go:46
↓ 4 callersMethodDeleteAllFromSignalsRequestedSets
DeleteAllFromSignalsRequestedSets deletes all rows from signals_requested_sets table
common/persistence/sql/sqlplugin/history_signal_request.go:44
↓ 4 callersMethodDeleteAllFromTimerInfoMaps
DeleteAllFromTimerInfoMaps deletes all rows from timer_info_maps table
common/persistence/sql/sqlplugin/history_timer.go:46
↓ 4 callersMethodDeleteFromBufferedEvents
(ctx context.Context, filter BufferedEventsFilter)
common/persistence/sql/sqlplugin/history_buffer.go:34
↓ 4 callersMethodDeleteFromTaskQueues
(ctx context.Context, filter TaskQueuesFilter, v MatchingTaskVersion)
common/persistence/sql/sqlplugin/matching_task_queue.go:52
↓ 4 callersMethodDeleteFromTasks
DeleteFromTasks deletes multiple rows from tasks table Required filter params: - {namespaceID, taskqueueName, taskType, exclusiveMaxTaskID, limit } -
common/persistence/sql/sqlplugin/matching_task_v1.go:39
↓ 4 callersMethodDeleteFromVisibility
(ctx context.Context, filter VisibilityDeleteFilter)
common/persistence/sql/sqlplugin/visibility.go:107
↓ 4 callersMethodDeleteNexusOperation
(ctx context.Context, in *DeleteNexusOperationRequest, opts ...grpc.CallOption)
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_grpc.pb.go:39
↓ 4 callersMethodDeleteWorkflowExecutionByRetention
( ctx context.Context, nsID namespace.ID, we *commonpb.WorkflowExecution, weCtx historyi.WorkflowC
service/history/deletemanager/delete_manager.go:38
↓ 4 callersFunctionDeploymentFromCapabilities
DeploymentFromCapabilities returns the deployment if it is using versioning V3, otherwise nil. It returns the deployment from the `options` if present
common/worker_versioning/worker_versioning.go:186
↓ 4 callersMethodDescribeBatchOperation
( ctx context.Context, request *workflowservice.DescribeBatchOperationRequest, opts ...grpc.CallOption, )
client/frontend/client_gen.go:192
↓ 4 callersMethodDescribeNexusOperation
(ctx context.Context, in *DescribeNexusOperationRequest, opts ...grpc.CallOption)
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/service_grpc.pb.go:36
↓ 4 callersMethodDeserialize
(data []byte)
common/tasktoken/serializer.go:22
↓ 4 callersMethodDeserializeEvent
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:74
↓ 4 callersFunctionDeserializeVisibilityPageToken
(data []byte)
common/persistence/sql/sqlplugin/visibility_query_converter.go:21
↓ 4 callersFunctionDirectiveDeployment
DirectiveDeployment Temporary function until Directive proto is removed.
common/worker_versioning/worker_versioning.go:1069
↓ 4 callersMethodDropAllTables
DropAllTables drops all tables
tools/common/schema/types.go:39
↓ 4 callersFunctionESDocID
ESDocID returns tag for ESDocID
common/log/tag/tags.go:760
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/api/consistency_checker_mock.go:44
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
service/history/workflow/cache/cache_mock.go:44
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/historyservicemock/v1/service_grpc.pb.mock.go:1606
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
api/adminservicemock/v1/service_grpc.pb.mock.go:1885
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/membership/interfaces_mock.go:327
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/searchattribute/search_attribute_mock.go:40
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/gcloud/query_parser_mock.go:38
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/gcloud/connector/client_delegate_mock.go:145
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
common/archiver/gcloud/connector/client_delegate_mock.go:213
← previousnext →4,701–4,800 of 43,335, ranked by callers