(self, app,
serializer=None, max_cached_results=None, accept=None,
expires=None, expires_type=None, url=None, **kwargs)
| 136 | } |
| 137 | |
| 138 | def __init__(self, app, |
| 139 | serializer=None, max_cached_results=None, accept=None, |
| 140 | expires=None, expires_type=None, url=None, **kwargs): |
| 141 | self.app = app |
| 142 | conf = self.app.conf |
| 143 | self.serializer = serializer or conf.result_serializer |
| 144 | (self.content_type, |
| 145 | self.content_encoding, |
| 146 | self.encoder) = serializer_registry._encoders[self.serializer] |
| 147 | cmax = max_cached_results or conf.result_cache_max |
| 148 | self._cache = _nulldict() if cmax == -1 else LRUCache(limit=cmax) |
| 149 | |
| 150 | self.expires = self.prepare_expires(expires, expires_type) |
| 151 | |
| 152 | # precedence: accept, conf.result_accept_content, conf.accept_content |
| 153 | self.accept = conf.result_accept_content if accept is None else accept |
| 154 | self.accept = conf.accept_content if self.accept is None else self.accept |
| 155 | self.accept = prepare_accept_content(self.accept) |
| 156 | |
| 157 | self.always_retry = conf.get('result_backend_always_retry', False) |
| 158 | self.max_sleep_between_retries_ms = conf.get('result_backend_max_sleep_between_retries_ms', 10000) |
| 159 | self.base_sleep_between_retries_ms = conf.get('result_backend_base_sleep_between_retries_ms', 10) |
| 160 | self.max_retries = conf.get('result_backend_max_retries', float("inf")) |
| 161 | self.thread_safe = conf.get('result_backend_thread_safe', False) |
| 162 | |
| 163 | self._pending_results = pending_results_t({}, WeakValueDictionary()) |
| 164 | self._pending_messages = BufferMap(MESSAGE_BUFFER_MAX) |
| 165 | self.url = url |
| 166 | |
| 167 | def as_uri(self, include_password=False): |
| 168 | """Return the backend as an URI, sanitizing the password or not.""" |
no test coverage detected