saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

New flag for watching minion returns by function.

Browse source
This commit is contained in:
Mike Place 2014-03-18 13:49:47 -06:00
parent c8f255b3d8
commit d4738b6352
1 changed files with 21 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
tests/eventlisten.py
View file

@ -37,6 +37,11 @@ def parse():
help=('State if this listener will attach to a master or a '
'minion daemon, pass "master" or "minion"'))
parser.add_option('-f',
'--func_count',
help=('Retun a count of the number of minons which have '
'replied to a job with a given func.'))
options, args = parser.parse_args()
opts = {}
@ -67,15 +72,26 @@ def listen(sock_dir, node, id=None):
id=id
)
print(event.puburi)
jid_counter = 0
found_minions = []
while True:
ret = event.get_event(full=True)
if ret is None:
continue
print('Event fired at {0}'.format(time.asctime()))
print('*' * 25)
print('Tag: {0}'.format(ret['tag']))
print('Data:')
pprint.pprint(ret['data'])
if opts.get('func_count', False):
data = ret.get('data', False)
if data:
if data.get('id', False) and data.get('id', False) not in found_minions:
jid_counter += 1
found_minions.append(data['id'])
print('Reply received from [{0}]. Total replies now: [{1}].'.format(ret['data']['id'], jid_counter))
continue
else:
print('Event fired at {0}'.format(time.asctime()))
print('*' * 25)
print('Tag: {0}'.format(ret['tag']))
print('Data:')
pprint.pprint(ret['data'])
if __name__ == '__main__':