Skip to content

Commit cb9ce20

Browse files
stainless-app[bot]stainless-app[bot]
committed
chore(api): upload stainless config from cloudflare-config
1 parent 3a35ffd commit cb9ce20

14 files changed

+1824
-48
lines changed

‎.stats.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
configured_endpoints: 1794
1+
configured_endpoints: 1798
22
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-c972b67141d4322a331c3f8191fd859e88c23d0528b1e8daac86c49521cd3510.yml
33
openapi_spec_hash: 55643b37c147c204b6b0d70c3e99a6b6
4-
config_hash: 8c6400dba3f7d3f5c77b79f2e4a018bf
4+
config_hash: a1304617cd14c003fb430a6827269eba

‎api.md

Lines changed: 36 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -2627,22 +2627,6 @@ Methods:
26272627
- <code title="patch /accounts/{account_id}/queues/{queue_id}">client.queues.<a href="./src/cloudflare/resources/queues/queues.py">edit</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/queue_edit_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/queue.py">Optional[Queue]</a></code>
26282628
- <code title="get /accounts/{account_id}/queues/{queue_id}">client.queues.<a href="./src/cloudflare/resources/queues/queues.py">get</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/queue.py">Optional[Queue]</a></code>
26292629

2630-
## Consumers
2631-
2632-
Types:
2633-
2634-
```python
2635-
from cloudflare.types.queues import Consumer, ConsumerDeleteResponse
2636-
```
2637-
2638-
Methods:
2639-
2640-
- <code title="post /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">create</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/consumer_create_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2641-
- <code title="put /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">update</a>(consumer_id, \*, account_id, queue_id, \*\*<a href="src/cloudflare/types/queues/consumer_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2642-
- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">list</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/consumer.py">SyncSinglePage[Consumer]</a></code>
2643-
- <code title="delete /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">delete</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer_delete_response.py">ConsumerDeleteResponse</a></code>
2644-
- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">get</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2645-
26462630
## Messages
26472631

26482632
Types:
@@ -2676,6 +2660,42 @@ Methods:
26762660
- <code title="post /accounts/{account_id}/queues/{queue_id}/purge">client.queues.purge.<a href="./src/cloudflare/resources/queues/purge.py">start</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/purge_start_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/queue.py">Optional[Queue]</a></code>
26772661
- <code title="get /accounts/{account_id}/queues/{queue_id}/purge">client.queues.purge.<a href="./src/cloudflare/resources/queues/purge.py">status</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/purge_status_response.py">Optional[PurgeStatusResponse]</a></code>
26782662

2663+
## Consumers
2664+
2665+
Types:
2666+
2667+
```python
2668+
from cloudflare.types.queues import Consumer, ConsumerDeleteResponse
2669+
```
2670+
2671+
Methods:
2672+
2673+
- <code title="post /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">create</a>(queue_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/consumer_create_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2674+
- <code title="put /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">update</a>(consumer_id, \*, account_id, queue_id, \*\*<a href="src/cloudflare/types/queues/consumer_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2675+
- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">list</a>(queue_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/consumer.py">SyncSinglePage[Consumer]</a></code>
2676+
- <code title="delete /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">delete</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer_delete_response.py">ConsumerDeleteResponse</a></code>
2677+
- <code title="get /accounts/{account_id}/queues/{queue_id}/consumers/{consumer_id}">client.queues.consumers.<a href="./src/cloudflare/resources/queues/consumers.py">get</a>(consumer_id, \*, account_id, queue_id) -> <a href="./src/cloudflare/types/queues/consumer.py">Optional[Consumer]</a></code>
2678+
2679+
## Subscriptions
2680+
2681+
Types:
2682+
2683+
```python
2684+
from cloudflare.types.queues import (
2685+
SubscriptionCreateResponse,
2686+
SubscriptionUpdateResponse,
2687+
SubscriptionListResponse,
2688+
SubscriptionDeleteResponse,
2689+
)
2690+
```
2691+
2692+
Methods:
2693+
2694+
- <code title="post /accounts/{account_id}/event_subscriptions/subscriptions">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">create</a>(\*, account_id, \*\*<a href="src/cloudflare/types/queues/subscription_create_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/subscription_create_response.py">Optional[SubscriptionCreateResponse]</a></code>
2695+
- <code title="patch /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">update</a>(subscription_id, \*, account_id, \*\*<a href="src/cloudflare/types/queues/subscription_update_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/subscription_update_response.py">Optional[SubscriptionUpdateResponse]</a></code>
2696+
- <code title="get /accounts/{account_id}/event_subscriptions/subscriptions">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">list</a>(\*, account_id, \*\*<a href="src/cloudflare/types/queues/subscription_list_params.py">params</a>) -> <a href="./src/cloudflare/types/queues/subscription_list_response.py">SyncV4PagePaginationArray[SubscriptionListResponse]</a></code>
2697+
- <code title="delete /accounts/{account_id}/event_subscriptions/subscriptions/{subscription_id}">client.queues.subscriptions.<a href="./src/cloudflare/resources/queues/subscriptions.py">delete</a>(subscription_id, \*, account_id) -> <a href="./src/cloudflare/types/queues/subscription_delete_response.py">Optional[SubscriptionDeleteResponse]</a></code>
2698+
26792699
# APIGateway
26802700

26812701
## Configurations

‎src/cloudflare/resources/queues/__init__.py

Lines changed: 20 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -32,14 +32,16 @@
3232
ConsumersResourceWithStreamingResponse,
3333
AsyncConsumersResourceWithStreamingResponse,
3434
)
35+
from .subscriptions import (
36+
SubscriptionsResource,
37+
AsyncSubscriptionsResource,
38+
SubscriptionsResourceWithRawResponse,
39+
AsyncSubscriptionsResourceWithRawResponse,
40+
SubscriptionsResourceWithStreamingResponse,
41+
AsyncSubscriptionsResourceWithStreamingResponse,
42+
)
3543

3644
__all__ = [
37-
"ConsumersResource",
38-
"AsyncConsumersResource",
39-
"ConsumersResourceWithRawResponse",
40-
"AsyncConsumersResourceWithRawResponse",
41-
"ConsumersResourceWithStreamingResponse",
42-
"AsyncConsumersResourceWithStreamingResponse",
4345
"MessagesResource",
4446
"AsyncMessagesResource",
4547
"MessagesResourceWithRawResponse",
@@ -52,6 +54,18 @@
5254
"AsyncPurgeResourceWithRawResponse",
5355
"PurgeResourceWithStreamingResponse",
5456
"AsyncPurgeResourceWithStreamingResponse",
57+
"ConsumersResource",
58+
"AsyncConsumersResource",
59+
"ConsumersResourceWithRawResponse",
60+
"AsyncConsumersResourceWithRawResponse",
61+
"ConsumersResourceWithStreamingResponse",
62+
"AsyncConsumersResourceWithStreamingResponse",
63+
"SubscriptionsResource",
64+
"AsyncSubscriptionsResource",
65+
"SubscriptionsResourceWithRawResponse",
66+
"AsyncSubscriptionsResourceWithRawResponse",
67+
"SubscriptionsResourceWithStreamingResponse",
68+
"AsyncSubscriptionsResourceWithStreamingResponse",
5569
"QueuesResource",
5670
"AsyncQueuesResource",
5771
"QueuesResourceWithRawResponse",

‎src/cloudflare/resources/queues/queues.py

Lines changed: 56 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,14 @@
4242
)
4343
from ..._wrappers import ResultWrapper
4444
from ...pagination import SyncSinglePage, AsyncSinglePage
45+
from .subscriptions import (
46+
SubscriptionsResource,
47+
AsyncSubscriptionsResource,
48+
SubscriptionsResourceWithRawResponse,
49+
AsyncSubscriptionsResourceWithRawResponse,
50+
SubscriptionsResourceWithStreamingResponse,
51+
AsyncSubscriptionsResourceWithStreamingResponse,
52+
)
4553
from ..._base_client import AsyncPaginator, make_request_options
4654
from ...types.queues import queue_edit_params, queue_create_params, queue_update_params
4755
from ...types.queues.queue import Queue
@@ -51,10 +59,6 @@
5159

5260

5361
class QueuesResource(SyncAPIResource):
54-
@cached_property
55-
def consumers(self) -> ConsumersResource:
56-
return ConsumersResource(self._client)
57-
5862
@cached_property
5963
def messages(self) -> MessagesResource:
6064
return MessagesResource(self._client)
@@ -63,6 +67,14 @@ def messages(self) -> MessagesResource:
6367
def purge(self) -> PurgeResource:
6468
return PurgeResource(self._client)
6569

70+
@cached_property
71+
def consumers(self) -> ConsumersResource:
72+
return ConsumersResource(self._client)
73+
74+
@cached_property
75+
def subscriptions(self) -> SubscriptionsResource:
76+
return SubscriptionsResource(self._client)
77+
6678
@cached_property
6779
def with_raw_response(self) -> QueuesResourceWithRawResponse:
6880
"""
@@ -354,10 +366,6 @@ def get(
354366

355367

356368
class AsyncQueuesResource(AsyncAPIResource):
357-
@cached_property
358-
def consumers(self) -> AsyncConsumersResource:
359-
return AsyncConsumersResource(self._client)
360-
361369
@cached_property
362370
def messages(self) -> AsyncMessagesResource:
363371
return AsyncMessagesResource(self._client)
@@ -366,6 +374,14 @@ def messages(self) -> AsyncMessagesResource:
366374
def purge(self) -> AsyncPurgeResource:
367375
return AsyncPurgeResource(self._client)
368376

377+
@cached_property
378+
def consumers(self) -> AsyncConsumersResource:
379+
return AsyncConsumersResource(self._client)
380+
381+
@cached_property
382+
def subscriptions(self) -> AsyncSubscriptionsResource:
383+
return AsyncSubscriptionsResource(self._client)
384+
369385
@cached_property
370386
def with_raw_response(self) -> AsyncQueuesResourceWithRawResponse:
371387
"""
@@ -679,10 +695,6 @@ def __init__(self, queues: QueuesResource) -> None:
679695
queues.get,
680696
)
681697

682-
@cached_property
683-
def consumers(self) -> ConsumersResourceWithRawResponse:
684-
return ConsumersResourceWithRawResponse(self._queues.consumers)
685-
686698
@cached_property
687699
def messages(self) -> MessagesResourceWithRawResponse:
688700
return MessagesResourceWithRawResponse(self._queues.messages)
@@ -691,6 +703,14 @@ def messages(self) -> MessagesResourceWithRawResponse:
691703
def purge(self) -> PurgeResourceWithRawResponse:
692704
return PurgeResourceWithRawResponse(self._queues.purge)
693705

706+
@cached_property
707+
def consumers(self) -> ConsumersResourceWithRawResponse:
708+
return ConsumersResourceWithRawResponse(self._queues.consumers)
709+
710+
@cached_property
711+
def subscriptions(self) -> SubscriptionsResourceWithRawResponse:
712+
return SubscriptionsResourceWithRawResponse(self._queues.subscriptions)
713+
694714

695715
class AsyncQueuesResourceWithRawResponse:
696716
def __init__(self, queues: AsyncQueuesResource) -> None:
@@ -715,10 +735,6 @@ def __init__(self, queues: AsyncQueuesResource) -> None:
715735
queues.get,
716736
)
717737

718-
@cached_property
719-
def consumers(self) -> AsyncConsumersResourceWithRawResponse:
720-
return AsyncConsumersResourceWithRawResponse(self._queues.consumers)
721-
722738
@cached_property
723739
def messages(self) -> AsyncMessagesResourceWithRawResponse:
724740
return AsyncMessagesResourceWithRawResponse(self._queues.messages)
@@ -727,6 +743,14 @@ def messages(self) -> AsyncMessagesResourceWithRawResponse:
727743
def purge(self) -> AsyncPurgeResourceWithRawResponse:
728744
return AsyncPurgeResourceWithRawResponse(self._queues.purge)
729745

746+
@cached_property
747+
def consumers(self) -> AsyncConsumersResourceWithRawResponse:
748+
return AsyncConsumersResourceWithRawResponse(self._queues.consumers)
749+
750+
@cached_property
751+
def subscriptions(self) -> AsyncSubscriptionsResourceWithRawResponse:
752+
return AsyncSubscriptionsResourceWithRawResponse(self._queues.subscriptions)
753+
730754

731755
class QueuesResourceWithStreamingResponse:
732756
def __init__(self, queues: QueuesResource) -> None:
@@ -751,10 +775,6 @@ def __init__(self, queues: QueuesResource) -> None:
751775
queues.get,
752776
)
753777

