Atlas › Test

TestIsExcludedAPI_UnknownMethod

Exact test identity: go.temporal.io/server/common/rpc/interceptor/TestIsExcludedAPI_UnknownMethod

Package
go.temporal.io/server/common/rpc/interceptor
Suite / test hierarchy
TestIsExcludedAPI_UnknownMethod
Test
TestIsExcludedAPI_UnknownMethod
Introduced at
request_response.pb.go ×295 Frontier kind: Joint frontier
Covered ranges
649
Covered lines
2853
Covered files
88

Co-introduced tests

3 other tests enter at the same concept.

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/api/historyservice/v1/request_response.pb.go 661 covered LOC · 309 ranges

Open complete file

220 func (*StartWorkflowExecutionRequest) ProtoMessage() {}
221
222 > func (x *StartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
223 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[1]
224 > if x != nil {
225 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
226 if ms.LoadMessageInfo() == nil {
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
486 > func (x *GetMutableStateRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
3843 func (*RecordChildExecutionCompletedRequest) ProtoMessage() {}
3844
3845 > func (x *RecordChildExecutionCompletedRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
3846 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[50]
3847 > if x != nil {
3848 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3849 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 {
3978 func (*VerifyChildExecutionCompletionRecordedRequest) ProtoMessage() {}
3979
3980 > func (x *VerifyChildExecutionCompletionRecordedRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
3981 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[52]
3982 > if x != nil {
3983 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3984 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
4623 > func (x *SyncActivityRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5128 > func (x *SyncActivityResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
5167 func (*DescribeMutableStateRequest) ProtoMessage() {}
5168
5169 > func (x *DescribeMutableStateRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
5170 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[66]
5171 > if x != nil {
5172 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
5173 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
5427 > func (x *CloseShardRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5470 > func (x *CloseShardResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5507 > func (x *GetShardRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5551 > func (x *GetShardResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5599 > func (x *RemoveTaskRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5663 > func (x *RemoveTaskResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5885 > func (x *QueryWorkflowRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5936 > func (x *QueryWorkflowResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
5981 > func (x *ReapplyEventsRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
6031 > func (x *ReapplyEventsResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
6073 > func (x *GetDLQMessagesRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
6551 func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage() {}
6552
6553 > func (x *GenerateLastHistoryReplicationTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
6554 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[92]
6555 > if x != nil {
6556 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6557 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 {
6669 func (*GetReplicationStatusRequest) ProtoMessage() {}
6670
6671 > func (x *GetReplicationStatusRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
6672 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[94]
6673 > if x != nil {
6674 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
6675 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 {
7034 func (*ImportWorkflowExecutionRequest) ProtoMessage() {}
7035
7036 > func (x *ImportWorkflowExecutionRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
7037 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[101]
7038 > if x != nil {
7039 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7040 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 {
7644 func (*GetWorkflowExecutionHistoryResponse) ProtoMessage() {}
7645
7646 > func (x *GetWorkflowExecutionHistoryResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
7647 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[112]
7648 > if x != nil {
7649 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
7650 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 {
8260 func (*GetDLQTasksRequest) ProtoMessage() {}
8261
8262 > func (x *GetDLQTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
8263 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[124]
8264 > if x != nil {
8265 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8266 if ms.LoadMessageInfo() == nil {
8322 func (*GetDLQTasksResponse) ProtoMessage() {}
8323
8324 > func (x *GetDLQTasksResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
8325 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[125]
8326 > if x != nil {
8327 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8328 if ms.LoadMessageInfo() == nil {
8374 func (*DeleteDLQTasksRequest) ProtoMessage() {}
8375
8376 > func (x *DeleteDLQTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
8377 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[126]
8378 > if x != nil {
8379 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8380 if ms.LoadMessageInfo() == nil {
8426 func (*DeleteDLQTasksResponse) ProtoMessage() {}
8427
8428 > func (x *DeleteDLQTasksResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
8429 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[127]
8430 > if x != nil {
8431 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8432 if ms.LoadMessageInfo() == nil {
8472 func (*ListQueuesRequest) ProtoMessage() {}
8473
8474 > func (x *ListQueuesRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
8533 > func (x *ListQueuesResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
8589 > func (x *AddTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
8639 > func (x *AddTasksResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
8676 > func (x *ListTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
8718 func (*ListTasksResponse) ProtoMessage() {}
8719
8720 > func (x *ListTasksResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
8721 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[133]
8722 > if x != nil {
8723 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8724 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
9563 > func (x *PauseActivityRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
9613 > func (x *PauseActivityResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
9741 > func (x *ResetActivityRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
9791 > func (x *ResetActivityResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
11956 }
11957
11958 > func init() { file_temporal_server_api_historyservice_v1_request_response_proto_init() } request_response.pb.go
11959 > func file_temporal_server_api_historyservice_v1_request_response_proto_init() {
11960 > if File_temporal_server_api_historyservice_v1_request_response_proto != nil {
11961 > return
11962 > }
11963 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[107].OneofWrappers = []any{
11964 > (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState)(nil),
11965 > }
11966 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[108].OneofWrappers = []any{
11967 > (*StreamWorkflowReplicationMessagesResponse_Messages)(nil),
11968 > }
11969 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[134].OneofWrappers = []any{
11970 > (*CompleteNexusOperationChasmRequest_Success)(nil),
11971 > (*CompleteNexusOperationChasmRequest_Failure)(nil),
11972 > }
11973 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[136].OneofWrappers = []any{
11974 > (*CompleteNexusOperationRequest_Success)(nil),
11975 > (*CompleteNexusOperationRequest_Failure)(nil),
11976 > }
11977 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[162].OneofWrappers = []any{
11978 > (*ExecuteMultiOperationRequest_Operation_StartWorkflow)(nil),
11979 > (*ExecuteMultiOperationRequest_Operation_UpdateWorkflow)(nil),
11980 > }
11981 > file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[163].OneofWrappers = []any{
11982 > (*ExecuteMultiOperationResponse_Response_StartWorkflow)(nil),
11983 > (*ExecuteMultiOperationResponse_Response_UpdateWorkflow)(nil),
11984 > }
11985 > type x struct{}
11986 > out := protoimpl.TypeBuilder{
11987 > File: protoimpl.DescBuilder{
11988 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
11989 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_historyservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_historyservice_v1_request_response_proto_rawDesc)),
11990 > NumEnums: 0,
11991 > NumMessages: 171,
11992 > NumExtensions: 1,
11993 > NumServices: 0,
11994 > },
11995 > GoTypes: file_temporal_server_api_historyservice_v1_request_response_proto_goTypes,
11996 > DependencyIndexes: file_temporal_server_api_historyservice_v1_request_response_proto_depIdxs,
11997 > MessageInfos: file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes,
11998 > ExtensionInfos: file_temporal_server_api_historyservice_v1_request_response_proto_extTypes,
11999 > }.Build()
12000 > File_temporal_server_api_historyservice_v1_request_response_proto = out.File
12001 > file_temporal_server_api_historyservice_v1_request_response_proto_goTypes = nil
12002 > file_temporal_server_api_historyservice_v1_request_response_proto_depIdxs = nil
12003 }
go.temporal.io/server/common/dynamicconfig/setting_gen.go 245 covered LOC · 51 ranges

Open complete file

26 type GlobalBoolConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[bool]
27
28 > func NewGlobalBoolSetting(key string, def bool, description string) GlobalBoolSetting { setting_gen.go
29 > return NewGlobalTypedSettingWithConverter[bool](key, convertBool, def, description)
30 > }
31
32 func NewGlobalBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) GlobalBoolConstrainedDefaultSetting {
43 type NamespaceBoolConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[bool]
44
45 > func NewNamespaceBoolSetting(key string, def bool, description string) NamespaceBoolSetting { setting_gen.go
46 > return NewNamespaceTypedSettingWithConverter[bool](key, convertBool, def, description)
47 > }
48
49 func NewNamespaceBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) NamespaceBoolConstrainedDefaultSetting {
60 type NamespaceIDBoolConstrainedDefaultSetting = NamespaceIDTypedConstrainedDefaultSetting[bool]
61
62 > func NewNamespaceIDBoolSetting(key string, def bool, description string) NamespaceIDBoolSetting { setting_gen.go
63 > return NewNamespaceIDTypedSettingWithConverter[bool](key, convertBool, def, description)
64 > }
65
66 func NewNamespaceIDBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) NamespaceIDBoolConstrainedDefaultSetting {
77 type TaskQueueBoolConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[bool]
78
79 > func NewTaskQueueBoolSetting(key string, def bool, description string) TaskQueueBoolSetting { setting_gen.go
80 > return NewTaskQueueTypedSettingWithConverter[bool](key, convertBool, def, description)
81 > }
82
83 func NewTaskQueueBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) TaskQueueBoolConstrainedDefaultSetting {
128 type DestinationBoolConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[bool]
129
130 > func NewDestinationBoolSetting(key string, def bool, description string) DestinationBoolSetting { setting_gen.go
131 > return NewDestinationTypedSettingWithConverter[bool](key, convertBool, def, description)
132 > }
133
134 func NewDestinationBoolSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[bool], description string) DestinationBoolConstrainedDefaultSetting {
162 type GlobalIntConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[int]
163
164 > func NewGlobalIntSetting(key string, def int, description string) GlobalIntSetting { setting_gen.go
165 > return NewGlobalTypedSettingWithConverter[int](key, convertInt, def, description)
166 > }
167
168 func NewGlobalIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) GlobalIntConstrainedDefaultSetting {
179 type NamespaceIntConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[int]
180
181 > func NewNamespaceIntSetting(key string, def int, description string) NamespaceIntSetting { setting_gen.go
182 > return NewNamespaceTypedSettingWithConverter[int](key, convertInt, def, description)
183 > }
184
185 func NewNamespaceIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) NamespaceIntConstrainedDefaultSetting {
189 type IntPropertyFnWithNamespaceFilter = TypedPropertyFnWithNamespaceFilter[int]
190
191 > func GetIntPropertyFnFilteredByNamespace(value int) IntPropertyFnWithNamespaceFilter { setting_gen.go
192 > return GetTypedPropertyFnFilteredByNamespace(value)
193 > }
194
195 type NamespaceIDIntSetting = NamespaceIDTypedSetting[int]
213 type TaskQueueIntConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[int]
214
215 > func NewTaskQueueIntSetting(key string, def int, description string) TaskQueueIntSetting { setting_gen.go
216 > return NewTaskQueueTypedSettingWithConverter[int](key, convertInt, def, description)
217 > }
218
219 > func NewTaskQueueIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) TaskQueueIntConstrainedDefaultSetting { setting_gen.go
220 > return NewTaskQueueTypedSettingWithConstrainedDefault[int](key, convertInt, cdef, description)
221 > }
222
223 type IntPropertyFnWithTaskQueueFilter = TypedPropertyFnWithTaskQueueFilter[int]
230 type ShardIDIntConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[int]
231
232 > func NewShardIDIntSetting(key string, def int, description string) ShardIDIntSetting { setting_gen.go
233 > return NewShardIDTypedSettingWithConverter[int](key, convertInt, def, description)
234 > }
235
236 func NewShardIDIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) ShardIDIntConstrainedDefaultSetting {
264 type DestinationIntConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[int]
265
266 > func NewDestinationIntSetting(key string, def int, description string) DestinationIntSetting { setting_gen.go
267 > return NewDestinationTypedSettingWithConverter[int](key, convertInt, def, description)
268 > }
269
270 func NewDestinationIntSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[int], description string) DestinationIntConstrainedDefaultSetting {
298 type GlobalFloatConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[float64]
299
300 > func NewGlobalFloatSetting(key string, def float64, description string) GlobalFloatSetting { setting_gen.go
301 > return NewGlobalTypedSettingWithConverter[float64](key, convertFloat, def, description)
302 > }
303
304 func NewGlobalFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) GlobalFloatConstrainedDefaultSetting {
315 type NamespaceFloatConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[float64]
316
317 > func NewNamespaceFloatSetting(key string, def float64, description string) NamespaceFloatSetting { setting_gen.go
318 > return NewNamespaceTypedSettingWithConverter[float64](key, convertFloat, def, description)
319 > }
320
321 func NewNamespaceFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) NamespaceFloatConstrainedDefaultSetting {
349 type TaskQueueFloatConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[float64]
350
351 > func NewTaskQueueFloatSetting(key string, def float64, description string) TaskQueueFloatSetting { setting_gen.go
352 > return NewTaskQueueTypedSettingWithConverter[float64](key, convertFloat, def, description)
353 > }
354
355 func NewTaskQueueFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) TaskQueueFloatConstrainedDefaultSetting {
366 type ShardIDFloatConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[float64]
367
368 > func NewShardIDFloatSetting(key string, def float64, description string) ShardIDFloatSetting { setting_gen.go
369 > return NewShardIDTypedSettingWithConverter[float64](key, convertFloat, def, description)
370 > }
371
372 func NewShardIDFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) ShardIDFloatConstrainedDefaultSetting {
400 type DestinationFloatConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[float64]
401
402 > func NewDestinationFloatSetting(key string, def float64, description string) DestinationFloatSetting { setting_gen.go
403 > return NewDestinationTypedSettingWithConverter[float64](key, convertFloat, def, description)
404 > }
405
406 func NewDestinationFloatSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[float64], description string) DestinationFloatConstrainedDefaultSetting {
434 type GlobalStringConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[string]
435
436 > func NewGlobalStringSetting(key string, def string, description string) GlobalStringSetting { setting_gen.go
437 > return NewGlobalTypedSettingWithConverter[string](key, convertString, def, description)
438 > }
439
440 func NewGlobalStringSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[string], description string) GlobalStringConstrainedDefaultSetting {
570 type GlobalDurationConstrainedDefaultSetting = GlobalTypedConstrainedDefaultSetting[time.Duration]
571
572 > func NewGlobalDurationSetting(key string, def time.Duration, description string) GlobalDurationSetting { setting_gen.go
573 > return NewGlobalTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
574 > }
575
576 func NewGlobalDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) GlobalDurationConstrainedDefaultSetting {
587 type NamespaceDurationConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[time.Duration]
588
589 > func NewNamespaceDurationSetting(key string, def time.Duration, description string) NamespaceDurationSetting { setting_gen.go
590 > return NewNamespaceTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
591 > }
592
593 func NewNamespaceDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) NamespaceDurationConstrainedDefaultSetting {
604 type NamespaceIDDurationConstrainedDefaultSetting = NamespaceIDTypedConstrainedDefaultSetting[time.Duration]
605
606 > func NewNamespaceIDDurationSetting(key string, def time.Duration, description string) NamespaceIDDurationSetting { setting_gen.go
607 > return NewNamespaceIDTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
608 > }
609
610 func NewNamespaceIDDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) NamespaceIDDurationConstrainedDefaultSetting {
621 type TaskQueueDurationConstrainedDefaultSetting = TaskQueueTypedConstrainedDefaultSetting[time.Duration]
622
623 > func NewTaskQueueDurationSetting(key string, def time.Duration, description string) TaskQueueDurationSetting { setting_gen.go
624 > return NewTaskQueueTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
625 > }
626
627 > func NewTaskQueueDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) TaskQueueDurationConstrainedDefaultSetting { setting_gen.go
628 > return NewTaskQueueTypedSettingWithConstrainedDefault[time.Duration](key, convertDuration, cdef, description)
629 > }
630
631 type DurationPropertyFnWithTaskQueueFilter = TypedPropertyFnWithTaskQueueFilter[time.Duration]
638 type ShardIDDurationConstrainedDefaultSetting = ShardIDTypedConstrainedDefaultSetting[time.Duration]
639
640 > func NewShardIDDurationSetting(key string, def time.Duration, description string) ShardIDDurationSetting { setting_gen.go
641 > return NewShardIDTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
642 > }
643
644 func NewShardIDDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) ShardIDDurationConstrainedDefaultSetting {
655 type TaskTypeDurationConstrainedDefaultSetting = TaskTypeTypedConstrainedDefaultSetting[time.Duration]
656
657 > func NewTaskTypeDurationSetting(key string, def time.Duration, description string) TaskTypeDurationSetting { setting_gen.go
658 > return NewTaskTypeTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
659 > }
660
661 func NewTaskTypeDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) TaskTypeDurationConstrainedDefaultSetting {
672 type DestinationDurationConstrainedDefaultSetting = DestinationTypedConstrainedDefaultSetting[time.Duration]
673
674 > func NewDestinationDurationSetting(key string, def time.Duration, description string) DestinationDurationSetting { setting_gen.go
675 > return NewDestinationTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
676 > }
677
678 func NewDestinationDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) DestinationDurationConstrainedDefaultSetting {
689 type ChasmTaskTypeDurationConstrainedDefaultSetting = ChasmTaskTypeTypedConstrainedDefaultSetting[time.Duration]
690
691 > func NewChasmTaskTypeDurationSetting(key string, def time.Duration, description string) ChasmTaskTypeDurationSetting { setting_gen.go
692 > return NewChasmTaskTypeTypedSettingWithConverter[time.Duration](key, convertDuration, def, description)
693 > }
694
695 func NewChasmTaskTypeDurationSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[time.Duration], description string) ChasmTaskTypeDurationConstrainedDefaultSetting {
723 type NamespaceMapConstrainedDefaultSetting = NamespaceTypedConstrainedDefaultSetting[map[string]any]
724
725 > func NewNamespaceMapSetting(key string, def map[string]any, description string) NamespaceMapSetting { setting_gen.go
726 > return NewNamespaceTypedSettingWithConverter[map[string]any](key, convertMap, def, description)
727 > }
728
729 func NewNamespaceMapSettingWithConstrainedDefault(key string, cdef []TypedConstrainedValue[map[string]any], description string) NamespaceMapConstrainedDefaultSetting {
845 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful
846 // when using non-empty maps or slices as defaults, the result may not be what you want.
847 > func NewGlobalTypedSetting[T any](key string, def T, description string) GlobalTypedSetting[T] { setting_gen.go
848 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.
849 > warnDefaultSharedStructure(key, def)
850 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.
851 > _ = deepCopyForMapstructure(def)
852 >
853 > s := GlobalTypedSetting[T]{
854 > key: MakeKey(key),
855 > def: def,
856 > convert: ConvertStructure[T](def),
857 > description: description,
858 > }
859 > register(s)
860 > return s
861 > }
862
863 // NewGlobalTypedSettingWithConverter creates a setting with a custom converter function.
864 > func NewGlobalTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) GlobalTypedSetting[T] { setting_gen.go
865 > s := GlobalTypedSetting[T]{
866 > key: MakeKey(key),
867 > def: def,
868 > convert: convert,
869 > description: description,
870 > }
871 > register(s)
872 > return s
873 > }
874
875 // NewGlobalTypedSettingWithConstrainedDefault creates a setting with a compound default value.
885 }
886
887 > func (s GlobalTypedSetting[T]) Key() Key { return s.key } setting_gen.go
888 func (s GlobalTypedSetting[T]) Precedence() Precedence { return PrecedenceGlobal }
889 func (s GlobalTypedSetting[T]) Validate(v any) error {
981 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful
982 // when using non-empty maps or slices as defaults, the result may not be what you want.
983 > func NewNamespaceTypedSetting[T any](key string, def T, description string) NamespaceTypedSetting[T] { setting_gen.go
984 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.
985 > warnDefaultSharedStructure(key, def)
986 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.
987 > _ = deepCopyForMapstructure(def)
988 >
989 > s := NamespaceTypedSetting[T]{
990 > key: MakeKey(key),
991 > def: def,
992 > convert: ConvertStructure[T](def),
993 > description: description,
994 > }
995 > register(s)
996 > return s
997 > }
998
999 // NewNamespaceTypedSettingWithConverter creates a setting with a custom converter function.
1000 > func NewNamespaceTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) NamespaceTypedSetting[T] { setting_gen.go
1001 > s := NamespaceTypedSetting[T]{
1002 > key: MakeKey(key),
1003 > def: def,
1004 > convert: convert,
1005 > description: description,
1006 > }
1007 > register(s)
1008 > return s
1009 > }
1010
1011 // NewNamespaceTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1021 }
1022
1023 > func (s NamespaceTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1024 func (s NamespaceTypedSetting[T]) Precedence() Precedence { return PrecedenceNamespace }
1025 func (s NamespaceTypedSetting[T]) Validate(v any) error {
1105 }
1106
1107 > func GetTypedPropertyFnFilteredByNamespace[T any](value T) TypedPropertyFnWithNamespaceFilter[T] { setting_gen.go
1108 > return func(namespace string) T {
1109 return value
1110 }
1134
1135 // NewNamespaceIDTypedSettingWithConverter creates a setting with a custom converter function.
1136 > func NewNamespaceIDTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) NamespaceIDTypedSetting[T] { setting_gen.go
1137 > s := NamespaceIDTypedSetting[T]{
1138 > key: MakeKey(key),
1139 > def: def,
1140 > convert: convert,
1141 > description: description,
1142 > }
1143 > register(s)
1144 > return s
1145 > }
1146
1147 // NewNamespaceIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1157 }
1158
1159 > func (s NamespaceIDTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1160 func (s NamespaceIDTypedSetting[T]) Precedence() Precedence { return PrecedenceNamespaceID }
1161 func (s NamespaceIDTypedSetting[T]) Validate(v any) error {
1253 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful
1254 // when using non-empty maps or slices as defaults, the result may not be what you want.
1255 > func NewTaskQueueTypedSetting[T any](key string, def T, description string) TaskQueueTypedSetting[T] { setting_gen.go
1256 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.
1257 > warnDefaultSharedStructure(key, def)
1258 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.
1259 > _ = deepCopyForMapstructure(def)
1260 >
1261 > s := TaskQueueTypedSetting[T]{
1262 > key: MakeKey(key),
1263 > def: def,
1264 > convert: ConvertStructure[T](def),
1265 > description: description,
1266 > }
1267 > register(s)
1268 > return s
1269 > }
1270
1271 // NewTaskQueueTypedSettingWithConverter creates a setting with a custom converter function.
1272 > func NewTaskQueueTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) TaskQueueTypedSetting[T] { setting_gen.go
1273 > s := TaskQueueTypedSetting[T]{
1274 > key: MakeKey(key),
1275 > def: def,
1276 > convert: convert,
1277 > description: description,
1278 > }
1279 > register(s)
1280 > return s
1281 > }
1282
1283 // NewTaskQueueTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1284 > func NewTaskQueueTypedSettingWithConstrainedDefault[T any](key string, convert func(any) (T, error), cdef []TypedConstrainedValue[T], description string) TaskQueueTypedConstrainedDefaultSetting[T] { setting_gen.go
1285 > s := TaskQueueTypedConstrainedDefaultSetting[T]{
1286 > key: MakeKey(key),
1287 > cdef: cdef,
1288 > convert: convert,
1289 > description: description,
1290 > }
1291 > register(s)
1292 > return s
1293 > }
1294
1295 > func (s TaskQueueTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1296 func (s TaskQueueTypedSetting[T]) Precedence() Precedence { return PrecedenceTaskQueue }
1297 func (s TaskQueueTypedSetting[T]) Validate(v any) error {
1300 }
1301
1302 > func (s TaskQueueTypedConstrainedDefaultSetting[T]) Key() Key { return s.key } setting_gen.go
1303 func (s TaskQueueTypedConstrainedDefaultSetting[T]) Precedence() Precedence { return PrecedenceTaskQueue }
1304 func (s TaskQueueTypedConstrainedDefaultSetting[T]) Validate(v any) error {
1430
1431 // NewShardIDTypedSettingWithConverter creates a setting with a custom converter function.
1432 > func NewShardIDTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) ShardIDTypedSetting[T] { setting_gen.go
1433 > s := ShardIDTypedSetting[T]{
1434 > key: MakeKey(key),
1435 > def: def,
1436 > convert: convert,
1437 > description: description,
1438 > }
1439 > register(s)
1440 > return s
1441 > }
1442
1443 // NewShardIDTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1453 }
1454
1455 > func (s ShardIDTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1456 func (s ShardIDTypedSetting[T]) Precedence() Precedence { return PrecedenceShardID }
1457 func (s ShardIDTypedSetting[T]) Validate(v any) error {
1566
1567 // NewTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.
1568 > func NewTaskTypeTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) TaskTypeTypedSetting[T] { setting_gen.go
1569 > s := TaskTypeTypedSetting[T]{
1570 > key: MakeKey(key),
1571 > def: def,
1572 > convert: convert,
1573 > description: description,
1574 > }
1575 > register(s)
1576 > return s
1577 > }
1578
1579 // NewTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1589 }
1590
1591 > func (s TaskTypeTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1592 func (s TaskTypeTypedSetting[T]) Precedence() Precedence { return PrecedenceTaskType }
1593 func (s TaskTypeTypedSetting[T]) Validate(v any) error {
1685 // values. The value from dynamic config will be _merged_ over a deep copy of 'def'. Be very careful
1686 // when using non-empty maps or slices as defaults, the result may not be what you want.
1687 > func NewDestinationTypedSetting[T any](key string, def T, description string) DestinationTypedSetting[T] { setting_gen.go
1688 > // Warn on any shared structure used with ConvertStructure, even though we handle it by deep copying.
1689 > warnDefaultSharedStructure(key, def)
1690 > // If even deep copy won't even work, we should panic early. Do that by calling deep copy once here.
1691 > _ = deepCopyForMapstructure(def)
1692 >
1693 > s := DestinationTypedSetting[T]{
1694 > key: MakeKey(key),
1695 > def: def,
1696 > convert: ConvertStructure[T](def),
1697 > description: description,
1698 > }
1699 > register(s)
1700 > return s
1701 > }
1702
1703 // NewDestinationTypedSettingWithConverter creates a setting with a custom converter function.
1704 > func NewDestinationTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) DestinationTypedSetting[T] { setting_gen.go
1705 > s := DestinationTypedSetting[T]{
1706 > key: MakeKey(key),
1707 > def: def,
1708 > convert: convert,
1709 > description: description,
1710 > }
1711 > register(s)
1712 > return s
1713 > }
1714
1715 // NewDestinationTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1725 }
1726
1727 > func (s DestinationTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1728 func (s DestinationTypedSetting[T]) Precedence() Precedence { return PrecedenceDestination }
1729 func (s DestinationTypedSetting[T]) Validate(v any) error {
1858
1859 // NewChasmTaskTypeTypedSettingWithConverter creates a setting with a custom converter function.
1860 > func NewChasmTaskTypeTypedSettingWithConverter[T any](key string, convert func(any) (T, error), def T, description string) ChasmTaskTypeTypedSetting[T] { setting_gen.go
1861 > s := ChasmTaskTypeTypedSetting[T]{
1862 > key: MakeKey(key),
1863 > def: def,
1864 > convert: convert,
1865 > description: description,
1866 > }
1867 > register(s)
1868 > return s
1869 > }
1870
1871 // NewChasmTaskTypeTypedSettingWithConstrainedDefault creates a setting with a compound default value.
1881 }
1882
1883 > func (s ChasmTaskTypeTypedSetting[T]) Key() Key { return s.key } setting_gen.go
1884 func (s ChasmTaskTypeTypedSetting[T]) Precedence() Precedence { return PrecedenceChasmTaskType }
1885 func (s ChasmTaskTypeTypedSetting[T]) Validate(v any) error {
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/request_response.pb.go 102 covered LOC · 41 ranges

Open complete file

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 {
1057 }
1058
1059 > func init() { file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_init() } request_response.pb.go
1060 > func file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_init() {
1061 > if File_temporal_server_chasm_lib_activity_proto_v1_request_response_proto != nil {
1062 > return
1063 > }
1064 > type x struct{}
1065 > out := protoimpl.TypeBuilder{
1066 > File: protoimpl.DescBuilder{
1067 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1068 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_rawDesc), len(file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_rawDesc)),
1069 > NumEnums: 0,
1070 > NumMessages: 20,
1071 > NumExtensions: 0,
1072 > NumServices: 0,
1073 > },
1074 > GoTypes: file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_goTypes,
1075 > DependencyIndexes: file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_depIdxs,
1076 > MessageInfos: file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_msgTypes,
1077 > }.Build()
1078 > File_temporal_server_chasm_lib_activity_proto_v1_request_response_proto = out.File
1079 > file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_goTypes = nil
1080 > file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_depIdxs = nil
1081 }
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/request_response.pb.go 95 covered LOC · 37 ranges

Open complete file

46 func (*CreateScheduleRequest) ProtoMessage() {}
47
48 > func (x *CreateScheduleRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
99 > func (x *CreateScheduleResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
145 > func (x *UpdateScheduleRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
196 > func (x *UpdateScheduleResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
242 > func (x *PatchScheduleRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
293 > func (x *PatchScheduleResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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
339 > func (x *DeleteScheduleRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
390 > func (x *DeleteScheduleResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
628 func (*CreateFromMigrationStateRequest) ProtoMessage() {}
629
630 > func (x *CreateFromMigrationStateRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
631 > mi := &file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes[12]
632 > if x != nil {
633 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
634 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
720 > func (x *CreateSentinelRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
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
777 > func (x *CreateSentinelResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
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 {
1021 }
1022
1023 > func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init() } request_response.pb.go
1024 > func file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init() {
1025 > if File_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto != nil {
1026 > return
1027 > }
1028 > file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_init()
1029 > type x struct{}
1030 > out := protoimpl.TypeBuilder{
1031 > File: protoimpl.DescBuilder{
1032 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1033 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_rawDesc)),
1034 > NumEnums: 0,
1035 > NumMessages: 18,
1036 > NumExtensions: 0,
1037 > NumServices: 0,
1038 > },
1039 > GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_goTypes,
1040 > DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs,
1041 > MessageInfos: file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_msgTypes,
1042 > }.Build()
1043 > File_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto = out.File
1044 > file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_goTypes = nil
1045 > file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_depIdxs = nil
1046 }
go.temporal.io/server/api/persistence/v1/predicates.pb.go 82 covered LOC · 22 ranges

Open complete file

57 func (*Predicate) ProtoMessage() {}
58
59 > func (x *Predicate) ProtoReflect() protoreflect.Message { predicates.pb.go
60 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0]
61 > if x != nil {
62 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
63 > if ms.LoadMessageInfo() == nil {
64 > ms.StoreMessageInfo(mi)
65 > }
66 > return ms
67 }
68 return mi.MessageOf(x)
261 func (*UniversalPredicateAttributes) ProtoMessage() {}
262
263 > func (x *UniversalPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
264 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[1]
265 > if x != nil {
266 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
267 if ms.LoadMessageInfo() == nil {
297 func (*EmptyPredicateAttributes) ProtoMessage() {}
298
299 > func (x *EmptyPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
300 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[2]
301 > if x != nil {
302 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
303 if ms.LoadMessageInfo() == nil {
334 func (*AndPredicateAttributes) ProtoMessage() {}
335
336 > func (x *AndPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
337 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[3]
338 > if x != nil {
339 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
340 if ms.LoadMessageInfo() == nil {
378 func (*OrPredicateAttributes) ProtoMessage() {}
379
380 > func (x *OrPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
381 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[4]
382 > if x != nil {
383 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
384 if ms.LoadMessageInfo() == nil {
422 func (*NotPredicateAttributes) ProtoMessage() {}
423
424 > func (x *NotPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
425 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[5]
426 > if x != nil {
427 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
428 if ms.LoadMessageInfo() == nil {
466 func (*NamespaceIdPredicateAttributes) ProtoMessage() {}
467
468 > func (x *NamespaceIdPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
469 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[6]
470 > if x != nil {
471 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
472 if ms.LoadMessageInfo() == nil {
510 func (*TaskTypePredicateAttributes) ProtoMessage() {}
511
512 > func (x *TaskTypePredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
513 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[7]
514 > if x != nil {
515 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
516 if ms.LoadMessageInfo() == nil {
554 func (*DestinationPredicateAttributes) ProtoMessage() {}
555
556 > func (x *DestinationPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
557 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[8]
558 > if x != nil {
559 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
560 if ms.LoadMessageInfo() == nil {
598 func (*OutboundTaskGroupPredicateAttributes) ProtoMessage() {}
599
600 > func (x *OutboundTaskGroupPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
601 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[9]
602 > if x != nil {
603 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
604 if ms.LoadMessageInfo() == nil {
642 func (*OutboundTaskPredicateAttributes) ProtoMessage() {}
643
644 > func (x *OutboundTaskPredicateAttributes) ProtoReflect() protoreflect.Message { predicates.pb.go
645 > mi := &file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[10]
646 > if x != nil {
647 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
648 if ms.LoadMessageInfo() == nil {
828 }
829
830 > func init() { file_temporal_server_api_persistence_v1_predicates_proto_init() } predicates.pb.go
831 > func file_temporal_server_api_persistence_v1_predicates_proto_init() {
832 > if File_temporal_server_api_persistence_v1_predicates_proto != nil {
833 > return
834 > }
835 > file_temporal_server_api_persistence_v1_predicates_proto_msgTypes[0].OneofWrappers = []any{
836 > (*Predicate_UniversalPredicateAttributes)(nil),
837 > (*Predicate_EmptyPredicateAttributes)(nil),
838 > (*Predicate_AndPredicateAttributes)(nil),
839 > (*Predicate_OrPredicateAttributes)(nil),
840 > (*Predicate_NotPredicateAttributes)(nil),
841 > (*Predicate_NamespaceIdPredicateAttributes)(nil),
842 > (*Predicate_TaskTypePredicateAttributes)(nil),
843 > (*Predicate_DestinationPredicateAttributes)(nil),
844 > (*Predicate_OutboundTaskGroupPredicateAttributes)(nil),
845 > (*Predicate_OutboundTaskPredicateAttributes)(nil),
846 > }
847 > type x struct{}
848 > out := protoimpl.TypeBuilder{
849 > File: protoimpl.DescBuilder{
850 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
851 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc), len(file_temporal_server_api_persistence_v1_predicates_proto_rawDesc)),
852 > NumEnums: 0,
853 > NumMessages: 12,
854 > NumExtensions: 0,
855 > NumServices: 0,
856 > },
857 > GoTypes: file_temporal_server_api_persistence_v1_predicates_proto_goTypes,
858 > DependencyIndexes: file_temporal_server_api_persistence_v1_predicates_proto_depIdxs,
859 > MessageInfos: file_temporal_server_api_persistence_v1_predicates_proto_msgTypes,
860 > }.Build()
861 > File_temporal_server_api_persistence_v1_predicates_proto = out.File
862 > file_temporal_server_api_persistence_v1_predicates_proto_goTypes = nil
863 > file_temporal_server_api_persistence_v1_predicates_proto_depIdxs = nil
864 }
go.temporal.io/server/chasm/search_attribute.go 75 covered LOC · 12 ranges

Open complete file

136 }
137
138 > func newSearchAttributeFieldBool(index int) SearchAttributeFieldBool { search_attribute.go
139 > return SearchAttributeFieldBool{
140 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_BOOL, index),
141 > }
142 > }
143
144 // SearchAttributeFieldDateTime is a search attribute field for a datetime value.
147 }
148
149 > func newSearchAttributeFieldDateTime(index int) SearchAttributeFieldDateTime { search_attribute.go
150 > return SearchAttributeFieldDateTime{
151 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_DATETIME, index),
152 > }
153 > }
154
155 // SearchAttributeFieldInt is a search attribute field for an integer value.
158 }
159
160 > func newSearchAttributeFieldInt(index int) SearchAttributeFieldInt { search_attribute.go
161 > return SearchAttributeFieldInt{
162 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_INT, index),
163 > }
164 > }
165
166 // SearchAttributeFieldDouble is a search attribute field for a double value.
169 }
170
171 > func newSearchAttributeFieldDouble(index int) SearchAttributeFieldDouble { search_attribute.go
172 > return SearchAttributeFieldDouble{
173 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_DOUBLE, index),
174 > }
175 > }
176
177 // SearchAttributeFieldKeyword is a search attribute field for a keyword value.
180 }
181
182 > func newSearchAttributeFieldKeyword(index int) SearchAttributeFieldKeyword { search_attribute.go
183 > return SearchAttributeFieldKeyword{
184 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_KEYWORD, index),
185 > }
186 > }
187
188 > func newSearchAttributeFieldLowCardinalityKeyword(index int) SearchAttributeFieldKeyword { search_attribute.go
189 > return SearchAttributeFieldKeyword{
190 > field: fmt.Sprintf("%s%s%02d", sadefs.ReservedPrefix, "LowCardinalityKeyword", index),
191 > }
192 > }
193
194 // SearchAttributeFieldKeywordList is a search attribute field for a keyword list value.
197 }
198
199 > func newSearchAttributeFieldKeywordList(index int) SearchAttributeFieldKeywordList { search_attribute.go
200 > return SearchAttributeFieldKeywordList{
201 > field: resolveFieldName(enumspb.INDEXED_VALUE_TYPE_KEYWORD_LIST, index),
202 > }
203 > }
204
205 // SearchAttributeFieldText is a search attribute field for a text value.
214 }
215
216 > func resolveFieldName(valueType enumspb.IndexedValueType, index int) string { search_attribute.go
217 > // Columns are named like TemporalBool01, TemporalDatetime01, TemporalDouble01, TemporalInt01.
218 > return fmt.Sprintf("%s%s%02d", sadefs.ReservedPrefix, valueType.String(), index)
219 > }
220
221 func (s searchAttributeDefinition) definition() searchAttributeDefinition {
239 }
240
241 > func newSearchAttributeBoolByField(field string) SearchAttributeBool { search_attribute.go
242 > return SearchAttributeBool{
243 > searchAttributeDefinition: searchAttributeDefinition{
244 > alias: field,
245 > field: field,
246 > valueType: enumspb.INDEXED_VALUE_TYPE_BOOL,
247 > },
248 > }
249 > }
250
251 // Value sets the boolean value of the search attribute.
276 }
277
278 > func newSearchAttributeDateTimeByField(field string) SearchAttributeDateTime { search_attribute.go
279 > return SearchAttributeDateTime{
280 > searchAttributeDefinition: searchAttributeDefinition{
281 > alias: field,
282 > field: field,
283 > valueType: enumspb.INDEXED_VALUE_TYPE_DATETIME,
284 > },
285 > }
286 > }
287
288 // Value sets the date time value of the search attribute.
377 }
378
379 > func newSearchAttributeKeywordByField(field string) SearchAttributeKeyword { search_attribute.go
380 > return SearchAttributeKeyword{
381 > searchAttributeDefinition: searchAttributeDefinition{
382 > alias: field,
383 > field: field,
384 > valueType: enumspb.INDEXED_VALUE_TYPE_KEYWORD,
385 > },
386 > }
387 > }
388
389 // Value sets the string value of the search attribute.
414 }
415
416 > func newSearchAttributeKeywordListByField(field string) SearchAttributeKeywordList { search_attribute.go
417 > return SearchAttributeKeywordList{
418 > searchAttributeDefinition: searchAttributeDefinition{
419 > alias: field,
420 > field: field,
421 > valueType: enumspb.INDEXED_VALUE_TYPE_KEYWORD_LIST,
422 > },
423 > }
424 > }
425
426 // Value sets the string list value of the search attribute.
go.temporal.io/server/api/persistence/v1/executions.pb.go 60 covered LOC · 1 range

Open complete file

5706 }
5707
5708 > func init() { file_temporal_server_api_persistence_v1_executions_proto_init() } executions.pb.go
5709 > func file_temporal_server_api_persistence_v1_executions_proto_init() {
5710 > if File_temporal_server_api_persistence_v1_executions_proto != nil {
5711 > return
5712 > }
5713 > file_temporal_server_api_persistence_v1_chasm_proto_init()
5714 > file_temporal_server_api_persistence_v1_hsm_proto_init()
5715 > file_temporal_server_api_persistence_v1_queues_proto_init()
5716 > file_temporal_server_api_persistence_v1_update_proto_init()
5717 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[1].OneofWrappers = []any{
5718 > (*WorkflowExecutionInfo_LastWorkflowTaskFailureCause)(nil),
5719 > (*WorkflowExecutionInfo_LastWorkflowTaskTimedOutType)(nil),
5720 > }
5721 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[8].OneofWrappers = []any{
5722 > (*TransferTaskInfo_CloseExecutionTaskDetails_)(nil),
5723 > (*TransferTaskInfo_ChasmTaskInfo)(nil),
5724 > }
5725 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[10].OneofWrappers = []any{
5726 > (*VisibilityTaskInfo_ChasmTaskInfo)(nil),
5727 > }
5728 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[11].OneofWrappers = []any{
5729 > (*TimerTaskInfo_ChasmTaskInfo)(nil),
5730 > }
5731 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[13].OneofWrappers = []any{
5732 > (*OutboundTaskInfo_StateMachineInfo)(nil),
5733 > (*OutboundTaskInfo_ChasmTaskInfo)(nil),
5734 > (*OutboundTaskInfo_WorkerCommandsTask)(nil),
5735 > }
5736 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[17].OneofWrappers = []any{
5737 > (*ActivityInfo_UseWorkflowBuildIdInfo_)(nil),
5738 > (*ActivityInfo_LastIndependentlyAssignedBuildId)(nil),
5739 > }
5740 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[23].OneofWrappers = []any{
5741 > (*Callback_Nexus_)(nil),
5742 > (*Callback_Hsm)(nil),
5743 > }
5744 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[40].OneofWrappers = []any{
5745 > (*ActivityInfo_PauseInfo_Manual_)(nil),
5746 > (*ActivityInfo_PauseInfo_RuleId)(nil),
5747 > }
5748 > file_temporal_server_api_persistence_v1_executions_proto_msgTypes[46].OneofWrappers = []any{
5749 > (*CallbackInfo_Trigger_WorkflowClosed)(nil),
5750 > }
5751 > type x struct{}
5752 > out := protoimpl.TypeBuilder{
5753 > File: protoimpl.DescBuilder{
5754 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
5755 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_executions_proto_rawDesc), len(file_temporal_server_api_persistence_v1_executions_proto_rawDesc)),
5756 > NumEnums: 0,
5757 > NumMessages: 47,
5758 > NumExtensions: 0,
5759 > NumServices: 0,
5760 > },
5761 > GoTypes: file_temporal_server_api_persistence_v1_executions_proto_goTypes,
5762 > DependencyIndexes: file_temporal_server_api_persistence_v1_executions_proto_depIdxs,
5763 > MessageInfos: file_temporal_server_api_persistence_v1_executions_proto_msgTypes,
5764 > }.Build()
5765 > File_temporal_server_api_persistence_v1_executions_proto = out.File
5766 > file_temporal_server_api_persistence_v1_executions_proto_goTypes = nil
5767 > file_temporal_server_api_persistence_v1_executions_proto_depIdxs = nil
5768 }
go.temporal.io/server/api/matchingservice/v1/request_response.pb.go 43 covered LOC · 1 range

Open complete file

6833 }
6834
6835 > func init() { file_temporal_server_api_matchingservice_v1_request_response_proto_init() } request_response.pb.go
6836 > func file_temporal_server_api_matchingservice_v1_request_response_proto_init() {
6837 > if File_temporal_server_api_matchingservice_v1_request_response_proto != nil {
6838 > return
6839 > }
6840 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[27].OneofWrappers = []any{
6841 > (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_)(nil),
6842 > (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_)(nil),
6843 > (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId)(nil),
6844 > }
6845 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[29].OneofWrappers = []any{
6846 > (*GetWorkerVersioningRulesRequest_Request)(nil),
6847 > }
6848 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[31].OneofWrappers = []any{
6849 > (*UpdateWorkerVersioningRulesRequest_Request)(nil),
6850 > }
6851 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[37].OneofWrappers = []any{
6852 > (*SyncDeploymentUserDataRequest_UpdateVersionData)(nil),
6853 > (*SyncDeploymentUserDataRequest_ForgetVersion)(nil),
6854 > }
6855 > file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[56].OneofWrappers = []any{
6856 > (*DispatchNexusTaskResponse_HandlerError)(nil),
6857 > (*DispatchNexusTaskResponse_Response)(nil),
6858 > (*DispatchNexusTaskResponse_RequestTimeout)(nil),
6859 > (*DispatchNexusTaskResponse_Failure)(nil),
6860 > }
6861 > type x struct{}
6862 > out := protoimpl.TypeBuilder{
6863 > File: protoimpl.DescBuilder{
6864 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
6865 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_matchingservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_matchingservice_v1_request_response_proto_rawDesc)),
6866 > NumEnums: 0,
6867 > NumMessages: 97,
6868 > NumExtensions: 0,
6869 > NumServices: 0,
6870 > },
6871 > GoTypes: file_temporal_server_api_matchingservice_v1_request_response_proto_goTypes,
6872 > DependencyIndexes: file_temporal_server_api_matchingservice_v1_request_response_proto_depIdxs,
6873 > MessageInfos: file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes,
6874 > }.Build()
6875 > File_temporal_server_api_matchingservice_v1_request_response_proto = out.File
6876 > file_temporal_server_api_matchingservice_v1_request_response_proto_goTypes = nil
6877 > file_temporal_server_api_matchingservice_v1_request_response_proto_depIdxs = nil
6878 }
go.temporal.io/server/api/adminservice/v1/request_response.pb.go 36 covered LOC · 1 range

Open complete file

6623 }
6624
6625 > func init() { file_temporal_server_api_adminservice_v1_request_response_proto_init() } request_response.pb.go
6626 > func file_temporal_server_api_adminservice_v1_request_response_proto_init() {
6627 > if File_temporal_server_api_adminservice_v1_request_response_proto != nil {
6628 > return
6629 > }
6630 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[59].OneofWrappers = []any{
6631 > (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState)(nil),
6632 > }
6633 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[60].OneofWrappers = []any{
6634 > (*StreamWorkflowReplicationMessagesResponse_Messages)(nil),
6635 > }
6636 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[61].OneofWrappers = []any{
6637 > (*GetNamespaceRequest_Namespace)(nil),
6638 > (*GetNamespaceRequest_Id)(nil),
6639 > }
6640 > file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[90].OneofWrappers = []any{
6641 > (*StartAdminBatchOperationRequest_RefreshTasksOperation)(nil),
6642 > }
6643 > type x struct{}
6644 > out := protoimpl.TypeBuilder{
6645 > File: protoimpl.DescBuilder{
6646 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
6647 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_adminservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_adminservice_v1_request_response_proto_rawDesc)),
6648 > NumEnums: 1,
6649 > NumMessages: 105,
6650 > NumExtensions: 0,
6651 > NumServices: 0,
6652 > },
6653 > GoTypes: file_temporal_server_api_adminservice_v1_request_response_proto_goTypes,
6654 > DependencyIndexes: file_temporal_server_api_adminservice_v1_request_response_proto_depIdxs,
6655 > EnumInfos: file_temporal_server_api_adminservice_v1_request_response_proto_enumTypes,
6656 > MessageInfos: file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes,
6657 > }.Build()
6658 > File_temporal_server_api_adminservice_v1_request_response_proto = out.File
6659 > file_temporal_server_api_adminservice_v1_request_response_proto_goTypes = nil
6660 > file_temporal_server_api_adminservice_v1_request_response_proto_depIdxs = nil
6661 }
go.temporal.io/server/api/replication/v1/message.pb.go 36 covered LOC · 2 ranges

Open complete file

2441 }
2442
2443 > func init() { file_temporal_server_api_replication_v1_message_proto_init() } message.pb.go
2444 > func file_temporal_server_api_replication_v1_message_proto_init() {
2445 > if File_temporal_server_api_replication_v1_message_proto != nil {
2446 return
2447 }
2448 > file_temporal_server_api_replication_v1_message_proto_msgTypes[0].OneofWrappers = []any{ message.pb.go
2449 > (*ReplicationTask_NamespaceTaskAttributes)(nil),
2450 > (*ReplicationTask_SyncShardStatusTaskAttributes)(nil),
2451 > (*ReplicationTask_SyncActivityTaskAttributes)(nil),
2452 > (*ReplicationTask_HistoryTaskAttributes)(nil),
2453 > (*ReplicationTask_SyncWorkflowStateTaskAttributes)(nil),
2454 > (*ReplicationTask_TaskQueueUserDataAttributes)(nil),
2455 > (*ReplicationTask_SyncHsmAttributes)(nil),
2456 > (*ReplicationTask_BackfillHistoryTaskAttributes)(nil),
2457 > (*ReplicationTask_VerifyVersionedTransitionTaskAttributes)(nil),
2458 > (*ReplicationTask_SyncVersionedTransitionTaskAttributes)(nil),
2459 > }
2460 > file_temporal_server_api_replication_v1_message_proto_msgTypes[21].OneofWrappers = []any{
2461 > (*VersionedTransitionArtifact_SyncWorkflowStateMutationAttributes)(nil),
2462 > (*VersionedTransitionArtifact_SyncWorkflowStateSnapshotAttributes)(nil),
2463 > }
2464 > type x struct{}
2465 > out := protoimpl.TypeBuilder{
2466 > File: protoimpl.DescBuilder{
2467 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
2468 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_replication_v1_message_proto_rawDesc), len(file_temporal_server_api_replication_v1_message_proto_rawDesc)),
2469 > NumEnums: 0,
2470 > NumMessages: 23,
2471 > NumExtensions: 0,
2472 > NumServices: 0,
2473 > },
2474 > GoTypes: file_temporal_server_api_replication_v1_message_proto_goTypes,
2475 > DependencyIndexes: file_temporal_server_api_replication_v1_message_proto_depIdxs,
2476 > MessageInfos: file_temporal_server_api_replication_v1_message_proto_msgTypes,
2477 > }.Build()
2478 > File_temporal_server_api_replication_v1_message_proto = out.File
2479 > file_temporal_server_api_replication_v1_message_proto_goTypes = nil
2480 > file_temporal_server_api_replication_v1_message_proto_depIdxs = nil
2481 }
go.temporal.io/server/common/rpc/interceptor/health_check.go 36 covered LOC · 3 ranges

Open complete file

68 )
69
70 > func initExcludedAPIs() { health_check.go
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.
112 > func isExcludedAPI(fullMethod string) bool { health_check.go
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 35 covered LOC · 5 ranges

Open complete file

119 func (*ApiCategoryOptions) ProtoMessage() {}
120
121 > func (x *ApiCategoryOptions) ProtoReflect() protoreflect.Message { api_category.pb.go
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 }
130 > return mi.MessageOf(x) api_category.pb.go
131 }
132
136 }
137
138 > func (x *ApiCategoryOptions) GetCategory() ApiCategory { api_category.pb.go
139 > if x != nil {
140 > return x.Category
141 > }
142 return API_CATEGORY_UNSPECIFIED
143 }
204 }
205
206 > func init() { file_temporal_server_api_common_v1_api_category_proto_init() } api_category.pb.go
207 > func file_temporal_server_api_common_v1_api_category_proto_init() {
208 > if File_temporal_server_api_common_v1_api_category_proto != nil {
209 return
210 }
211 > type x struct{} api_category.pb.go
212 > out := protoimpl.TypeBuilder{
213 > File: protoimpl.DescBuilder{
214 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
215 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_common_v1_api_category_proto_rawDesc), len(file_temporal_server_api_common_v1_api_category_proto_rawDesc)),
216 > NumEnums: 1,
217 > NumMessages: 1,
218 > NumExtensions: 1,
219 > NumServices: 0,
220 > },
221 > GoTypes: file_temporal_server_api_common_v1_api_category_proto_goTypes,
222 > DependencyIndexes: file_temporal_server_api_common_v1_api_category_proto_depIdxs,
223 > EnumInfos: file_temporal_server_api_common_v1_api_category_proto_enumTypes,
224 > MessageInfos: file_temporal_server_api_common_v1_api_category_proto_msgTypes,
225 > ExtensionInfos: file_temporal_server_api_common_v1_api_category_proto_extTypes,
226 > }.Build()
227 > File_temporal_server_api_common_v1_api_category_proto = out.File
228 > file_temporal_server_api_common_v1_api_category_proto_goTypes = nil
229 > file_temporal_server_api_common_v1_api_category_proto_depIdxs = nil
230 }
go.temporal.io/server/common/metrics/defs.go 35 covered LOC · 5 ranges

Open complete file

20 )
21
22 > func NewTimerDef(name string, opts ...Option) timerDefinition { defs.go
23 > // This line cannot be combined with others!
24 > // This ensures the stack trace has information of the caller.
25 > def := newMetricDefinition(name, opts...)
26 > globalRegistry.register(def)
27 > return timerDefinition{def}
28 > }
29
30 > func NewBytesHistogramDef(name string, opts ...Option) histogramDefinition { defs.go
31 > // This line cannot be combined with others!
32 > // This ensures the stack trace has information of the caller.
33 > def := newMetricDefinition(name, append(opts, WithUnit(Bytes))...)
34 > globalRegistry.register(def)
35 > return histogramDefinition{def}
36 > }
37
38 > func NewDimensionlessHistogramDef(name string, opts ...Option) histogramDefinition { defs.go
39 > // This line cannot be combined with others!
40 > // This ensures the stack trace has information of the caller.
41 > def := newMetricDefinition(name, append(opts, WithUnit(Dimensionless))...)
42 > globalRegistry.register(def)
43 > return histogramDefinition{def}
44 > }
45
46 > func NewCounterDef(name string, opts ...Option) counterDefinition { defs.go
47 > // This line cannot be combined with others!
48 > // This ensures the stack trace has information of the caller.
49 > def := newMetricDefinition(name, opts...)
50 > globalRegistry.register(def)
51 > return counterDefinition{def}
52 > }
53
54 > func NewGaugeDef(name string, opts ...Option) gaugeDefinition { defs.go
55 > // This line cannot be combined with others!
56 > // This ensures the stack trace has information of the caller.
57 > def := newMetricDefinition(name, opts...)
58 > globalRegistry.register(def)
59 > return gaugeDefinition{def}
60 > }
61
62 func (d histogramDefinition) With(handler Handler) HistogramIface {
go.temporal.io/server/api/persistence/v1/chasm.pb.go 33 covered LOC · 1 range

Open complete file

1180 }
1181
1182 > func init() { file_temporal_server_api_persistence_v1_chasm_proto_init() } chasm.pb.go
1183 > func file_temporal_server_api_persistence_v1_chasm_proto_init() {
1184 > if File_temporal_server_api_persistence_v1_chasm_proto != nil {
1185 > return
1186 > }
1187 > file_temporal_server_api_persistence_v1_hsm_proto_init()
1188 > file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[1].OneofWrappers = []any{
1189 > (*ChasmNodeMetadata_ComponentAttributes)(nil),
1190 > (*ChasmNodeMetadata_DataAttributes)(nil),
1191 > (*ChasmNodeMetadata_CollectionAttributes)(nil),
1192 > (*ChasmNodeMetadata_PointerAttributes)(nil),
1193 > }
1194 > file_temporal_server_api_persistence_v1_chasm_proto_msgTypes[10].OneofWrappers = []any{
1195 > (*ChasmNexusCompletion_Success)(nil),
1196 > (*ChasmNexusCompletion_Failure)(nil),
1197 > }
1198 > type x struct{}
1199 > out := protoimpl.TypeBuilder{
1200 > File: protoimpl.DescBuilder{
1201 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1202 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_chasm_proto_rawDesc), len(file_temporal_server_api_persistence_v1_chasm_proto_rawDesc)),
1203 > NumEnums: 0,
1204 > NumMessages: 15,
1205 > NumExtensions: 0,
1206 > NumServices: 0,
1207 > },
1208 > GoTypes: file_temporal_server_api_persistence_v1_chasm_proto_goTypes,
1209 > DependencyIndexes: file_temporal_server_api_persistence_v1_chasm_proto_depIdxs,
1210 > MessageInfos: file_temporal_server_api_persistence_v1_chasm_proto_msgTypes,
1211 > }.Build()
1212 > File_temporal_server_api_persistence_v1_chasm_proto = out.File
1213 > file_temporal_server_api_persistence_v1_chasm_proto_goTypes = nil
1214 > file_temporal_server_api_persistence_v1_chasm_proto_depIdxs = nil
1215 }
go.temporal.io/server/api/persistence/v1/hsm.pb.go 32 covered LOC · 1 range

Open complete file

895 }
896
897 > func init() { file_temporal_server_api_persistence_v1_hsm_proto_init() } hsm.pb.go
898 > func file_temporal_server_api_persistence_v1_hsm_proto_init() {
899 > if File_temporal_server_api_persistence_v1_hsm_proto != nil {
900 > return
901 > }
902 > file_temporal_server_api_persistence_v1_hsm_proto_msgTypes[8].OneofWrappers = []any{
903 > (*StateMachineTombstone_ActivityScheduledEventId)(nil),
904 > (*StateMachineTombstone_TimerId)(nil),
905 > (*StateMachineTombstone_ChildExecutionInitiatedEventId)(nil),
906 > (*StateMachineTombstone_RequestCancelInitiatedEventId)(nil),
907 > (*StateMachineTombstone_SignalExternalInitiatedEventId)(nil),
908 > (*StateMachineTombstone_UpdateId)(nil),
909 > (*StateMachineTombstone_StateMachinePath)(nil),
910 > (*StateMachineTombstone_ChasmNodePath)(nil),
911 > }
912 > type x struct{}
913 > out := protoimpl.TypeBuilder{
914 > File: protoimpl.DescBuilder{
915 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
916 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_hsm_proto_rawDesc), len(file_temporal_server_api_persistence_v1_hsm_proto_rawDesc)),
917 > NumEnums: 0,
918 > NumMessages: 12,
919 > NumExtensions: 0,
920 > NumServices: 0,
921 > },
922 > GoTypes: file_temporal_server_api_persistence_v1_hsm_proto_goTypes,
923 > DependencyIndexes: file_temporal_server_api_persistence_v1_hsm_proto_depIdxs,
924 > MessageInfos: file_temporal_server_api_persistence_v1_hsm_proto_msgTypes,
925 > }.Build()
926 > File_temporal_server_api_persistence_v1_hsm_proto = out.File
927 > file_temporal_server_api_persistence_v1_hsm_proto_goTypes = nil
928 > file_temporal_server_api_persistence_v1_hsm_proto_depIdxs = nil
929 }
go.temporal.io/server/api/persistence/v1/update.pb.go 31 covered LOC · 1 range

Open complete file

422 }
423
424 > func init() { file_temporal_server_api_persistence_v1_update_proto_init() } update.pb.go
425 > func file_temporal_server_api_persistence_v1_update_proto_init() {
426 > if File_temporal_server_api_persistence_v1_update_proto != nil {
427 > return
428 > }
429 > file_temporal_server_api_persistence_v1_hsm_proto_init()
430 > file_temporal_server_api_persistence_v1_update_proto_msgTypes[0].OneofWrappers = []any{
431 > (*UpdateAdmissionInfo_HistoryPointer_)(nil),
432 > }
433 > file_temporal_server_api_persistence_v1_update_proto_msgTypes[3].OneofWrappers = []any{
434 > (*UpdateInfo_Acceptance)(nil),
435 > (*UpdateInfo_Completion)(nil),
436 > (*UpdateInfo_Admission)(nil),
437 > }
438 > type x struct{}
439 > out := protoimpl.TypeBuilder{
440 > File: protoimpl.DescBuilder{
441 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
442 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_update_proto_rawDesc), len(file_temporal_server_api_persistence_v1_update_proto_rawDesc)),
443 > NumEnums: 0,
444 > NumMessages: 5,
445 > NumExtensions: 0,
446 > NumServices: 0,
447 > },
448 > GoTypes: file_temporal_server_api_persistence_v1_update_proto_goTypes,
449 > DependencyIndexes: file_temporal_server_api_persistence_v1_update_proto_depIdxs,
450 > MessageInfos: file_temporal_server_api_persistence_v1_update_proto_msgTypes,
451 > }.Build()
452 > File_temporal_server_api_persistence_v1_update_proto = out.File
453 > file_temporal_server_api_persistence_v1_update_proto_goTypes = nil
454 > file_temporal_server_api_persistence_v1_update_proto_depIdxs = nil
455 }
go.temporal.io/server/common/dynamicconfig/deepcopy.go 31 covered LOC · 6 ranges

Open complete file

9 // deepCopyForMapstructure does a simple deep copy of T. Fancy cases (anything other than plain old data)
10 // is not handled and will panic.
11 > func deepCopyForMapstructure[T any](t T) T { deepcopy.go
12 > // nolint:revive // this will be triggered from a static initializer before it can be triggered from production code
13 > return deepCopyValue(reflect.ValueOf(t)).Interface().(T)
14 > }
15
16 > func deepCopyValue(v reflect.Value) reflect.Value { deepcopy.go
17 > switch v.Kind() {
18 case reflect.Bool, reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,
19 reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64,
20 > reflect.Uintptr, reflect.Float32, reflect.Float64, reflect.String: deepcopy.go
21 > nv := reflect.New(v.Type()).Elem()
22 > nv.Set(v)
23 > return nv
24 case reflect.Array:
25 nv := reflect.New(v.Type()).Elem()
42 }
43 return deepCopyValue(v.Elem()).Addr()
44 > case reflect.Slice: deepcopy.go
45 > if v.IsNil() {
46 > return v
47 > }
48 nv := reflect.MakeSlice(v.Type(), v.Len(), v.Len())
49 for i := range v.Len() {
51 }
52 return nv
53 > case reflect.Struct: deepcopy.go
54 > // Special case for time.Time: it has unexported fields so we can't copy it field by
55 > // field, but we can copy zero values (which is all we need for default values).
56 > if v.Type() == reflect.TypeFor[time.Time]() {
57 > if v.Interface().(time.Time).IsZero() {
58 > return reflect.ValueOf(time.Time{})
59 > }
60 // nolint:forbidigo // this will be triggered from a static initializer before it can be triggered from production code
61 panic(fmt.Sprintf("Can't deep copy non-zero time.Time: %v", v.Interface()))
62 }
63 > nv := reflect.New(v.Type()).Elem() deepcopy.go
64 > for i := range v.Type().NumField() {
65 > nv.Field(i).Set(deepCopyValue(v.Field(i)))
66 > }
67 > return nv
68 > case reflect.Interface, reflect.Func, reflect.Chan:
69 > // only nil values of any other reference types allowed!
70 > if v.IsNil() {
71 > return v
72 > }
73 fallthrough
74 default:
go.temporal.io/server/api/routing/v1/extension.pb.go 30 covered LOC · 4 ranges

Open complete file

50 func (*RoutingOptions) ProtoMessage() {}
51
52 > func (x *RoutingOptions) ProtoReflect() protoreflect.Message { extension.pb.go
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 }
61 > return mi.MessageOf(x) extension.pb.go
62 }
63
144 }
145
146 > func init() { file_temporal_server_api_routing_v1_extension_proto_init() } extension.pb.go
147 > func file_temporal_server_api_routing_v1_extension_proto_init() {
148 > if File_temporal_server_api_routing_v1_extension_proto != nil {
149 return
150 }
151 > type x struct{} extension.pb.go
152 > out := protoimpl.TypeBuilder{
153 > File: protoimpl.DescBuilder{
154 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
155 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_routing_v1_extension_proto_rawDesc), len(file_temporal_server_api_routing_v1_extension_proto_rawDesc)),
156 > NumEnums: 0,
157 > NumMessages: 1,
158 > NumExtensions: 1,
159 > NumServices: 0,
160 > },
161 > GoTypes: file_temporal_server_api_routing_v1_extension_proto_goTypes,
162 > DependencyIndexes: file_temporal_server_api_routing_v1_extension_proto_depIdxs,
163 > MessageInfos: file_temporal_server_api_routing_v1_extension_proto_msgTypes,
164 > ExtensionInfos: file_temporal_server_api_routing_v1_extension_proto_extTypes,
165 > }.Build()
166 > File_temporal_server_api_routing_v1_extension_proto = out.File
167 > file_temporal_server_api_routing_v1_extension_proto_goTypes = nil
168 > file_temporal_server_api_routing_v1_extension_proto_depIdxs = nil
169 }
go.temporal.io/server/api/taskqueue/v1/message.pb.go 29 covered LOC · 2 ranges

Open complete file

1330 }
1331
1332 > func init() { file_temporal_server_api_taskqueue_v1_message_proto_init() } message.pb.go
1333 > func file_temporal_server_api_taskqueue_v1_message_proto_init() {
1334 > if File_temporal_server_api_taskqueue_v1_message_proto != nil {
1335 return
1336 }
1337 > file_temporal_server_api_taskqueue_v1_message_proto_msgTypes[0].OneofWrappers = []any{ message.pb.go
1338 > (*TaskVersionDirective_UseAssignmentRules)(nil),
1339 > (*TaskVersionDirective_AssignedBuildId)(nil),
1340 > }
1341 > file_temporal_server_api_taskqueue_v1_message_proto_msgTypes[5].OneofWrappers = []any{
1342 > (*TaskQueuePartition_NormalPartitionId)(nil),
1343 > (*TaskQueuePartition_StickyName)(nil),
1344 > (*TaskQueuePartition_WorkerCommands)(nil),
1345 > }
1346 > type x struct{}
1347 > out := protoimpl.TypeBuilder{
1348 > File: protoimpl.DescBuilder{
1349 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1350 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_taskqueue_v1_message_proto_rawDesc), len(file_temporal_server_api_taskqueue_v1_message_proto_rawDesc)),
1351 > NumEnums: 0,
1352 > NumMessages: 16,
1353 > NumExtensions: 0,
1354 > NumServices: 0,
1355 > },
1356 > GoTypes: file_temporal_server_api_taskqueue_v1_message_proto_goTypes,
1357 > DependencyIndexes: file_temporal_server_api_taskqueue_v1_message_proto_depIdxs,
1358 > MessageInfos: file_temporal_server_api_taskqueue_v1_message_proto_msgTypes,
1359 > }.Build()
1360 > File_temporal_server_api_taskqueue_v1_message_proto = out.File
1361 > file_temporal_server_api_taskqueue_v1_message_proto_goTypes = nil
1362 > file_temporal_server_api_taskqueue_v1_message_proto_depIdxs = nil
1363 }
go.temporal.io/server/common/log/tag/tags.go 27 covered LOC · 9 ranges

Open complete file

70
71 // WorkflowAction returns tag for WorkflowAction
72 > func workflowAction(action string) ZapTag { tags.go
73 > return NewStringTag("wf-action", action)
74 > }
75
76 // WorkflowListFilterType returns tag for WorkflowListFilterType
77 > func workflowListFilterType(listFilterType string) ZapTag { tags.go
78 > return NewStringTag("wf-list-filter-type", listFilterType)
79 > }
80
81 // general
376
377 // Component returns tag for Component
378 > func component(component string) ZapTag { tags.go
379 > return NewStringTag("component", component)
380 > }
381
382 // Lifecycle returns tag for Lifecycle
383 > func lifecycle(lifecycle string) ZapTag { tags.go
384 > return NewStringTag("lifecycle", lifecycle)
385 > }
386
387 // StoreOperation returns tag for StoreOperation
388 > func storeOperation(storeOperation string) ZapTag { tags.go
389 > return NewStringTag("store-operation", storeOperation)
390 > }
391
392 // OperationResult returns tag for OperationResult
393 > func operationResult(operationResult string) ZapTag { tags.go
394 > return NewStringTag("operation-result", operationResult)
395 > }
396
397 // ErrorType returns tag for ErrorType
401
402 // errorType returns tag for ErrorType given a string
403 > func errorType(errorType string) ZapTag { tags.go
404 > return NewStringTag("error-type", errorType)
405 > }
406
407 // Shardupdate returns tag for Shardupdate
408 > func shardupdate(shardupdate string) ZapTag { tags.go
409 > return NewStringTag("shard-update", shardupdate)
410 > }
411
412 // scope returns a tag for scope
413 // Pre-defined scope tags are in values.go.
414 > func scope(scope string) ZapTag { tags.go
415 > return NewStringTag("scope", scope)
416 > }
417
418 // general
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/message.pb.go 26 covered LOC · 1 range

Open complete file

843 }
844
845 > func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_init() } message.pb.go
846 > func file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_init() {
847 > if File_temporal_server_chasm_lib_scheduler_proto_v1_message_proto != nil {
848 > return
849 > }
850 > file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_msgTypes[4].OneofWrappers = []any{
851 > (*BackfillerState_BackfillRequest)(nil),
852 > (*BackfillerState_TriggerRequest)(nil),
853 > }
854 > type x struct{}
855 > out := protoimpl.TypeBuilder{
856 > File: protoimpl.DescBuilder{
857 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
858 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_rawDesc)),
859 > NumEnums: 0,
860 > NumMessages: 12,
861 > NumExtensions: 0,
862 > NumServices: 0,
863 > },
864 > GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_goTypes,
865 > DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_depIdxs,
866 > MessageInfos: file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_msgTypes,
867 > }.Build()
868 > File_temporal_server_chasm_lib_scheduler_proto_v1_message_proto = out.File
869 > file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_goTypes = nil
870 > file_temporal_server_chasm_lib_scheduler_proto_v1_message_proto_depIdxs = nil
871 }
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/activity_state.pb.go 25 covered LOC · 2 ranges

Open complete file

1382 }
1383
1384 > func init() { file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_init() } activity_state.pb.go
1385 > func file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_init() {
1386 > if File_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto != nil {
1387 return
1388 }
1389 > file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_msgTypes[7].OneofWrappers = []any{ activity_state.pb.go
1390 > (*ActivityOutcome_Successful_)(nil),
1391 > (*ActivityOutcome_Failed_)(nil),
1392 > }
1393 > type x struct{}
1394 > out := protoimpl.TypeBuilder{
1395 > File: protoimpl.DescBuilder{
1396 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1397 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_rawDesc), len(file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_rawDesc)),
1398 > NumEnums: 2,
1399 > NumMessages: 11,
1400 > NumExtensions: 0,
1401 > NumServices: 0,
1402 > },
1403 > GoTypes: file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_goTypes,
1404 > DependencyIndexes: file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_depIdxs,
1405 > EnumInfos: file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_enumTypes,
1406 > MessageInfos: file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_msgTypes,
1407 > }.Build()
1408 > File_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto = out.File
1409 > file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_goTypes = nil
1410 > file_temporal_server_chasm_lib_activity_proto_v1_activity_state_proto_depIdxs = nil
1411 }
go.temporal.io/server/api/persistence/v1/nexus.pb.go 24 covered LOC · 2 ranges

Open complete file

481 }
482
483 > func init() { file_temporal_server_api_persistence_v1_nexus_proto_init() } nexus.pb.go
484 > func file_temporal_server_api_persistence_v1_nexus_proto_init() {
485 > if File_temporal_server_api_persistence_v1_nexus_proto != nil {
486 return
487 }
488 > file_temporal_server_api_persistence_v1_nexus_proto_msgTypes[1].OneofWrappers = []any{ nexus.pb.go
489 > (*NexusEndpointTarget_Worker_)(nil),
490 > (*NexusEndpointTarget_External_)(nil),
491 > }
492 > type x struct{}
493 > out := protoimpl.TypeBuilder{
494 > File: protoimpl.DescBuilder{
495 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
496 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_nexus_proto_rawDesc), len(file_temporal_server_api_persistence_v1_nexus_proto_rawDesc)),
497 > NumEnums: 0,
498 > NumMessages: 6,
499 > NumExtensions: 0,
500 > NumServices: 0,
501 > },
502 > GoTypes: file_temporal_server_api_persistence_v1_nexus_proto_goTypes,
503 > DependencyIndexes: file_temporal_server_api_persistence_v1_nexus_proto_depIdxs,
504 > MessageInfos: file_temporal_server_api_persistence_v1_nexus_proto_msgTypes,
505 > }.Build()
506 > File_temporal_server_api_persistence_v1_nexus_proto = out.File
507 > file_temporal_server_api_persistence_v1_nexus_proto_goTypes = nil
508 > file_temporal_server_api_persistence_v1_nexus_proto_depIdxs = nil
509 }
go.temporal.io/server/api/persistence/v1/workflow_mutable_state.pb.go 24 covered LOC · 2 ranges

Open complete file

532 }
533
534 > func init() { file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_init() } workflow_mutable_state.pb.go
535 > func file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_init() {
536 > if File_temporal_server_api_persistence_v1_workflow_mutable_state_proto != nil {
537 return
538 }
539 > file_temporal_server_api_persistence_v1_chasm_proto_init() workflow_mutable_state.pb.go
540 > file_temporal_server_api_persistence_v1_executions_proto_init()
541 > file_temporal_server_api_persistence_v1_hsm_proto_init()
542 > file_temporal_server_api_persistence_v1_update_proto_init()
543 > type x struct{}
544 > out := protoimpl.TypeBuilder{
545 > File: protoimpl.DescBuilder{
546 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
547 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_rawDesc), len(file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_rawDesc)),
548 > NumEnums: 0,
549 > NumMessages: 16,
550 > NumExtensions: 0,
551 > NumServices: 0,
552 > },
553 > GoTypes: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_goTypes,
554 > DependencyIndexes: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_depIdxs,
555 > MessageInfos: file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_msgTypes,
556 > }.Build()
557 > File_temporal_server_api_persistence_v1_workflow_mutable_state_proto = out.File
558 > file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_goTypes = nil
559 > file_temporal_server_api_persistence_v1_workflow_mutable_state_proto_depIdxs = nil
560 }
go.temporal.io/server/api/schedule/v1/message.pb.go 24 covered LOC · 2 ranges

Open complete file

1224 }
1225
1226 > func init() { file_temporal_server_api_schedule_v1_message_proto_init() } message.pb.go
1227 > func file_temporal_server_api_schedule_v1_message_proto_init() {
1228 > if File_temporal_server_api_schedule_v1_message_proto != nil {
1229 return
1230 }
1231 > file_temporal_server_api_schedule_v1_message_proto_msgTypes[7].OneofWrappers = []any{ message.pb.go
1232 > (*WatchWorkflowResponse_Result)(nil),
1233 > (*WatchWorkflowResponse_Failure)(nil),
1234 > }
1235 > type x struct{}
1236 > out := protoimpl.TypeBuilder{
1237 > File: protoimpl.DescBuilder{
1238 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
1239 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_schedule_v1_message_proto_rawDesc), len(file_temporal_server_api_schedule_v1_message_proto_rawDesc)),
1240 > NumEnums: 0,
1241 > NumMessages: 13,
1242 > NumExtensions: 0,
1243 > NumServices: 0,
1244 > },
1245 > GoTypes: file_temporal_server_api_schedule_v1_message_proto_goTypes,
1246 > DependencyIndexes: file_temporal_server_api_schedule_v1_message_proto_depIdxs,
1247 > MessageInfos: file_temporal_server_api_schedule_v1_message_proto_msgTypes,
1248 > }.Build()
1249 > File_temporal_server_api_schedule_v1_message_proto = out.File
1250 > file_temporal_server_api_schedule_v1_message_proto_goTypes = nil
1251 > file_temporal_server_api_schedule_v1_message_proto_depIdxs = nil
1252 }
go.temporal.io/server/api/enums/v1/predicate.pb.go 23 covered LOC · 3 ranges

Open complete file

111 }
112
113 > func (PredicateType) Descriptor() protoreflect.EnumDescriptor { predicate.pb.go
114 > return file_temporal_server_api_enums_v1_predicate_proto_enumTypes[0].Descriptor()
115 > }
116
117 func (PredicateType) Type() protoreflect.EnumType {
170 }
171
172 > func init() { file_temporal_server_api_enums_v1_predicate_proto_init() } predicate.pb.go
173 > func file_temporal_server_api_enums_v1_predicate_proto_init() {
174 > if File_temporal_server_api_enums_v1_predicate_proto != nil {
175 return
176 }
177 > type x struct{} predicate.pb.go
178 > out := protoimpl.TypeBuilder{
179 > File: protoimpl.DescBuilder{
180 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
181 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_predicate_proto_rawDesc), len(file_temporal_server_api_enums_v1_predicate_proto_rawDesc)),
182 > NumEnums: 1,
183 > NumMessages: 0,
184 > NumExtensions: 0,
185 > NumServices: 0,
186 > },
187 > GoTypes: file_temporal_server_api_enums_v1_predicate_proto_goTypes,
188 > DependencyIndexes: file_temporal_server_api_enums_v1_predicate_proto_depIdxs,
189 > EnumInfos: file_temporal_server_api_enums_v1_predicate_proto_enumTypes,
190 > }.Build()
191 > File_temporal_server_api_enums_v1_predicate_proto = out.File
192 > file_temporal_server_api_enums_v1_predicate_proto_goTypes = nil
193 > file_temporal_server_api_enums_v1_predicate_proto_depIdxs = nil
194 }
go.temporal.io/server/api/enums/v1/task.pb.go 23 covered LOC · 3 ranges

Open complete file

303 }
304
305 > func (TaskType) Descriptor() protoreflect.EnumDescriptor { task.pb.go
306 > return file_temporal_server_api_enums_v1_task_proto_enumTypes[1].Descriptor()
307 > }
308
309 func (TaskType) Type() protoreflect.EnumType {
456 }
457
458 > func init() { file_temporal_server_api_enums_v1_task_proto_init() } task.pb.go
459 > func file_temporal_server_api_enums_v1_task_proto_init() {
460 > if File_temporal_server_api_enums_v1_task_proto != nil {
461 return
462 }
463 > type x struct{} task.pb.go
464 > out := protoimpl.TypeBuilder{
465 > File: protoimpl.DescBuilder{
466 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
467 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_task_proto_rawDesc), len(file_temporal_server_api_enums_v1_task_proto_rawDesc)),
468 > NumEnums: 3,
469 > NumMessages: 0,
470 > NumExtensions: 0,
471 > NumServices: 0,
472 > },
473 > GoTypes: file_temporal_server_api_enums_v1_task_proto_goTypes,
474 > DependencyIndexes: file_temporal_server_api_enums_v1_task_proto_depIdxs,
475 > EnumInfos: file_temporal_server_api_enums_v1_task_proto_enumTypes,
476 > }.Build()
477 > File_temporal_server_api_enums_v1_task_proto = out.File
478 > file_temporal_server_api_enums_v1_task_proto_goTypes = nil
479 > file_temporal_server_api_enums_v1_task_proto_depIdxs = nil
480 }
go.temporal.io/server/api/persistence/v1/queues.pb.go 23 covered LOC · 1 range

Open complete file

616 }
617
618 > func init() { file_temporal_server_api_persistence_v1_queues_proto_init() } queues.pb.go
619 > func file_temporal_server_api_persistence_v1_queues_proto_init() {
620 > if File_temporal_server_api_persistence_v1_queues_proto != nil {
621 > return
622 > }
623 > file_temporal_server_api_persistence_v1_predicates_proto_init()
624 > type x struct{}
625 > out := protoimpl.TypeBuilder{
626 > File: protoimpl.DescBuilder{
627 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
628 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_queues_proto_rawDesc), len(file_temporal_server_api_persistence_v1_queues_proto_rawDesc)),
629 > NumEnums: 0,
630 > NumMessages: 12,
631 > NumExtensions: 0,
632 > NumServices: 0,
633 > },
634 > GoTypes: file_temporal_server_api_persistence_v1_queues_proto_goTypes,
635 > DependencyIndexes: file_temporal_server_api_persistence_v1_queues_proto_depIdxs,
636 > MessageInfos: file_temporal_server_api_persistence_v1_queues_proto_msgTypes,
637 > }.Build()
638 > File_temporal_server_api_persistence_v1_queues_proto = out.File
639 > file_temporal_server_api_persistence_v1_queues_proto_goTypes = nil
640 > file_temporal_server_api_persistence_v1_queues_proto_depIdxs = nil
641 }
go.temporal.io/server/api/persistence/v1/task_queues.pb.go 21 covered LOC · 2 ranges

Open complete file

899 }
900
901 > func init() { file_temporal_server_api_persistence_v1_task_queues_proto_init() } task_queues.pb.go
902 > func file_temporal_server_api_persistence_v1_task_queues_proto_init() {
903 > if File_temporal_server_api_persistence_v1_task_queues_proto != nil {
904 return
905 }
906 > type x struct{} task_queues.pb.go
907 > out := protoimpl.TypeBuilder{
908 > File: protoimpl.DescBuilder{
909 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
910 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_task_queues_proto_rawDesc), len(file_temporal_server_api_persistence_v1_task_queues_proto_rawDesc)),
911 > NumEnums: 1,
912 > NumMessages: 13,
913 > NumExtensions: 0,
914 > NumServices: 0,
915 > },
916 > GoTypes: file_temporal_server_api_persistence_v1_task_queues_proto_goTypes,
917 > DependencyIndexes: file_temporal_server_api_persistence_v1_task_queues_proto_depIdxs,
918 > EnumInfos: file_temporal_server_api_persistence_v1_task_queues_proto_enumTypes,
919 > MessageInfos: file_temporal_server_api_persistence_v1_task_queues_proto_msgTypes,
920 > }.Build()
921 > File_temporal_server_api_persistence_v1_task_queues_proto = out.File
922 > file_temporal_server_api_persistence_v1_task_queues_proto_goTypes = nil
923 > file_temporal_server_api_persistence_v1_task_queues_proto_depIdxs = nil
924 }
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/tasks.pb.go 21 covered LOC · 2 ranges

Open complete file

495 }
496
497 > func init() { file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_init() } tasks.pb.go
498 > func file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_init() {
499 > if File_temporal_server_chasm_lib_activity_proto_v1_tasks_proto != nil {
500 return
501 }
502 > type x struct{} tasks.pb.go
503 > out := protoimpl.TypeBuilder{
504 > File: protoimpl.DescBuilder{
505 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
506 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_rawDesc), len(file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_rawDesc)),
507 > NumEnums: 2,
508 > NumMessages: 5,
509 > NumExtensions: 0,
510 > NumServices: 0,
511 > },
512 > GoTypes: file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_goTypes,
513 > DependencyIndexes: file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_depIdxs,
514 > EnumInfos: file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_enumTypes,
515 > MessageInfos: file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_msgTypes,
516 > }.Build()
517 > File_temporal_server_chasm_lib_activity_proto_v1_tasks_proto = out.File
518 > file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_goTypes = nil
519 > file_temporal_server_chasm_lib_activity_proto_v1_tasks_proto_depIdxs = nil
520 }
go.temporal.io/server/api/adminservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

273 }
274
275 > func init() { file_temporal_server_api_adminservice_v1_service_proto_init() } service.pb.go
276 > func file_temporal_server_api_adminservice_v1_service_proto_init() {
277 > if File_temporal_server_api_adminservice_v1_service_proto != nil {
278 return
279 }
280 > file_temporal_server_api_adminservice_v1_request_response_proto_init() service.pb.go
281 > type x struct{}
282 > out := protoimpl.TypeBuilder{
283 > File: protoimpl.DescBuilder{
284 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
285 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_adminservice_v1_service_proto_rawDesc), len(file_temporal_server_api_adminservice_v1_service_proto_rawDesc)),
286 > NumEnums: 0,
287 > NumMessages: 0,
288 > NumExtensions: 0,
289 > NumServices: 1,
290 > },
291 > GoTypes: file_temporal_server_api_adminservice_v1_service_proto_goTypes,
292 > DependencyIndexes: file_temporal_server_api_adminservice_v1_service_proto_depIdxs,
293 > }.Build()
294 > File_temporal_server_api_adminservice_v1_service_proto = out.File
295 > file_temporal_server_api_adminservice_v1_service_proto_goTypes = nil
296 > file_temporal_server_api_adminservice_v1_service_proto_depIdxs = nil
297 }
go.temporal.io/server/api/chasm/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

206 }
207
208 > func init() { file_temporal_server_api_chasm_v1_message_proto_init() } message.pb.go
209 > func file_temporal_server_api_chasm_v1_message_proto_init() {
210 > if File_temporal_server_api_chasm_v1_message_proto != nil {
211 return
212 }
213 > type x struct{} message.pb.go
214 > out := protoimpl.TypeBuilder{
215 > File: protoimpl.DescBuilder{
216 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
217 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_chasm_v1_message_proto_rawDesc), len(file_temporal_server_api_chasm_v1_message_proto_rawDesc)),
218 > NumEnums: 0,
219 > NumMessages: 1,
220 > NumExtensions: 0,
221 > NumServices: 0,
222 > },
223 > GoTypes: file_temporal_server_api_chasm_v1_message_proto_goTypes,
224 > DependencyIndexes: file_temporal_server_api_chasm_v1_message_proto_depIdxs,
225 > MessageInfos: file_temporal_server_api_chasm_v1_message_proto_msgTypes,
226 > }.Build()
227 > File_temporal_server_api_chasm_v1_message_proto = out.File
228 > file_temporal_server_api_chasm_v1_message_proto_goTypes = nil
229 > file_temporal_server_api_chasm_v1_message_proto_depIdxs = nil
230 }
go.temporal.io/server/api/clock/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

193 }
194
195 > func init() { file_temporal_server_api_clock_v1_message_proto_init() } message.pb.go
196 > func file_temporal_server_api_clock_v1_message_proto_init() {
197 > if File_temporal_server_api_clock_v1_message_proto != nil {
198 return
199 }
200 > type x struct{} message.pb.go
201 > out := protoimpl.TypeBuilder{
202 > File: protoimpl.DescBuilder{
203 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
204 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_clock_v1_message_proto_rawDesc), len(file_temporal_server_api_clock_v1_message_proto_rawDesc)),
205 > NumEnums: 0,
206 > NumMessages: 2,
207 > NumExtensions: 0,
208 > NumServices: 0,
209 > },
210 > GoTypes: file_temporal_server_api_clock_v1_message_proto_goTypes,
211 > DependencyIndexes: file_temporal_server_api_clock_v1_message_proto_depIdxs,
212 > MessageInfos: file_temporal_server_api_clock_v1_message_proto_msgTypes,
213 > }.Build()
214 > File_temporal_server_api_clock_v1_message_proto = out.File
215 > file_temporal_server_api_clock_v1_message_proto_goTypes = nil
216 > file_temporal_server_api_clock_v1_message_proto_depIdxs = nil
217 }
go.temporal.io/server/api/cluster/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

342 }
343
344 > func init() { file_temporal_server_api_cluster_v1_message_proto_init() } message.pb.go
345 > func file_temporal_server_api_cluster_v1_message_proto_init() {
346 > if File_temporal_server_api_cluster_v1_message_proto != nil {
347 return
348 }
349 > type x struct{} message.pb.go
350 > out := protoimpl.TypeBuilder{
351 > File: protoimpl.DescBuilder{
352 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
353 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_cluster_v1_message_proto_rawDesc), len(file_temporal_server_api_cluster_v1_message_proto_rawDesc)),
354 > NumEnums: 0,
355 > NumMessages: 4,
356 > NumExtensions: 0,
357 > NumServices: 0,
358 > },
359 > GoTypes: file_temporal_server_api_cluster_v1_message_proto_goTypes,
360 > DependencyIndexes: file_temporal_server_api_cluster_v1_message_proto_depIdxs,
361 > MessageInfos: file_temporal_server_api_cluster_v1_message_proto_msgTypes,
362 > }.Build()
363 > File_temporal_server_api_cluster_v1_message_proto = out.File
364 > file_temporal_server_api_cluster_v1_message_proto_goTypes = nil
365 > file_temporal_server_api_cluster_v1_message_proto_depIdxs = nil
366 }
go.temporal.io/server/api/common/v1/dlq.pb.go 20 covered LOC · 2 ranges

Open complete file

295 }
296
297 > func init() { file_temporal_server_api_common_v1_dlq_proto_init() } dlq.pb.go
298 > func file_temporal_server_api_common_v1_dlq_proto_init() {
299 > if File_temporal_server_api_common_v1_dlq_proto != nil {
300 return
301 }
302 > type x struct{} dlq.pb.go
303 > out := protoimpl.TypeBuilder{
304 > File: protoimpl.DescBuilder{
305 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
306 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_common_v1_dlq_proto_rawDesc), len(file_temporal_server_api_common_v1_dlq_proto_rawDesc)),
307 > NumEnums: 0,
308 > NumMessages: 4,
309 > NumExtensions: 0,
310 > NumServices: 0,
311 > },
312 > GoTypes: file_temporal_server_api_common_v1_dlq_proto_goTypes,
313 > DependencyIndexes: file_temporal_server_api_common_v1_dlq_proto_depIdxs,
314 > MessageInfos: file_temporal_server_api_common_v1_dlq_proto_msgTypes,
315 > }.Build()
316 > File_temporal_server_api_common_v1_dlq_proto = out.File
317 > file_temporal_server_api_common_v1_dlq_proto_goTypes = nil
318 > file_temporal_server_api_common_v1_dlq_proto_depIdxs = nil
319 }
go.temporal.io/server/api/contextpropagation/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

109 }
110
111 > func init() { file_temporal_server_api_contextpropagation_v1_message_proto_init() } message.pb.go
112 > func file_temporal_server_api_contextpropagation_v1_message_proto_init() {
113 > if File_temporal_server_api_contextpropagation_v1_message_proto != nil {
114 return
115 }
116 > type x struct{} message.pb.go
117 > out := protoimpl.TypeBuilder{
118 > File: protoimpl.DescBuilder{
119 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
120 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_contextpropagation_v1_message_proto_rawDesc), len(file_temporal_server_api_contextpropagation_v1_message_proto_rawDesc)),
121 > NumEnums: 0,
122 > NumMessages: 2,
123 > NumExtensions: 0,
124 > NumServices: 0,
125 > },
126 > GoTypes: file_temporal_server_api_contextpropagation_v1_message_proto_goTypes,
127 > DependencyIndexes: file_temporal_server_api_contextpropagation_v1_message_proto_depIdxs,
128 > MessageInfos: file_temporal_server_api_contextpropagation_v1_message_proto_msgTypes,
129 > }.Build()
130 > File_temporal_server_api_contextpropagation_v1_message_proto = out.File
131 > file_temporal_server_api_contextpropagation_v1_message_proto_goTypes = nil
132 > file_temporal_server_api_contextpropagation_v1_message_proto_depIdxs = nil
133 }
go.temporal.io/server/api/deployment/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

