csle_collector.five_g_cu_manager.dao package

Submodules

csle_collector.five_g_cu_manager.dao.five_g_cu_app_resource_usage_metrics module

class csle_collector.five_g_cu_manager.dao.five_g_cu_app_resource_usage_metrics.FiveGCUAppResourceUsageMetrics(cpu_usage_percent: float = 0.0, memory_usage_mb: float = 0.0, power_consumption_watts: float = 0.0, ip: Union[None, str] = None, ts: Optional[float] = None)[source]

Bases: JSONSerializable

DTO class containing srsRAN CU (Central Unit) Application Resource Usage metrics. Captures system-level performance indicators for the application process.

copy() → FiveGCUAppResourceUsageMetrics[source]
Returns

a copy of the object

static from_dict(d: Dict[str, Any]) → FiveGCUAppResourceUsageMetrics[source]

Converts a dict representation to an instance. Expects the flat dictionary format produced by to_dict().

Parameters

d – the dict to convert

Returns

the created instance

static from_json_file(json_file_path: str) → FiveGCUAppResourceUsageMetrics[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) → FiveGCUAppResourceUsageMetrics[source]

Converts the Kafka record string to a DTO

Parameters

record – the kafka record

Returns

the created DTO

static from_ws_dict(d: Dict[str, Any], ip: str) → FiveGCUAppResourceUsageMetrics[source]

Converts the raw dictionary from the WebSocket JSON stream to an instance. Handles the nested “app_resource_usage” structure.

Parameters

  • d – the raw dictionary from srsRAN WebSocket

  • ip – the IP of the source CU

Returns

the created instance

num_attributes() → int[source]
Returns

The number of attributes of the DTO

static schema() → FiveGCUAppResourceUsageMetrics[source]
Returns

get the schema of the DTO

to_dict() → Dict[str, Any][source]
Returns

a dict representation of the instance

to_kafka_record(ip: str) → str[source]

Converts the DTO into a Kafka record string

Parameters

ip – the IP to add to the record in addition to the metrics

Returns

a comma separated string representing the kafka record

update_with_kafka_record(record: str, ip: str) → None[source]

Updates the DTO based on a kafka record

Parameters

  • record – the kafka record

  • ip – the host ip

Returns

None

csle_collector.five_g_cu_manager.dao.five_g_cu_buffer_pool_metrics module

class csle_collector.five_g_cu_manager.dao.five_g_cu_buffer_pool_metrics.FiveGCUBufferPoolMetrics(central_cache_size: int = 0, ip: Union[None, str] = None, ts: Optional[float] = None)[source]

Bases: JSONSerializable

DTO class containing srsRAN CU (Central Unit) Buffer Pool metrics

copy() → FiveGCUBufferPoolMetrics[source]
Returns

a copy of the object

static from_dict(d: Dict[str, Any]) → FiveGCUBufferPoolMetrics[source]

Converts a dict representation to an instance. Expects the flat dictionary format produced by to_dict().

Parameters

d – the dict to convert

Returns

the created instance

static from_json_file(json_file_path: str) → FiveGCUBufferPoolMetrics[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) → FiveGCUBufferPoolMetrics[source]

Converts the Kafka record string to a DTO

Parameters

record – the kafka record

Returns

the created DTO

static from_ws_dict(d: Dict[str, Any], ip: str) → FiveGCUBufferPoolMetrics[source]

Converts the raw dictionary from the WebSocket JSON stream to an instance. Handles the nested “buffer_pool” structure.

Parameters

  • d – the raw dictionary from srsRAN WebSocket

  • ip – the IP of the source CU

Returns

the created instance

num_attributes() → int[source]
Returns

The number of attributes of the DTO

static schema() → FiveGCUBufferPoolMetrics[source]
Returns

get the schema of the DTO

to_dict() → Dict[str, Any][source]
Returns

a dict representation of the instance

to_kafka_record(ip: str) → str[source]

Converts the DTO into a Kafka record string

Parameters

ip – the IP to add to the record in addition to the metrics

Returns

a comma separated string representing the kafka record

update_with_kafka_record(record: str, ip: str) → None[source]

Updates the DTO based on a kafka record

Parameters

  • record – the kafka record

  • ip – the host ip

Returns

None

csle_collector.five_g_cu_manager.dao.five_g_cu_cp_metrics module

class csle_collector.five_g_cu_manager.dao.five_g_cu_cp_metrics.FiveGCUCPMetrics(cu_cp_id: str = '', amf_connected: bool = False, nof_cn_initiated_paging_requests: int = 0, nof_pdu_sessions_requested_to_setup: int = 0, nof_pdu_sessions_successfully_setup: int = 0, nof_pdu_sessions_failed_to_setup_total: int = 0, nof_handover_preparations_requested: int = 0, nof_successful_handover_preparations: int = 0, rrc_establishments_attempted_total: int = 0, rrc_establishments_successful_total: int = 0, rrc_establishments_attempted_mo_data: int = 0, rrc_establishments_successful_mo_data: int = 0, rrc_establishments_attempted_mo_sig: int = 0, rrc_establishments_successful_mo_sig: int = 0, max_nof_rrc_connections: int = 0, mean_nof_rrc_connections: int = 0, rrc_reestablishments_attempted: int = 0, rrc_reestablishments_successful: int = 0, nof_handover_executions_requested: int = 0, nof_successful_handover_executions: int = 0, ip: Union[None, str] = None, ts: Optional[float] = None)[source]

Bases: JSONSerializable

DTO class containing srsRAN CU-CP (Central Unit - Control Plane) metrics. Captures NGAP (AMF interface) and RRC (UE/DU interface) statistics.

copy() → FiveGCUCPMetrics[source]
Returns

a copy of the object

static from_dict(d: Dict[str, Any]) → FiveGCUCPMetrics[source]

Converts a dict representation to an instance. Expects the flat dictionary format produced by to_dict().

Parameters

d – the dict to convert

Returns

the created instance

static from_json_file(json_file_path: str) → FiveGCUCPMetrics[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) → FiveGCUCPMetrics[source]

Converts the Kafka record string to a DTO

Parameters

record – the kafka record

Returns

the created DTO

static from_ws_dict(d: Dict[str, Any], ip: str) → FiveGCUCPMetrics[source]

Converts the raw dictionary from the WebSocket JSON stream to an instance. Handles the nested “cu-cp” structure.

Parameters

  • d – the raw dictionary from srsRAN WebSocket

  • ip – the IP of the source CU-CP

Returns

the created instance

num_attributes() → int[source]
Returns

The number of attributes of the DTO

static schema() → FiveGCUCPMetrics[source]
Returns

get the schema of the DTO

to_dict() → Dict[str, Any][source]
Returns

a dict representation of the instance

to_kafka_record(ip: str) → str[source]

Converts the DTO into a Kafka record string

Parameters

ip – the IP to add to the record in addition to the metrics

Returns

a comma separated string representing the kafka record

update_with_kafka_record(record: str, ip: str) → None[source]

Updates the DTO based on a kafka record

Parameters

  • record – the kafka record

  • ip – the host ip

Returns

None

Module contents