Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/temporalio/temporal
/ functions
Functions
43,335 in github.com/temporalio/temporal
⨍
Functions
43,335
◇
Types & classes
5,614
↓ 2 callers
Method
SyncActivities
(ctx context.Context, request *historyservice.SyncActivitiesRequest)
service/history/interfaces/engine.go:71
↓ 2 callers
Method
SyncActivity
SyncActivity sync the activity status.
api/historyservice/v1/service_grpc.pb.go:241
↓ 2 callers
Method
SyncDeploymentUserData
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 callers
Method
SyncShardStatus
SyncShardStatus sync the status between shards.
api/historyservice/v1/service_grpc.pb.go:239
↓ 2 callers
Method
SyncWorkflowState
(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:157
↓ 2 callers
Method
SyncWorkflowState
(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:324
↓ 2 callers
Function
System
System returns a clone of the system search attributes map.
common/searchattribute/sadefs/constants.go:257
↓ 2 callers
Method
Task
(fqn string)
chasm/export_test.go:12
↓ 2 callers
Function
TaskCategoryRegistryProvider
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 callers
Method
TaskQueueFamily
()
service/matching/physical_task_queue_key.go:53
↓ 2 callers
Method
TaskQueueInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:89
↓ 2 callers
Function
TaskQueueTypeTag
(tqType enumspb.TaskQueueType)
common/metrics/tags.go:186
↓ 2 callers
Method
TaskQueueUserDataFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:90
↓ 2 callers
Method
TaskStats
()
service/history/queues/slice.go:36
↓ 2 callers
Function
TaskVersion
TaskVersion returns tag for TaskVersion
common/log/tag/tags.go:632
↓ 2 callers
Method
TearDownCluster
()
tests/testcore/functional_test_base.go:469
↓ 2 callers
Method
TearDownTestDatabase
()
common/persistence/persistence-tests/persistence_test_base.go:113
↓ 2 callers
Method
TerminateWorkflowExecution
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 callers
Method
Test
(task Task)
service/history/tasks/predicates.go:50
↓ 2 callers
Method
Test
(task Task)
service/history/tasks/predicates.go:85
↓ 2 callers
Method
Test
(task Task)
service/history/tasks/predicates.go:124
↓ 2 callers
Method
Test
(task Task)
service/history/tasks/predicates.go:163
↓ 2 callers
Function
TestEsNameTypeMapWithScheduleID
()
common/searchattribute/test_provider.go:74
↓ 2 callers
Function
TestSearchAttributesToRegister
()
common/searchattribute/test_provider.go:70
↓ 2 callers
Function
TimeoutTypeTag
(timeoutType string)
common/metrics/tags.go:594
↓ 2 callers
Function
TimeoutWorkflow
( mutableState historyi.MutableState, retryState enumspb.RetryState, continuedRunID string, )
service/history/workflow/util.go:72
↓ 2 callers
Method
TimerInfoToBlob
(info *persistencespb.TimerInfo)
common/persistence/serialization/serializer.go:48
↓ 2 callers
Method
TimerTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:98
↓ 2 callers
Function
ToPersistenceRange
( r Range, )
service/history/queues/convert.go:70
↓ 2 callers
Function
ToPersistenceScope
( scope Scope, )
service/history/queues/convert.go:52
↓ 2 callers
Method
ToRealTime
(virtualTime time.Time)
service/history/workflow/mutable_state_impl.go:10237
↓ 2 callers
Method
ToString
(payload *commonpb.Payload)
tests/testcore/test_data_converter.go:92
↓ 2 callers
Method
Track
Track walks all values reachable from root and tracks pointer objects it finds.
common/testing/objectleak/leakcheck.go:75
↓ 2 callers
Method
TransferTaskInfoFromBlob
(data *commonpb.DataBlob)
common/persistence/serialization/serializer.go:97
↓ 2 callers
Method
UInt32
()
common/testing/testvars/any.go:48
↓ 2 callers
Function
URL
URL returns tag for URL
common/log/tag/tags.go:1027
↓ 2 callers
Method
UnaryServerInterceptor
UnaryServerInterceptor returns a gRPC unary server interceptor that captures messages
tests/testcore/replication_stream_recorder.go:248
↓ 2 callers
Function
UnexpectedErrorAttempts
UnexpectedErrorAttempts returns tag for UnexpectedErrorAttempts
common/log/tag/tags.go:681
↓ 2 callers
Method
Unmarshal
Unmarshal an object of type HistoryBlob from the protobuf v3 wire format
api/archiver/v1/message.go-helpers.pb.go:51
↓ 2 callers
Method
Unmarshal
Unmarshal an object of type HealthCheck from the protobuf v3 wire format
api/health/v1/message.go-helpers.pb.go:14
↓ 2 callers
Method
Unmarshal
Unmarshal an object of type RootExecutionInfo from the protobuf v3 wire format
api/workflow/v1/message.go-helpers.pb.go:51
↓ 2 callers
Method
Unmarshal
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 callers
Method
Unmarshal
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 callers
Method
Unmarshal
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 callers
Method
UnpauseActivity
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 callers
Function
UnpauseActivityWithResume
( shardContext historyi.ShardContext, mutableState historyi.MutableState, ai *persistencespb.ActivityInfo,
service/history/workflow/activity.go:444
↓ 2 callers
Method
UnpauseWorkflowExecution
UnpauseWorkflowExecution unpauses the workflow execution specified in the request.
api/historyservice/v1/service_grpc.pb.go:387
↓ 2 callers
Function
UnsafePartitionFromProto
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 callers
Method
Unwrap
()
service/history/transfer_queue_standby_task_executor.go:674
↓ 2 callers
Function
Update
Update updates the schema for the specified database
tools/common/schema/handler.go:23
↓ 2 callers
Method
Update
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 callers
Method
UpdateActivityOptions
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 callers
Method
UpdateBuildIdAssignment
(buildId string)
service/history/interfaces/mutable_state.go:300
↓ 2 callers
Method
UpdateCurrentVersion
( version int64, forceUpdate bool, )
service/history/workflow/mutable_state_impl.go:1131
↓ 2 callers
Method
UpdateFairnessState
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 callers
Method
UpdateFutureActionTimes
UpdateFutureActionTimes computes and stores the next scheduled action times.
chasm/lib/scheduler/generator.go:65
↓ 2 callers
Method
UpdateLastActiveTime
(now time.Time)
common/tasks/weighted_channel.go:52
↓ 2 callers
Method
UpdateNamespaceDLQAckLevel
UpdateNamespaceDLQAckLevel updates namespace dlq ack level
common/persistence/persistence-tests/persistence_test_base.go:408
↓ 2 callers
Method
UpdateNexusEndpoint
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 callers
Method
UpdatePerKeySimpleRateLimitWithBurstForTesting
(burstDuration time.Duration)
service/matching/ratelimit_manager_test.go:66
↓ 2 callers
Method
UpdateQueueV2Metadata
(ctx context.Context, row *QueueV2MetadataRow)
common/persistence/sql/sqlplugin/queue_v2_metadata.go:32
↓ 2 callers
Method
UpdateRemotePriorityBacklogs
(remotePriorityBacklogSet)
service/matching/physical_task_queue_manager_interface.go:73
↓ 2 callers
Method
UpdateReplicatorDLQAckLevel
(sourCluster string, ackLevel int64)
service/history/interfaces/shard_context.go:74
↓ 2 callers
Method
UpdateTaskQueueConfig
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 callers
Method
UpdateTaskQueueUserData
UpdateTaskQueueUserData implements persistence.TaskManager
service/matching/matching_engine_test.go:5571
↓ 2 callers
Method
UpdateTaskQueueUserData
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 callers
Method
UpdateVersionMetadata
( ctx context.Context, namespaceEntry *namespace.Namespace, version *deploymentpb.WorkerDeploymentVersio
service/worker/workerdeployment/client.go:130
↓ 2 callers
Function
UpdateWithStartExecution
( ctx context.Context, key ExecutionKey, startFn func(MutableContext, I) (C, error), updateFn func(C, Muta
chasm/engine.go:238
↓ 2 callers
Method
UpdateWorkerBuildIdCompatibility
(-- 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 callers
Method
UpdateWorkerVersioningRules
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 callers
Method
UpdateWorkflowExecution
(-- 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 callers
Method
UpdateWorkflowExecutionAsPassive
( ctx context.Context, shardContext historyi.ShardContext, )
service/history/workflow/context.go:504
↓ 2 callers
Method
UpdateWorkflowExecutionOptions
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 callers
Method
UpdateWorkflowExecutionWithNewAsPassive
( ctx context.Context, shardContext ShardContext, newContext WorkflowContext, newMutableState Muta
service/history/interfaces/workflow_context.go:88
↓ 2 callers
Function
Upload
(ctx context.Context, s3cli S3API, URI archiver.URI, key string, data []byte)
common/archiver/s3store/util.go:187
↓ 2 callers
Method
UserMetadata
UserMetadata returns the user metadata attached to the given component, or nil if none.
chasm/context.go:58
↓ 2 callers
Method
Username
()
common/archiver/uri.go:14
↓ 2 callers
Method
Validate
()
common/namespace/archival_config_state_machine.go:46
↓ 2 callers
Method
Validate
( ctx chasm.Context, scheduler *Scheduler, taskAttrs chasm.TaskAttributes, task *schedulerpb.SchedulerIdle
chasm/lib/scheduler/scheduler_tasks.go:72
↓ 2 callers
Function
ValidateDeployment
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 callers
Method
ValidateName
ValidateName validates a namespace name (currently only a max length check).
common/rpc/interceptor/namespace_validator.go:132
↓ 2 callers
Method
ValidateNamespaceConfig
(config *persistencespb.NamespaceConfig)
common/namespace/nsmanager/attr_validator.go:27
↓ 2 callers
Method
ValidateRequest
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 callers
Method
ValidateRetryPolicy
(namespaceName string, retryPolicy *commonpb.RetryPolicy)
chasm/lib/workflow/validator.go:87
↓ 2 callers
Method
ValidateStartChildExecutionAttributes
( namespaceID namespace.ID, targetNamespaceID namespace.ID, targetNamespace namespace.Name, attributes *co
service/history/api/command_attr_validator.go:453
↓ 2 callers
Function
ValidateTaskVersionDirective
( directive *taskqueuespb.TaskVersionDirective, wfBehavior enumspb.VersioningBehavior, wfDeployment *deploy
common/worker_versioning/worker_versioning.go:1032
↓ 2 callers
Method
ValidateURI
ValidateURI is used to define what a valid URI for an implementation is.
common/archiver/gcloud/history_archiver.go:280
↓ 2 callers
Method
ValidateURI
ValidateURI is used to define what a valid URI for an implementation is.
common/archiver/gcloud/visibility_archiver.go:290
↓ 2 callers
Method
ValidateURI
(URI archiver.URI)
common/archiver/filestore/history_archiver.go:276
↓ 2 callers
Method
ValidateURI
(URI archiver.URI)
common/archiver/filestore/visibility_archiver.go:239
↓ 2 callers
Function
ValidateVisibilityQuery
( namespaceName namespace.Name, saNameType searchattribute.NameTypeMap, saMapperProvider searchattribute.Ma
service/worker/scheduler/query.go:68
↓ 2 callers
Method
ValidateWorkflowIDReusePolicy
( reusePolicy enumspb.WorkflowIdReusePolicy, conflictPolicy enumspb.WorkflowIdConflictPolicy, )
chasm/lib/workflow/validator.go:111
↓ 2 callers
Method
ValidateWorkflowStartDelay
( cronSchedule string, startDelay *durationpb.Duration, )
chasm/lib/workflow/validator.go:97
↓ 2 callers
Method
Value
()
common/log/tag/interface.go:7
↓ 2 callers
Method
ValueType
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 callers
Function
Verify
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 callers
Method
VerifyBinaryChecksum
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 callers
Method
VerifyChildExecutionCompletionRecorded
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 callers
Function
VerifyCompatibleVersion
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 callers
Method
VerifyFirstWorkflowTaskScheduled
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
← previous
next →
7,701–7,800 of 43,335, ranked by callers