valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 17:33:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add get jids and get minions to redis returner

Browse Source
This commit is contained in:
Thomas S Hatch 2012-11-20 16:12:13 -07:00
parent 3d55771591
commit 4c99db2cc1
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
salt/returners/redis_return.py
View File

@ -44,14 +44,16 @@ def returner(ret):
serv.set('{0}:{1}'.format(ret['id'], ret['jid']), json.dumps(ret))
serv.lpush('{0}:{1}'.format(ret['id'], ret['fun']), ret['jid'])
serv.sadd('minions', ret['id'])
serv.sadd('jids', jid)
def save_load(jid, load):
'''
Save the load to the speified jib id
Save the load to the specified jid
'''
serv = _get_serv()
serv.set(jid, json.dumps(load))
serv.sadd('jids', jid)
def get_load(jid):
@ -77,6 +79,7 @@ def get_jid(jid):
ret[minion] = json.loads(data)
return ret
def get_fun(fun):
'''
Return a dict of the last function called for all minions
@ -93,3 +96,19 @@ def get_fun(fun):
if data:
ret[minion] = json.loads(data)
return ret
def get_jids():
'''
Return a list of all job ids
'''
serv = _get_serv()
return serv.smembers('jids')
def get_minions():
'''
Return a list of minions
'''
serv = _get_serv()
return serv.smembers('minions')