4626 }
4627
4628 > func init() { file_temporal_server_api_deployment_v1_message_proto_init() } message.pb.go
4629 > func file_temporal_server_api_deployment_v1_message_proto_init() {
4630 > if File_temporal_server_api_deployment_v1_message_proto != nil {
4631 return
4632 }
4633 > type x struct{} message.pb.go
4634 > out := protoimpl.TypeBuilder{
4635 > File: protoimpl.DescBuilder{
4636 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
4637 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_deployment_v1_message_proto_rawDesc), len(file_temporal_server_api_deployment_v1_message_proto_rawDesc)),
4638 > NumEnums: 0,
4639 > NumMessages: 75,
4640 > NumExtensions: 0,
4641 > NumServices: 0,
4642 > },
4643 > GoTypes: file_temporal_server_api_deployment_v1_message_proto_goTypes,
4644 > DependencyIndexes: file_temporal_server_api_deployment_v1_message_proto_depIdxs,
4645 > MessageInfos: file_temporal_server_api_deployment_v1_message_proto_msgTypes,
4646 > }.Build()
4647 > File_temporal_server_api_deployment_v1_message_proto = out.File
4648 > file_temporal_server_api_deployment_v1_message_proto_goTypes = nil
4649 > file_temporal_server_api_deployment_v1_message_proto_depIdxs = nil
4650 }
go.temporal.io/server/api/enums/v1/cluster.pb.go 20 covered LOC · 2 ranges

