log_common memcache passthrough to internal_proxy
This commit is contained in:
parent
6f3b21e918
commit
8faa0a8580
|
@ -53,8 +53,10 @@ class InternalProxy(object):
|
||||||
:param retries: number of times to retry each request
|
:param retries: number of times to retry each request
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, proxy_server_conf=None, logger=None, retries=0):
|
def __init__(self, proxy_server_conf=None, logger=None, retries=0,
|
||||||
self.upload_app = BaseApplication(proxy_server_conf, logger=logger)
|
memcache=None):
|
||||||
|
self.upload_app = BaseApplication(proxy_server_conf, memcache=memcache,
|
||||||
|
logger=logger)
|
||||||
self.retries = retries
|
self.retries = retries
|
||||||
|
|
||||||
def _handle_request(self, req, source_file=None, compress=True):
|
def _handle_request(self, req, source_file=None, compress=True):
|
||||||
|
|
|
@ -85,7 +85,8 @@ class LogProcessorCommon(object):
|
||||||
proxy_server_conf = None
|
proxy_server_conf = None
|
||||||
self._internal_proxy = InternalProxy(proxy_server_conf,
|
self._internal_proxy = InternalProxy(proxy_server_conf,
|
||||||
self.logger,
|
self.logger,
|
||||||
retries=3)
|
retries=3,
|
||||||
|
memcache=self.memcache)
|
||||||
return self._internal_proxy
|
return self._internal_proxy
|
||||||
|
|
||||||
def calculate_lookback(self):
|
def calculate_lookback(self):
|
||||||
|
|
Loading…
Reference in New Issue