request_response.pb.go ×295
Frontier kind: Joint frontier
unlabeled · c_6fe0103abe16
14 tests · 2853 LOC · 88 files · introduces 4 tests · 784 LOC · 6 files
Introduces — evidence that enters the hierarchy at this concept
- Code
- 378 ranges784 lines · 6 files
- Tests
- 4 tests
Contains — complete concept membership
- All code (extent)
- 649 ranges2853 lines · 88 files · Browse complete extent
- All tests (intent)
- 14 testsBrowse complete intent
Neighbourhood graph
The orange circle is the focus. Violet and green circles are every ancestor and descendant, broader and narrower, at any distance; blue squares and pink diamonds are the introduced files and exact introduced tests of every visible concept, not only the focus's. Arrows point from broader to narrower concepts and bridge only concepts omitted from this view. Undirected links show source or test introduction. Concept and file size follows LOC; exact test nodes use test-count units.
- Focus concept
- Ancestors (broader)
- Descendants (narrower)
- Introduced files
- Introduced tests
Introduced files, introduced tests, and structurally relevant concept specialization
In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the native relationship evidence on this page.
Graph controls are ready.
Interactive rendering requires JavaScript and WebGL. Use the native relationship evidence on this page while the interactive map is unavailable.
Native relationship evidence
Every exact file and test below is linked only from the concept that introduces it.
-
request_response.pb.go ×295 — Focused concept
Introduced files:
- go.temporal.io/server/api/common/v1/api_category.pb.go
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/routing/v1/extension.pb.go
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go
- go.temporal.io/server/common/rpc/interceptor/health_check.go
go.temporal.io/server/common/rpc/interceptor/TestIsExcludedAPI_ChasmActivityServicego.temporal.io/server/common/rpc/interceptor/TestIsExcludedAPI_ChasmSchedulerServicego.temporal.io/server/common/rpc/interceptor/TestIsExcludedAPI_HistoryServicego.temporal.io/server/common/rpc/interceptor/TestIsExcludedAPI_UnknownMethod
-
workflow_handler.go ×11 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/matching/client_gen.go
- go.temporal.io/server/client/matching/metric_client_gen.go
- go.temporal.io/server/client/matching/retryable_client_gen.go
- go.temporal.io/server/common/rpc/interceptor/routing_key_extractor_gen.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/matching/handler.go
-
common.go ×1 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/persistence/sql/common.go
- go.temporal.io/server/service/history/queues/queue_scheduled.go
- go.temporal.io/server/service/matching/db.go
- go.temporal.io/server/temporaltest/options.go
-
request_response.pb.go ×6 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/history/client.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/service/history/queues/scheduler.go
- go.temporal.io/server/service/history/transfer_queue_task_executor_base.go
- go.temporal.io/server/service/history/worker_versioning_util.go
- go.temporal.io/server/service/matching/handler.go
- go.temporal.io/server/service/matching/matching_engine.go
- go.temporal.io/server/service/matching/pri_forwarder.go
-
visibility_store.go ×17 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/common/client_cache.go
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/visibility.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/visibility.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy_factory.go
- go.temporal.io/server/common/persistence/visibility/store/sql/query_converter_legacy_sqlite.go
- go.temporal.io/server/common/persistence/visibility/store/sql/visibility_store.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go
- go.temporal.io/server/common/searchattribute/mapper.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/matching/pri_matcher.go
- go.temporal.io/server/service/matching/task.go
- go.temporal.io/server/temporaltest/server.go
-
telemetry.go ×2 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/searchattribute/mapper.go
- go.temporal.io/server/temporaltest/options.go
- fx.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
-
collector.go ×7 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/testing/testtelemetry/collector.go
- go.temporal.io/server/temporal/fx.go
-
data_store_factory.go ×29 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/persistence/client/fx.go
- go.temporal.io/server/common/persistence/telemetry/cluster_metadata_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/data_store_factory.go
- go.temporal.io/server/common/persistence/telemetry/execution_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/nexus_endpoint_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/queue_gen.go
- go.temporal.io/server/common/persistence/telemetry/queue_v2_gen.go
- go.temporal.io/server/common/persistence/telemetry/shard_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/shared_store_gen.go
- go.temporal.io/server/common/persistence/telemetry/task_store_gen.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/rpc/interceptor/logtags/admin_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/history_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/matching_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/workflow_service_server_gen.go
- go.temporal.io/server/common/rpc/interceptor/logtags/workflow_tags.go
- go.temporal.io/server/common/telemetry/grpc.go
- go.temporal.io/server/service/frontend/fx.go
- go.temporal.io/server/service/fx.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/temporal/fx.go
- TestNewServer — Ancestor (broader) Introduced tests:
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- timer_queue_active_task_executor.go ×1 — Ancestor (broader) Introduced files:
- TestNewServer — Ancestor (broader) Introduced tests:
-
metric_client.go ×3 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/api/persistence/v1/namespaces.pb.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client.go
- go.temporal.io/server/service/frontend/workflow_handler.go
-
request_response.pb.go ×12 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/adminservice/v1/request_response.pb.go
- go.temporal.io/server/api/adminservice/v1/service_grpc.pb.go
- go.temporal.io/server/common/log/with_logger.go
- go.temporal.io/server/common/namespace/nsregistry/registry.go
- go.temporal.io/server/common/persistence/persistence_metric_clients.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/plugin.go
- go.temporal.io/server/common/resource/fx.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/service/frontend/admin_handler.go
- go.temporal.io/server/service/frontend/http_api_server.go
- go.temporal.io/server/temporal/server_option.go
-
workflow_task_completed_handler.go ×9 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/common/persistence/visibility/visibility_manager_impl.go
- go.temporal.io/server/common/persistence/visibility/visibility_manager_rate_limited.go
- go.temporal.io/server/common/persistence/visibility/visiblity_manager_metrics.go
- go.temporal.io/server/service/history/api/get_history_util.go
- go.temporal.io/server/service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/matching/pri_forwarder.go
- pri_forwarder.go ×2 — Ancestor (broader) Introduced files:
- request_response.pb.go ×1 — Ancestor (broader) Introduced files:
- logger.go ×1 — Ancestor (broader) Introduced files:
- connections.go ×1 — Ancestor (broader) Introduced files:
- persistence_rate_limited_clients.go ×2 — Ancestor (broader) Introduced files:
- logger.go ×1 — Ancestor (broader) Introduced files: Introduced tests:
- metric_client.go ×2 — Ancestor (broader) Introduced files:
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- task_queue_partition_manager.go ×2 — Ancestor (broader) Introduced files:
- connections.go ×2 — Ancestor (broader) Introduced files:
-
workflow_handler.go ×8 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/history/workflow/workflow_task_state_machine.go
- go.temporal.io/server/temporaltest/logger.go
- pri_matcher.go ×1 — Ancestor (broader) Introduced files:
- handler.go ×1 — Ancestor (broader) Introduced files:
- pri_matcher.go ×8 — Ancestor (broader) Introduced files:
- matching_engine.go ×1 — Ancestor (broader) Introduced files:
- server.go ×1 — Ancestor (broader) Introduced files:
- logger.go ×2 — Ancestor (broader) Introduced files:
- queue_scheduled.go ×1 — Ancestor (broader) Introduced files:
-
handler.go ×25 — Ancestor (broader)
Introduced files:
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go
- go.temporal.io/server/api/taskqueue/v1/message.pb.go
- go.temporal.io/server/chasm/lib/nexusoperation/gen/nexusoperationpb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/tests/gen/testspb/v1/request_response.pb.go
- go.temporal.io/server/client/history/client.go
- go.temporal.io/server/client/history/client_gen.go
- go.temporal.io/server/client/history/metric_client.go
- go.temporal.io/server/client/history/metric_client_gen.go
- go.temporal.io/server/client/history/retryable_client_gen.go
- go.temporal.io/server/client/matching/client.go
- go.temporal.io/server/client/matching/loadbalancer.go
- go.temporal.io/server/client/matching/metric_client.go
- go.temporal.io/server/common/cluster/metadata.go
- go.temporal.io/server/common/membership/ringpop/service_resolver.go
- go.temporal.io/server/common/namespace/namespace.go
- go.temporal.io/server/common/namespace/nsregistry/registry.go
- go.temporal.io/server/common/persistence/client/quotas.go
- go.temporal.io/server/common/persistence/execution_manager.go
- go.temporal.io/server/common/persistence/persistence_metric_clients.go
- go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go
- go.temporal.io/server/common/persistence/persistence_retryable_clients.go
- go.temporal.io/server/common/persistence/sql/execution.go
- go.temporal.io/server/common/rpc/interceptor/health_check.go
- go.temporal.io/server/common/rpc/interceptor/namespace_rate_limit.go
- go.temporal.io/server/common/rpc/interceptor/telemetry.go
- go.temporal.io/server/common/rpc/rpc.go
- go.temporal.io/server/common/tasks/fifo_scheduler.go
- go.temporal.io/server/common/util.go
- go.temporal.io/server/common/worker_versioning/worker_versioning.go
- go.temporal.io/server/service/frontend/workflow_handler.go
- go.temporal.io/server/service/history/api/get_history_util.go
- go.temporal.io/server/service/history/configs/quotas.go
- go.temporal.io/server/service/history/fx.go
- go.temporal.io/server/service/history/handler.go
- go.temporal.io/server/service/history/queues/executable.go
- go.temporal.io/server/service/history/queues/queue_base.go
- go.temporal.io/server/service/history/shard/controller_impl.go
- go.temporal.io/server/service/history/shard/ownership_based_quota_calculator.go
- go.temporal.io/server/service/history/workflow/cache/cache.go
- go.temporal.io/server/service/history/workflow/metrics.go
- go.temporal.io/server/service/history/workflow/mutable_state_impl.go
- go.temporal.io/server/service/matching/handler.go
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
-
TestHistoryAPIMetrics, TestFrontendAPIMetrics, +2 — Descendant (narrower)
Introduced tests:
go.temporal.io/server/common/rpc/interceptor/TestMethodToPatternMappinggo.temporal.io/server/common/rpc/interceptor/TestNamespaceSuite/TestFrontendAPIMetricsgo.temporal.io/server/common/rpc/interceptor/TestNamespaceSuite/TestHistoryAPIMetricsgo.temporal.io/server/common/rpc/interceptor/TestNamespaceSuite/TestMatchingAPIMetrics
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
-
activity_state.pb.go ×2 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/service.pb.go
- go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/tasks.pb.go
-
message.pb.go ×2 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/api/schedule/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service.pb.go
- go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- message.pb.go ×2 — Descendant (narrower) Introduced files:
- extension.pb.go ×2 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- noop_moving_window_average.go ×1 — Descendant (narrower) Introduced files:
- test_impl.go ×2 — Descendant (narrower) Introduced files:
- search_attribute.go ×12 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- key.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- request_response.pb.go ×2 — Descendant (narrower) Introduced files:
- request_response.pb.go ×1 — Descendant (narrower) Introduced files:
- priority.go ×1 — Descendant (narrower) Introduced files:
-
setting_gen.go ×51 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/common/dynamicconfig/collection.go
- go.temporal.io/server/common/dynamicconfig/deepcopy.go
- go.temporal.io/server/common/dynamicconfig/gradual_change.go
- go.temporal.io/server/common/dynamicconfig/key.go
- go.temporal.io/server/common/dynamicconfig/registry.go
- go.temporal.io/server/common/dynamicconfig/setting_gen.go
- go.temporal.io/server/common/dynamicconfig/shared_structure.go
- go.temporal.io/server/common/util/wildcard.go
go.temporal.io/server/common/circuitbreaker/TestTSCBWithDynamicSettingsgo.temporal.io/server/common/dynamicconfig/TestDeepCopy_OtherReferenceTypes_Nilgo.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIPrioritiesOrderedgo.temporal.io/server/service/matching/configs/TestQuotasSuite/TestAPIToPriorityMapping
- grpc_resolver.go ×2 — Descendant (narrower) Introduced files:
- predicates.pb.go ×21 — Descendant (narrower) Introduced files:
-
service.pb.go ×2 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/api/adminservice/v1/request_response.pb.go
- go.temporal.io/server/api/adminservice/v1/service.pb.go
- go.temporal.io/server/api/cluster/v1/message.pb.go
- go.temporal.io/server/api/common/v1/api_category.pb.go
- go.temporal.io/server/api/common/v1/dlq.pb.go
- go.temporal.io/server/api/health/v1/message.pb.go
- go.temporal.io/server/api/historyservice/v1/request_response.pb.go
- go.temporal.io/server/api/historyservice/v1/service.pb.go
- go.temporal.io/server/api/matchingservice/v1/request_response.pb.go
- go.temporal.io/server/api/matchingservice/v1/service.pb.go
- go.temporal.io/server/api/namespace/v1/message.pb.go
- go.temporal.io/server/api/replication/v1/message.pb.go
- go.temporal.io/server/api/token/v1/message.pb.go
- message.pb.go ×2 — Descendant (narrower) Introduced files:
- constants.go ×1 — Descendant (narrower) Introduced files:
- task.pb.go ×1 — Descendant (narrower) Introduced files:
-
message.pb.go ×2 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/api/history/v1/message.pb.go
- go.temporal.io/server/api/persistence/v1/chasm.pb.go
- go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go
- go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go
- go.temporal.io/server/api/persistence/v1/executions.pb.go
- go.temporal.io/server/api/persistence/v1/history_tree.pb.go
- go.temporal.io/server/api/persistence/v1/hsm.pb.go
- go.temporal.io/server/api/persistence/v1/namespaces.pb.go
- go.temporal.io/server/api/persistence/v1/nexus.pb.go
- go.temporal.io/server/api/persistence/v1/predicates.pb.go
- go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go
- go.temporal.io/server/api/persistence/v1/queues.pb.go
- go.temporal.io/server/api/persistence/v1/task_queues.pb.go
- go.temporal.io/server/api/persistence/v1/tasks.pb.go
- go.temporal.io/server/api/persistence/v1/update.pb.go
- go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go
- go.temporal.io/server/api/workflow/v1/message.pb.go
-
defs.go ×5 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/api/metrics/v1/message.pb.go
- go.temporal.io/server/common/build/build.go
- go.temporal.io/server/common/metrics/defs.go
- go.temporal.io/server/common/metrics/defs_base.go
- go.temporal.io/server/common/metrics/noop_impl.go
- go.temporal.io/server/common/metrics/option.go
- go.temporal.io/server/common/metrics/registry.go
- tags.go ×9 — Descendant (narrower) Introduced files:
- message.pb.go ×2 — Descendant (narrower) Introduced files:
-
cluster.pb.go ×2 — Descendant (narrower)
Introduced files:
- go.temporal.io/server/api/enums/v1/cluster.pb.go
- go.temporal.io/server/api/enums/v1/common.pb.go
- go.temporal.io/server/api/enums/v1/dlq.pb.go
- go.temporal.io/server/api/enums/v1/fairness_state.pb.go
- go.temporal.io/server/api/enums/v1/nexus.pb.go
- go.temporal.io/server/api/enums/v1/predicate.pb.go
- go.temporal.io/server/api/enums/v1/replication.pb.go
- go.temporal.io/server/api/enums/v1/task.pb.go
- go.temporal.io/server/api/enums/v1/workflow.pb.go
- go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go
- wildcard.go ×1 — Descendant (narrower) Introduced files:
- wildcard.go ×4 — Descendant (narrower) Introduced files:
- retrypolicy.go ×3 — Descendant (narrower) Introduced files:
- message.pb.go ×2 — Descendant (narrower) Introduced files:
- payload.go ×1 — Descendant (narrower) Introduced files:
- TestOperatorServiceMetadata, TestWorkflowServiceMetadata — Descendant (narrower) Introduced tests:
Introduced tests
Every collected test enters the hierarchy at exactly one concept.
4 tests introduced at this concept.
Introduced code
Every collected source range enters the hierarchy at exactly one concept.
6 files ranked by introduced lines: 784 introduced LOC across 378 ranges. Expand a file to inspect source; the > gutter marks introduced lines.
go.temporal.io/server/api/historyservice/v1/request_response.pb.go 577 introduced LOC · 295 ranges
393
func (*StartWorkflowExecutionResponse) ProtoMessage() {}
394
395
>
func (x *StartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
396
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[2]
397
>
if x != nil {
398
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
399
if ms.LoadMessageInfo() == nil {
484
func (*GetMutableStateRequest) ProtoMessage() {}
485
487
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[3]
488
>
if x != nil {
489
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
490
if ms.LoadMessageInfo() == nil {
592
func (*GetMutableStateResponse) ProtoMessage() {}
593
594
>
func (x *GetMutableStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
595
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[4]
596
>
if x != nil {
597
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
598
if ms.LoadMessageInfo() == nil {
780
func (*PollMutableStateRequest) ProtoMessage() {}
781
782
>
func (x *PollMutableStateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
783
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[5]
784
>
if x != nil {
785
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
786
if ms.LoadMessageInfo() == nil {
868
func (*PollMutableStateResponse) ProtoMessage() {}
869
870
>
func (x *PollMutableStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
871
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[6]
872
>
if x != nil {
873
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
874
if ms.LoadMessageInfo() == nil {
1004
func (*ResetStickyTaskQueueRequest) ProtoMessage() {}
1005
1006
>
func (x *ResetStickyTaskQueueRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
1007
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[7]
1008
>
if x != nil {
1009
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1010
if ms.LoadMessageInfo() == nil {
1054
func (*ResetStickyTaskQueueResponse) ProtoMessage() {}
1055
1056
>
func (x *ResetStickyTaskQueueResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
1057
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[8]
1058
>
if x != nil {
1059
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1060
if ms.LoadMessageInfo() == nil {
1093
func (*ExecuteMultiOperationRequest) ProtoMessage() {}
1094
1095
>
func (x *ExecuteMultiOperationRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
1096
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[9]
1097
>
if x != nil {
1098
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1099
if ms.LoadMessageInfo() == nil {
1151
func (*ExecuteMultiOperationResponse) ProtoMessage() {}
1152
1153
>
func (x *ExecuteMultiOperationResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
1154
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[10]
1155
>
if x != nil {
1156
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1157
if ms.LoadMessageInfo() == nil {
1216
func (*RecordWorkflowTaskStartedRequest) ProtoMessage() {}
1217
1218
>
func (x *RecordWorkflowTaskStartedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
1219
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[11]
1220
>
if x != nil {
1221
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1222
if ms.LoadMessageInfo() == nil {
1371
func (*RecordWorkflowTaskStartedResponse) ProtoMessage() {}
1372
1373
>
func (x *RecordWorkflowTaskStartedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
1374
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[12]
1375
>
if x != nil {
1376
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1377
if ms.LoadMessageInfo() == nil {
1789
func (*RecordActivityTaskStartedRequest) ProtoMessage() {}
1790
1791
>
func (x *RecordActivityTaskStartedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
1792
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[14]
1793
>
if x != nil {
1794
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1795
if ms.LoadMessageInfo() == nil {
1923
func (*RecordActivityTaskStartedResponse) ProtoMessage() {}
1924
1925
>
func (x *RecordActivityTaskStartedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
1926
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[15]
1927
>
if x != nil {
1928
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1929
if ms.LoadMessageInfo() == nil {
2052
func (*RespondWorkflowTaskCompletedRequest) ProtoMessage() {}
2053
2054
>
func (x *RespondWorkflowTaskCompletedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2055
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[16]
2056
>
if x != nil {
2057
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2058
if ms.LoadMessageInfo() == nil {
2107
func (*RespondWorkflowTaskCompletedResponse) ProtoMessage() {}
2108
2109
>
func (x *RespondWorkflowTaskCompletedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2110
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[17]
2111
>
if x != nil {
2112
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2113
if ms.LoadMessageInfo() == nil {
2174
func (*RespondWorkflowTaskFailedRequest) ProtoMessage() {}
2175
2176
>
func (x *RespondWorkflowTaskFailedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2177
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[18]
2178
>
if x != nil {
2179
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2180
if ms.LoadMessageInfo() == nil {
2224
func (*RespondWorkflowTaskFailedResponse) ProtoMessage() {}
2225
2226
>
func (x *RespondWorkflowTaskFailedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2227
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[19]
2228
>
if x != nil {
2229
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2230
if ms.LoadMessageInfo() == nil {
2265
func (*IsWorkflowTaskValidRequest) ProtoMessage() {}
2266
2267
>
func (x *IsWorkflowTaskValidRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2268
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[20]
2269
>
if x != nil {
2270
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2271
if ms.LoadMessageInfo() == nil {
2338
func (*IsWorkflowTaskValidResponse) ProtoMessage() {}
2339
2340
>
func (x *IsWorkflowTaskValidResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2341
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[21]
2342
>
if x != nil {
2343
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2344
if ms.LoadMessageInfo() == nil {
2383
func (*RecordActivityTaskHeartbeatRequest) ProtoMessage() {}
2384
2385
>
func (x *RecordActivityTaskHeartbeatRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2386
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[22]
2387
>
if x != nil {
2388
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2389
if ms.LoadMessageInfo() == nil {
2436
func (*RecordActivityTaskHeartbeatResponse) ProtoMessage() {}
2437
2438
>
func (x *RecordActivityTaskHeartbeatResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2439
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[23]
2440
>
if x != nil {
2441
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2442
if ms.LoadMessageInfo() == nil {
2495
func (*RespondActivityTaskCompletedRequest) ProtoMessage() {}
2496
2497
>
func (x *RespondActivityTaskCompletedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2498
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[24]
2499
>
if x != nil {
2500
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2501
if ms.LoadMessageInfo() == nil {
2545
func (*RespondActivityTaskCompletedResponse) ProtoMessage() {}
2546
2547
>
func (x *RespondActivityTaskCompletedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2548
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[25]
2549
>
if x != nil {
2550
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2551
if ms.LoadMessageInfo() == nil {
2583
func (*RespondActivityTaskFailedRequest) ProtoMessage() {}
2584
2585
>
func (x *RespondActivityTaskFailedRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2586
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[26]
2587
>
if x != nil {
2588
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2589
if ms.LoadMessageInfo() == nil {
2633
func (*RespondActivityTaskFailedResponse) ProtoMessage() {}
2634
2635
>
func (x *RespondActivityTaskFailedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2636
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[27]
2637
>
if x != nil {
2638
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2639
if ms.LoadMessageInfo() == nil {
2671
func (*RespondActivityTaskCanceledRequest) ProtoMessage() {}
2672
2673
>
func (x *RespondActivityTaskCanceledRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2674
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[28]
2675
>
if x != nil {
2676
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2677
if ms.LoadMessageInfo() == nil {
2721
func (*RespondActivityTaskCanceledResponse) ProtoMessage() {}
2722
2723
>
func (x *RespondActivityTaskCanceledResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2724
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[29]
2725
>
if x != nil {
2726
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2727
if ms.LoadMessageInfo() == nil {
2763
func (*IsActivityTaskValidRequest) ProtoMessage() {}
2764
2765
>
func (x *IsActivityTaskValidRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2766
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[30]
2767
>
if x != nil {
2768
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2769
if ms.LoadMessageInfo() == nil {
2836
func (*IsActivityTaskValidResponse) ProtoMessage() {}
2837
2838
>
func (x *IsActivityTaskValidResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2839
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[31]
2840
>
if x != nil {
2841
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2842
if ms.LoadMessageInfo() == nil {
2883
func (*SignalWorkflowExecutionRequest) ProtoMessage() {}
2884
2885
>
func (x *SignalWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2886
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[32]
2887
>
if x != nil {
2888
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2889
if ms.LoadMessageInfo() == nil {
2948
func (*SignalWorkflowExecutionResponse) ProtoMessage() {}
2949
2950
>
func (x *SignalWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
2951
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[33]
2952
>
if x != nil {
2953
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2954
if ms.LoadMessageInfo() == nil {
2996
func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage() {}
2997
2998
>
func (x *SignalWithStartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
2999
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[34]
3000
>
if x != nil {
3001
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3002
if ms.LoadMessageInfo() == nil {
3053
func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage() {}
3054
3055
>
func (x *SignalWithStartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3056
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[35]
3057
>
if x != nil {
3058
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3059
if ms.LoadMessageInfo() == nil {
3120
func (*RemoveSignalMutableStateRequest) ProtoMessage() {}
3121
3122
>
func (x *RemoveSignalMutableStateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3123
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[36]
3124
>
if x != nil {
3125
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3126
if ms.LoadMessageInfo() == nil {
3177
func (*RemoveSignalMutableStateResponse) ProtoMessage() {}
3178
3179
>
func (x *RemoveSignalMutableStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3180
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[37]
3181
>
if x != nil {
3182
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3183
if ms.LoadMessageInfo() == nil {
3217
func (*TerminateWorkflowExecutionRequest) ProtoMessage() {}
3218
3219
>
func (x *TerminateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3220
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[38]
3221
>
if x != nil {
3222
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3223
if ms.LoadMessageInfo() == nil {
3281
func (*TerminateWorkflowExecutionResponse) ProtoMessage() {}
3282
3283
>
func (x *TerminateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3284
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[39]
3285
>
if x != nil {
3286
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3287
if ms.LoadMessageInfo() == nil {
3320
func (*DeleteWorkflowExecutionRequest) ProtoMessage() {}
3321
3322
>
func (x *DeleteWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3323
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[40]
3324
>
if x != nil {
3325
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3326
if ms.LoadMessageInfo() == nil {
3377
func (*DeleteWorkflowExecutionResponse) ProtoMessage() {}
3378
3379
>
func (x *DeleteWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3380
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[41]
3381
>
if x != nil {
3382
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3383
if ms.LoadMessageInfo() == nil {
3415
func (*ResetWorkflowExecutionRequest) ProtoMessage() {}
3416
3417
>
func (x *ResetWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3418
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[42]
3419
>
if x != nil {
3420
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3421
if ms.LoadMessageInfo() == nil {
3466
func (*ResetWorkflowExecutionResponse) ProtoMessage() {}
3467
3468
>
func (x *ResetWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3469
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[43]
3470
>
if x != nil {
3471
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3472
if ms.LoadMessageInfo() == nil {
3514
func (*RequestCancelWorkflowExecutionRequest) ProtoMessage() {}
3515
3516
>
func (x *RequestCancelWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3517
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[44]
3518
>
if x != nil {
3519
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3520
if ms.LoadMessageInfo() == nil {
3585
func (*RequestCancelWorkflowExecutionResponse) ProtoMessage() {}
3586
3587
>
func (x *RequestCancelWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3588
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[45]
3589
>
if x != nil {
3590
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3591
if ms.LoadMessageInfo() == nil {
3626
func (*ScheduleWorkflowTaskRequest) ProtoMessage() {}
3627
3628
>
func (x *ScheduleWorkflowTaskRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3629
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[46]
3630
>
if x != nil {
3631
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3632
if ms.LoadMessageInfo() == nil {
3697
func (*ScheduleWorkflowTaskResponse) ProtoMessage() {}
3698
3699
>
func (x *ScheduleWorkflowTaskResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3700
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[47]
3701
>
if x != nil {
3702
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3703
if ms.LoadMessageInfo() == nil {
3736
func (*VerifyFirstWorkflowTaskScheduledRequest) ProtoMessage() {}
3737
3738
>
func (x *VerifyFirstWorkflowTaskScheduledRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
3739
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[48]
3740
>
if x != nil {
3741
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3742
if ms.LoadMessageInfo() == nil {
3793
func (*VerifyFirstWorkflowTaskScheduledResponse) ProtoMessage() {}
3794
3795
>
func (x *VerifyFirstWorkflowTaskScheduledResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3796
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[49]
3797
>
if x != nil {
3798
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3799
if ms.LoadMessageInfo() == nil {
3935
func (*RecordChildExecutionCompletedResponse) ProtoMessage() {}
3936
3937
>
func (x *RecordChildExecutionCompletedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
3938
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[51]
3939
>
if x != nil {
3940
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3941
if ms.LoadMessageInfo() == nil {
4063
func (*VerifyChildExecutionCompletionRecordedResponse) ProtoMessage() {}
4064
4065
>
func (x *VerifyChildExecutionCompletionRecordedResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
4066
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[53]
4067
>
if x != nil {
4068
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4069
if ms.LoadMessageInfo() == nil {
4101
func (*DescribeWorkflowExecutionRequest) ProtoMessage() {}
4102
4103
>
func (x *DescribeWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
4104
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[54]
4105
>
if x != nil {
4106
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4107
if ms.LoadMessageInfo() == nil {
4159
func (*DescribeWorkflowExecutionResponse) ProtoMessage() {}
4160
4161
>
func (x *DescribeWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
4162
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[55]
4163
>
if x != nil {
4164
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4165
if ms.LoadMessageInfo() == nil {
4259
func (*ReplicateEventsV2Request) ProtoMessage() {}
4260
4261
>
func (x *ReplicateEventsV2Request) ProtoReflect() protoreflect.Message {
request_response.pb.go
4262
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[56]
4263
>
if x != nil {
4264
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4265
if ms.LoadMessageInfo() == nil {
4344
func (*ReplicateEventsV2Response) ProtoMessage() {}
4345
4346
>
func (x *ReplicateEventsV2Response) ProtoReflect() protoreflect.Message {
request_response.pb.go
4347
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[57]
4348
>
if x != nil {
4349
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4350
if ms.LoadMessageInfo() == nil {
4385
func (*ReplicateWorkflowStateRequest) ProtoMessage() {}
4386
4387
>
func (x *ReplicateWorkflowStateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
4388
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[58]
4389
>
if x != nil {
4390
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4391
if ms.LoadMessageInfo() == nil {
4456
func (*ReplicateWorkflowStateResponse) ProtoMessage() {}
4457
4458
>
func (x *ReplicateWorkflowStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
4459
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[59]
4460
>
if x != nil {
4461
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4462
if ms.LoadMessageInfo() == nil {
4495
func (*SyncShardStatusRequest) ProtoMessage() {}
4496
4497
>
func (x *SyncShardStatusRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
4498
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[60]
4499
>
if x != nil {
4500
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4501
if ms.LoadMessageInfo() == nil {
4552
func (*SyncShardStatusResponse) ProtoMessage() {}
4553
4554
>
func (x *SyncShardStatusResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
4555
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[61]
4556
>
if x != nil {
4557
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4558
if ms.LoadMessageInfo() == nil {
4621
func (*SyncActivityRequest) ProtoMessage() {}
4622
4624
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[62]
4625
>
if x != nil {
4626
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
4627
if ms.LoadMessageInfo() == nil {
5126
func (*SyncActivityResponse) ProtoMessage() {}
5127
5129
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[65]
5130
>
if x != nil {
5131
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5132
if ms.LoadMessageInfo() == nil {
5236
func (*DescribeMutableStateResponse) ProtoMessage() {}
5237
5238
>
func (x *DescribeMutableStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
5239
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[67]
5240
>
if x != nil {
5241
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5242
if ms.LoadMessageInfo() == nil {
5292
func (*DescribeHistoryHostRequest) ProtoMessage() {}
5293
5294
>
func (x *DescribeHistoryHostRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
5295
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[68]
5296
>
if x != nil {
5297
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5298
if ms.LoadMessageInfo() == nil {
5360
func (*DescribeHistoryHostResponse) ProtoMessage() {}
5361
5362
>
func (x *DescribeHistoryHostResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
5363
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[69]
5364
>
if x != nil {
5365
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5366
if ms.LoadMessageInfo() == nil {
5425
func (*CloseShardRequest) ProtoMessage() {}
5426
5428
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[70]
5429
>
if x != nil {
5430
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5431
if ms.LoadMessageInfo() == nil {
5468
func (*CloseShardResponse) ProtoMessage() {}
5469
5471
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[71]
5472
>
if x != nil {
5473
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5474
if ms.LoadMessageInfo() == nil {
5505
func (*GetShardRequest) ProtoMessage() {}
5506
5508
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[72]
5509
>
if x != nil {
5510
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5511
if ms.LoadMessageInfo() == nil {
5549
func (*GetShardResponse) ProtoMessage() {}
5550
5552
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[73]
5553
>
if x != nil {
5554
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5555
if ms.LoadMessageInfo() == nil {
5597
func (*RemoveTaskRequest) ProtoMessage() {}
5598
5600
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[74]
5601
>
if x != nil {
5602
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5603
if ms.LoadMessageInfo() == nil {
5661
func (*RemoveTaskResponse) ProtoMessage() {}
5662
5664
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[75]
5665
>
if x != nil {
5666
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5667
if ms.LoadMessageInfo() == nil {
5699
func (*GetReplicationMessagesRequest) ProtoMessage() {}
5700
5701
>
func (x *GetReplicationMessagesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
5702
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[76]
5703
>
if x != nil {
5704
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5705
if ms.LoadMessageInfo() == nil {
5750
func (*GetReplicationMessagesResponse) ProtoMessage() {}
5751
5752
>
func (x *GetReplicationMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
5753
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[77]
5754
>
if x != nil {
5755
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5756
if ms.LoadMessageInfo() == nil {
5794
func (*GetDLQReplicationMessagesRequest) ProtoMessage() {}
5795
5796
>
func (x *GetDLQReplicationMessagesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
5797
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[78]
5798
>
if x != nil {
5799
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5800
if ms.LoadMessageInfo() == nil {
5838
func (*GetDLQReplicationMessagesResponse) ProtoMessage() {}
5839
5840
>
func (x *GetDLQReplicationMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
5841
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[79]
5842
>
if x != nil {
5843
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5844
if ms.LoadMessageInfo() == nil {
5883
func (*QueryWorkflowRequest) ProtoMessage() {}
5884
5886
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[80]
5887
>
if x != nil {
5888
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5889
if ms.LoadMessageInfo() == nil {
5934
func (*QueryWorkflowResponse) ProtoMessage() {}
5935
5937
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[81]
5938
>
if x != nil {
5939
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5940
if ms.LoadMessageInfo() == nil {
5979
func (*ReapplyEventsRequest) ProtoMessage() {}
5980
5982
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[82]
5983
>
if x != nil {
5984
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5985
if ms.LoadMessageInfo() == nil {
6029
func (*ReapplyEventsResponse) ProtoMessage() {}
6030
6032
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[83]
6033
>
if x != nil {
6034
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6035
if ms.LoadMessageInfo() == nil {
6071
func (*GetDLQMessagesRequest) ProtoMessage() {}
6072
6074
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[84]
6075
>
if x != nil {
6076
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6077
if ms.LoadMessageInfo() == nil {
6153
func (*GetDLQMessagesResponse) ProtoMessage() {}
6154
6155
>
func (x *GetDLQMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6156
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[85]
6157
>
if x != nil {
6158
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6159
if ms.LoadMessageInfo() == nil {
6221
func (*PurgeDLQMessagesRequest) ProtoMessage() {}
6222
6223
>
func (x *PurgeDLQMessagesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
6224
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[86]
6225
>
if x != nil {
6226
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6227
if ms.LoadMessageInfo() == nil {
6285
func (*PurgeDLQMessagesResponse) ProtoMessage() {}
6286
6287
>
func (x *PurgeDLQMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6288
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[87]
6289
>
if x != nil {
6290
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6291
if ms.LoadMessageInfo() == nil {
6327
func (*MergeDLQMessagesRequest) ProtoMessage() {}
6328
6329
>
func (x *MergeDLQMessagesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
6330
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[88]
6331
>
if x != nil {
6332
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6333
if ms.LoadMessageInfo() == nil {
6406
func (*MergeDLQMessagesResponse) ProtoMessage() {}
6407
6408
>
func (x *MergeDLQMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6409
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[89]
6410
>
if x != nil {
6411
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6412
if ms.LoadMessageInfo() == nil {
6453
func (*RefreshWorkflowTasksRequest) ProtoMessage() {}
6454
6455
>
func (x *RefreshWorkflowTasksRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
6456
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[90]
6457
>
if x != nil {
6458
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6459
if ms.LoadMessageInfo() == nil {
6510
func (*RefreshWorkflowTasksResponse) ProtoMessage() {}
6511
6512
>
func (x *RefreshWorkflowTasksResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6513
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[91]
6514
>
if x != nil {
6515
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6516
if ms.LoadMessageInfo() == nil {
6617
func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage() {}
6618
6619
>
func (x *GenerateLastHistoryReplicationTasksResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6620
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[93]
6621
>
if x != nil {
6622
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6623
if ms.LoadMessageInfo() == nil {
6713
func (*GetReplicationStatusResponse) ProtoMessage() {}
6714
6715
>
func (x *GetReplicationStatusResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6716
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[95]
6717
>
if x != nil {
6718
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6719
if ms.LoadMessageInfo() == nil {
6943
func (*RebuildMutableStateRequest) ProtoMessage() {}
6944
6945
>
func (x *RebuildMutableStateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
6946
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[99]
6947
>
if x != nil {
6948
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6949
if ms.LoadMessageInfo() == nil {
6993
func (*RebuildMutableStateResponse) ProtoMessage() {}
6994
6995
>
func (x *RebuildMutableStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
6996
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[100]
6997
>
if x != nil {
6998
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6999
if ms.LoadMessageInfo() == nil {
7107
func (*ImportWorkflowExecutionResponse) ProtoMessage() {}
7108
7109
>
func (x *ImportWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7110
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[102]
7111
>
if x != nil {
7112
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7113
if ms.LoadMessageInfo() == nil {
7161
func (*DeleteWorkflowVisibilityRecordRequest) ProtoMessage() {}
7162
7163
>
func (x *DeleteWorkflowVisibilityRecordRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7164
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[103]
7165
>
if x != nil {
7166
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7167
if ms.LoadMessageInfo() == nil {
7225
func (*DeleteWorkflowVisibilityRecordResponse) ProtoMessage() {}
7226
7227
>
func (x *DeleteWorkflowVisibilityRecordResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7228
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[104]
7229
>
if x != nil {
7230
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7231
if ms.LoadMessageInfo() == nil {
7266
func (*UpdateWorkflowExecutionRequest) ProtoMessage() {}
7267
7268
>
func (x *UpdateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7269
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[105]
7270
>
if x != nil {
7271
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7272
if ms.LoadMessageInfo() == nil {
7317
func (*UpdateWorkflowExecutionResponse) ProtoMessage() {}
7318
7319
>
func (x *UpdateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7320
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[106]
7321
>
if x != nil {
7322
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7323
if ms.LoadMessageInfo() == nil {
7364
func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage() {}
7365
7366
>
func (x *StreamWorkflowReplicationMessagesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7367
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[107]
7368
>
if x != nil {
7369
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7370
if ms.LoadMessageInfo() == nil {
7431
func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage() {}
7432
7433
>
func (x *StreamWorkflowReplicationMessagesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7434
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[108]
7435
>
if x != nil {
7436
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7437
if ms.LoadMessageInfo() == nil {
7496
func (*PollWorkflowExecutionUpdateRequest) ProtoMessage() {}
7497
7498
>
func (x *PollWorkflowExecutionUpdateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7499
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[109]
7500
>
if x != nil {
7501
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7502
if ms.LoadMessageInfo() == nil {
7547
func (*PollWorkflowExecutionUpdateResponse) ProtoMessage() {}
7548
7549
>
func (x *PollWorkflowExecutionUpdateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7550
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[110]
7551
>
if x != nil {
7552
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7553
if ms.LoadMessageInfo() == nil {
7592
func (*GetWorkflowExecutionHistoryRequest) ProtoMessage() {}
7593
7594
>
func (x *GetWorkflowExecutionHistoryRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7595
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[111]
7596
>
if x != nil {
7597
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7598
if ms.LoadMessageInfo() == nil {
7749
func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage() {}
7750
7751
>
func (x *GetWorkflowExecutionHistoryReverseRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7752
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[114]
7753
>
if x != nil {
7754
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7755
if ms.LoadMessageInfo() == nil {
7800
func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage() {}
7801
7802
>
func (x *GetWorkflowExecutionHistoryReverseResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7803
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[115]
7804
>
if x != nil {
7805
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7806
if ms.LoadMessageInfo() == nil {
7848
func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage() {}
7849
7850
>
func (x *GetWorkflowExecutionRawHistoryV2Request) ProtoReflect() protoreflect.Message {
request_response.pb.go
7851
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[116]
7852
>
if x != nil {
7853
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7854
if ms.LoadMessageInfo() == nil {
7899
func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage() {}
7900
7901
>
func (x *GetWorkflowExecutionRawHistoryV2Response) ProtoReflect() protoreflect.Message {
request_response.pb.go
7902
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[117]
7903
>
if x != nil {
7904
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7905
if ms.LoadMessageInfo() == nil {
7944
func (*GetWorkflowExecutionRawHistoryRequest) ProtoMessage() {}
7945
7946
>
func (x *GetWorkflowExecutionRawHistoryRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
7947
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[118]
7948
>
if x != nil {
7949
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7950
if ms.LoadMessageInfo() == nil {
7995
func (*GetWorkflowExecutionRawHistoryResponse) ProtoMessage() {}
7996
7997
>
func (x *GetWorkflowExecutionRawHistoryResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
7998
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[119]
7999
>
if x != nil {
8000
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8001
if ms.LoadMessageInfo() == nil {
8042
func (*ForceDeleteWorkflowExecutionRequest) ProtoMessage() {}
8043
8044
>
func (x *ForceDeleteWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
8045
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[120]
8046
>
if x != nil {
8047
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8048
if ms.LoadMessageInfo() == nil {
8100
func (*ForceDeleteWorkflowExecutionResponse) ProtoMessage() {}
8101
8102
>
func (x *ForceDeleteWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
8103
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[121]
8104
>
if x != nil {
8105
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8106
if ms.LoadMessageInfo() == nil {
8149
func (*DeleteExecutionRequest) ProtoMessage() {}
8150
8151
>
func (x *DeleteExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
8152
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[122]
8153
>
if x != nil {
8154
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8155
if ms.LoadMessageInfo() == nil {
8220
func (*DeleteExecutionResponse) ProtoMessage() {}
8221
8222
>
func (x *DeleteExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
8223
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[123]
8224
>
if x != nil {
8225
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8226
if ms.LoadMessageInfo() == nil {
8472
func (*ListQueuesRequest) ProtoMessage() {}
8473
8475
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[128]
8476
>
if x != nil {
8477
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8478
if ms.LoadMessageInfo() == nil {
8531
func (*ListQueuesResponse) ProtoMessage() {}
8532
8534
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[129]
8535
>
if x != nil {
8536
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8537
if ms.LoadMessageInfo() == nil {
8587
func (*AddTasksRequest) ProtoMessage() {}
8588
8590
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[130]
8591
>
if x != nil {
8592
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8593
if ms.LoadMessageInfo() == nil {
8637
func (*AddTasksResponse) ProtoMessage() {}
8638
8640
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[131]
8641
>
if x != nil {
8642
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8643
if ms.LoadMessageInfo() == nil {
8674
func (*ListTasksRequest) ProtoMessage() {}
8675
8677
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[132]
8678
>
if x != nil {
8679
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8680
if ms.LoadMessageInfo() == nil {
8777
func (*CompleteNexusOperationChasmRequest) ProtoMessage() {}
8778
8779
>
func (x *CompleteNexusOperationChasmRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
8780
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[134]
8781
>
if x != nil {
8782
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8783
if ms.LoadMessageInfo() == nil {
8891
func (*CompleteNexusOperationChasmResponse) ProtoMessage() {}
8892
8893
>
func (x *CompleteNexusOperationChasmResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
8894
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[135]
8895
>
if x != nil {
8896
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8897
if ms.LoadMessageInfo() == nil {
8942
func (*CompleteNexusOperationRequest) ProtoMessage() {}
8943
8944
>
func (x *CompleteNexusOperationRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
8945
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[136]
8946
>
if x != nil {
8947
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8948
if ms.LoadMessageInfo() == nil {
9056
func (*CompleteNexusOperationResponse) ProtoMessage() {}
9057
9058
>
func (x *CompleteNexusOperationResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9059
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[137]
9060
>
if x != nil {
9061
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9062
if ms.LoadMessageInfo() == nil {
9109
func (*InvokeStateMachineMethodRequest) ProtoMessage() {}
9110
9111
>
func (x *InvokeStateMachineMethodRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9112
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[138]
9113
>
if x != nil {
9114
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9115
if ms.LoadMessageInfo() == nil {
9189
func (*InvokeStateMachineMethodResponse) ProtoMessage() {}
9190
9191
>
func (x *InvokeStateMachineMethodResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9192
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[139]
9193
>
if x != nil {
9194
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9195
if ms.LoadMessageInfo() == nil {
9233
func (*DeepHealthCheckRequest) ProtoMessage() {}
9234
9235
>
func (x *DeepHealthCheckRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9236
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[140]
9237
>
if x != nil {
9238
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9239
if ms.LoadMessageInfo() == nil {
9279
func (*DeepHealthCheckResponse) ProtoMessage() {}
9280
9281
>
func (x *DeepHealthCheckResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9282
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[141]
9283
>
if x != nil {
9284
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9285
if ms.LoadMessageInfo() == nil {
9336
func (*SyncWorkflowStateRequest) ProtoMessage() {}
9337
9338
>
func (x *SyncWorkflowStateRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9339
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[142]
9340
>
if x != nil {
9341
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9342
if ms.LoadMessageInfo() == nil {
9415
func (*SyncWorkflowStateResponse) ProtoMessage() {}
9416
9417
>
func (x *SyncWorkflowStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9418
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[143]
9419
>
if x != nil {
9420
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9421
if ms.LoadMessageInfo() == nil {
9463
func (*UpdateActivityOptionsRequest) ProtoMessage() {}
9464
9465
>
func (x *UpdateActivityOptionsRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9466
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[144]
9467
>
if x != nil {
9468
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9469
if ms.LoadMessageInfo() == nil {
9515
func (*UpdateActivityOptionsResponse) ProtoMessage() {}
9516
9517
>
func (x *UpdateActivityOptionsResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9518
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[145]
9519
>
if x != nil {
9520
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9521
if ms.LoadMessageInfo() == nil {
9561
func (*PauseActivityRequest) ProtoMessage() {}
9562
9564
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[146]
9565
>
if x != nil {
9566
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9567
if ms.LoadMessageInfo() == nil {
9611
func (*PauseActivityResponse) ProtoMessage() {}
9612
9614
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[147]
9615
>
if x != nil {
9616
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9617
if ms.LoadMessageInfo() == nil {
9650
func (*UnpauseActivityRequest) ProtoMessage() {}
9651
9652
>
func (x *UnpauseActivityRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9653
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[148]
9654
>
if x != nil {
9655
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9656
if ms.LoadMessageInfo() == nil {
9700
func (*UnpauseActivityResponse) ProtoMessage() {}
9701
9702
>
func (x *UnpauseActivityResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9703
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[149]
9704
>
if x != nil {
9705
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9706
if ms.LoadMessageInfo() == nil {
9739
func (*ResetActivityRequest) ProtoMessage() {}
9740
9742
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[150]
9743
>
if x != nil {
9744
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9745
if ms.LoadMessageInfo() == nil {
9789
func (*ResetActivityResponse) ProtoMessage() {}
9790
9792
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[151]
9793
>
if x != nil {
9794
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9795
if ms.LoadMessageInfo() == nil {
9829
func (*UpdateWorkflowExecutionOptionsRequest) ProtoMessage() {}
9830
9831
>
func (x *UpdateWorkflowExecutionOptionsRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9832
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[152]
9833
>
if x != nil {
9834
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9835
if ms.LoadMessageInfo() == nil {
9884
func (*UpdateWorkflowExecutionOptionsResponse) ProtoMessage() {}
9885
9886
>
func (x *UpdateWorkflowExecutionOptionsResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9887
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[153]
9888
>
if x != nil {
9889
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9890
if ms.LoadMessageInfo() == nil {
9937
func (*PauseWorkflowExecutionRequest) ProtoMessage() {}
9938
9939
>
func (x *PauseWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
9940
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[154]
9941
>
if x != nil {
9942
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9943
if ms.LoadMessageInfo() == nil {
9987
func (*PauseWorkflowExecutionResponse) ProtoMessage() {}
9988
9989
>
func (x *PauseWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
9990
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[155]
9991
>
if x != nil {
9992
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
9993
if ms.LoadMessageInfo() == nil {
10026
func (*UnpauseWorkflowExecutionRequest) ProtoMessage() {}
10027
10028
>
func (x *UnpauseWorkflowExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
10029
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[156]
10030
>
if x != nil {
10031
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10032
if ms.LoadMessageInfo() == nil {
10076
func (*UnpauseWorkflowExecutionResponse) ProtoMessage() {}
10077
10078
>
func (x *UnpauseWorkflowExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
10079
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[157]
10080
>
if x != nil {
10081
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10082
if ms.LoadMessageInfo() == nil {
10115
func (*StartNexusOperationRequest) ProtoMessage() {}
10116
10117
>
func (x *StartNexusOperationRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
10118
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[158]
10119
>
if x != nil {
10120
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10121
if ms.LoadMessageInfo() == nil {
10173
func (*StartNexusOperationResponse) ProtoMessage() {}
10174
10175
>
func (x *StartNexusOperationResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
10176
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[159]
10177
>
if x != nil {
10178
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10179
if ms.LoadMessageInfo() == nil {
10219
func (*CancelNexusOperationRequest) ProtoMessage() {}
10220
10221
>
func (x *CancelNexusOperationRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
10222
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[160]
10223
>
if x != nil {
10224
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10225
if ms.LoadMessageInfo() == nil {
10277
func (*CancelNexusOperationResponse) ProtoMessage() {}
10278
10279
>
func (x *CancelNexusOperationResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
10280
>
mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[161]
10281
>
if x != nil {
10282
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
10283
if ms.LoadMessageInfo() == nil {
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/request_response.pb.go 80 introduced LOC · 40 ranges
45
func (*StartActivityExecutionRequest) ProtoMessage() {}
46
47
>
func (x *StartActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
48
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[0]
49
>
if x != nil {
50
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
51
if ms.LoadMessageInfo() == nil {
96
func (*StartActivityExecutionResponse) ProtoMessage() {}
97
98
>
func (x *StartActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
99
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[1]
100
>
if x != nil {
101
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
102
if ms.LoadMessageInfo() == nil {
141
func (*DescribeActivityExecutionRequest) ProtoMessage() {}
142
143
>
func (x *DescribeActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
144
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[2]
145
>
if x != nil {
146
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
147
if ms.LoadMessageInfo() == nil {
192
func (*DescribeActivityExecutionResponse) ProtoMessage() {}
193
194
>
func (x *DescribeActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
195
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[3]
196
>
if x != nil {
197
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
198
if ms.LoadMessageInfo() == nil {
237
func (*PollActivityExecutionRequest) ProtoMessage() {}
238
239
>
func (x *PollActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
240
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[4]
241
>
if x != nil {
242
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
243
if ms.LoadMessageInfo() == nil {
288
func (*PollActivityExecutionResponse) ProtoMessage() {}
289
290
>
func (x *PollActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
291
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[5]
292
>
if x != nil {
293
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
294
if ms.LoadMessageInfo() == nil {
333
func (*TerminateActivityExecutionRequest) ProtoMessage() {}
334
335
>
func (x *TerminateActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
336
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[6]
337
>
if x != nil {
338
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
339
if ms.LoadMessageInfo() == nil {
383
func (*TerminateActivityExecutionResponse) ProtoMessage() {}
384
385
>
func (x *TerminateActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
386
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[7]
387
>
if x != nil {
388
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
389
if ms.LoadMessageInfo() == nil {
421
func (*RequestCancelActivityExecutionRequest) ProtoMessage() {}
422
423
>
func (x *RequestCancelActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
424
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[8]
425
>
if x != nil {
426
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
427
if ms.LoadMessageInfo() == nil {
471
func (*RequestCancelActivityExecutionResponse) ProtoMessage() {}
472
473
>
func (x *RequestCancelActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
474
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[9]
475
>
if x != nil {
476
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
477
if ms.LoadMessageInfo() == nil {
509
func (*DeleteActivityExecutionRequest) ProtoMessage() {}
510
511
>
func (x *DeleteActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
512
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[10]
513
>
if x != nil {
514
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
515
if ms.LoadMessageInfo() == nil {
559
func (*DeleteActivityExecutionResponse) ProtoMessage() {}
560
561
>
func (x *DeleteActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
562
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[11]
563
>
if x != nil {
564
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
565
if ms.LoadMessageInfo() == nil {
597
func (*PauseActivityExecutionRequest) ProtoMessage() {}
598
599
>
func (x *PauseActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
600
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[12]
601
>
if x != nil {
602
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
603
if ms.LoadMessageInfo() == nil {
647
func (*PauseActivityExecutionResponse) ProtoMessage() {}
648
649
>
func (x *PauseActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
650
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[13]
651
>
if x != nil {
652
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
653
if ms.LoadMessageInfo() == nil {
685
func (*UnpauseActivityExecutionRequest) ProtoMessage() {}
686
687
>
func (x *UnpauseActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
688
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[14]
689
>
if x != nil {
690
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
691
if ms.LoadMessageInfo() == nil {
735
func (*UnpauseActivityExecutionResponse) ProtoMessage() {}
736
737
>
func (x *UnpauseActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
738
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[15]
739
>
if x != nil {
740
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
741
if ms.LoadMessageInfo() == nil {
773
func (*ResetActivityExecutionRequest) ProtoMessage() {}
774
775
>
func (x *ResetActivityExecutionRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
776
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[16]
777
>
if x != nil {
778
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
779
if ms.LoadMessageInfo() == nil {
823
func (*ResetActivityExecutionResponse) ProtoMessage() {}
824
825
>
func (x *ResetActivityExecutionResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
826
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[17]
827
>
if x != nil {
828
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
829
if ms.LoadMessageInfo() == nil {
861
func (*UpdateActivityExecutionOptionsRequest) ProtoMessage() {}
862
863
>
func (x *UpdateActivityExecutionOptionsRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
864
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[18]
865
>
if x != nil {
866
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
867
if ms.LoadMessageInfo() == nil {
912
func (*UpdateActivityExecutionOptionsResponse) ProtoMessage() {}
913
914
>
func (x *UpdateActivityExecutionOptionsResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
915
>
mi := &file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes[19]
916
>
if x != nil {
917
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
918
if ms.LoadMessageInfo() == nil {
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go 69 introduced LOC · 35 ranges
46
func (*CreateScheduleRequest) ProtoMessage() {}
47
49
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[0]
50
>
if x != nil {
51
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
52
if ms.LoadMessageInfo() == nil {
97
func (*CreateScheduleResponse) ProtoMessage() {}
98
100
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[1]
101
>
if x != nil {
102
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
103
if ms.LoadMessageInfo() == nil {
143
func (*UpdateScheduleRequest) ProtoMessage() {}
144
146
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[2]
147
>
if x != nil {
148
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
149
if ms.LoadMessageInfo() == nil {
194
func (*UpdateScheduleResponse) ProtoMessage() {}
195
197
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[3]
198
>
if x != nil {
199
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
200
if ms.LoadMessageInfo() == nil {
240
func (*PatchScheduleRequest) ProtoMessage() {}
241
243
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[4]
244
>
if x != nil {
245
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
246
if ms.LoadMessageInfo() == nil {
291
func (*PatchScheduleResponse) ProtoMessage() {}
292
294
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[5]
295
>
if x != nil {
296
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
297
if ms.LoadMessageInfo() == nil {
337
func (*DeleteScheduleRequest) ProtoMessage() {}
338
340
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[6]
341
>
if x != nil {
342
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
343
if ms.LoadMessageInfo() == nil {
388
func (*DeleteScheduleResponse) ProtoMessage() {}
389
391
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[7]
392
>
if x != nil {
393
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
394
if ms.LoadMessageInfo() == nil {
434
func (*DescribeScheduleRequest) ProtoMessage() {}
435
436
>
func (x *DescribeScheduleRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
437
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[8]
438
>
if x != nil {
439
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
440
if ms.LoadMessageInfo() == nil {
485
func (*DescribeScheduleResponse) ProtoMessage() {}
486
487
>
func (x *DescribeScheduleResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
488
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[9]
489
>
if x != nil {
490
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
491
if ms.LoadMessageInfo() == nil {
531
func (*ListScheduleMatchingTimesRequest) ProtoMessage() {}
532
533
>
func (x *ListScheduleMatchingTimesRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
534
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[10]
535
>
if x != nil {
536
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
537
if ms.LoadMessageInfo() == nil {
582
func (*ListScheduleMatchingTimesResponse) ProtoMessage() {}
583
584
>
func (x *ListScheduleMatchingTimesResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
585
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[11]
586
>
if x != nil {
587
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
588
if ms.LoadMessageInfo() == nil {
678
func (*CreateFromMigrationStateResponse) ProtoMessage() {}
679
680
>
func (x *CreateFromMigrationStateResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
681
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[13]
682
>
if x != nil {
683
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
684
if ms.LoadMessageInfo() == nil {
718
func (*CreateSentinelRequest) ProtoMessage() {}
719
721
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[14]
722
>
if x != nil {
723
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
724
if ms.LoadMessageInfo() == nil {
775
func (*CreateSentinelResponse) ProtoMessage() {}
776
778
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[15]
779
>
if x != nil {
780
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
781
if ms.LoadMessageInfo() == nil {
819
func (*MigrateToWorkflowRequest) ProtoMessage() {}
820
821
>
func (x *MigrateToWorkflowRequest) ProtoReflect() protoreflect.Message {
request_response.pb.go
822
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[16]
823
>
if x != nil {
824
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
825
if ms.LoadMessageInfo() == nil {
883
func (*MigrateToWorkflowResponse) ProtoMessage() {}
884
885
>
func (x *MigrateToWorkflowResponse) ProtoReflect() protoreflect.Message {
request_response.pb.go
886
>
mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[17]
887
>
if x != nil {
888
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
889
if ms.LoadMessageInfo() == nil {
go.temporal.io/server/common/rpc/interceptor/health_check.go 36 introduced LOC · 3 ranges
68
)
69
71
>
excludedAPIs = make(map[string]bool)
72
>
excludedCategories := map[commonspb.ApiCategory]bool{
73
>
commonspb.API_CATEGORY_LONG_POLL: true,
74
>
commonspb.API_CATEGORY_SYSTEM: true,
75
>
}
76
>
77
>
// Process HistoryService explicitly.
78
>
processServiceFile(historyservice.File_temporal_server_api_historyservice_v1_service_proto, excludedCategories)
79
>
80
>
// Auto-detect all registered chasm/lib service files.
81
>
// New services under chasm/lib are picked up automatically without code changes here.
82
>
protoregistry.GlobalFiles.RangeFiles(func(fd protoreflect.FileDescriptor) bool {
83
>
path := string(fd.Path())
84
>
if strings.HasPrefix(path, chasmProtoPrefix) && strings.HasSuffix(path, serviceProtoSuffix) {
85
>
processServiceFile(fd, excludedCategories)
86
>
}
87
>
return true
88
})
89
}
90
91
// processServiceFile enumerates all methods in a service file and adds excluded categories to excludedAPIs.
92
>
func processServiceFile(file protoreflect.FileDescriptor, excludedCategories map[commonspb.ApiCategory]bool) {
health_check.go
93
>
services := file.Services()
94
>
for i := 0; i < services.Len(); i++ {
95
>
service := services.Get(i)
96
>
methods := service.Methods()
97
>
for j := 0; j < methods.Len(); j++ {
98
>
method := methods.Get(j)
99
>
opts, ok := method.Options().(*descriptorpb.MethodOptions)
100
>
if ok && proto.HasExtension(opts, commonspb.E_ApiCategory) {
101
>
categoryOpts, ok := proto.GetExtension(opts, commonspb.E_ApiCategory).(*commonspb.ApiCategoryOptions)
102
>
if ok && categoryOpts != nil && excludedCategories[categoryOpts.GetCategory()] {
103
>
fullMethod := fmt.Sprintf("/%s/%s", service.FullName(), method.Name())
104
>
excludedAPIs[fullMethod] = true
105
>
}
106
}
107
}
110
111
// isExcludedAPI checks if an API is marked as a non-standard API via proto options.
113
>
excludedAPIsOnce.Do(initExcludedAPIs)
114
>
return excludedAPIs[fullMethod]
115
>
}
116
117
// NewHealthCheckInterceptor creates a new health check interceptor
go.temporal.io/server/api/common/v1/api_category.pb.go 13 introduced LOC · 3 ranges
119
func (*ApiCategoryOptions) ProtoMessage() {}
120
122
>
mi := &file_temporal_server_api_common_v1_api_category_proto_msgTypes[0]
123
>
if x != nil {
124
>
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
125
>
if ms.LoadMessageInfo() == nil {
126
>
ms.StoreMessageInfo(mi)
127
>
}
128
>
return ms
129
}
131
}
132
136
}
137
139
>
if x != nil {
140
>
return x.Category
141
>
}
142
return API_CATEGORY_UNSPECIFIED
143
}
go.temporal.io/server/api/routing/v1/extension.pb.go 9 introduced LOC · 2 ranges
50
func (*RoutingOptions) ProtoMessage() {}
51
53
>
mi := &file_temporal_server_api_routing_v1_extension_proto_msgTypes[0]
54
>
if x != nil {
55
>
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
56
>
if ms.LoadMessageInfo() == nil {
57
>
ms.StoreMessageInfo(mi)
58
>
}
59
>
return ms
60
}
62
}
63