Open complete file

209 }
210
211 > func init() { file_temporal_server_api_enums_v1_cluster_proto_init() } cluster.pb.go
212 > func file_temporal_server_api_enums_v1_cluster_proto_init() {
213 > if File_temporal_server_api_enums_v1_cluster_proto != nil {
214 return
215 }
216 > type x struct{} cluster.pb.go
217 > out := protoimpl.TypeBuilder{
218 > File: protoimpl.DescBuilder{
219 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
220 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_cluster_proto_rawDesc), len(file_temporal_server_api_enums_v1_cluster_proto_rawDesc)),
221 > NumEnums: 2,
222 > NumMessages: 0,
223 > NumExtensions: 0,
224 > NumServices: 0,
225 > },
226 > GoTypes: file_temporal_server_api_enums_v1_cluster_proto_goTypes,
227 > DependencyIndexes: file_temporal_server_api_enums_v1_cluster_proto_depIdxs,
228 > EnumInfos: file_temporal_server_api_enums_v1_cluster_proto_enumTypes,
229 > }.Build()
230 > File_temporal_server_api_enums_v1_cluster_proto = out.File
231 > file_temporal_server_api_enums_v1_cluster_proto_goTypes = nil
232 > file_temporal_server_api_enums_v1_cluster_proto_depIdxs = nil
233 }
go.temporal.io/server/api/enums/v1/common.pb.go 20 covered LOC · 2 ranges

