Class e.p.g.a.GstMetadataMaster(Loggable, Master):

def __init__(self, max_restart_retries, slave_spawn_timeout, slave_retry_timeout_step):

def get_metadata(self, metadata):

def startSlaves(self, num, spawn_timeout=None):

def stop(self):

def _check_deleted_file(self, metadata):

def _schedule_next_request(self):

def _next_request(self):

def _get_metadata_cb(self, result, request):

def _restart_callback(self, result):

def _restart_errback(self, failure):

def _get_metadata_eb(self, failure, request):

def _try_restart_slave(self):

def _abort_pending_requests(self, failure):