added rest-connector extractions

Homeostase · Sep 20, 2024 · d0cf40e · d0cf40e
1 parent b7b21b3
commit d0cf40e
Show file tree

Hide file tree

Showing 2 changed files with 108 additions and 5 deletions.
diff --git a/package/default/props.conf b/package/default/props.conf
@@ -65,8 +65,12 @@ REPORT-swift_agi_activity_outgoing_imp_send_request_error = swift_agi_activity_o
 REPORT-swift_agi_activity_incoming_technical_ack = swift_agi_activity_incoming_technical_ack
 
 # rest-connector
-
-
-
+REPORT-swift_agi_activity_rest_incoming_technical_ack = swift_agi_activity_rest_incoming_technical_ack
+REPORT-swift_agi_activity_rest_incoming_network_message_error = swift_agi_activity_rest_incoming_network_message_error
+REPORT-swift_agi_activity_rest_incoming_receive_indication = swift_agi_activity_rest_incoming_receive_indication
+REPORT-swift_agi_activity_rest_incoming_unknown_network_message_error = swift_agi_activity_rest_incoming_unknown_network_message_error
+REPORT-swift_agi_activity_rest_incoming_receive_indication_error = swift_agi_activity_rest_incoming_receive_indication_error
+REPORT-swift_agi_activity_rest_outgoing_request = swift_agi_activity_rest_outgoing_request
+REPORT-swift_agi_activity_rest_outgoing_request_error = swift_agi_activity_rest_outgoing_request_error
 
 # wan-connector
diff --git a/package/default/transforms.conf b/package/default/transforms.conf
@@ -67,15 +67,114 @@ REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|
 REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>INCOMING-TECHNICAL-ACK)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<ack_type>[^\|]+)\|(?<aft_act_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)
 
 
-# rest-connector
+# rest-connector 
 