Open complete file

264 }
265
266 > func init() { file_temporal_server_api_enums_v1_common_proto_init() } common.pb.go
267 > func file_temporal_server_api_enums_v1_common_proto_init() {
268 > if File_temporal_server_api_enums_v1_common_proto != nil {
269 return
270 }
271 > type x struct{} common.pb.go
272 > out := protoimpl.TypeBuilder{
273 > File: protoimpl.DescBuilder{
274 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
275 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_common_proto_rawDesc), len(file_temporal_server_api_enums_v1_common_proto_rawDesc)),
276 > NumEnums: 3,
277 > NumMessages: 0,
278 > NumExtensions: 0,
279 > NumServices: 0,
280 > },
281 > GoTypes: file_temporal_server_api_enums_v1_common_proto_goTypes,
282 > DependencyIndexes: file_temporal_server_api_enums_v1_common_proto_depIdxs,
283 > EnumInfos: file_temporal_server_api_enums_v1_common_proto_enumTypes,
284 > }.Build()
285 > File_temporal_server_api_enums_v1_common_proto = out.File
286 > file_temporal_server_api_enums_v1_common_proto_goTypes = nil
287 > file_temporal_server_api_enums_v1_common_proto_depIdxs = nil
288 }
go.temporal.io/server/api/enums/v1/dlq.pb.go 20 covered LOC · 2 ranges