754-
@cached_property
755-
def consumers(self) -> ConsumersResourceWithStreamingResponse:
756-
return ConsumersResourceWithStreamingResponse(self._queues.consumers)
757-
758778
@cached_property
759779
def messages(self) -> MessagesResourceWithStreamingResponse:
760780
return MessagesResourceWithStreamingResponse(self._queues.messages)
@@ -763,6 +783,14 @@ def messages(self) -> MessagesResourceWithStreamingResponse:
763783
def purge(self) -> PurgeResourceWithStreamingResponse:
764784
return PurgeResourceWithStreamingResponse(self._queues.purge)
765785

786+
@cached_property
787+
def consumers(self) -> ConsumersResourceWithStreamingResponse:
788+
return ConsumersResourceWithStreamingResponse(self._queues.consumers)
789+
790+
@cached_property
791+
def subscriptions(self) -> SubscriptionsResourceWithStreamingResponse:
792+
return SubscriptionsResourceWithStreamingResponse(self._queues.subscriptions)
793+
766794

767795
class AsyncQueuesResourceWithStreamingResponse:
768796
def __init__(self, queues: AsyncQueuesResource) -> None:
@@ -787,14 +815,18 @@ def __init__(self, queues: AsyncQueuesResource) -> None:
787815
queues.get,
788816
)
789817

790-
@cached_property
791-
def consumers(self) -> AsyncConsumersResourceWithStreamingResponse:
792-
return AsyncConsumersResourceWithStreamingResponse(self._queues.consumers)
793-
794818
@cached_property
795819
def messages(self) -> AsyncMessagesResourceWithStreamingResponse:
796820
return AsyncMessagesResourceWithStreamingResponse(self._queues.messages)
797821

798822
@cached_property
799823
def purge(self) -> AsyncPurgeResourceWithStreamingResponse:
800824
return AsyncPurgeResourceWithStreamingResponse(self._queues.purge)
825+
826+
@cached_property
827+
def consumers(self) -> AsyncConsumersResourceWithStreamingResponse:
828+
return AsyncConsumersResourceWithStreamingResponse(self._queues.consumers)
829+
830+
@cached_property
831+
def subscriptions(self) -> AsyncSubscriptionsResourceWithStreamingResponse:
832+
return AsyncSubscriptionsResourceWithStreamingResponse(self._queues.subscriptions)

0 commit comments

Comments
 (0)