mirror of
https://github.com/xcat2/confluent.git
synced 2024-11-22 17:43:14 +00:00
19 lines
687 B
Python
19 lines
687 B
Python
|
import confluent.messages as msg
|
||
|
|
|
||
|
|
def retrieve(nodes, element, configmanager):
|
||
|
|
attributes = configmanager.get_node_attributes(nodes)
|
||
|
|
for node in attributes.iterkeys():
|
||
|
|
for attribute in attributes[node].iterkeys():
|
||
|
|
currattr = attributes[node][attribute]
|
||
|
|
if 'value' in currattr:
|
||
|
|
yield msg.Attributes(node,
|
||
|
|
{attribute: currattr['value']})
|
||
|
|
elif 'cryptvalue' in currattr:
|
||
|
|
yield msg.CryptedAttributes(node,
|
||
|
|
{attribute: currattr['cryptvalue']})
|
||
|
|
else:
|
||
|
|
print repr(currattr)
|
||
|
|
raise Exception("BUGGY ATTRIBUTE FOR NODE")
|
||
|
|
|
||
|
|
|