(self, config, name=None)
| 938 | ''' |
| 939 | |
| 940 | def __init__(self, config, name=None): |
| 941 | self.config = config |
| 942 | self._buffer_size = 50000 |
| 943 | redis_param = self._parse_config(self.config['redis']) |
| 944 | self._redis = redis.Redis(**redis_param) |
| 945 | redis_buffer_param = self._parse_config(self.config.get('redis_buffer', {})) |
| 946 | self._buffer = RedisBuffer(self._redis.connection_pool, |
| 947 | self._redis.response_callbacks, |
| 948 | transaction=redis_buffer_param.get('transaction', True), |
| 949 | buffer_size=self._buffer_size) |
| 950 | if name is None: |
| 951 | name = _random_name(11) |
| 952 | self._name = name |
| 953 | |
| 954 | @property |
| 955 | def buffer_size(self): |
no test coverage detected