Method add

acouchbase/datastructures.py:714–739

Add an item to a set if the item does not yet exist. :param value: Value to add .. seealso:: :meth:`map_add`

(self, value: Any)

                                          transcoder=transcoder)

    async def add(self, value: Any) -> bool:
        """
        Add an item to a set if the item does not yet exist.

        :param value: Value to add
        .. seealso:: :meth:`map_add`
        """
        op_type = DatastructureOperationType.SetAdd
        async with ObservableRequestHandler(op_type, self._impl.observability_instruments) as ds_obs_handler:
            ds_obs_handler.create_kv_span(self._impl._request_builder._collection_dtls.get_details_as_dict())
            kv_op_type = KeyValueOperationType.MutateIn
            async with ObservableRequestHandler(kv_op_type, self._impl.observability_instruments) as obs_handler:
                try:
                    op = array_addunique('', value)
                    req = self._impl.request_builder.build_mutate_in_request(self._key,
                                                                             (op,),
                                                                             obs_handler,
                                                                             parent_span=ds_obs_handler.wrapped_span)
                    await self._execute_op(self._impl.mutate_in,
                                           req,
                                           obs_handler,
                                           ds_obs_handler.wrapped_span,
                                           create_type=True)
                    return True
                except PathExistsException:
                    return False

    async def remove(self, value: Any, timeout: Optional[timedelta] = None) -> None:  # noqa: C901
        """