csle_collector.five_g_core_manager.dao package
Submodules
csle_collector.five_g_core_manager.dao.five_g_core_amf_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_amf_metrics.FiveGCoreAMFMetrics(gnb: int = 0, fivegs_amffunction_mm_confupdate: int = 0, fivegs_amffunction_rm_reginitreq: int = 0, fivegs_amffunction_rm_regemergreq: int = 0, fivegs_amffunction_mm_paging5greq: int = 0, fivegs_amffunction_rm_regperiodreq: int = 0, fivegs_amffunction_mm_confupdatesucc: int = 0, fivegs_amffunction_rm_reginitsucc: int = 0, fivegs_amffunction_amf_authreject: int = 0, fivegs_amffunction_rm_regmobreq: int = 0, amf_session: int = 0, fivegs_amffunction_rm_regmobsucc: int = 0, fivegs_amffunction_amf_authreq: int = 0, fivegs_amffunction_rm_regemergsucc: int = 0, fivegs_amffunction_mm_paging5gsucc: int = 0, ran_ue: int = 0, fivegs_amffunction_rm_regperiodsucc: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0, ip: Union[None, str] = None, ts: Optional[float] = None)[source]
Bases:
JSONSerializableDTO class containing 5G core metrics related to the AMF service
- copy() FiveGCoreAMFMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCoreAMFMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCoreAMFMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCoreAMFMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCoreAMFMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_hss_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_hss_metrics.FiveGCoreHSSMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, cx_rx_lir: int = 0, cx_rx_uar: int = 0, cx_tx_lia: int = 0, cx_rx_unknown: int = 0, cx_rx_sar: int = 0, s6a_rx_pur: int = 0, swx_rx_mar_error: int = 0, cx_tx_uaa: int = 0, s6a_rx_pur_error: int = 0, s6a_tx_clr: int = 0, cx_tx_saa: int = 0, cx_rx_lir_error: int = 0, s6a_rx_ulr: int = 0, s6a_rx_cla: int = 0, s6a_rx_cla_error: int = 0, s6a_rx_air: int = 0, cx_rx_mar: int = 0, swx_rx_sar: int = 0, s6a_rx_air_error: int = 0, s6a_rx_ida_error: int = 0, cx_tx_maa: int = 0, swx_rx_mar: int = 0, s6a_rx_unknown: int = 0, s6a_tx_pua: int = 0, swx_rx_unknown: int = 0, cx_rx_mar_error: int = 0, cx_rx_uar_error: int = 0, s6a_tx_ula: int = 0, s6a_rx_ulr_error: int = 0, s6a_tx_aia: int = 0, s6a_tx_idr: int = 0, s6a_rx_ida: int = 0, cx_rx_sar_error: int = 0, swx_rx_sar_error: int = 0, swx_tx_maa: int = 0, swx_tx_saa: int = 0, hss_imsi: int = 0, hss_impi: int = 0, hss_impu: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core HSS metrics
- copy() FiveGCoreHSSMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCoreHSSMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCoreHSSMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCoreHSSMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCoreHSSMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_mme_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_mme_metrics.FiveGCoreMMEMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, enb_ue: int = 0, mme_session: int = 0, enb: int = 0, process_max_fds: int = 1024, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core MME metrics
- copy() FiveGCoreMMEMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCoreMMEMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCoreMMEMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCoreMMEMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCoreMMEMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_pcf_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_pcf_metrics.FiveGCorePCFMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, fivegs_pcffunction_pa_policyamassoreq: int = 0, fivegs_pcffunction_pa_policyamassosucc: int = 0, fivegs_pcffunction_pa_policysmassoreq: int = 0, fivegs_pcffunction_pa_policysmassosucc: int = 0, fivegs_pcffunction_pa_sessionnbr: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core PCF metrics
- copy() FiveGCorePCFMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCorePCFMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCorePCFMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCorePCFMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCorePCFMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_pcrf_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_pcrf_metrics.FiveGCorePCRFMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, gx_rx_unknown: int = 0, gx_rx_ccr: int = 0, gx_rx_ccr_error: int = 0, gx_rx_raa: int = 0, gx_tx_cca: int = 0, gx_tx_rar: int = 0, gx_tx_rar_error: int = 0, rx_rx_unknown: int = 0, rx_rx_aar: int = 0, rx_rx_aar_error: int = 0, rx_rx_asa: int = 0, rx_rx_asa_error: int = 0, rx_rx_str_error: int = 0, rx_tx_aaa: int = 0, rx_tx_sar: int = 0, rx_tx_sta: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core PCRF metrics (Gx and Rx interfaces)
- copy() FiveGCorePCRFMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCorePCRFMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCorePCRFMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCorePCRFMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCorePCRFMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_smf_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_smf_metrics.FiveGCoreSMFMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, gn_rx_createpdpcontextreq: int = 0, gn_rx_deletepdpcontextreq: int = 0, gtp1_pdpctxs_active: int = 0, pfcp_peers_active: int = 0, fivegs_smffunction_sm_n4sessionreport: int = 0, ues_active: int = 0, gtp2_sessions_active: int = 0, pfcp_sessions_active: int = 0, s5c_rx_createsession: int = 0, s5c_rx_deletesession: int = 0, gtp_new_node_failed: int = 0, s5c_rx_parse_failed: int = 0, fivegs_smffunction_sm_n4sessionreportsucc: int = 0, fivegs_smffunction_sm_n4sessionestabreq: int = 0, bearers_active: int = 0, gn_rx_parse_failed: int = 0, gtp_peers_active: int = 0, fivegs_smffunction_sm_sessionnbr: int = 0, fivegs_smffunction_sm_pdusessioncreationreq: int = 0, fivegs_smffunction_sm_pdusessioncreationsucc: int = 0, fivegs_smffunction_sm_qos_flow_nbr: int = 0, fivegs_smffunction_sm_n4sessionestabfail: int = 0, fivegs_smffunction_sm_pdusessioncreationfail: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core SMF metrics
- copy() FiveGCoreSMFMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCoreSMFMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCoreSMFMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCoreSMFMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCoreSMFMetrics[source]
- Returns
get the schema of the DTO
csle_collector.five_g_core_manager.dao.five_g_core_upf_metrics module
- class csle_collector.five_g_core_manager.dao.five_g_core_upf_metrics.FiveGCoreUPFMetrics(ip: Union[None, str] = None, ts: Optional[float] = None, fivegs_ep_n3_gtp_indatapktn3upf: int = 0, fivegs_ep_n3_gtp_outdatapktn3upf: int = 0, fivegs_upffunction_sm_n4sessionestabreq: int = 0, fivegs_upffunction_sm_n4sessionreport: int = 0, fivegs_upffunction_sm_n4sessionreportsucc: int = 0, fivegs_upffunction_upf_sessionnbr: int = 0, pfcp_peers_active: int = 0, process_max_fds: int = 0, process_virtual_memory_max_bytes: int = 0, process_cpu_seconds_total: int = 0, process_virtual_memory_bytes: int = 0, process_resident_memory_bytes: int = 0, process_start_time_seconds: int = 0, process_open_fds: int = 0)[source]
Bases:
JSONSerializableDTO class containing 5G Core UPF metrics
- copy() FiveGCoreUPFMetrics[source]
- Returns
a copy of the object
- static from_dict(d: Dict[str, Any]) FiveGCoreUPFMetrics[source]
Converts a dict representation to an instance
- Parameters
d – the dict to convert
- Returns
the created instance
- static from_json_file(json_file_path: str) FiveGCoreUPFMetrics[source]
Reads a json file and converts it to a DTO
- Parameters
json_file_path – the json file path
- Returns
the converted DTO
- static from_kafka_record(record: str) FiveGCoreUPFMetrics[source]
Converts the Kafka record string to a DTO
- Parameters
record – the kafka record
- Returns
the created DTO
- static schema() FiveGCoreUPFMetrics[source]
- Returns
get the schema of the DTO