Show More
__init__.py
75 lines
| 2.5 KiB
| text/x-python
|
PythonLexer
r2845 | # -*- coding: utf-8 -*- | |||
# Copyright (C) 2015-2018 RhodeCode GmbH | ||||
# | ||||
# This program is free software: you can redistribute it and/or modify | ||||
# it under the terms of the GNU Affero General Public License, version 3 | ||||
# (only), as published by the Free Software Foundation. | ||||
# | ||||
# This program is distributed in the hope that it will be useful, | ||||
# but WITHOUT ANY WARRANTY; without even the implied warranty of | ||||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||||
# GNU General Public License for more details. | ||||
# | ||||
# You should have received a copy of the GNU Affero General Public License | ||||
# along with this program. If not, see <http://www.gnu.org/licenses/>. | ||||
# | ||||
# This program is dual-licensed. If you wish to learn more about the | ||||
# RhodeCode Enterprise Edition, including its added features, Support services, | ||||
# and proprietary license terms, please see https://rhodecode.com/licenses/ | ||||
r2885 | import logging | |||
r2845 | from dogpile.cache import register_backend | |||
register_backend( | ||||
"dogpile.cache.rc.memory_lru", "rhodecode.lib.rc_cache.backends", | ||||
"LRUMemoryBackend") | ||||
register_backend( | ||||
"dogpile.cache.rc.file_namespace", "rhodecode.lib.rc_cache.backends", | ||||
"FileNamespaceBackend") | ||||
register_backend( | ||||
"dogpile.cache.rc.redis", "rhodecode.lib.rc_cache.backends", | ||||
"RedisPickleBackend") | ||||
r2885 | log = logging.getLogger(__name__) | |||
r2845 | from . import region_meta | |||
r2846 | from .utils import ( | |||
get_default_cache_settings, key_generator, get_or_create_region, | ||||
r2932 | clear_cache_namespace, make_region, InvalidationContext, | |||
FreshRegionCache, ActiveRegionCache) | ||||
r2845 | ||||
def configure_dogpile_cache(settings): | ||||
cache_dir = settings.get('cache_dir') | ||||
if cache_dir: | ||||
region_meta.dogpile_config_defaults['cache_dir'] = cache_dir | ||||
rc_cache_data = get_default_cache_settings(settings, prefixes=['rc_cache.']) | ||||
# inspect available namespaces | ||||
avail_regions = set() | ||||
for key in rc_cache_data.keys(): | ||||
namespace_name = key.split('.', 1)[0] | ||||
avail_regions.add(namespace_name) | ||||
r2885 | log.debug('dogpile: found following cache regions: %s', avail_regions) | |||
r2845 | ||||
# register them into namespace | ||||
for region_name in avail_regions: | ||||
new_region = make_region( | ||||
name=region_name, | ||||
function_key_generator=key_generator | ||||
) | ||||
new_region.configure_from_config(settings, 'rc_cache.{}.'.format(region_name)) | ||||
r2885 | ||||
log.debug('dogpile: registering a new region %s[%s]', | ||||
region_name, new_region.__dict__) | ||||
r2845 | region_meta.dogpile_cache_regions[region_name] = new_region | |||
def includeme(config): | ||||
configure_dogpile_cache(config.registry.settings) | ||||