MCPcopy Create free account

hub / github.com/temporalio/temporal / functions

Functions43,335 in github.com/temporalio/temporal

⨍ Functions 43,335◇ Types & classes 5,614
↓ 9 callersFunctionExternalWorkerDeploymentVersionToStringV31
(v *deploymentpb.WorkerDeploymentVersion)
common/worker_versioning/worker_versioning.go:1173
↓ 9 callersMethodFailed
Failed reports whether this attempt has failed.
common/testing/await/t.go:68
↓ 9 callersMethodField
Field returns the field for a given alias.
chasm/visibility.go:74
↓ 9 callersFunctionFilterNilMemo
FilterNilMemo returns a new Memo with nil/empty payload values filtered out. If the input is nil or all values are nil/empty, returns nil. This is use
common/payload/payload.go:117
↓ 9 callersFunctionFilterNilSearchAttributes
FilterNilSearchAttributes returns a new SearchAttributes with nil/empty payload values filtered out. If the input is nil or all values are nil/empty,
common/payload/payload.go:101
↓ 9 callersFunctionFindLCAVersionHistoryItem
FindLCAVersionHistoryItem returns the lowest common ancestor VersionHistoryItem.
common/persistence/versionhistory/version_history.go:109
↓ 9 callersMethodForceLoadTaskQueuePartition
(ctx context.Context, request *matchingservice.ForceLoadTaskQueuePartitionRequest)
service/matching/matching_engine_interfaces.go:34
↓ 9 callersMethodFqType
()
chasm/export_test.go:36
↓ 9 callersMethodGenerateActivityRetryTasks
(activityInfo *persistencespb.ActivityInfo)
service/history/workflow/task_generator.go:65
↓ 9 callersMethodGetAllPollerInfo
()
service/matching/physical_task_queue_manager_interface.go:60
↓ 9 callersMethodGetAttempt
()
chasm/lib/callback/gen/callbackpb/v1/tasks.pb.go:108
↓ 9 callersFunctionGetBoolPropertyFnFilteredByTaskQueue
(value bool)
common/dynamicconfig/setting_gen.go:89
↓ 9 callersMethodGetBusinessId
()
api/routing/v1/extension.pb.go:82
↓ 9 callersMethodGetCallback
()
api/persistence/v1/executions.pb.go:3933
↓ 9 callersMethodGetChildExecutionInfo
GetChildExecutionInfo gives details about a child execution that is currently in progress.
service/history/workflow/mutable_state_impl.go:1658
↓ 9 callersMethodGetClusterMembers
(ctx context.Context, request *GetClusterMembersRequest)
common/persistence/data_interfaces.go:1235
↓ 9 callersMethodGetCronSchedule
()
api/persistence/v1/executions.pb.go:733
↓ 9 callersMethodGetDLQMessages
(ctx context.Context, messagesRequest *historyservice.GetDLQMessagesRequest)
service/history/interfaces/engine.go:78
↓ 9 callersMethodGetFailure
()
chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go:510
↓ 9 callersFunctionGetFirstVersionHistoryItem
GetFirstVersionHistoryItem return the first VersionHistoryItem.
common/persistence/versionhistory/version_history.go:209
↓ 9 callersMethodGetHistorySize
()
service/history/interfaces/mutable_state.go:305
↓ 9 callersMethodGetHistoryTasks
(ctx context.Context, request *GetHistoryTasksRequest)
common/persistence/data_interfaces.go:1137
↓ 9 callersMethodGetHostInfo
GetHostInfo for testing
common/resourcetest/test_resource.go:215
↓ 9 callersMethodGetIndexName
()
common/persistence/visibility/store/sql/visibility_store.go:104
↓ 9 callersMethodGetIsGlobalNamespace
()
api/adminservice/v1/request_response.pb.go:3975
↓ 9 callersMethodGetLastIndependentlyAssignedBuildId
()
api/persistence/v1/executions.pb.go:3123
↓ 9 callersMethodGetLastModifierIdentity
()
api/deployment/v1/message.pb.go:485
↓ 9 callersMethodGetLink
()
api/historyservice/v1/request_response.pb.go:443
↓ 9 callersMethodGetLinks
()
chasm/lib/nexusoperation/gen/nexusoperationpb/v1/operation.pb.go:433
↓ 9 callersMethodGetMatchingClient
(namespaceIDToName NamespaceIDToNameFunc)
client/client_bean.go:27
↓ 9 callersMethodGetMaxReadLevel
GetMaxReadLevel returns the current maxReadLevel
service/matching/db.go:120
↓ 9 callersMethodGetMaximumAttempts
()
api/cli/v1/message.pb.go:358
↓ 9 callersFunctionGetOrPollWorkflowMutableState
nolint:revive // cognitive complexity 39 (> max enabled 25)
service/history/api/get_workflow_util.go:28
↓ 9 callersMethodGetPendingActivityInfos
()
service/history/workflow/mutable_state_impl.go:2336
↓ 9 callersFunctionGetRepoRootDirectory
GetRepoRootDirectory returns the root directory of the temporal repo.
tests/testutils/source_root.go:15
↓ 9 callersMethodGetScheduleToStartTimeout
()
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:244
↓ 9 callersMethodGetSearchAttributesProvider
()
service/history/interfaces/shard_context.go:55
↓ 9 callersMethodGetService
()
api/health/v1/message.pb.go:220
↓ 9 callersMethodGetShardID
GetShardID mocks base method.
service/history/interfaces/shard_context_mock.go:630
↓ 9 callersMethodGetSignalLink
()
api/historyservice/v1/request_response.pb.go:3071
↓ 9 callersMethodGetSyncWorkflowStateMutationAttributes
()
api/replication/v1/message.pb.go:1978
↓ 9 callersMethodGetSyncWorkflowStateSnapshotAttributes
()
api/replication/v1/message.pb.go:1987
↓ 9 callersMethodGetTotalSliceCount
()
service/history/queues/monitor.go:32
↓ 9 callersMethodGetTransitionHistory
()
api/persistence/v1/executions.pb.go:950
↓ 9 callersMethodGetUpdateOutcome
(ctx context.Context, updateID string)
service/history/workflow/update/store.go:19
↓ 9 callersMethodGetUserMetadata
Deprecated: Marked as deprecated in temporal/server/chasm/lib/activity/proto/v1/activity_state.proto.
chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go:700
↓ 9 callersMethodGetVariant
()
api/persistence/v1/executions.pb.go:3759
↓ 9 callersMethodHandleNexusCompletion
(ctx MutableContext, completion *persistencespb.ChasmNexusCompletion)
chasm/nexus_completion.go:22
↓ 9 callersMethodHasBufferEvents
()
service/history/historybuilder/event_store.go:134
↓ 9 callersMethodHasOutgoingMessages
HasOutgoingMessages returns true if the Registry has any Updates for which outgoing message can be generated. If includeAlreadySent is set to true, th
service/history/workflow/update/registry.go:50
↓ 9 callersMethodHasQueue
HasQueue returns true if a queue exists for the given execution key. This is used by other schedulers to check if they should route tasks here.
common/tasks/execution_queue_scheduler.go:114
↓ 9 callersFunctionIgnoreFields
IgnoreFields returns an Option that ignores the specified fields (by proto name) on the top-level message type when comparing.
common/testing/protorequire/require.go:30
↓ 9 callersMethodInitialShardsAcquired
InitialShardsAcquired blocks until initial shard acquisition is complete, context timeout, or Stop is called. Returns nil if shards are acquired, othe
service/history/shard/controller.go:26
↓ 9 callersMethodInsertIntoHistoryNode
(ctx context.Context, row *HistoryNodeRow)
common/persistence/sql/sqlplugin/history_node.go:49
↓ 9 callersMethodInsertIntoQueueMetadata
(ctx context.Context, row *QueueMetadataRow)
common/persistence/sql/sqlplugin/queue_metadata.go:24
↓ 9 callersMethodInsertIntoShards
(ctx context.Context, rows *ShardsRow)
common/persistence/sql/sqlplugin/history_shard.go:25
↓ 9 callersMethodIntercept
( ctx context.Context, req any, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler, )
common/rpc/interceptor/service_error_interceptor.go:29
↓ 9 callersMethodIsActivityTaskValid
(ctx context.Context, request *historyservice.IsActivityTaskValidRequest)
service/history/interfaces/engine.go:52
↓ 9 callersFunctionIsEqualVersionHistoryItem
IsEqualVersionHistoryItem checks whether version history items are equal
common/persistence/versionhistory/version_history_item.go:24
↓ 9 callersFunctionIsLCAVersionHistoryItemAppendable
IsLCAVersionHistoryItemAppendable checks if a LCA VersionHistoryItem is appendable.
common/persistence/versionhistory/version_history.go:197
↓ 9 callersMethodIsServerEnabled
()
common/config/config.go:725
↓ 9 callersMethodIsWorkflowPendingOnWorkflowTaskBackoff
()
service/history/interfaces/mutable_state.go:236
↓ 9 callersMethodIsWorkflowTaskValid
(ctx context.Context, request *historyservice.IsWorkflowTaskValidRequest)
service/history/interfaces/engine.go:53
↓ 9 callersMethodLegacyDescribeTaskQueue
LegacyDescribeTaskQueue returns pollers info and legacy TaskQueueStatus for this physical queue
service/matching/physical_task_queue_manager_interface.go:63
↓ 9 callersMethodListQueues
(c *cli.Context)
tools/tdbg/dlq_service.go:23
↓ 9 callersMethodListScheduleMatchingTimes
(ctx context.Context, in *ListScheduleMatchingTimesRequest, opts ...grpc.CallOption)
chasm/lib/scheduler/gen/schedulerpb/v1/service_grpc.pb.go:43
↓ 9 callersMethodListTables
()
tools/common/schema/test/dbtest.go:23
↓ 9 callersFunctionLoadAndSplitQueryFromReaders
LoadAndSplitQueryFromReaders loads and split cql / sql query into one statement per string. Comments are removed from the query.
common/persistence/query_util.go:55
↓ 9 callersFunctionLoadYamlFile
LoadYamlFile is a convenience function to create a YamlLoader and call LoadFile.
common/dynamicconfig/yaml_loader.go:37
↓ 9 callersMethodLookup
Lookup looks up the host that currently owns the resource identified by the given key.
common/membership/interfaces.go:71
↓ 9 callersFunctionMachineCollection
MachineCollection creates a new typed [statemachines.Collection] for operations.
components/nexusoperations/statemachine.go:36
↓ 9 callersMethodMakeURL
(service primitives.ServiceName)
common/membership/grpc_resolver.go:78
↓ 9 callersMethodMatches
(mask stateSet)
service/history/workflow/update/state.go:57
↓ 9 callersMethodMemberCount
MemberCount returns the number of known hosts running this service.
common/membership/interfaces.go:82
↓ 9 callersMethodMergeDLQMessages
(ctx context.Context, messagesRequest *historyservice.MergeDLQMessagesRequest)
service/history/interfaces/engine.go:80
↓ 9 callersFunctionNew
( timeSource clock.TimeSource, taskIDGenerator TaskIDGenerator, version int64, nextEventID int64, dbBuffe
service/history/historybuilder/history_builder.go:60
↓ 9 callersFunctionNewBasicRedirector
( connections connectionPool[C], historyServiceResolver membership.ServiceResolver, )
client/history/redirector.go:38
↓ 9 callersFunctionNewCallerInfo
NewCallerInfo creates a new CallerInfo
common/headers/caller_info.go:64
↓ 9 callersFunctionNewClientWithParams
NewClientWithParams return a gcloudstorage.Client based on input parameters
common/archiver/gcloud/connector/client.go:66
↓ 9 callersFunctionNewConfig
NewConfig returns new service config with default values
service/history/configs/config.go:437
↓ 9 callersFunctionNewContextWithTimeoutAndVersionHeaders
NewContextWithTimeoutAndVersionHeaders creates context with timeout and version headers.
common/rpc/context.go:41
↓ 9 callersFunctionNewDefaultVersionChecker
NewDefaultVersionChecker constructs a new VersionChecker using default versions from const.
common/headers/version_checker.go:78
↓ 9 callersMethodNewFairTaskStore
NewFairTaskStore returns a new task store with fairness enabled
common/persistence/persistence_interface.go:38
↓ 9 callersFunctionNewHistoryTaskQueueManager
( queue QueueV2, serializer serialization.Serializer, )
common/persistence/history_task_queue_manager.go:49
↓ 9 callersFunctionNewLoggedNamespaceCalculator
( calculator NamespaceCalculator, logger log.Logger, )
common/quotas/calculator/logged_calculator.go:53
↓ 9 callersFunctionNewMemoryClient
NewMemoryClient - returns a memory based dynamic config client
common/dynamicconfig/memory_client.go:25
↓ 9 callersFunctionNewMetadataForTest
NewMetadataForTest returns a new [cluster.Metadata] instance for testing.
common/cluster/clustertest/test_metadata.go:9
↓ 9 callersFunctionNewMockEagerNamespaceRefresher
NewMockEagerNamespaceRefresher creates a new mock instance.
service/history/replication/eager_namespace_refresher_mock.go:33
↓ 9 callersFunctionNewMockGcloudStorageClient
NewMockGcloudStorageClient creates a new mock instance.
common/archiver/gcloud/connector/client_delegate_mock.go:33
↓ 9 callersFunctionNewMockReservation
NewMockReservation creates a new mock instance.
common/quotas/reservation_mock.go:32
↓ 9 callersFunctionNewNameTypeMapStub
(attributes map[string]enumspb.IndexedValueType)
common/searchattribute/test_provider.go:159
↓ 9 callersFunctionNewNexusServer
(t *testing.T, listenAddr string, handler nexus.Handler)
common/nexus/nexustest/server.go:21
↓ 9 callersFunctionNewReceiverFlowControl
(signals map[enumsspb.TaskPriority]FlowControlSignalProvider, config *configs.Config)
service/history/replication/stream_receiver_flow_controller.go:36
↓ 9 callersFunctionNewRescheduler
( scheduler Scheduler, timeSource clock.TimeSource, logger log.Logger, metricsHandler metrics.Handler, )
service/history/queues/rescheduler.go:72
↓ 9 callersFunctionNewRoutingInfoCache
NewRoutingInfoCache wraps the provided cache with a typed API and metrics.
common/worker_versioning/routing_info_cache.go:65
↓ 9 callersFunctionNewSQLStore
(db sqlplugin.DB, logger log.Logger, serializer serialization.Serializer)
common/persistence/sql/common.go:27
↓ 9 callersFunctionNewServiceErrorInterceptor
( maxMessageLength dynamicconfig.IntPropertyFn, )
common/rpc/interceptor/service_error_interceptor.go:21
↓ 9 callersFunctionNewTest
NewTest returns a new test resource instance
common/resourcetest/test_resource.go:97
↓ 9 callersFunctionNewValidator
NewValidator create Validator
common/searchattribute/validator.go:47
↓ 9 callersMethodNode
Node gets an [Node] for a given state machine ID.
service/history/hsm/tree.go:653
← previousnext →2,601–2,700 of 43,335, ranked by callers