Method _get

acouchbase/datastructures.py:927–941

Get the entire queuee.

(self, parent_span: Optional[WrappedSpan] = None)

                raise

    async def _get(self, parent_span: Optional[WrappedSpan] = None) -> List:
        """
        Get the entire queuee.
        """
        op_type = KeyValueOperationType.Get
        async with ObservableRequestHandler(op_type, self._impl.observability_instruments) as obs_handler:
            req, transcoder = self._impl.request_builder.build_get_request(self._key,
                                                                           obs_handler,
                                                                           parent_span=parent_span)
            return await self._execute_op(self._impl.get,
                                          req,
                                          obs_handler,
                                          parent_span,
                                          create_type=True,
                                          transcoder=transcoder)

    async def push(self, value: JSONType) -> None:
        """