Open complete file

187 }
188
189 > func init() { file_temporal_server_api_enums_v1_dlq_proto_init() } dlq.pb.go
190 > func file_temporal_server_api_enums_v1_dlq_proto_init() {
191 > if File_temporal_server_api_enums_v1_dlq_proto != nil {
192 return
193 }
194 > type x struct{} dlq.pb.go
195 > out := protoimpl.TypeBuilder{
196 > File: protoimpl.DescBuilder{
197 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
198 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_dlq_proto_rawDesc), len(file_temporal_server_api_enums_v1_dlq_proto_rawDesc)),
199 > NumEnums: 2,
200 > NumMessages: 0,
201 > NumExtensions: 0,
202 > NumServices: 0,
203 > },
204 > GoTypes: file_temporal_server_api_enums_v1_dlq_proto_goTypes,
205 > DependencyIndexes: file_temporal_server_api_enums_v1_dlq_proto_depIdxs,
206 > EnumInfos: file_temporal_server_api_enums_v1_dlq_proto_enumTypes,
207 > }.Build()
208 > File_temporal_server_api_enums_v1_dlq_proto = out.File
209 > file_temporal_server_api_enums_v1_dlq_proto_goTypes = nil
210 > file_temporal_server_api_enums_v1_dlq_proto_depIdxs = nil
211 }
go.temporal.io/server/api/enums/v1/fairness_state.pb.go 20 covered LOC · 2 ranges

