'Reads a list of kube events, invalidates caches and and computes a set
of containers impacted by the changes, to refresh service discovery
Pod creation/deletion events are ignored for now, as docker_daemon already
sends container creation/deletion events to SD
Pod->containers matching is done using match_containers_for_pods'

def process_events(self, event_array, podlist=None):

    try:
        pods = set()
        if self._service_mapper:
            pods.update(self._service_mapper.process_events(event_array))
        return self.match_containers_for_pods(pods, podlist)
    except Exception as e:
        log.warning(('Error    processing    events    %s:    %s' % (str(event_array), e)))
        return set()
