@@ -296,6 +296,47 @@ def update(
296296 ),
297297 )
298298
299+ def list (
300+ self ,
301+ queue_id : str ,
302+ * ,
303+ account_id : str ,
304+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
305+ # The extra values given here take precedence over values defined on the client or passed to this method.
306+ extra_headers : Headers | None = None ,
307+ extra_query : Query | None = None ,
308+ extra_body : Body | None = None ,
309+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
310+ ) -> SyncSinglePage [Consumer ]:
311+ """
312+ Returns the consumers for a Queue
313+
314+ Args:
315+ account_id: A Resource identifier.
316+
317+ queue_id: A Resource identifier.
318+
319+ extra_headers: Send extra headers
320+
321+ extra_query: Add additional query parameters to the request
322+
323+ extra_body: Add additional JSON properties to the request
324+
325+ timeout: Override the client-level default timeout for this request, in seconds
326+ """
327+ if not account_id :
328+ raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
329+ if not queue_id :
330+ raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
331+ return self ._get_api_list (
332+ f"/accounts/{ account_id } { queue_id } ,
333+ page = SyncSinglePage [Consumer ],
334+ options = make_request_options (
335+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
336+ ),
337+ model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
338+ )
339+
299340 def delete (
300341 self ,
301342 consumer_id : str ,
@@ -343,24 +384,27 @@ def delete(
343384
344385 def get (
345386 self ,
346- queue_id : str ,
387+ consumer_id : str ,
347388 * ,
348389 account_id : str ,
390+ queue_id : str ,
349391 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
350392 # The extra values given here take precedence over values defined on the client or passed to this method.
351393 extra_headers : Headers | None = None ,
352394 extra_query : Query | None = None ,
353395 extra_body : Body | None = None ,
354396 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
355- ) -> SyncSinglePage [Consumer ]:
397+ ) -> Optional [Consumer ]:
356398 """
357- Returns the consumers for a Queue
399+ Fetches the consumer for a queue by consumer id
358400
359401 Args:
360402 account_id: A Resource identifier.
361403
362404 queue_id: A Resource identifier.
363405
406+ consumer_id: A Resource identifier.
407+
364408 extra_headers: Send extra headers
365409
366410 extra_query: Add additional query parameters to the request
@@ -373,13 +417,23 @@ def get(
373417 raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
374418 if not queue_id :
375419 raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
376- return self ._get_api_list (
377- f"/accounts/{ account_id } { queue_id } ,
378- page = SyncSinglePage [Consumer ],
379- options = make_request_options (
380- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
420+ if not consumer_id :
421+ raise ValueError (f"Expected a non-empty value for `consumer_id` but received { consumer_id !r} )
422+ return cast (
423+ Optional [Consumer ],
424+ self ._get (
425+ f"/accounts/{ account_id } { queue_id } { consumer_id } ,
426+ options = make_request_options (
427+ extra_headers = extra_headers ,
428+ extra_query = extra_query ,
429+ extra_body = extra_body ,
430+ timeout = timeout ,
431+ post_parser = ResultWrapper [Optional [Consumer ]]._unwrapper ,
432+ ),
433+ cast_to = cast (
434+ Any , ResultWrapper [Consumer ]
435+ ), # Union types cannot be passed in as arguments in the type system
381436 ),
382- model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
383437 )
384438
385439
@@ -652,6 +706,47 @@ async def update(
652706 ),
653707 )
654708
709+ def list (
710+ self ,
711+ queue_id : str ,
712+ * ,
713+ account_id : str ,
714+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
715+ # The extra values given here take precedence over values defined on the client or passed to this method.
716+ extra_headers : Headers | None = None ,
717+ extra_query : Query | None = None ,
718+ extra_body : Body | None = None ,
719+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
720+ ) -> AsyncPaginator [Consumer , AsyncSinglePage [Consumer ]]:
721+ """
722+ Returns the consumers for a Queue
723+
724+ Args:
725+ account_id: A Resource identifier.
726+
727+ queue_id: A Resource identifier.
728+
729+ extra_headers: Send extra headers
730+
731+ extra_query: Add additional query parameters to the request
732+
733+ extra_body: Add additional JSON properties to the request
734+
735+ timeout: Override the client-level default timeout for this request, in seconds
736+ """
737+ if not account_id :
738+ raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
739+ if not queue_id :
740+ raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
741+ return self ._get_api_list (
742+ f"/accounts/{ account_id } { queue_id } ,
743+ page = AsyncSinglePage [Consumer ],
744+ options = make_request_options (
745+ extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
746+ ),
747+ model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
748+ )
749+
655750 async def delete (
656751 self ,
657752 consumer_id : str ,
@@ -697,26 +792,29 @@ async def delete(
697792 cast_to = ConsumerDeleteResponse ,
698793 )
699794
700- def get (
795+ async def get (
701796 self ,
702- queue_id : str ,
797+ consumer_id : str ,
703798 * ,
704799 account_id : str ,
800+ queue_id : str ,
705801 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
706802 # The extra values given here take precedence over values defined on the client or passed to this method.
707803 extra_headers : Headers | None = None ,
708804 extra_query : Query | None = None ,
709805 extra_body : Body | None = None ,
710806 timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
711- ) -> AsyncPaginator [Consumer , AsyncSinglePage [ Consumer ] ]:
807+ ) -> Optional [Consumer ]:
712808 """
713- Returns the consumers for a Queue
809+ Fetches the consumer for a queue by consumer id
714810
715811 Args:
716812 account_id: A Resource identifier.
717813
718814 queue_id: A Resource identifier.
719815
816+ consumer_id: A Resource identifier.
817+
720818 extra_headers: Send extra headers
721819
722820 extra_query: Add additional query parameters to the request
@@ -729,13 +827,23 @@ def get(
729827 raise ValueError (f"Expected a non-empty value for `account_id` but received { account_id !r} )
730828 if not queue_id :
731829 raise ValueError (f"Expected a non-empty value for `queue_id` but received { queue_id !r} )
732- return self ._get_api_list (
733- f"/accounts/{ account_id } { queue_id } ,
734- page = AsyncSinglePage [Consumer ],
735- options = make_request_options (
736- extra_headers = extra_headers , extra_query = extra_query , extra_body = extra_body , timeout = timeout
830+ if not consumer_id :
831+ raise ValueError (f"Expected a non-empty value for `consumer_id` but received { consumer_id !r} )
832+ return cast (
833+ Optional [Consumer ],
834+ await self ._get (
835+ f"/accounts/{ account_id } { queue_id } { consumer_id } ,
836+ options = make_request_options (
837+ extra_headers = extra_headers ,
838+ extra_query = extra_query ,
839+ extra_body = extra_body ,
840+ timeout = timeout ,
841+ post_parser = ResultWrapper [Optional [Consumer ]]._unwrapper ,
842+ ),
843+ cast_to = cast (
844+ Any , ResultWrapper [Consumer ]
845+ ), # Union types cannot be passed in as arguments in the type system
737846 ),
738- model = cast (Any , Consumer ), # Union types cannot be passed in as arguments in the type system
739847 )
740848
741849
@@ -749,6 +857,9 @@ def __init__(self, consumers: ConsumersResource) -> None:
749857 self .update = to_raw_response_wrapper (
750858 consumers .update ,
751859 )
860+ self .list = to_raw_response_wrapper (
861+ consumers .list ,
862+ )
752863 self .delete = to_raw_response_wrapper (
753864 consumers .delete ,
754865 )
@@ -767,6 +878,9 @@ def __init__(self, consumers: AsyncConsumersResource) -> None:
767878 self .update = async_to_raw_response_wrapper (
768879 consumers .update ,
769880 )
881+ self .list = async_to_raw_response_wrapper (
882+ consumers .list ,
883+ )
770884 self .delete = async_to_raw_response_wrapper (
771885 consumers .delete ,
772886 )
@@ -785,6 +899,9 @@ def __init__(self, consumers: ConsumersResource) -> None:
785899 self .update = to_streamed_response_wrapper (
786900 consumers .update ,
787901 )
902+ self .list = to_streamed_response_wrapper (
903+ consumers .list ,
904+ )
788905 self .delete = to_streamed_response_wrapper (
789906 consumers .delete ,
790907 )
@@ -803,6 +920,9 @@ def __init__(self, consumers: AsyncConsumersResource) -> None:
803920 self .update = async_to_streamed_response_wrapper (
804921 consumers .update ,
805922 )
923+ self .list = async_to_streamed_response_wrapper (
924+ consumers .list ,
925+ )
806926 self .delete = async_to_streamed_response_wrapper (
807927 consumers .delete ,
808928 )
![stainless-app[bot]](https://avatars.githubusercontent.com/in/378072?v=4&size=40){kind=avatar}
0 commit comments