Open complete file

123 }
124
125 > func init() { file_temporal_server_api_enums_v1_fairness_state_proto_init() } fairness_state.pb.go
126 > func file_temporal_server_api_enums_v1_fairness_state_proto_init() {
127 > if File_temporal_server_api_enums_v1_fairness_state_proto != nil {
128 return
129 }
130 > type x struct{} fairness_state.pb.go
131 > out := protoimpl.TypeBuilder{
132 > File: protoimpl.DescBuilder{
133 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
134 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_fairness_state_proto_rawDesc), len(file_temporal_server_api_enums_v1_fairness_state_proto_rawDesc)),
135 > NumEnums: 1,
136 > NumMessages: 0,
137 > NumExtensions: 0,
138 > NumServices: 0,
139 > },
140 > GoTypes: file_temporal_server_api_enums_v1_fairness_state_proto_goTypes,
141 > DependencyIndexes: file_temporal_server_api_enums_v1_fairness_state_proto_depIdxs,
142 > EnumInfos: file_temporal_server_api_enums_v1_fairness_state_proto_enumTypes,
143 > }.Build()
144 > File_temporal_server_api_enums_v1_fairness_state_proto = out.File
145 > file_temporal_server_api_enums_v1_fairness_state_proto_goTypes = nil
146 > file_temporal_server_api_enums_v1_fairness_state_proto_depIdxs = nil
147 }
go.temporal.io/server/api/enums/v1/nexus.pb.go 20 covered LOC · 2 ranges

Open complete file

158 }
159
160 > func init() { file_temporal_server_api_enums_v1_nexus_proto_init() } nexus.pb.go
161 > func file_temporal_server_api_enums_v1_nexus_proto_init() {
162 > if File_temporal_server_api_enums_v1_nexus_proto != nil {
163 return
164 }
165 > type x struct{} nexus.pb.go
166 > out := protoimpl.TypeBuilder{
167 > File: protoimpl.DescBuilder{
168 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
169 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_nexus_proto_rawDesc), len(file_temporal_server_api_enums_v1_nexus_proto_rawDesc)),
170 > NumEnums: 1,
171 > NumMessages: 0,
172 > NumExtensions: 0,
173 > NumServices: 0,
174 > },
175 > GoTypes: file_temporal_server_api_enums_v1_nexus_proto_goTypes,
176 > DependencyIndexes: file_temporal_server_api_enums_v1_nexus_proto_depIdxs,
177 > EnumInfos: file_temporal_server_api_enums_v1_nexus_proto_enumTypes,
178 > }.Build()
179 > File_temporal_server_api_enums_v1_nexus_proto = out.File
180 > file_temporal_server_api_enums_v1_nexus_proto_goTypes = nil
181 > file_temporal_server_api_enums_v1_nexus_proto_depIdxs = nil
182 }
go.temporal.io/server/api/enums/v1/replication.pb.go 20 covered LOC · 2 ranges

Open complete file

314 }
315
316 > func init() { file_temporal_server_api_enums_v1_replication_proto_init() } replication.pb.go
317 > func file_temporal_server_api_enums_v1_replication_proto_init() {
318 > if File_temporal_server_api_enums_v1_replication_proto != nil {
319 return
320 }
321 > type x struct{} replication.pb.go
322 > out := protoimpl.TypeBuilder{
323 > File: protoimpl.DescBuilder{
324 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
325 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_replication_proto_rawDesc), len(file_temporal_server_api_enums_v1_replication_proto_rawDesc)),
326 > NumEnums: 3,
327 > NumMessages: 0,
328 > NumExtensions: 0,
329 > NumServices: 0,
330 > },
331 > GoTypes: file_temporal_server_api_enums_v1_replication_proto_goTypes,
332 > DependencyIndexes: file_temporal_server_api_enums_v1_replication_proto_depIdxs,
333 > EnumInfos: file_temporal_server_api_enums_v1_replication_proto_enumTypes,
334 > }.Build()
335 > File_temporal_server_api_enums_v1_replication_proto = out.File
336 > file_temporal_server_api_enums_v1_replication_proto_goTypes = nil
337 > file_temporal_server_api_enums_v1_replication_proto_depIdxs = nil
338 }
go.temporal.io/server/api/enums/v1/workflow.pb.go 20 covered LOC · 2 ranges

Open complete file

275 }
276
277 > func init() { file_temporal_server_api_enums_v1_workflow_proto_init() } workflow.pb.go
278 > func file_temporal_server_api_enums_v1_workflow_proto_init() {
279 > if File_temporal_server_api_enums_v1_workflow_proto != nil {
280 return
281 }
282 > type x struct{} workflow.pb.go
283 > out := protoimpl.TypeBuilder{
284 > File: protoimpl.DescBuilder{
285 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
286 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_workflow_proto_rawDesc), len(file_temporal_server_api_enums_v1_workflow_proto_rawDesc)),
287 > NumEnums: 3,
288 > NumMessages: 0,
289 > NumExtensions: 0,
290 > NumServices: 0,
291 > },
292 > GoTypes: file_temporal_server_api_enums_v1_workflow_proto_goTypes,
293 > DependencyIndexes: file_temporal_server_api_enums_v1_workflow_proto_depIdxs,
294 > EnumInfos: file_temporal_server_api_enums_v1_workflow_proto_enumTypes,
295 > }.Build()
296 > File_temporal_server_api_enums_v1_workflow_proto = out.File
297 > file_temporal_server_api_enums_v1_workflow_proto_goTypes = nil
298 > file_temporal_server_api_enums_v1_workflow_proto_depIdxs = nil
299 }
go.temporal.io/server/api/enums/v1/workflow_task_type.pb.go 20 covered LOC · 2 ranges

Open complete file

124 }
125
126 > func init() { file_temporal_server_api_enums_v1_workflow_task_type_proto_init() } workflow_task_type.pb.go
127 > func file_temporal_server_api_enums_v1_workflow_task_type_proto_init() {
128 > if File_temporal_server_api_enums_v1_workflow_task_type_proto != nil {
129 return
130 }
131 > type x struct{} workflow_task_type.pb.go
132 > out := protoimpl.TypeBuilder{
133 > File: protoimpl.DescBuilder{
134 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
135 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_enums_v1_workflow_task_type_proto_rawDesc), len(file_temporal_server_api_enums_v1_workflow_task_type_proto_rawDesc)),
136 > NumEnums: 1,
137 > NumMessages: 0,
138 > NumExtensions: 0,
139 > NumServices: 0,
140 > },
141 > GoTypes: file_temporal_server_api_enums_v1_workflow_task_type_proto_goTypes,
142 > DependencyIndexes: file_temporal_server_api_enums_v1_workflow_task_type_proto_depIdxs,
143 > EnumInfos: file_temporal_server_api_enums_v1_workflow_task_type_proto_enumTypes,
144 > }.Build()
145 > File_temporal_server_api_enums_v1_workflow_task_type_proto = out.File
146 > file_temporal_server_api_enums_v1_workflow_task_type_proto_goTypes = nil
147 > file_temporal_server_api_enums_v1_workflow_task_type_proto_depIdxs = nil
148 }
go.temporal.io/server/api/errordetails/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

625 }
626
627 > func init() { file_temporal_server_api_errordetails_v1_message_proto_init() } message.pb.go
628 > func file_temporal_server_api_errordetails_v1_message_proto_init() {
629 > if File_temporal_server_api_errordetails_v1_message_proto != nil {
630 return
631 }
632 > type x struct{} message.pb.go
633 > out := protoimpl.TypeBuilder{
634 > File: protoimpl.DescBuilder{
635 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
636 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_errordetails_v1_message_proto_rawDesc), len(file_temporal_server_api_errordetails_v1_message_proto_rawDesc)),
637 > NumEnums: 0,
638 > NumMessages: 10,
639 > NumExtensions: 0,
640 > NumServices: 0,
641 > },
642 > GoTypes: file_temporal_server_api_errordetails_v1_message_proto_goTypes,
643 > DependencyIndexes: file_temporal_server_api_errordetails_v1_message_proto_depIdxs,
644 > MessageInfos: file_temporal_server_api_errordetails_v1_message_proto_msgTypes,
645 > }.Build()
646 > File_temporal_server_api_errordetails_v1_message_proto = out.File
647 > file_temporal_server_api_errordetails_v1_message_proto_goTypes = nil
648 > file_temporal_server_api_errordetails_v1_message_proto_depIdxs = nil
649 }
go.temporal.io/server/api/health/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

300 }
301
302 > func init() { file_temporal_server_api_health_v1_message_proto_init() } message.pb.go
303 > func file_temporal_server_api_health_v1_message_proto_init() {
304 > if File_temporal_server_api_health_v1_message_proto != nil {
305 return
306 }
307 > type x struct{} message.pb.go
308 > out := protoimpl.TypeBuilder{
309 > File: protoimpl.DescBuilder{
310 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
311 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_health_v1_message_proto_rawDesc), len(file_temporal_server_api_health_v1_message_proto_rawDesc)),
312 > NumEnums: 0,
313 > NumMessages: 3,
314 > NumExtensions: 0,
315 > NumServices: 0,
316 > },
317 > GoTypes: file_temporal_server_api_health_v1_message_proto_goTypes,
318 > DependencyIndexes: file_temporal_server_api_health_v1_message_proto_depIdxs,
319 > MessageInfos: file_temporal_server_api_health_v1_message_proto_msgTypes,
320 > }.Build()
321 > File_temporal_server_api_health_v1_message_proto = out.File
322 > file_temporal_server_api_health_v1_message_proto_goTypes = nil
323 > file_temporal_server_api_health_v1_message_proto_depIdxs = nil
324 }
go.temporal.io/server/api/history/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

498 }
499
500 > func init() { file_temporal_server_api_history_v1_message_proto_init() } message.pb.go
501 > func file_temporal_server_api_history_v1_message_proto_init() {
502 > if File_temporal_server_api_history_v1_message_proto != nil {
503 return
504 }
505 > type x struct{} message.pb.go
506 > out := protoimpl.TypeBuilder{
507 > File: protoimpl.DescBuilder{
508 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
509 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_history_v1_message_proto_rawDesc), len(file_temporal_server_api_history_v1_message_proto_rawDesc)),
510 > NumEnums: 0,
511 > NumMessages: 8,
512 > NumExtensions: 0,
513 > NumServices: 0,
514 > },
515 > GoTypes: file_temporal_server_api_history_v1_message_proto_goTypes,
516 > DependencyIndexes: file_temporal_server_api_history_v1_message_proto_depIdxs,
517 > MessageInfos: file_temporal_server_api_history_v1_message_proto_msgTypes,
518 > }.Build()
519 > File_temporal_server_api_history_v1_message_proto = out.File
520 > file_temporal_server_api_history_v1_message_proto_goTypes = nil
521 > file_temporal_server_api_history_v1_message_proto_depIdxs = nil
522 }
go.temporal.io/server/api/historyservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

428 }
429
430 > func init() { file_temporal_server_api_historyservice_v1_service_proto_init() } service.pb.go
431 > func file_temporal_server_api_historyservice_v1_service_proto_init() {
432 > if File_temporal_server_api_historyservice_v1_service_proto != nil {
433 return
434 }
435 > file_temporal_server_api_historyservice_v1_request_response_proto_init() service.pb.go
436 > type x struct{}
437 > out := protoimpl.TypeBuilder{
438 > File: protoimpl.DescBuilder{
439 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
440 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_historyservice_v1_service_proto_rawDesc), len(file_temporal_server_api_historyservice_v1_service_proto_rawDesc)),
441 > NumEnums: 0,
442 > NumMessages: 0,
443 > NumExtensions: 0,
444 > NumServices: 1,
445 > },
446 > GoTypes: file_temporal_server_api_historyservice_v1_service_proto_goTypes,
447 > DependencyIndexes: file_temporal_server_api_historyservice_v1_service_proto_depIdxs,
448 > }.Build()
449 > File_temporal_server_api_historyservice_v1_service_proto = out.File
450 > file_temporal_server_api_historyservice_v1_service_proto_goTypes = nil
451 > file_temporal_server_api_historyservice_v1_service_proto_depIdxs = nil
452 }
go.temporal.io/server/api/matchingservice/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

