xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-20 06:34:26 +00:00
Code Issues Projects Releases Wiki Activity

SRLinux async handling advancement

Browse Source
This commit is contained in:
Jarrod Johnson
2026-02-19 16:34:36 -05:00
parent 4173356a70
commit 09089befc8
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
confluent_server/confluent/plugins/hardwaremanagement/srlinux.py
View File

@@ -22,36 +22,36 @@ async def retrieve_node_backend(node, element, user, pwd, configmanager, inputda
cli = srlinux.SRLinuxClient(node, user, pwd, configmanager)
await cli.login()
if element == ['power', 'state']: # client initted successfully, must be on
results.put(msg.PowerState(node, 'on'))
await results.put(msg.PowerState(node, 'on'))
elif element == ['health', 'hardware']:
hinfo = await cli.get_health()
results.put(msg.HealthSummary(hinfo.get('health', 'unknown'), name=node))
results.put(msg.SensorReadings(hinfo.get('sensors', []), name=node))
await results.put(msg.HealthSummary(hinfo.get('health', 'unknown'), name=node))
await results.put(msg.SensorReadings(hinfo.get('sensors', []), name=node))
elif element[:3] == ['inventory', 'hardware', 'all']:
if len(element) == 3:
results.put(msg.ChildCollection('all'))
await results.put(msg.ChildCollection('all'))
return
invinfo = await cli.get_inventory()
if invinfo:
results.put(msg.KeyValueData({'inventory': invinfo}, node))
await results.put(msg.KeyValueData({'inventory': invinfo}, node))
elif element[:3] == ['inventory', 'firmware', 'all']:
if len(element) == 3:
results.put(msg.ChildCollection('all'))
await results.put(msg.ChildCollection('all'))
return
fwinfo = []
for fwnam, fwdat in (await cli.get_firmware()).items():
fwinfo.append({fwnam: fwdat})
if fwinfo:
results.put(msg.Firmware(fwinfo, node))
await results.put(msg.Firmware(fwinfo, node))
elif element == ['sensors', 'hardware', 'all']:
sensors = await cli.get_sensors()
for sensor in sensors:
results.put(msg.ChildCollection(simplify_name(sensor['name'])))
await results.put(msg.ChildCollection(simplify_name(sensor['name'])))
elif element[:3] == ['sensors', 'hardware', 'all']:
sensors = await cli.get_sensors()
for sensor in sensors:
if element[-1] == 'all' or simplify_name(sensor['name']) == element[-1]:
results.put(msg.SensorReadings([sensor], node))
await results.put(msg.SensorReadings([sensor], node))
else:
print(repr(element))