Create a pool named unique_pool_X where X is unique.
(self, pg_num=16,
erasure_code_profile_name=None,
erasure_code_crush_rule_name=None,
min_size=None,
erasure_code_use_overwrites=False)
| 2203 | self.raw_cluster_cmd(*args) |
| 2204 | |
| 2205 | def create_pool_with_unique_name(self, pg_num=16, |
| 2206 | erasure_code_profile_name=None, |
| 2207 | erasure_code_crush_rule_name=None, |
| 2208 | min_size=None, |
| 2209 | erasure_code_use_overwrites=False): |
| 2210 | """ |
| 2211 | Create a pool named unique_pool_X where X is unique. |
| 2212 | """ |
| 2213 | name = "" |
| 2214 | with self.lock: |
| 2215 | name = "unique_pool_%s" % (str(self.next_pool_id),) |
| 2216 | self.next_pool_id += 1 |
| 2217 | self.create_pool( |
| 2218 | name, |
| 2219 | pg_num, |
| 2220 | erasure_code_profile_name=erasure_code_profile_name, |
| 2221 | erasure_code_crush_rule_name=erasure_code_crush_rule_name, |
| 2222 | min_size=min_size, |
| 2223 | erasure_code_use_overwrites=erasure_code_use_overwrites) |
| 2224 | return name |
| 2225 | |
| 2226 | @contextlib.contextmanager |
| 2227 | def pool(self, pool_name, pg_num=16, erasure_code_profile_name=None): |