250 }
251
252 > func init() { file_temporal_server_api_matchingservice_v1_service_proto_init() } service.pb.go
253 > func file_temporal_server_api_matchingservice_v1_service_proto_init() {
254 > if File_temporal_server_api_matchingservice_v1_service_proto != nil {
255 return
256 }
257 > file_temporal_server_api_matchingservice_v1_request_response_proto_init() service.pb.go
258 > type x struct{}
259 > out := protoimpl.TypeBuilder{
260 > File: protoimpl.DescBuilder{
261 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
262 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_matchingservice_v1_service_proto_rawDesc), len(file_temporal_server_api_matchingservice_v1_service_proto_rawDesc)),
263 > NumEnums: 0,
264 > NumMessages: 0,
265 > NumExtensions: 0,
266 > NumServices: 1,
267 > },
268 > GoTypes: file_temporal_server_api_matchingservice_v1_service_proto_goTypes,
269 > DependencyIndexes: file_temporal_server_api_matchingservice_v1_service_proto_depIdxs,
270 > }.Build()
271 > File_temporal_server_api_matchingservice_v1_service_proto = out.File
272 > file_temporal_server_api_matchingservice_v1_service_proto_goTypes = nil
273 > file_temporal_server_api_matchingservice_v1_service_proto_depIdxs = nil
274 }
go.temporal.io/server/api/metrics/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

104 }
105
106 > func init() { file_temporal_server_api_metrics_v1_message_proto_init() } message.pb.go
107 > func file_temporal_server_api_metrics_v1_message_proto_init() {
108 > if File_temporal_server_api_metrics_v1_message_proto != nil {
109 return
110 }
111 > type x struct{} message.pb.go
112 > out := protoimpl.TypeBuilder{
113 > File: protoimpl.DescBuilder{
114 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
115 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_metrics_v1_message_proto_rawDesc), len(file_temporal_server_api_metrics_v1_message_proto_rawDesc)),
116 > NumEnums: 0,
117 > NumMessages: 2,
118 > NumExtensions: 0,
119 > NumServices: 0,
120 > },
121 > GoTypes: file_temporal_server_api_metrics_v1_message_proto_goTypes,
122 > DependencyIndexes: file_temporal_server_api_metrics_v1_message_proto_depIdxs,
123 > MessageInfos: file_temporal_server_api_metrics_v1_message_proto_msgTypes,
124 > }.Build()
125 > File_temporal_server_api_metrics_v1_message_proto = out.File
126 > file_temporal_server_api_metrics_v1_message_proto_goTypes = nil
127 > file_temporal_server_api_metrics_v1_message_proto_depIdxs = nil
128 }
go.temporal.io/server/api/namespace/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

114 }
115
116 > func init() { file_temporal_server_api_namespace_v1_message_proto_init() } message.pb.go
117 > func file_temporal_server_api_namespace_v1_message_proto_init() {
118 > if File_temporal_server_api_namespace_v1_message_proto != nil {
119 return
120 }
121 > type x struct{} message.pb.go
122 > out := protoimpl.TypeBuilder{
123 > File: protoimpl.DescBuilder{
124 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
125 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_namespace_v1_message_proto_rawDesc), len(file_temporal_server_api_namespace_v1_message_proto_rawDesc)),
126 > NumEnums: 0,
127 > NumMessages: 1,
128 > NumExtensions: 0,
129 > NumServices: 0,
130 > },
131 > GoTypes: file_temporal_server_api_namespace_v1_message_proto_goTypes,
132 > DependencyIndexes: file_temporal_server_api_namespace_v1_message_proto_depIdxs,
133 > MessageInfos: file_temporal_server_api_namespace_v1_message_proto_msgTypes,
134 > }.Build()
135 > File_temporal_server_api_namespace_v1_message_proto = out.File
136 > file_temporal_server_api_namespace_v1_message_proto_goTypes = nil
137 > file_temporal_server_api_namespace_v1_message_proto_depIdxs = nil
138 }
go.temporal.io/server/api/persistence/v1/chasm_visibility.pb.go 20 covered LOC · 2 ranges

Open complete file

146 }
147
148 > func init() { file_temporal_server_api_persistence_v1_chasm_visibility_proto_init() } chasm_visibility.pb.go
149 > func file_temporal_server_api_persistence_v1_chasm_visibility_proto_init() {
150 > if File_temporal_server_api_persistence_v1_chasm_visibility_proto != nil {
151 return
152 }
153 > type x struct{} chasm_visibility.pb.go
154 > out := protoimpl.TypeBuilder{
155 > File: protoimpl.DescBuilder{
156 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
157 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDesc), len(file_temporal_server_api_persistence_v1_chasm_visibility_proto_rawDesc)),
158 > NumEnums: 0,
159 > NumMessages: 2,
160 > NumExtensions: 0,
161 > NumServices: 0,
162 > },
163 > GoTypes: file_temporal_server_api_persistence_v1_chasm_visibility_proto_goTypes,
164 > DependencyIndexes: file_temporal_server_api_persistence_v1_chasm_visibility_proto_depIdxs,
165 > MessageInfos: file_temporal_server_api_persistence_v1_chasm_visibility_proto_msgTypes,
166 > }.Build()
167 > File_temporal_server_api_persistence_v1_chasm_visibility_proto = out.File
168 > file_temporal_server_api_persistence_v1_chasm_visibility_proto_goTypes = nil
169 > file_temporal_server_api_persistence_v1_chasm_visibility_proto_depIdxs = nil
170 }
go.temporal.io/server/api/persistence/v1/cluster_metadata.pb.go 20 covered LOC · 2 ranges

Open complete file

289 }
290
291 > func init() { file_temporal_server_api_persistence_v1_cluster_metadata_proto_init() } cluster_metadata.pb.go
292 > func file_temporal_server_api_persistence_v1_cluster_metadata_proto_init() {
293 > if File_temporal_server_api_persistence_v1_cluster_metadata_proto != nil {
294 return
295 }
296 > type x struct{} cluster_metadata.pb.go
297 > out := protoimpl.TypeBuilder{
298 > File: protoimpl.DescBuilder{
299 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
300 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDesc), len(file_temporal_server_api_persistence_v1_cluster_metadata_proto_rawDesc)),
301 > NumEnums: 0,
302 > NumMessages: 5,
303 > NumExtensions: 0,
304 > NumServices: 0,
305 > },
306 > GoTypes: file_temporal_server_api_persistence_v1_cluster_metadata_proto_goTypes,
307 > DependencyIndexes: file_temporal_server_api_persistence_v1_cluster_metadata_proto_depIdxs,
308 > MessageInfos: file_temporal_server_api_persistence_v1_cluster_metadata_proto_msgTypes,
309 > }.Build()
310 > File_temporal_server_api_persistence_v1_cluster_metadata_proto = out.File
311 > file_temporal_server_api_persistence_v1_cluster_metadata_proto_goTypes = nil
312 > file_temporal_server_api_persistence_v1_cluster_metadata_proto_depIdxs = nil
313 }
go.temporal.io/server/api/persistence/v1/history_tree.pb.go 20 covered LOC · 2 ranges

Open complete file

274 }
275
276 > func init() { file_temporal_server_api_persistence_v1_history_tree_proto_init() } history_tree.pb.go
277 > func file_temporal_server_api_persistence_v1_history_tree_proto_init() {
278 > if File_temporal_server_api_persistence_v1_history_tree_proto != nil {
279 return
280 }
281 > type x struct{} history_tree.pb.go
282 > out := protoimpl.TypeBuilder{
283 > File: protoimpl.DescBuilder{
284 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
285 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_history_tree_proto_rawDesc), len(file_temporal_server_api_persistence_v1_history_tree_proto_rawDesc)),
286 > NumEnums: 0,
287 > NumMessages: 3,
288 > NumExtensions: 0,
289 > NumServices: 0,
290 > },
291 > GoTypes: file_temporal_server_api_persistence_v1_history_tree_proto_goTypes,
292 > DependencyIndexes: file_temporal_server_api_persistence_v1_history_tree_proto_depIdxs,
293 > MessageInfos: file_temporal_server_api_persistence_v1_history_tree_proto_msgTypes,
294 > }.Build()
295 > File_temporal_server_api_persistence_v1_history_tree_proto = out.File
296 > file_temporal_server_api_persistence_v1_history_tree_proto_goTypes = nil
297 > file_temporal_server_api_persistence_v1_history_tree_proto_depIdxs = nil
298 }
go.temporal.io/server/api/persistence/v1/namespaces.pb.go 20 covered LOC · 2 ranges

Open complete file

536 }
537
538 > func init() { file_temporal_server_api_persistence_v1_namespaces_proto_init() } namespaces.pb.go
539 > func file_temporal_server_api_persistence_v1_namespaces_proto_init() {
540 > if File_temporal_server_api_persistence_v1_namespaces_proto != nil {
541 return
542 }
543 > type x struct{} namespaces.pb.go
544 > out := protoimpl.TypeBuilder{
545 > File: protoimpl.DescBuilder{
546 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
547 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_namespaces_proto_rawDesc), len(file_temporal_server_api_persistence_v1_namespaces_proto_rawDesc)),
548 > NumEnums: 0,
549 > NumMessages: 8,
550 > NumExtensions: 0,
551 > NumServices: 0,
552 > },
553 > GoTypes: file_temporal_server_api_persistence_v1_namespaces_proto_goTypes,
554 > DependencyIndexes: file_temporal_server_api_persistence_v1_namespaces_proto_depIdxs,
555 > MessageInfos: file_temporal_server_api_persistence_v1_namespaces_proto_msgTypes,
556 > }.Build()
557 > File_temporal_server_api_persistence_v1_namespaces_proto = out.File
558 > file_temporal_server_api_persistence_v1_namespaces_proto_goTypes = nil
559 > file_temporal_server_api_persistence_v1_namespaces_proto_depIdxs = nil
560 }
go.temporal.io/server/api/persistence/v1/queue_metadata.pb.go 20 covered LOC · 2 ranges

Open complete file

105 }
106
107 > func init() { file_temporal_server_api_persistence_v1_queue_metadata_proto_init() } queue_metadata.pb.go
108 > func file_temporal_server_api_persistence_v1_queue_metadata_proto_init() {
109 > if File_temporal_server_api_persistence_v1_queue_metadata_proto != nil {
110 return
111 }
112 > type x struct{} queue_metadata.pb.go
113 > out := protoimpl.TypeBuilder{
114 > File: protoimpl.DescBuilder{
115 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
116 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_queue_metadata_proto_rawDesc), len(file_temporal_server_api_persistence_v1_queue_metadata_proto_rawDesc)),
117 > NumEnums: 0,
118 > NumMessages: 2,
119 > NumExtensions: 0,
120 > NumServices: 0,
121 > },
122 > GoTypes: file_temporal_server_api_persistence_v1_queue_metadata_proto_goTypes,
123 > DependencyIndexes: file_temporal_server_api_persistence_v1_queue_metadata_proto_depIdxs,
124 > MessageInfos: file_temporal_server_api_persistence_v1_queue_metadata_proto_msgTypes,
125 > }.Build()
126 > File_temporal_server_api_persistence_v1_queue_metadata_proto = out.File
127 > file_temporal_server_api_persistence_v1_queue_metadata_proto_goTypes = nil
128 > file_temporal_server_api_persistence_v1_queue_metadata_proto_depIdxs = nil
129 }
go.temporal.io/server/api/persistence/v1/tasks.pb.go 20 covered LOC · 2 ranges

Open complete file

846 }
847
848 > func init() { file_temporal_server_api_persistence_v1_tasks_proto_init() } tasks.pb.go
849 > func file_temporal_server_api_persistence_v1_tasks_proto_init() {
850 > if File_temporal_server_api_persistence_v1_tasks_proto != nil {
851 return
852 }
853 > type x struct{} tasks.pb.go
854 > out := protoimpl.TypeBuilder{
855 > File: protoimpl.DescBuilder{
856 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
857 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc), len(file_temporal_server_api_persistence_v1_tasks_proto_rawDesc)),
858 > NumEnums: 0,
859 > NumMessages: 8,
860 > NumExtensions: 0,
861 > NumServices: 0,
862 > },
863 > GoTypes: file_temporal_server_api_persistence_v1_tasks_proto_goTypes,
864 > DependencyIndexes: file_temporal_server_api_persistence_v1_tasks_proto_depIdxs,
865 > MessageInfos: file_temporal_server_api_persistence_v1_tasks_proto_msgTypes,
866 > }.Build()
867 > File_temporal_server_api_persistence_v1_tasks_proto = out.File
868 > file_temporal_server_api_persistence_v1_tasks_proto_goTypes = nil
869 > file_temporal_server_api_persistence_v1_tasks_proto_depIdxs = nil
870 }
go.temporal.io/server/api/token/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

785 }
786
787 > func init() { file_temporal_server_api_token_v1_message_proto_init() } message.pb.go
788 > func file_temporal_server_api_token_v1_message_proto_init() {
789 > if File_temporal_server_api_token_v1_message_proto != nil {
790 return
791 }
792 > type x struct{} message.pb.go
793 > out := protoimpl.TypeBuilder{
794 > File: protoimpl.DescBuilder{
795 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
796 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_token_v1_message_proto_rawDesc), len(file_temporal_server_api_token_v1_message_proto_rawDesc)),
797 > NumEnums: 0,
798 > NumMessages: 7,
799 > NumExtensions: 0,
800 > NumServices: 0,
801 > },
802 > GoTypes: file_temporal_server_api_token_v1_message_proto_goTypes,
803 > DependencyIndexes: file_temporal_server_api_token_v1_message_proto_depIdxs,
804 > MessageInfos: file_temporal_server_api_token_v1_message_proto_msgTypes,
805 > }.Build()
806 > File_temporal_server_api_token_v1_message_proto = out.File
807 > file_temporal_server_api_token_v1_message_proto_goTypes = nil
808 > file_temporal_server_api_token_v1_message_proto_depIdxs = nil
809 }
go.temporal.io/server/api/visibilityservice/v1/request_response.pb.go 20 covered LOC · 2 ranges

Open complete file

402 }
403
404 > func init() { file_temporal_server_api_visibilityservice_v1_request_response_proto_init() } request_response.pb.go
405 > func file_temporal_server_api_visibilityservice_v1_request_response_proto_init() {
406 > if File_temporal_server_api_visibilityservice_v1_request_response_proto != nil {
407 return
408 }
409 > type x struct{} request_response.pb.go
410 > out := protoimpl.TypeBuilder{
411 > File: protoimpl.DescBuilder{
412 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
413 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_visibilityservice_v1_request_response_proto_rawDesc), len(file_temporal_server_api_visibilityservice_v1_request_response_proto_rawDesc)),
414 > NumEnums: 0,
415 > NumMessages: 5,
416 > NumExtensions: 0,
417 > NumServices: 0,
418 > },
419 > GoTypes: file_temporal_server_api_visibilityservice_v1_request_response_proto_goTypes,
420 > DependencyIndexes: file_temporal_server_api_visibilityservice_v1_request_response_proto_depIdxs,
421 > MessageInfos: file_temporal_server_api_visibilityservice_v1_request_response_proto_msgTypes,
422 > }.Build()
423 > File_temporal_server_api_visibilityservice_v1_request_response_proto = out.File
424 > file_temporal_server_api_visibilityservice_v1_request_response_proto_goTypes = nil
425 > file_temporal_server_api_visibilityservice_v1_request_response_proto_depIdxs = nil
426 }
go.temporal.io/server/api/workflow/v1/message.pb.go 20 covered LOC · 2 ranges

Open complete file

278 }
279
280 > func init() { file_temporal_server_api_workflow_v1_message_proto_init() } message.pb.go
281 > func file_temporal_server_api_workflow_v1_message_proto_init() {
282 > if File_temporal_server_api_workflow_v1_message_proto != nil {
283 return
284 }
285 > type x struct{} message.pb.go
286 > out := protoimpl.TypeBuilder{
287 > File: protoimpl.DescBuilder{
288 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
289 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_workflow_v1_message_proto_rawDesc), len(file_temporal_server_api_workflow_v1_message_proto_rawDesc)),
290 > NumEnums: 0,
291 > NumMessages: 3,
292 > NumExtensions: 0,
293 > NumServices: 0,
294 > },
295 > GoTypes: file_temporal_server_api_workflow_v1_message_proto_goTypes,
296 > DependencyIndexes: file_temporal_server_api_workflow_v1_message_proto_depIdxs,
297 > MessageInfos: file_temporal_server_api_workflow_v1_message_proto_msgTypes,
298 > }.Build()
299 > File_temporal_server_api_workflow_v1_message_proto = out.File
300 > file_temporal_server_api_workflow_v1_message_proto_goTypes = nil
301 > file_temporal_server_api_workflow_v1_message_proto_depIdxs = nil
302 }
go.temporal.io/server/chasm/lib/activity/gen/activitypb/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

