3726
}
3727
3729
>
if x != nil {
3731
>
}
3732
return nil
3733
}
Atlas › Test
TestCRC32OverProto
Exact test identity: go.temporal.io/server/common/checksum/TestCRC32OverProto
- Package
go.temporal.io/server/common/checksum- Suite / test hierarchy
TestCRC32OverProto- Test
TestCRC32OverProto- Introduced at
- crc.go ×6 Frontier kind: Joint frontier
- Covered ranges
- 118
- Covered lines
- 1258
- Covered files
- 56
Covered source
Expand a file to inspect source; the > gutter marks covered lines.
go.temporal.io/server/api/persistence/v1/executions.pb.go 64 covered LOC · 3 ranges
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/historyservice/v1/request_response.pb.go 45 covered LOC · 1 range
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/api/matchingservice/v1/request_response.pb.go 43 covered LOC · 1 range
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
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
2441
}
2442
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/metrics/defs.go 35 covered LOC · 5 ranges
20
)
21
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
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
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
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
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/predicates.pb.go 34 covered LOC · 1 range
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/api/persistence/v1/chasm.pb.go 33 covered LOC · 1 range
1180
}
1181
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
895
}
896
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
422
}
423
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/api/taskqueue/v1/message.pb.go 29 covered LOC · 2 ranges
1330
}
1331
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
70
71
// WorkflowAction returns tag for WorkflowAction
73
>
return NewStringTag("wf-action", action)
74
>
}
75
76
// WorkflowListFilterType returns tag for WorkflowListFilterType
78
>
return NewStringTag("wf-list-filter-type", listFilterType)
79
>
}
80
81
// general
376
377
// Component returns tag for Component
379
>
return NewStringTag("component", component)
380
>
}
381
382
// Lifecycle returns tag for Lifecycle
384
>
return NewStringTag("lifecycle", lifecycle)
385
>
}
386
387
// StoreOperation returns tag for StoreOperation
389
>
return NewStringTag("store-operation", storeOperation)
390
>
}
391
392
// OperationResult returns tag for OperationResult
394
>
return NewStringTag("operation-result", operationResult)
395
>
}
396
397
// ErrorType returns tag for ErrorType
401
402
// errorType returns tag for ErrorType given a string
404
>
return NewStringTag("error-type", errorType)
405
>
}
406
407
// Shardupdate returns tag for Shardupdate
409
>
return NewStringTag("shard-update", shardupdate)
410
>
}
411
412
// scope returns a tag for scope
413
// Pre-defined scope tags are in values.go.
415
>
return NewStringTag("scope", scope)
416
>
}
417
418
// general
go.temporal.io/server/api/persistence/v1/nexus.pb.go 24 covered LOC · 2 ranges
481
}
482
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
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
}
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/persistence/v1/queues.pb.go 23 covered LOC · 1 range
616
}
617
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/common/v1/api_category.pb.go 22 covered LOC · 2 ranges
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
}
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/api/persistence/v1/task_queues.pb.go 21 covered LOC · 2 ranges
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
}
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/api/adminservice/v1/service.pb.go 20 covered LOC · 2 ranges
273
}
274
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
}
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/clock/v1/message.pb.go 20 covered LOC · 2 ranges
193
}
194
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
}
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
342
}
343
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
}
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
295
}
296
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
}
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/deployment/v1/message.pb.go 20 covered LOC · 2 ranges
4626
}
4627
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
}
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
209
}
210
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
}
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
264
}
265
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
}
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
187
}
188
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
}
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
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
}
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
158
}
159
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
}
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/predicate.pb.go 20 covered LOC · 2 ranges
170
}
171
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
}
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/replication.pb.go 20 covered LOC · 2 ranges
314
}
315
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
}
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/task.pb.go 20 covered LOC · 2 ranges
456
}
457
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
}
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/enums/v1/workflow.pb.go 20 covered LOC · 2 ranges
275
}
276
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
}
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
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
}
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
625
}
626
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
}
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
300
}
301
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
}
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
498
}
499
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
}
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
428
}
429
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
}
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
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
}
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
104
}
105
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
}
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
114
}
115
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
}
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
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
}
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
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
}
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
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
}
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
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
}
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
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
}
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
846
}
847
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
}
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
785
}
786
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
}
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/workflow/v1/message.pb.go 20 covered LOC · 2 ranges
278
}
279
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
}
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/common/backoff/retrypolicy.go 19 covered LOC · 3 ranges
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/checksum/crc.go 19 covered LOC · 6 ranges
26
payload Marshaler,
27
payloadVersion int32,
29
>
30
>
payloadBytes, err := payload.Marshal()
31
>
if err != nil {
32
return nil, err
33
}
34
36
>
checksum := make([]byte, 4)
37
>
binary.BigEndian.PutUint32(checksum, crc)
38
>
return &persistencespb.Checksum{
39
>
Value: checksum,
40
>
Version: payloadVersion,
41
>
Flavor: enumsspb.CHECKSUM_FLAVOR_IEEE_CRC32_OVER_PROTO3_BINARY,
42
>
}, nil
43
}
44
49
payload Marshaler,
50
checksum *persistencespb.Checksum,
52
>
53
>
if checksum.Flavor != enumsspb.CHECKSUM_FLAVOR_IEEE_CRC32_OVER_PROTO3_BINARY {
54
return fmt.Errorf("unknown checksum flavor %v", checksum.Flavor)
55
}
56
58
>
if err != nil {
59
return err
60
}
61
63
return ErrMismatch
64
}
65
67
}
go.temporal.io/server/common/util.go 15 covered LOC · 3 ranges
135
// Returns true if the Wait() call succeeded before the timeout
136
// Returns false if the Wait() did not return before the timeout
138
>
return BlockWithTimeout(wg.Wait, timeout)
139
>
}
140
141
// BlockWithTimeout invokes fn and waits for it to complete until the timeout.
142
// Returns true if the call completed before the timeout, otherwise returns false.
143
// fn is expected to be a blocking call and will continue to occupy a goroutine until it finally completes.
145
>
doneC := make(chan struct{})
146
>
147
>
go func() {
148
>
fn()
149
>
close(doneC)
150
>
}()
151
153
>
defer timer.Stop()
154
>
select {
155
>
case <-doneC:
156
>
return true
157
case <-timer.C:
158
return false
go.temporal.io/server/common/build/build.go 14 covered LOC · 2 ranges
27
)
28
30
>
buildInfo, ok := debug.ReadBuildInfo()
31
>
if !ok {
32
return
33
}
34
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/log/tag/zap_tag.go 10 covered LOC · 2 ranges
44
}
45
47
>
return ZapTag{
48
>
field: zap.String(key, value),
49
>
}
50
>
}
51
52
func NewStringsTag(key string, value []string) ZapTag {
118
}
119
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
10
}
11
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/metrics/option.go 6 covered LOC · 2 ranges
10
type WithDescription string
11
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
20
>
m.unit = MetricUnit(h)
21
>
}
go.temporal.io/server/common/metrics/registry.go 5 covered LOC · 1 range
43
44
// register adds a metric definition to the list of pending metric definitions. This method is thread-safe.
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/common/metrics/noop_impl.go 1 covered LOC · 1 range
15
)
16
18
19
// WithTags creates a new MetricProvder with provided []Tag