Package ganeti :: Package confd :: Module client :: Class ConfdFilterCallback

[frames] | no frames]

Class ConfdFilterCallback

Callback that calls another callback, but filters duplicate results.

Instance Methods

__init__(self, callback, logger=None)
Constructor for ConfdFilterCallback

source code

_LogFilter(self, salt, new_reply, old_reply)

source code

_HandleExpire(self, up)

source code

boolean

_HandleReply(self, up)
Handle a single confd reply, and decide whether to filter it.

source code

__call__(self, up)
Filtering callback

source code

Instance Variables

consistent
a dictionary indexed by salt; for each salt, if all responses ware identical, this will be True; this is the expected state on a healthy cluster; on inconsistent or partitioned clusters, this might be False, if we see answers with the same serial but different contents

Method Details

init(self, callback, logger=None)
(Constructor)

Constructor for ConfdFilterCallback

Parameters:

callback (f(ConfdUpcallPayload)) - function to call when getting answers
logger (logging.Logger) - optional logger for internal conditions

_HandleReply(self, up)

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

Returns: boolean: True if the reply should be filtered, False if it should be passed on to the up-callback

call(self, up)
(Call operator)

Filtering callback

Parameters:

up (ConfdUpcallPayload) - upper callback