Internal method used to specify a scan vector. :param mut_token: A tuple in the form of `(vbucket id, vbucket uuid, mutation sequence)`
(self, mut_token # type: MutationToken
)
| 39 | self._sv.add(mut_token) |
| 40 | |
| 41 | def _add_scanvec(self, mut_token # type: MutationToken |
| 42 | ) -> bool: |
| 43 | """ |
| 44 | Internal method used to specify a scan vector. |
| 45 | :param mut_token: A tuple in the form of |
| 46 | `(vbucket id, vbucket uuid, mutation sequence)` |
| 47 | """ |
| 48 | if isinstance(mut_token, MutationToken): |
| 49 | self._sv.add(mut_token) |
| 50 | return True |
| 51 | |
| 52 | return False |
| 53 | |
| 54 | def add_results(self, *rvs, # type: List[MutationResult] |
| 55 | **kwargs # type: Dict[str, Any] |