mirror of
https://github.com/KevinMidboe/mktxp-no-cli.git
synced 2025-12-08 20:38:48 +00:00
adds capsman interface datasource
This commit is contained in:
@@ -16,7 +16,7 @@ from mktxp.cli.config.config import MKTXPConfigKeys
|
|||||||
from mktxp.flow.processor.output import BaseOutputProcessor
|
from mktxp.flow.processor.output import BaseOutputProcessor
|
||||||
from mktxp.collector.base_collector import BaseCollector
|
from mktxp.collector.base_collector import BaseCollector
|
||||||
from mktxp.datasource.dhcp_ds import DHCPMetricsDataSource
|
from mktxp.datasource.dhcp_ds import DHCPMetricsDataSource
|
||||||
from mktxp.datasource.capsman_ds import CapsmanCapsMetricsDataSource, CapsmanRegistrationsMetricsDataSource
|
from mktxp.datasource.capsman_ds import CapsmanCapsMetricsDataSource, CapsmanRegistrationsMetricsDataSource, CapsmanInterfacesDatasource
|
||||||
|
|
||||||
|
|
||||||
class CapsmanCollector(BaseCollector):
|
class CapsmanCollector(BaseCollector):
|
||||||
@@ -70,3 +70,9 @@ class CapsmanCollector(BaseCollector):
|
|||||||
yield registration_metrics
|
yield registration_metrics
|
||||||
|
|
||||||
|
|
||||||
|
remote_cap_interface_labels = ['name', 'configuration', 'mac_address', 'current_state', 'current_channel', 'current_registered_clients']
|
||||||
|
remote_cap_interface_records = CapsmanInterfacesDatasource.metric_records(router_entry, metric_labels = remote_cap_interface_labels)
|
||||||
|
if remote_cap_interface_records:
|
||||||
|
remote_caps_metrics = BaseCollector.info_collector('capsman_interfaces', 'CAPsMAN interfaces', remote_cap_interface_records, remote_cap_interface_labels)
|
||||||
|
yield remote_caps_metrics
|
||||||
|
|
||||||
|
|||||||
@@ -14,7 +14,6 @@
|
|||||||
|
|
||||||
from mktxp.datasource.base_ds import BaseDSProcessor
|
from mktxp.datasource.base_ds import BaseDSProcessor
|
||||||
|
|
||||||
|
|
||||||
class CapsmanCapsMetricsDataSource:
|
class CapsmanCapsMetricsDataSource:
|
||||||
''' Caps Metrics data provider
|
''' Caps Metrics data provider
|
||||||
'''
|
'''
|
||||||
@@ -43,3 +42,19 @@ class CapsmanRegistrationsMetricsDataSource:
|
|||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
print(f'Error getting caps-man registration table info from router{router_entry.router_name}@{router_entry.config_entry.hostname}: {exc}')
|
print(f'Error getting caps-man registration table info from router{router_entry.router_name}@{router_entry.config_entry.hostname}: {exc}')
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|
||||||
|
class CapsmanInterfacesDatasource:
|
||||||
|
''' Data provider for CAPsMaN interfaces
|
||||||
|
'''
|
||||||
|
|
||||||
|
@staticmethod
|
||||||
|
def metric_records(router_entry, *, metric_labels = None):
|
||||||
|
if metric_labels is None:
|
||||||
|
metric_labels = []
|
||||||
|
try:
|
||||||
|
caps_interfaces = router_entry.api_connection.router_api().get_resource('/caps-man/interface').get()
|
||||||
|
return BaseDSProcessor.trimmed_records(router_entry, router_records = caps_interfaces, metric_labels = metric_labels)
|
||||||
|
except Exception as exc:
|
||||||
|
print(f'Error getting caps-man interfaces info from router{router_entry.router_name}@{router_entry.config_entry.hostname}: {exc}')
|
||||||
|
return None
|
||||||
|
|||||||
Reference in New Issue
Block a user