MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

↓ 2 callersMethodSyncActivities
(ctx context.Context, request *historyservice.SyncActivitiesRequest)
service/history/interfaces/engine.go:71
↓ 2 callersMethodSyncActivity
SyncActivity sync the activity status.
api/historyservice/v1/service_grpc.pb.go:241
↓ 2 callersMethodSyncDeploymentUserData
This request should always be routed to the node holding the root partition of the workflow task queue.
api/matchingservice/v1/service_grpc.pb.go:148
↓ 2 callersMethodSyncShardStatus
SyncShardStatus sync the status between shards.
api/historyservice/v1/service_grpc.pb.go:239
↓ 2 callersMethodSyncWorkflowState
(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:157
↓ 2 callersMethodSyncWorkflowState
(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:324
↓ 2 callersFunctionSystem
System returns a clone of the system search attributes map.
common/searchattribute/sadefs/constants.go:257
↓ 2 callersMethodTask
(fqn string)
chasm/export_test.go:12
↓ 2 callersFunctionTaskCategoryRegistryProvider
TaskCategoryRegistryProvider provides an immutable tasks.TaskCategoryRegistry to the server, which is intended to be shared by each service. Why do we
temporal/fx.go:479
↓ 2 callersMethodTaskQueueFamily
()
service/matching/physical_task_queue_key.go:53
↓ 2 callersMethodTaskQueueInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:89
↓ 2 callersFunctionTaskQueueTypeTag
(tqType enumspb.TaskQueueType)
common/metrics/tags.go:186
↓ 2 callersMethodTaskQueueUserDataFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:90
↓ 2 callersMethodTaskStats
()
service/history/queues/slice.go:36
↓ 2 callersFunctionTaskVersion
TaskVersion returns tag for TaskVersion
common/log/tag/tags.go:632
↓ 2 callersMethodTearDownCluster
()
tests/testcore/functional_test_base.go:469
↓ 2 callersMethodTearDownTestDatabase
()
common/persistence/persistence-tests/persistence_test_base.go:113
↓ 2 callersMethodTerminateWorkflowExecution
TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event in the history and immediately ter
api/historyservice/v1/service_grpc.pb.go:191
↓ 2 callersMethodTest
(task Task)
service/history/tasks/predicates.go:50
↓ 2 callersMethodTest
(task Task)
service/history/tasks/predicates.go:85
↓ 2 callersMethodTest
(task Task)
service/history/tasks/predicates.go:124
↓ 2 callersMethodTest
(task Task)
service/history/tasks/predicates.go:163
↓ 2 callersFunctionTestEsNameTypeMapWithScheduleID
()
common/searchattribute/test_provider.go:74
↓ 2 callersFunctionTestSearchAttributesToRegister
()
common/searchattribute/test_provider.go:70
↓ 2 callersFunctionTimeoutTypeTag
(timeoutType string)
common/metrics/tags.go:594
↓ 2 callersFunctionTimeoutWorkflow
( mutableState historyi.MutableState, retryState enumspb.RetryState, continuedRunID string, )
service/history/workflow/util.go:72
↓ 2 callersMethodTimerInfoToBlob
(info *persistencespb.TimerInfo)
common/persistence/serialization/serializer.go:48
↓ 2 callersMethodTimerTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:98
↓ 2 callersFunctionToPersistenceRange
( r Range, )
service/history/queues/convert.go:70
↓ 2 callersFunctionToPersistenceScope
( scope Scope, )
service/history/queues/convert.go:52
↓ 2 callersMethodToRealTime
(virtualTime time.Time)
service/history/workflow/mutable_state_impl.go:10237
↓ 2 callersMethodToString
(payload *commonpb.Payload)
tests/testcore/test_data_converter.go:92
↓ 2 callersMethodTrack
Track walks all values reachable from root and tracks pointer objects it finds.
common/testing/objectleak/leakcheck.go:75
↓ 2 callersMethodTransferTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:97
↓ 2 callersMethodUInt32
()
common/testing/testvars/any.go:48
↓ 2 callersFunctionURL
URL returns tag for URL
common/log/tag/tags.go:1027
↓ 2 callersMethodUnaryServerInterceptor
UnaryServerInterceptor returns a gRPC unary server interceptor that captures messages
tests/testcore/replication_stream_recorder.go:248
↓ 2 callersFunctionUnexpectedErrorAttempts
UnexpectedErrorAttempts returns tag for UnexpectedErrorAttempts
common/log/tag/tags.go:681
↓ 2 callersMethodUnmarshal
Unmarshal an object of type HistoryBlob from the protobuf v3 wire format
api/archiver/v1/message.go-helpers.pb.go:51
↓ 2 callersMethodUnmarshal
Unmarshal an object of type HealthCheck from the protobuf v3 wire format
api/health/v1/message.go-helpers.pb.go:14
↓ 2 callersMethodUnmarshal
Unmarshal an object of type RootExecutionInfo from the protobuf v3 wire format
api/workflow/v1/message.go-helpers.pb.go:51
↓ 2 callersMethodUnmarshal
Unmarshal an object of type TestPayloadStore from the protobuf v3 wire format
chasm/lib/tests/gen/testspb/v1/message.go-helpers.pb.go:14
↓ 2 callersMethodUnmarshal
Unmarshal an object of type Callback from the protobuf v3 wire format
chasm/lib/callback/gen/callbackpb/v1/message.go-helpers.pb.go:53
↓ 2 callersMethodUnmarshal
Unmarshal an object of type IncomingSignalData from the protobuf v3 wire format
chasm/lib/workflow/gen/workflowpb/v1/state.go-helpers.pb.go:88
↓ 2 callersMethodUnpauseActivity
UnpauseActivity unpauses the execution of an activity specified by its ID. If activity is not paused, this call will have no effect. If the activity
api/historyservice/v1/service_grpc.pb.go:364
↓ 2 callersFunctionUnpauseActivityWithResume
( shardContext historyi.ShardContext, mutableState historyi.MutableState, ai *persistencespb.ActivityInfo,
service/history/workflow/activity.go:444
↓ 2 callersMethodUnpauseWorkflowExecution
UnpauseWorkflowExecution unpauses the workflow execution specified in the request.
api/historyservice/v1/service_grpc.pb.go:387
↓ 2 callersFunctionUnsafePartitionFromProto
UnsafePartitionFromProto tries parsing proto using PartitionFromProto but if it fails still returns a Partition object using the raw values in the pro
common/tqid/task_queue_id.go:149
↓ 2 callersMethodUnwrap
()
service/history/transfer_queue_standby_task_executor.go:674
↓ 2 callersFunctionUpdate
Update updates the schema for the specified database
tools/common/schema/handler.go:23
↓ 2 callersMethodUpdate
This is public mainly for testing. The update loop will call this periodically, you don't have to call it explicitly.
common/dynamicconfig/file_based_client.go:154
↓ 2 callersMethodUpdateActivityOptions
UpdateActivityOptions is called by the client to update the options of an activity (-- api-linter: core::0134::method-signature=disabled (-- api-linte
api/historyservice/v1/service_grpc.pb.go:328
↓ 2 callersMethodUpdateBuildIdAssignment
(buildId string)
service/history/interfaces/mutable_state.go:300
↓ 2 callersMethodUpdateCurrentVersion
( version int64, forceUpdate bool, )
service/history/workflow/mutable_state_impl.go:1131
↓ 2 callersMethodUpdateFairnessState
UpdateFairnessState changes the fairness_state stored in UserData for automatically enabling priority and fairness. (-- api-linter: core::0134::method
api/matchingservice/v1/service_grpc.pb.go:249
↓ 2 callersMethodUpdateFutureActionTimes
UpdateFutureActionTimes computes and stores the next scheduled action times.
chasm/lib/scheduler/generator.go:65
↓ 2 callersMethodUpdateLastActiveTime
(now time.Time)
common/tasks/weighted_channel.go:52
↓ 2 callersMethodUpdateNamespaceDLQAckLevel
UpdateNamespaceDLQAckLevel updates namespace dlq ack level
common/persistence/persistence-tests/persistence_test_base.go:408
↓ 2 callersMethodUpdateNexusEndpoint
Optimistically update a Nexus endpoint based on provided version. If this request is accepted, the input is considered the "current" state of this ser
api/matchingservice/v1/service_grpc.pb.go:207
↓ 2 callersMethodUpdatePerKeySimpleRateLimitWithBurstForTesting
(burstDuration time.Duration)
service/matching/ratelimit_manager_test.go:66
↓ 2 callersMethodUpdateQueueV2Metadata
(ctx context.Context, row *QueueV2MetadataRow)
common/persistence/sql/sqlplugin/queue_v2_metadata.go:32
↓ 2 callersMethodUpdateRemotePriorityBacklogs
(remotePriorityBacklogSet)
service/matching/physical_task_queue_manager_interface.go:73
↓ 2 callersMethodUpdateReplicatorDLQAckLevel
(sourCluster string, ackLevel int64)
service/history/interfaces/shard_context.go:74
↓ 2 callersMethodUpdateTaskQueueConfig
Set the persisted task queue configuration. (-- api-linter: core::0134::method-signature=disabled aip.dev/not-precedent: UpdateTaskQueueConfig RPC d
api/matchingservice/v1/service_grpc.pb.go:232
↓ 2 callersMethodUpdateTaskQueueUserData
UpdateTaskQueueUserData implements persistence.TaskManager
service/matching/matching_engine_test.go:5571
↓ 2 callersMethodUpdateTaskQueueUserData
Update task queue user data in owning node for all updates in namespace. All user data updates must first go through the task queue owner using the `U
api/matchingservice/v1/service_grpc.pb.go:173
↓ 2 callersMethodUpdateVersionMetadata
( ctx context.Context, namespaceEntry *namespace.Namespace, version *deploymentpb.WorkerDeploymentVersio
service/worker/workerdeployment/client.go:130
↓ 2 callersFunctionUpdateWithStartExecution
( ctx context.Context, key ExecutionKey, startFn func(MutableContext, I) (C, error), updateFn func(C, Muta
chasm/engine.go:238
↓ 2 callersMethodUpdateWorkerBuildIdCompatibility
(-- api-linter: core::0134::response-message-name=disabled aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API for
api/matchingservice/v1/service_grpc.pb.go:125
↓ 2 callersMethodUpdateWorkerVersioningRules
Allows updating the Build ID assignment and redirect rules for a given Task Queue. (-- api-linter: core::0134::method-signature=disabled aip.dev/not
api/matchingservice/v1/service_grpc.pb.go:137
↓ 2 callersMethodUpdateWorkflowExecution
(-- api-linter: core::0134=disabled aip.dev/not-precedent: This service does not follow the update method API --)
api/historyservice/v1/service_grpc.pb.go:288
↓ 2 callersMethodUpdateWorkflowExecutionAsPassive
( ctx context.Context, shardContext historyi.ShardContext, )
service/history/workflow/context.go:504
↓ 2 callersMethodUpdateWorkflowExecutionOptions
UpdateWorkflowExecutionOptions modifies the options of an existing workflow execution. Currently the option that can be updated is setting and unsetti
api/historyservice/v1/service_grpc.pb.go:204
↓ 2 callersMethodUpdateWorkflowExecutionWithNewAsPassive
( ctx context.Context, shardContext ShardContext, newContext WorkflowContext, newMutableState Muta
service/history/interfaces/workflow_context.go:88
↓ 2 callersFunctionUpload
(ctx context.Context, s3cli S3API, URI archiver.URI, key string, data []byte)
common/archiver/s3store/util.go:187
↓ 2 callersMethodUserMetadata
UserMetadata returns the user metadata attached to the given component, or nil if none.
chasm/context.go:58
↓ 2 callersMethodUsername
()
common/archiver/uri.go:14
↓ 2 callersMethodValidate
()
common/namespace/archival_config_state_machine.go:46
↓ 2 callersMethodValidate
( ctx chasm.Context, scheduler *Scheduler, taskAttrs chasm.TaskAttributes, task *schedulerpb.SchedulerIdle
chasm/lib/scheduler/scheduler_tasks.go:72
↓ 2 callersFunctionValidateDeployment
ValidateDeployment returns error if the deployment is nil or it has empty build ID or deployment name.
common/worker_versioning/worker_versioning.go:564
↓ 2 callersMethodValidateName
ValidateName validates a namespace name (currently only a max length check).
common/rpc/interceptor/namespace_validator.go:132
↓ 2 callersMethodValidateNamespaceConfig
(config *persistencespb.NamespaceConfig)
common/namespace/nsmanager/attr_validator.go:27
↓ 2 callersMethodValidateRequest
ValidateRequest checks count, per-link size, and variant shape for the links on a single incoming request.
chasm/lib/activity/link_validator.go:33
↓ 2 callersMethodValidateRetryPolicy
(namespaceName string, retryPolicy *commonpb.RetryPolicy)
chasm/lib/workflow/validator.go:87
↓ 2 callersMethodValidateStartChildExecutionAttributes
( namespaceID namespace.ID, targetNamespaceID namespace.ID, targetNamespace namespace.Name, attributes *co
service/history/api/command_attr_validator.go:453
↓ 2 callersFunctionValidateTaskVersionDirective
( directive *taskqueuespb.TaskVersionDirective, wfBehavior enumspb.VersioningBehavior, wfDeployment *deploy
common/worker_versioning/worker_versioning.go:1032
↓ 2 callersMethodValidateURI
ValidateURI is used to define what a valid URI for an implementation is.
common/archiver/gcloud/history_archiver.go:280
↓ 2 callersMethodValidateURI
ValidateURI is used to define what a valid URI for an implementation is.
common/archiver/gcloud/visibility_archiver.go:290
↓ 2 callersMethodValidateURI
(URI archiver.URI)
common/archiver/filestore/history_archiver.go:276
↓ 2 callersMethodValidateURI
(URI archiver.URI)
common/archiver/filestore/visibility_archiver.go:239
↓ 2 callersFunctionValidateVisibilityQuery
( namespaceName namespace.Name, saNameType searchattribute.NameTypeMap, saMapperProvider searchattribute.Ma
service/worker/scheduler/query.go:68
↓ 2 callersMethodValidateWorkflowIDReusePolicy
( reusePolicy enumspb.WorkflowIdReusePolicy, conflictPolicy enumspb.WorkflowIdConflictPolicy, )
chasm/lib/workflow/validator.go:111
↓ 2 callersMethodValidateWorkflowStartDelay
( cronSchedule string, startDelay *durationpb.Duration, )
chasm/lib/workflow/validator.go:97
↓ 2 callersMethodValue
()
common/log/tag/interface.go:7
↓ 2 callersMethodValueType
ValueType returns the type of a CHASM search attribute field. Returns an error if the field is not found in the type map.
chasm/visibility.go:122
↓ 2 callersFunctionVerify
Verify verifies that the checksum generated from the given thrift object matches the specified expected checksum Return ErrMismatch when checksums mis
common/checksum/crc.go:48
↓ 2 callersMethodVerifyBinaryChecksum
VerifyBinaryChecksum returns an error if the provided checksum is one of this namespace's configured bad binary checksums. The returned error (if any)
common/namespace/namespace.go:149
↓ 2 callersMethodVerifyChildExecutionCompletionRecorded
VerifyChildExecutionCompletionRecorded checks if child completion result is recorded in parent workflow. This is only used by standby transfer close e
api/historyservice/v1/service_grpc.pb.go:231
↓ 2 callersFunctionVerifyCompatibleVersion
VerifyCompatibleVersion ensures that the installed version of temporal and visibility keyspaces is greater than or equal to the expected version. In m
common/persistence/cassandra/version_checker.go:19
↓ 2 callersMethodVerifyFirstWorkflowTaskScheduled
VerifyFirstWorkflowTaskScheduled checks if workflow has its first workflow task scheduled. This is only used by standby transfer start child workflow
api/historyservice/v1/service_grpc.pb.go:221
← previousnext →7,701–7,800 of 43,335, ranked by callers