ó ½-'Nc@s€ddlmZddlmZddlmZddlmZddlm Z de fd„ƒYZ de fd „ƒYZ d S( iÿÿÿÿ(tinfo(tsucceed(t format_object(t log_failure(tBrokerClientPlugint MonitorPlugincBsMeZdZdZd„Zd„Zed„ƒZed„ƒZ d„Z RS(sy @cvar persist_name: If specified as a string, a C{_persist} attribute will be available after registration. cCsitt|ƒj|ƒ|jdk r\|jjj|jƒ|_|j j j d|j ƒn d|_dS(Nt resynchronize( tsuperRtregistert persist_nametNonetmonitortpersisttroot_att_persisttregistrytreactortcall_ont_resynchronize(tselfR ((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyRs cCs|jjj|jƒdS(N(RR tremoveR (R((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyRscCs|jS(sReturn our L{Persist}, if any.(R(R((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR scCs|jS(s%An alias for the C{client} attribute.(tclient(R((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR "scs5‡‡‡fd†}|jjjd|f|ƒdS(sV Register a callback fired upon a C{message-type-acceptance-changed}. cs|rˆˆˆŽSdS(N((t acceptance(tcallabletargstkwargs(s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pytacceptance_changed,ssmessage-type-acceptance-changedN(R RR(RttypeRRRR((RRRs</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pytcall_on_accepted'sN( t__name__t __module__t__doc__R R RRtpropertyR R R(((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR s  t DataWatchercBsAeZdZdZdZd„Zd„Zd„Ze d„Z RS(sY A utility for plugins which send data to the Landscape server which does not constantly change. New messages will only be sent when the result of get_data() has changed since the last time it was called. Subclasses should provide a get_data method, and message_type, message_key, and persist_name class attributes. cCsS|jƒ}|jjdƒ|krO|jjd|ƒi|jd6||j6SdS(s} Construct a message with the latest data, or None, if the data has not changed since the last call. tdataRN(tget_dataRtgettsett message_typet message_key(RR"((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyt get_messageBs cs}ˆjƒ}|dk rstdtˆƒƒˆjjj|d|ƒ}‡fd†}|j|ƒ|jt ƒ|St dƒS(Ns9Queueing a message with updated data watcher info for %s.turgentcsˆjƒdS(N(t persist_data(t message_id(R(s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR*Ss( R(R RRRtbrokert send_messaget addCallbackt addErrbackRR(RR)tmessagetresultR*((Rs</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR-Ls     cCsdS(ss Sub-classes that need to defer the saving of persistent data should override this method. N((R((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR*[scCs|jjj|j|j|ƒS(sd Conditionally add a message to the message store if new data is available. (RR,tcall_if_acceptedR&R-(RR)((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pytexchangebsN( RRRR R&R'R(R-R*tFalseR3(((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyR!4s   N( tloggingRttwisted.internet.deferRt landscape.logRtlandscape.lib.logRtlandscape.broker.clientRRR!(((s</usr/lib/python2.7/dist-packages/landscape/monitor/plugin.pyts *