(cluster: Cluster)
| 56 | |
| 57 | |
| 58 | def load_search_idx(cluster: Cluster) -> None: |
| 59 | sixm = cluster.search_indexes() |
| 60 | params_json = None |
| 61 | with open(TEST_INDEX_PATH) as params_file: |
| 62 | input = params_file.read() |
| 63 | params_json = json.loads(input) |
| 64 | |
| 65 | if params_json is None: |
| 66 | print('Unabled to read search index params') |
| 67 | return |
| 68 | |
| 69 | idx = SearchIndex(name=TEST_INDEX_NAME, |
| 70 | idx_type='fulltext-index', |
| 71 | source_name='default', |
| 72 | source_type='couchbase', |
| 73 | params=params_json) |
| 74 | sixm.upsert_index(idx) |
| 75 | indexed_docs = check_doc_count(sixm, TEST_INDEX_NAME, 20, retries=10, delay=3) |
| 76 | print(f'Have {indexed_docs} indexed documents.') |
| 77 | |
| 78 | |
| 79 | def drop_search_idx(cluster: Cluster) -> None: |
no test coverage detected