91 }
92
93 > func init() { file_temporal_server_chasm_lib_activity_proto_v1_service_proto_init() } service.pb.go
94 > func file_temporal_server_chasm_lib_activity_proto_v1_service_proto_init() {
95 > if File_temporal_server_chasm_lib_activity_proto_v1_service_proto != nil {
96 return
97 }
98 > file_temporal_server_chasm_lib_activity_proto_v1_request_response_proto_init() service.pb.go
99 > type x struct{}
100 > out := protoimpl.TypeBuilder{
101 > File: protoimpl.DescBuilder{
102 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
103 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_activity_proto_v1_service_proto_rawDesc), len(file_temporal_server_chasm_lib_activity_proto_v1_service_proto_rawDesc)),
104 > NumEnums: 0,
105 > NumMessages: 0,
106 > NumExtensions: 0,
107 > NumServices: 1,
108 > },
109 > GoTypes: file_temporal_server_chasm_lib_activity_proto_v1_service_proto_goTypes,
110 > DependencyIndexes: file_temporal_server_chasm_lib_activity_proto_v1_service_proto_depIdxs,
111 > }.Build()
112 > File_temporal_server_chasm_lib_activity_proto_v1_service_proto = out.File
113 > file_temporal_server_chasm_lib_activity_proto_v1_service_proto_goTypes = nil
114 > file_temporal_server_chasm_lib_activity_proto_v1_service_proto_depIdxs = nil
115 }
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/service.pb.go 20 covered LOC · 2 ranges

Open complete file

86 }
87
88 > func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_init() } service.pb.go
89 > func file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_init() {
90 > if File_temporal_server_chasm_lib_scheduler_proto_v1_service_proto != nil {
91 return
92 }
93 > file_temporal_server_chasm_lib_scheduler_proto_v1_request_response_proto_init() service.pb.go
94 > type x struct{}
95 > out := protoimpl.TypeBuilder{
96 > File: protoimpl.DescBuilder{
97 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
98 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_rawDesc)),
99 > NumEnums: 0,
100 > NumMessages: 0,
101 > NumExtensions: 0,
102 > NumServices: 1,
103 > },
104 > GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_goTypes,
105 > DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_depIdxs,
106 > }.Build()
107 > File_temporal_server_chasm_lib_scheduler_proto_v1_service_proto = out.File
108 > file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_goTypes = nil
109 > file_temporal_server_chasm_lib_scheduler_proto_v1_service_proto_depIdxs = nil
110 }
go.temporal.io/server/chasm/lib/scheduler/gen/schedulerpb/v1/tasks.pb.go 20 covered LOC · 2 ranges

Open complete file

343 }
344
345 > func init() { file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_init() } tasks.pb.go
346 > func file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_init() {
347 > if File_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto != nil {
348 return
349 }
350 > type x struct{} tasks.pb.go
351 > out := protoimpl.TypeBuilder{
352 > File: protoimpl.DescBuilder{
353 > GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
354 > RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_rawDesc), len(file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_rawDesc)),
355 > NumEnums: 0,
356 > NumMessages: 7,
357 > NumExtensions: 0,
358 > NumServices: 0,
359 > },
360 > GoTypes: file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_goTypes,
361 > DependencyIndexes: file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_depIdxs,
362 > MessageInfos: file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_msgTypes,
363 > }.Build()
364 > File_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto = out.File
365 > file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_goTypes = nil
366 > file_temporal_server_chasm_lib_scheduler_proto_v1_tasks_proto_depIdxs = nil
367 }
go.temporal.io/server/common/util/wildcard.go 20 covered LOC · 7 ranges

Open complete file

18 // WildCardStringToRegexps converts a given slices of string patterns to a slice of regular expressions matching
19 // wildcards (*) with any substring.
20 > func WildCardStringsToRegexp(patterns []string) (*regexp.Regexp, error) { wildcard.go
21 > var result strings.Builder
22 > result.WriteRune('^')
23 > for i, pattern := range patterns {
24 > result.WriteRune('(')
25 > first := true
26 > for literal := range strings.SplitSeq(pattern, "*") {
27 > if !first {
28 // Replace * with .*
29 result.WriteString(".*")
30 }
31 > result.WriteString(regexp.QuoteMeta(literal)) wildcard.go
32 > first = false
33 }
34 > result.WriteRune(')') wildcard.go
35 > if i < len(patterns)-1 {
36 > result.WriteRune('|') wildcard.go
37 > }
38 }
39 > result.WriteRune('$') wildcard.go
40 > return regexp.Compile(result.String())
41 }
42
43 // MustWildCardStringsToRegexp is like WildCardStringsToRegexp but panics on error.
44 > func MustWildCardStringsToRegexp(patterns []string) *regexp.Regexp { wildcard.go
45 > re, err := WildCardStringsToRegexp(patterns)
46 > if err != nil {
47 panic(err) //nolint:forbidigo // Must* functions conventionally panic on error.
48 }
49 > return re wildcard.go
50 }
go.temporal.io/server/common/backoff/retrypolicy.go 19 covered LOC · 3 ranges

Open complete file

80
81 // NewExponentialRetryPolicy returns an instance of ExponentialRetryPolicy using the provided initialInterval
82 > func NewExponentialRetryPolicy(initialInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go
83 > p := &ExponentialRetryPolicy{
84 > initialInterval: initialInterval,
85 > backoffCoefficient: defaultBackoffCoefficient,
86 > maximumInterval: defaultMaximumInterval,
87 > expirationInterval: defaultExpirationInterval,
88 > maximumAttempts: defaultMaximumAttempts,
89 > }
90 >
91 > return p
92 > }
93
94 // NewRetrier is used for creating a new instance of Retrier
121 // This does *not* cause the policy to stop retrying when the interval between retries reaches the supplied duration.
122 // That is what WithExpirationInterval does. Instead, this prevents the interval from exceeding maximumInterval.
123 > func (p *ExponentialRetryPolicy) WithMaximumInterval(maximumInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go
124 > p.maximumInterval = maximumInterval
125 > return p
126 > }
127
128 // WithExpirationInterval sets the absolute expiration interval for all retries
129 > func (p *ExponentialRetryPolicy) WithExpirationInterval(expirationInterval time.Duration) *ExponentialRetryPolicy { retrypolicy.go
130 > p.expirationInterval = expirationInterval
131 > return p
132 > }
133
134 // WithMaximumAttempts sets the maximum number of retry attempts
go.temporal.io/server/common/dynamicconfig/collection.go 18 covered LOC · 3 ranges

Open complete file

676 // treat the fields independently), or the zero value of its type (if you want to treat the fields
677 // as a group and default unset fields to zero).
678 > func ConvertStructure[T any](def T) func(v any) (T, error) { collection.go
679 > return func(v any) (T, error) {
680 > // if we already have the right type, no conversion is necessary
681 > if typedV, ok := v.(T); ok {
682 return typedV, nil
683 }
685 // Deep-copy the default and decode over it. This allows using e.g. a struct with some
686 // default fields filled in and a config that only set some fields.
687 > out := deepCopyForMapstructure(def) collection.go
688 >
689 > dec, err := mapstructure.NewDecoder(&mapstructure.DecoderConfig{
690 > Result: &out,
691 > DecodeHook: mapstructure.ComposeDecodeHookFunc(
692 > mapstructureHookDuration,
693 > mapstructureHookTimestamp,
694 > mapstructureHookProtoEnum,
695 > mapstructureHookGeneric,
696 > ),
697 > })
698 > if err != nil {
699 return out, err
700 }
701 > err = dec.Decode(v) collection.go
702 > return out, err
703 }
704 }
go.temporal.io/server/common/build/build.go 14 covered LOC · 2 ranges

Open complete file

27 )
28
29 > func init() { build.go
30 > buildInfo, ok := debug.ReadBuildInfo()
31 > if !ok {
32 return
33 }
34
35 > InfoData.Available = true build.go
36 > InfoData.GoVersion = buildInfo.GoVersion
37 >
38 > for _, setting := range buildInfo.Settings {
39 > switch setting.Key {
40 > case "GOARCH":
41 > InfoData.GoArch = setting.Value
42 > case "GOOS":
43 > InfoData.GoOs = setting.Value
44 > case "CGO_ENABLED":
45 > InfoData.CgoEnabled = setting.Value == "1"
46 case "vcs.revision":
47 InfoData.GitRevision = setting.Value
go.temporal.io/server/common/dynamicconfig/gradual_change.go 14 covered LOC · 3 ranges

Open complete file

25 // StaticGradualChange returns a GradualChange whose Value always returns def and whose When
26 // always returns a time in the past.
27 > func StaticGradualChange[T any](def T) GradualChange[T] { gradual_change.go
28 > return GradualChange[T]{New: def}
29 > }
30
31 // Value returns the value for the given key at the given time.
56 // of type GradualChange into a GradualChange.
57 // nolint:revive // cognitive-complexity // this looks complicated but each case is fairly simple
58 > func ConvertGradualChange[T any](def T) func(v any) (GradualChange[T], error) { gradual_change.go
59 > changeConverter := ConvertStructure(StaticGradualChange(def))
60 >
61 > // Call this once so that if it's going to panic, it panics at static init time.
62 > _, _ = changeConverter(nil)
63 >
64 > switch reflect.TypeFor[T]() {
65 > case reflect.TypeFor[bool]():
66 > return func(v any) (GradualChange[T], error) {
67 if b, err := convertBool(v); err == nil {
68 var change GradualChange[T]
72 return changeConverter(v)
73 }
74 > case reflect.TypeFor[int](): gradual_change.go
75 > return func(v any) (GradualChange[T], error) {
76 if i, err := convertInt(v); err == nil {
77 var change GradualChange[T]
go.temporal.io/server/common/dynamicconfig/shared_structure.go 13 covered LOC · 5 ranges

Open complete file

17 )
18
19 > func warnDefaultSharedStructure(key string, def any) { shared_structure.go
20 > if path := hasSharedStructure(reflect.ValueOf(def), "root"); path != "" {
21 sharedStructureWarnings.Store(key, path)
22 }
42 }
43
44 > func hasSharedStructure(v reflect.Value, path string) string { shared_structure.go
45 > // nolint:exhaustive // deliberately not exhaustive
46 > switch v.Kind() {
47 > case reflect.Map, reflect.Slice, reflect.Pointer:
48 > if !v.IsNil() {
49 return path
50 }
51 > case reflect.Interface: shared_structure.go
52 > if !v.IsNil() {
53 return hasSharedStructure(v.Elem(), path)
54 }
55 > case reflect.Struct: shared_structure.go
56 > for i := range v.NumField() {
57 > if p := hasSharedStructure(v.Field(i), path+"."+v.Type().Field(i).Name); p != "" {
58 return p
59 }
go.temporal.io/server/common/log/tag/zap_tag.go 10 covered LOC · 2 ranges

Open complete file

44 }
45
46 > func NewStringTag(key string, value string) ZapTag { zap_tag.go
47 > return ZapTag{
48 > field: zap.String(key, value),
49 > }
50 > }
51
52 func NewStringsTag(key string, value []string) ZapTag {
118 }
119
120 > func NewBoolTag(key string, value bool) ZapTag { zap_tag.go
121 > return ZapTag{
122 > field: zap.Bool(key, value),
123 > }
124 > }
125
126 func NewErrorTag(key string, value error) ZapTag {
go.temporal.io/server/common/metrics/defs_base.go 10 covered LOC · 1 range

Open complete file

10 }
11
12 > func newMetricDefinition(name string, opts ...Option) metricDefinition { defs_base.go
13 > d := metricDefinition{
14 > name: name,
15 > description: "",
16 > unit: "",
17 > }
18 > for _, opt := range opts {
19 > opt.apply(&d)
20 > }
21 > return d
22 }
23
go.temporal.io/server/common/testing/testhooks/test_impl.go 9 covered LOC · 2 ranges

Open complete file

89 var keyCounter atomic.Int64
90
91 > func newKey[T any, S any]() Key[T, S] { test_impl.go
92 > var zero S
93 > var s ScopeType
94 > switch any(zero).(type) {
95 > case namespace.ID, namespace.Name:
96 > s = ScopeNamespace
97 > case global:
98 > s = ScopeGlobal
99 default:
100 panic("testhooks: unknown scope type")
101 }
102 > return Key[T, S]{id: keyCounter.Add(1), scopeType: s} test_impl.go
103 }
go.temporal.io/server/common/dynamicconfig/registry.go 7 covered LOC · 3 ranges

Open complete file

17 )
18
19 > func register(s GenericSetting) { registry.go
20 > if globalRegistry.queried.Load() {
21 panic("dynamicconfig.New*Setting must only be called from static initializers")
22 }
23 > if globalRegistry.settings == nil { registry.go
24 > globalRegistry.settings = make(map[Key]GenericSetting)
25 > }
26 > if globalRegistry.settings[s.Key()] != nil {
27 // nolint:forbidigo // only called during static initialization
28 panic(fmt.Sprintf("duplicate registration of dynamic config key: %q", s.Key().String()))
29 }
30 > globalRegistry.settings[s.Key()] = s registry.go
31 }
32
go.temporal.io/server/common/membership/grpc_resolver.go 7 covered LOC · 2 ranges

Open complete file

53 )
54
55 > func init() { grpc_resolver.go
56 > // This must be called in init to avoid race conditions.
57 > resolver.Register(&globalGrpcBuilder)
58 > }
59
60 // Most code should not use this, this is only exposed for code that has to recognize and use a
80 }
81
82 > func (m *grpcBuilder) Scheme() string { grpc_resolver.go
83 > return grpcResolverScheme
84 > }
85
86 func (m *grpcBuilder) getServiceResolver(u *url.URL) (ServiceResolver, error) {
go.temporal.io/server/common/metrics/option.go 6 covered LOC · 2 ranges

Open complete file

10 type WithDescription string
11
12 > func (h WithDescription) apply(m *metricDefinition) { option.go
13 > m.description = string(h)
14 > }
15
16 // WithUnit sets the unit of a metric. See NewBytesHistogramDef for an example.
17 type WithUnit MetricUnit
18
19 > func (h WithUnit) apply(m *metricDefinition) { option.go
20 > m.unit = MetricUnit(h)
21 > }
go.temporal.io/server/common/searchattribute/sadefs/constants.go 6 covered LOC · 1 range

Open complete file

261 }
262
263 > dbCustomSearchAttributeFieldNameRE = func() map[enumspb.IndexedValueType]*regexp.Regexp { constants.go
264 > res := map[enumspb.IndexedValueType]*regexp.Regexp{}
265 > for t := range defaultNumDBCustomSearchAttributes {
266 > res[t] = regexp.MustCompile(fmt.Sprintf(`^%s(0[1-9]|[1-9][0-9])$`, t.String()))
267 > }
268 > return res
269 }()
270 )
go.temporal.io/server/service/history/tasks/key.go 6 covered LOC · 1 range

Open complete file

35 }
36
37 > func NewKey(fireTime time.Time, taskID int64) Key { key.go
38 > return Key{
39 > FireTime: fireTime,
40 > TaskID: taskID,
41 > }
42 > }
43
44 func ValidateKey(key Key) error {
go.temporal.io/server/common/metrics/registry.go 5 covered LOC · 1 range

Open complete file

43
44 // register adds a metric definition to the list of pending metric definitions. This method is thread-safe.
45 > func (c *registry) register(d metricDefinition) { registry.go
46 > c.Lock()
47 > defer c.Unlock()
48 > c.definitions = append(c.definitions, d)
49 > }
50
51 // buildCatalog builds a catalog from the list of pending metric definitions. It is safe to call this method multiple
go.temporal.io/server/api/persistence/v1/predicates.go-helpers.pb.go 3 covered LOC · 1 range

Open complete file

17
18 // Size returns the size of the object, in bytes, once serialized
19 > func (val *Predicate) Size() int { predicates.go-helpers.pb.go
20 > return proto.Size(val)
21 > }
22
23 // Equal returns whether two Predicate values are equivalent by recursively
go.temporal.io/server/chasm/library.go 3 covered LOC · 1 range

Open complete file

56 // tasks within the CHASM framework.
57 // The format of the returned FQN is: "libName.name"
58 > func FullyQualifiedName(libName, name string) string { library.go
59 > return libName + "." + name
60 > }
go.temporal.io/server/chasm/registrable_component.go 3 covered LOC · 1 range

Open complete file

203 // The generated ID is used to uniquely identify components and tasks within the CHASM framework. The same FQN will
204 // always produce the same ID.
205 > func GenerateTypeID(fqn string) uint32 { registrable_component.go
206 > return farm.Fingerprint32([]byte(fqn))
207 > }
208
209 // hasBusinessIDAlias returns true if the component has a businessID alias configured
go.temporal.io/server/common/dynamicconfig/key.go 3 covered LOC · 1 range

Open complete file

13 )
14
15 > func MakeKey(s string) Key { key.go
16 > return Key{handle: unique.Make(strings.ToLower(s))}
17 > }
18
19 func (k Key) String() string {
go.temporal.io/server/common/payload/payload.go 3 covered LOC · 1 range

Open complete file

30 }
31
32 > func Encode(value any) (*commonpb.Payload, error) { payload.go
33 > return defaultDataConverter.ToPayload(value)
34 > }
35
36 func Decode(p *commonpb.Payload, valuePtr any) error {
go.temporal.io/server/common/tasks/priority.go 3 covered LOC · 1 range

Open complete file

77 func getPriority(
78 class, subClass Priority,
79 > ) Priority { priority.go
80 > return class | subClass
81 > }
go.temporal.io/server/common/aggregate/noop_moving_window_average.go 1 covered LOC · 1 range

Open complete file

7 )
8
9 > func newNoopMovingWindowAverage() *noopMovingWindowAverage { return &noopMovingWindowAverage{} } noop_moving_window_average.go
10
11 func (a *noopMovingWindowAverage) Record(_ int64) {}
go.temporal.io/server/common/metrics/noop_impl.go 1 covered LOC · 1 range

Open complete file

15 )
16
17 > func newNoopMetricsHandler() *noopMetricsHandler { return &noopMetricsHandler{} } noop_impl.go
18
19 // WithTags creates a new MetricProvder with provided []Tag
go.temporal.io/server/common/persistence/noop_health_signal_aggregator.go 1 covered LOC · 1 range

Open complete file

11 )
12
13 > func newNoopSignalAggregator() *noopSignalAggregator { return &noopSignalAggregator{} } noop_health_signal_aggregator.go
14
15 func (a *noopSignalAggregator) Start() {}