ganeti.confd.client.ConfdCountingCallback

class documentation

class ConfdCountingCallback(object):

View In Hierarchy

Callback that calls another callback, and counts the answers

Method __call__ Filtering callback
Method __init__ Constructor for ConfdCountingCallback
Method AllAnswered Have all the registered queries received at least an answer?
Method RegisterQuery Undocumented
Method _HandleExpire Undocumented
Method _HandleReply Handle a single confd reply, and decide whether to filter it.
Instance Variable _answers Undocumented
Instance Variable _callback Undocumented
Instance Variable _logger Undocumented
def __call__(self, up):

Filtering callback

Parameters
up:ConfdUpcallPayloadupper callback
def __init__(self, callback, logger=None):

Constructor for ConfdCountingCallback

Parameters
callback:f(ConfdUpcallPayload)function to call when getting answers
logger:logging.Loggeroptional logger for internal conditions
def AllAnswered(self):

Have all the registered queries received at least an answer?

def RegisterQuery(self, salt):

Undocumented

def _HandleExpire(self, up):

Undocumented

def _HandleReply(self, up):

Handle a single confd reply, and decide whether to filter it.

Returns
booleanTrue if the reply should be filtered, False if it should be passed on to the up-callback
_answers: dict =

Undocumented

_callback =

Undocumented

_logger =

Undocumented