+## REST-INCOMING-TECHNICAL-ACK
+[swift_agi_activity_rest_incoming_technical_ack]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<ack_type>[^\|]+)\|(?<aft_act_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
+## REST-INCOMING-NETWORK-MESSAGE-ERROR
+[swift_agi_activity_rest_incoming_network_message_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<aft_wan_get_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_verif_time>[^\|]+)\|(?<aft_verif_time>[^\|]+)\|(?<bef_bo_put_time>[^\|]+)\|(?<bef_ack_put_time>[^\|]+)\|(?<aft_ack_put_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<verify_bef_vldt_cert_time>[^\|]+)\|(?<verify_aft_vldt_cert_time>[^\|]+)\|(?<verify_bef_vldt_sign_time>[^\|]+)\|(?<verify_aft_vldt_sign_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
-# wan-connector
+## REST-INCOMING-RECEIVE-INDICATION
+[swift_agi_activity_rest_incoming_receive_indication]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<aft_wan_get_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_verif_time>[^\|]+)\|(?<aft_verif_time>[^\|]+)\|(?<bef_bo_put_time>[^\|]+)\|(?<bef_ack_put_time>[^\|]+)\|(?<aft_ack_put_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<verify_bef_vldt_cert_time>[^\|]+)\|(?<verify_aft_vldt_cert_time>[^\|]+)\|(?<verify_bef_vldt_sign_time>[^\|]+)\|(?<verify_aft_vldt_sign_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
+## REST-INCOMING-UNKNOWN-NETWORK-MESSAGE-ERROR
+[swift_agi_activity_rest_incoming_unknown_network_message_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<aft_wan_get_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_verif_time>[^\|]+)\|(?<aft_verif_time>[^\|]+)\|(?<bef_bo_put_time>[^\|]+)\|(?<bef_ack_put_time>[^\|]+)\|(?<aft_ack_put_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<verify_bef_vldt_cert_time>[^\|]+)\|(?<verify_aft_vldt_cert_time>[^\|]+)\|(?<verify_bef_vldt_sign_time>[^\|]+)\|(?<verify_aft_vldt_sign_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
+## REST-INCOMING-RECEIVE-INDICATION-ERROR
+[swift_agi_activity_rest_incoming_receive_indication_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<bef_wan_get_time>[^\|]+)\|(?<aft_wan_get_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_verif_time>[^\|]+)\|(?<aft_verif_time>[^\|]+)\|(?<bef_bo_put_time>[^\|]+)\|(?<bef_ack_put_time>[^\|]+)\|(?<aft_ack_put_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<verify_bef_vldt_cert_time>[^\|]+)\|(?<verify_aft_vldt_cert_time>[^\|]+)\|(?<verify_bef_vldt_sign_time>[^\|]+)\|(?<verify_aft_vldt_sign_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
+## REST-OUTGOING-REQUEST
+[swift_agi_activity_rest_outgoing_request]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<start_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_sign_time>[^\|]+)\|(?<aft_sign_time>[^\|]+)\|(?<bef_wan_put_time>[^\|]+)\|(?<aft_wan_put_time>[^\|]+)\|(?<end_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<sign_bef_self_vrfy_time>[^\|]+)\|(?<sign_aft_self_vrfy_time>[^\|]+)\|(?<sign_bef_sign_crea_time>[^\|]+)\|(?<sign_aft_sign_crea_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
 
+## REST-OUTGOING-REQUEST-ERROR
+[swift_agi_activity_rest_outgoing_request_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<partner>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<biz_id>[^\|]+)\|(?<poss_dupl>[^\|]+)\|(?<start_time>[^\|]+)\|(?<sign_req_creat_dur_ms>[^\|]+)\|(?<bef_sign_time>[^\|]+)\|(?<aft_sign_time>[^\|]+)\|(?<bef_wan_put_time>[^\|]+)\|(?<aft_wan_put_time>[^\|]+)\|(?<end_time>[^\|]+)\|(?<x_request_id>[^\|]+)\|(?<sign_bef_self_vrfy_time>[^\|]+)\|(?<sign_aft_self_vrfy_time>[^\|]+)\|(?<sign_bef_sign_crea_time>[^\|]+)\|(?<sign_aft_sign_crea_time>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<sender>[^\|]+)\|(?<receiver>[^\|]+)\|(?<message_type>[^\|]+)\|(?<service>[^\|]+)
+
+
+# wan-connector 
+
+## GET-REQ-DROP
+[swift_agi_activity_get_req_drop]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<error>[^\|]+)
+
+## GET-REQ-ENQUED
+[swift_agi_activity_get_req_enqued]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)
+
+## GET-REQ-ERROR
+[swift_agi_activity_get_req_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<session_type>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<error>[^\|]+)
+
+## GET-REQ-SENT
+[swift_agi_activity_get_req_sent]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<session_type>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<sender_ref>[^\|]+)\|(?<primitive_type>[^\|]+)\|(?<size>[^\|]+)\|(?<request_queueing_dura tion>[^\|]+)\|(?<message_queueing_dur ation>[^\|]+)\|(?<message_processing_du ration>[^\|]+)\|(?<grpc_sending_duration>[^\|]+)\|(?<message_queue_depth>[^\|]+)\|(?<ipsw_time>[^\|]+)
+
+## GET-REQ-TIMEOUT
+[swift_agi_activity_get_req_timeout]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<error>[^\|]+)
+
+## LS-CONNECTED
+[swift_agi_activity_ls_connected]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)
+
+## LS-CREATED
+[swift_agi_activity_ls_created]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)
+
+## LS-SHUTDOWN
+[swift_agi_activity_ls_shutdown]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)
+
+## LS-TERMINATE
+[swift_agi_activity_ls_terminate]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<reason>[^\|]+)
+
+## MSG-ERROR
+[swift_agi_activity_msg_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<sender_ref>[^\|]+)\|(?<primitive_type>[^\|]+)\|(?<size>[^\|]+)\|(?<message_queueing_dur ation>[^\|]+)\|(?<error>[^\|]+)
+
+## MSG-NACK-ERROR
+[swift_agi_activity_msg_nack_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<service>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<sender_ref>[^\|]+)
+
+## MSG-NACK-SENT
+[swift_agi_activity_msg_nack_sent]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_type>[^\|]+)\|(?<partner>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<service>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<sender_ref>[^\|]+)
+
+## PS-DISCONNECT
+[swift_agi_activity_ps_disconnect]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_id>[^\|]+)\|(?<session_key>[^\|]+)
+
+## PS-RECONNECT
+[swift_agi_activity_ps_reconnect]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_id>[^\|]+)\|(?<session_key>[^\|]+)
+
+## PS-TERMINATE
+[swift_agi_activity_ps_terminate]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_id>[^\|]+)\|(?<session_key>[^\|]+)\|(?<error>[^\|]+)
+
+## PUT-REQ-ERROR
+[swift_agi_activity_put_req_error]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<session_type>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<error>[^\|]+)
+
+## PUT-REQ-SENT
+[swift_agi_activity_put_req_sent]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<tx_remote_ip>[^\|]+)\|(?<tx_deadline>[^\|]+)\|(?<partner>[^\|]+)\|(?<session_type>[^\|]+)\|(?<psid>[^\|]+)\|(?<lsid>[^\|]+)\|(?<msg_id>[^\|]+)\|(?<sender_ref>[^\|]+)\|(?<primitive_type>[^\|]+)\|(?<size>[^\|]+)\|(?<message_queueing_dur ation>[^\|]+)\|(?<message_processing_du ration>[^\|]+)\|(?<grpc_sending_duration>[^\|]+)
+
+## SIGN-MRR
+[swift_agi_activity_sign_mrr]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_id>[^\|]+)\|(?<session_key>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<duration>[^\|]+)\|(?<receiver>[^\|]+)\|(?<size>[^\|]+)
+
+## SIGN-MRR-ERR
+[swift_agi_activity_sign_mrr_err]
+REGEX = (?<activity_time>[^\|]+)\|(?<container_id>[^\|]+)\|(?<micro_service>[^\|]+)\|(?<process_id>[^\|]+)\|(?<thread_id>[^\|]+)\|(?<activity>[^\|]+)\|(?<session_id>[^\|]+)\|(?<session_key>[^\|]+)\|(?<tx_span_trace_id>[^\|]+)\|(?<tx_span_id>[^\|]+)\|(?<duration>[^\|]+)\|(?<receiver>[^\|]+)\|(?<size>[^\|]+)\|(?<error>[^\|]+)
 
 
 #