MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 2 callersFunctionGetOverridePinnedVersion
(override *workflowpb.VersioningOverride)
common/worker_versioning/worker_versioning.go:654
↓ 2 callersMethodGetOverrideState
()
api/deployment/v1/message.pb.go:3839
↓ 2 callersMethodGetOverrideState
()
api/deployment/v1/message.pb.go:3886
↓ 2 callersMethodGetPageSize
()
common/persistence/visibility/manager/visibility_manager.go:175
↓ 2 callersMethodGetParentClosePolicy
()
api/persistence/v1/executions.pb.go:3460
↓ 2 callersMethodGetPartitionId
()
api/taskqueue/v1/message.pb.go:543
↓ 2 callersMethodGetPendingRequestCancelExternalInfos
()
service/history/workflow/mutable_state_impl.go:2356
↓ 2 callersMethodGetPendingSignalExternalInfos
()
service/history/workflow/mutable_state_impl.go:2360
↓ 2 callersMethodGetPendingSignalRequestedIds
()
service/history/interfaces/mutable_state.go:194
↓ 2 callersMethodGetPendingWorkflowTask
()
service/history/workflow/mutable_state_impl.go:2376
↓ 2 callersMethodGetPredicateType
()
api/persistence/v1/predicates.pb.go:76
↓ 2 callersMethodGetPreviousManagerIdentity
()
api/deployment/v1/message.pb.go:3114
↓ 2 callersMethodGetPrimaryVisibility
()
common/persistence/visibility/visibility_manager_dual.go:52
↓ 2 callersMethodGetPrivateScalerState
()
api/persistence/v1/tasks.pb.go:638
↓ 2 callersMethodGetQueries
()
api/matchingservice/v1/request_response.pb.go:288
↓ 2 callersMethodGetRawHistory
()
api/matchingservice/v1/request_response.pb.go:323
↓ 2 callersMethodGetReaderWatermark
(readerID int64)
service/history/queues/monitor.go:29
↓ 2 callersMethodGetRegistrySize
()
common/namespace/registry.go:33
↓ 2 callersMethodGetReplicationConfig
()
api/adminservice/v1/request_response.pb.go:3947
↓ 2 callersMethodGetReplicationMessages
GetReplicationMessages returns new replication tasks since the read level provided in the token.
api/adminservice/v1/service_grpc.pb.go:98
↓ 2 callersMethodGetReplicationMessages
GetReplicationMessages return replication messages based on the read level
api/historyservice/v1/service_grpc.pb.go:253
↓ 2 callersMethodGetReplicationStatus
(ctx context.Context, in *GetReplicationStatusRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:274
↓ 2 callersMethodGetReportPollers
()
api/matchingservice/v1/request_response.pb.go:1955
↓ 2 callersMethodGetRequestCancelInfo
GetRequestCancelInfo gives details about a request cancellation that is currently in progress.
service/history/workflow/mutable_state_impl.go:1706
↓ 2 callersMethodGetRequestCancelInitiatedEventId
()
api/persistence/v1/hsm.pb.go:645
↓ 2 callersMethodGetRequestTimeout
()
api/matchingservice/v1/request_response.pb.go:3964
↓ 2 callersMethodGetRequesteCancelExternalInitiatedEvent
(context.Context, int64)
service/history/interfaces/mutable_state.go:164
↓ 2 callersMethodGetRequestedEventId
()
chasm/lib/workflow/gen/workflowpb/v1/state.pb.go:121
↓ 2 callersMethodGetResetRunId
()
api/persistence/v1/executions.pb.go:1034
↓ 2 callersMethodGetResponses
()
api/historyservice/v1/request_response.pb.go:1159
↓ 2 callersMethodGetRunId
()
api/historyservice/v1/request_response.pb.go:3057
↓ 2 callersMethodGetSDKClientFactory
internal services clients GetSDKClientFactory for testing
common/resourcetest/test_resource.go:296
↓ 2 callersMethodGetSchedule
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:91
↓ 2 callersMethodGetScheduleToStartTimeout
()
api/matchingservice/v1/request_response.pb.go:919
↓ 2 callersMethodGetScheduleToStartTimeout
()
api/matchingservice/v1/request_response.pb.go:1090
↓ 2 callersMethodGetScheduledEventId
()
api/matchingservice/v1/request_response.pb.go:912
↓ 2 callersMethodGetScheduledEventId
()
api/matchingservice/v1/request_response.pb.go:1083
↓ 2 callersMethodGetSearchAttributes
GetSearchAttributes returns comprehensive information about search attributes. Deprecated. Use operatorservice instead.
api/adminservice/v1/service_grpc.pb.go:113
↓ 2 callersMethodGetSearchAttributesManager
()
common/resourcetest/test_resource.go:403
↓ 2 callersMethodGetSecondaryVisibility
()
common/persistence/visibility/visibility_manager_dual.go:56
↓ 2 callersMethodGetSerialConsistency
GetSerialConsistency returns the gosql.SerialConsistency setting from the configuration for the store
common/config/persistence.go:204
↓ 2 callersMethodGetServerDelete
()
api/deployment/v1/message.pb.go:2668
↓ 2 callersMethodGetSetIds
()
api/persistence/v1/task_queues.pb.go:226
↓ 2 callersMethodGetShard
GetShard gets the ShardInfo
api/historyservice/v1/service_grpc.pb.go:249
↓ 2 callersMethodGetShardManager
GetShardManager for testing
common/resourcetest/test_resource.go:373
↓ 2 callersMethodGetShardMessages
()
api/adminservice/v1/request_response.pb.go:1522
↓ 2 callersMethodGetShouldUseRampingVersion
()
service/history/interfaces/mutable_state.go:405
↓ 2 callersMethodGetSignalExternalInitiatedEvent
(context.Context, int64)
service/history/interfaces/mutable_state.go:173
↓ 2 callersMethodGetSignalExternalInitiatedEventId
()
api/persistence/v1/hsm.pb.go:654
↓ 2 callersMethodGetSignalInfo
GetSignalInfo get the details about a signal request that is currently in progress.
service/history/workflow/mutable_state_impl.go:1785
↓ 2 callersMethodGetSignalWithStartRequest
()
api/historyservice/v1/request_response.pb.go:3011
↓ 2 callersMethodGetSize
GetSize returns approximate size of the Registry in bytes.
service/history/workflow/update/registry.go:75
↓ 2 callersMethodGetSkipForceReload
()
api/adminservice/v1/request_response.pb.go:370
↓ 2 callersMethodGetSliceCount
(readerID int64)
service/history/queues/monitor.go:33
↓ 2 callersFunctionGetStandbyTimerTaskTypeTagValue
( task tasks.Task, chasmRegistry *chasm.Registry, )
service/history/queues/metrics.go:123
↓ 2 callersFunctionGetStandbyTransferTaskTypeTagValue
( task tasks.Task, chasmRegistry *chasm.Registry, )
service/history/queues/metrics.go:58
↓ 2 callersMethodGetStartEvent
GetStartEvent retrieves the workflow start event from mutable state
service/history/workflow/mutable_state_impl.go:1948
↓ 2 callersMethodGetStartedWorkflowTask
()
service/history/workflow/mutable_state_impl.go:2384
↓ 2 callersMethodGetStateMachinePath
()
api/persistence/v1/hsm.pb.go:672
↓ 2 callersMethodGetSyncHsmAttributes
()
api/replication/v1/message.pb.go:168
↓ 2 callersMethodGetSyncShardStatus
()
api/replication/v1/message.pb.go:612
↓ 2 callersMethodGetSyncWorkflowStateArtifactFromMutableState
( ctx context.Context, namespaceID string, execution *commonpb.WorkflowExecution, mutableState his
service/history/replication/sync_state_retriever.go:53
↓ 2 callersMethodGetTargetVersion
()
api/persistence/v1/tasks.pb.go:624
↓ 2 callersMethodGetTaskQueue
()
api/matchingservice/v1/request_response.pb.go:905
↓ 2 callersMethodGetTaskQueueUserData
Fetch user data for a task queue, 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:128
↓ 2 callersMethodGetTaskQueueUserData
(ctx context.Context, in *GetTaskQueueUserDataRequest, opts ...grpc.CallOption)
api/adminservice/v1/service_grpc.pb.go:161
↓ 2 callersMethodGetTaskRange
()
api/adminservice/v1/request_response.pb.go:824
↓ 2 callersMethodGetTaskToken
()
api/matchingservice/v1/request_response.pb.go:699
↓ 2 callersMethodGetTerminateState
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:300
↓ 2 callersMethodGetTestCluster
()
tests/testcore/functional_test_base.go:217
↓ 2 callersFunctionGetTimerStateMachineTaskTypeTagValue
(taskType string, isActive bool)
service/history/queues/metrics.go:210
↓ 2 callersFunctionGetTimerTaskEventID
( timerTask Task, )
service/history/tasks/utils.go:89
↓ 2 callersMethodGetTransientOrSpeculativeTasks
()
api/historyservice/v1/request_response.pb.go:740
↓ 2 callersMethodGetType
()
service/history/tasks/archive_execution_task.go:43
↓ 2 callersMethodGetUpdateRoutingConfig
()
api/deployment/v1/message.pb.go:1953
↓ 2 callersMethodGetUserData
GetUserData returns the user data for this task queue and a channel that signals when the data has been updated. Do not mutate the returned pointer, a
service/matching/user_data_manager.go:193
↓ 2 callersMethodGetVariant
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:748
↓ 2 callersMethodGetVectorClock
()
service/history/ndc/workflow.go:73
↓ 2 callersMethodGetVersionHistoryItem
()
api/token/v1/message.pb.go:115
↓ 2 callersMethodGetVersionedTransition
()
api/token/v1/message.pb.go:122
↓ 2 callersFunctionGetVisibilityTaskTypeTagValue
( task tasks.Task, )
service/history/queues/metrics.go:156
↓ 2 callersMethodGetVisibilityTime
()
service/history/tasks/chasm_task.go:104
↓ 2 callersMethodGetWorkerBuildIdCompatibility
(ctx context.Context, in *GetWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption)
api/matchingservice/v1/service_grpc.pb.go:126
↓ 2 callersMethodGetWorkerControlTaskQueue
()
api/persistence/v1/executions.pb.go:3230
↓ 2 callersMethodGetWorkerDeploymentSA
()
service/history/workflow/mutable_state_impl.go:9651
↓ 2 callersMethodGetWorkerIdentity
()
api/matchingservice/v1/request_response.pb.go:1605
↓ 2 callersMethodGetWorkerVersioningRules
Fetches the Build ID assignment and redirect rules for a Task Queue (-- api-linter: core::0127::resource-name-extraction=disabled aip.dev/not-preced
api/matchingservice/v1/service_grpc.pb.go:146
↓ 2 callersMethodGetWorkflowExecutionHistory
(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:294
↓ 2 callersMethodGetWorkflowExecutionHistoryReverse
(ctx context.Context, in *GetWorkflowExecutionHistoryReverseRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:295
↓ 2 callersMethodGetWorkflowExecutionRawHistory
StartEventId defines the beginning of the event to fetch. The first event is inclusive. EndEventId and EndEventVersion defines the end of the event to
api/adminservice/v1/service_grpc.pb.go:96
↓ 2 callersMethodGetWorkflowExecutionRawHistory
(ctx context.Context, in *GetWorkflowExecutionRawHistoryRequest, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:297
↓ 2 callersMethodGetWorkflowExecutionRawHistoryV2
Returns the raw history of specified workflow execution. It fails with 'NotFound' if specified workflow execution in unknown to the service. StartEve
api/adminservice/v1/service_grpc.pb.go:93
↓ 2 callersMethodGetWorkflowExecutionRawHistoryV2
(ctx context.Context, in *GetWorkflowExecutionRawHistoryV2Request, opts ...grpc.CallOption)
api/historyservice/v1/service_grpc.pb.go:296
↓ 2 callersMethodGetWorkflowNamespace
()
api/matchingservice/v1/request_response.pb.go:797
↓ 2 callersMethodGetWorkflowTaskBuildId
()
api/persistence/v1/executions.pb.go:621
↓ 2 callersMethodGetWorkflowTaskByID
GetWorkflowTaskByID returns details about the current workflow task by scheduled event ID.
service/history/workflow/workflow_task_state_machine.go:1217
↓ 2 callersFunctionGetXDCCacheValue
( executionInfo *persistencespb.WorkflowExecutionInfo, eventID int64, version int64, )
common/persistence/xdc_cache.go:136
↓ 2 callersMethodGoType
GoType returns the reflect.Type of the task's Go struct.
chasm/registrable_task.go:173
↓ 2 callersMethodHadOrHasWorkflowTask
()
service/history/workflow/mutable_state_impl.go:2368
↓ 2 callersMethodHandleLegacyQuery
( tv *testvars.TestVars, handler func(task *workflowservice.PollWorkflowTaskQueueResponse) (*workflowservice
common/testing/taskpoller/taskpoller.go:395
← previousnext →7,101–7,200 of 43,335, ranked by callers