def __init__(self, next_factory, sink_properties, global_properties):
    endpoint = global_properties[SinkProperties.Endpoint]
    service = global_properties[SinkProperties.Label]
    endpoint_source = '%s:%d' % (endpoint.host, endpoint.port)
    self.endpoint = endpoint_source
    self._log = ROOT_LOG.getChild('[%s.%s]' % (service, endpoint_source))
    self._properties = global_properties
    self._next_factory = next_factory
    self._resurrector = None
    self._down_on = None
    self._initial_wait_interval = sink_properties.initial_wait_interval
    self._max_wait_interval = sink_properties.max_wait_interval
    self._backoff_exponent = sink_properties.backoff_exponent
    self._varz = self.Varz(Source(service=service,
                                  endpoint=endpoint_source))
    super(ResurrectorSink, self).__init__()
dataset/ETHPy150Open steveniemitz/scales/scales/resurrector.py/ResurrectorSink.__init__/original