feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 1791
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-64483197e6ec54fe413eb3d5e1aa5802dd66280506b340471310d18aaf2e7893.yml
-openapi_spec_hash: a6226495494c058cd1753989aaa27b06
+configured_endpoints: 1793
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-2119f3b01d3ef7f8c45c95c01f473a249a08f79bad8297e7aa4b2d2665503bc9.yml
+openapi_spec_hash: a52c7f5deed1454a7288c7c374b1e569
 config_hash: de4c81cee29cd7dd907279e8916b334f

api.md

@@ -1854,6 +1854,11 @@ Types:
 from cloudflare.types.logpush import InstantLogpushJob
 ```
 
+Methods:
+
+- <code title="post /zones/{zone_id}/logpush/edge">client.logpush.edge.<a href="./src/cloudflare/resources/logpush/edge.py">create</a>(\*, zone_id, \*\*<a href="src/cloudflare/types/logpush/edge_create_params.py">params</a>) -> <a href="./src/cloudflare/types/logpush/instant_logpush_job.py">Optional[InstantLogpushJob]</a></code>
+- <code title="get /zones/{zone_id}/logpush/edge">client.logpush.edge.<a href="./src/cloudflare/resources/logpush/edge.py">get</a>(\*, zone_id) -> <a href="./src/cloudflare/types/logpush/instant_logpush_job.py">SyncSinglePage[Optional[InstantLogpushJob]]</a></code>
+
 ## Jobs
 
 Types:

src/cloudflare/resources/logpush/__init__.py

@@ -1,5 +1,13 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
+from .edge import (
+    EdgeResource,
+    AsyncEdgeResource,
+    EdgeResourceWithRawResponse,
+    AsyncEdgeResourceWithRawResponse,
+    EdgeResourceWithStreamingResponse,
+    AsyncEdgeResourceWithStreamingResponse,
+)
 from .jobs import (
     JobsResource,
     AsyncJobsResource,
@@ -48,6 +56,12 @@
     "AsyncDatasetsResourceWithRawResponse",
     "DatasetsResourceWithStreamingResponse",
     "AsyncDatasetsResourceWithStreamingResponse",
+    "EdgeResource",
+    "AsyncEdgeResource",
+    "EdgeResourceWithRawResponse",
+    "AsyncEdgeResourceWithRawResponse",
+    "EdgeResourceWithStreamingResponse",
+    "AsyncEdgeResourceWithStreamingResponse",
     "JobsResource",
     "AsyncJobsResource",
     "JobsResourceWithRawResponse",

src/cloudflare/resources/logpush/edge.py

@@ -0,0 +1,303 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing import Type, Optional, cast
+
+import httpx
+
+from ..._types import NOT_GIVEN, Body, Query, Headers, NotGiven
+from ..._utils import maybe_transform, async_maybe_transform
+from ..._compat import cached_property
+from ..._resource import SyncAPIResource, AsyncAPIResource
+from ..._response import (
+    to_raw_response_wrapper,
+    to_streamed_response_wrapper,
+    async_to_raw_response_wrapper,
+    async_to_streamed_response_wrapper,
+)
+from ..._wrappers import ResultWrapper
+from ...pagination import SyncSinglePage, AsyncSinglePage
+from ..._base_client import AsyncPaginator, make_request_options
+from ...types.logpush import edge_create_params
+from ...types.logpush.instant_logpush_job import InstantLogpushJob
+
+__all__ = ["EdgeResource", "AsyncEdgeResource"]
+
+
+class EdgeResource(SyncAPIResource):
+    @cached_property
+    def with_raw_response(self) -> EdgeResourceWithRawResponse:
+        """
+        This property can be used as a prefix for any HTTP method call to return
+        the raw response object instead of the parsed content.
+
+        For more information, see https://www.github.com/cloudflare/cloudflare-python#accessing-raw-response-data-eg-headers
+        """
+        return EdgeResourceWithRawResponse(self)
+
+    @cached_property
+    def with_streaming_response(self) -> EdgeResourceWithStreamingResponse:
+        """
+        An alternative to `.with_raw_response` that doesn't eagerly read the response body.
+
+        For more information, see https://www.github.com/cloudflare/cloudflare-python#with_streaming_response
+        """
+        return EdgeResourceWithStreamingResponse(self)
+
+    def create(
+        self,
+        *,
+        zone_id: str,
+        fields: str | NotGiven = NOT_GIVEN,
+        filter: str | NotGiven = NOT_GIVEN,
+        sample: int | NotGiven = NOT_GIVEN,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> Optional[InstantLogpushJob]:
+        """
+        Creates a new Instant Logs job for a zone.
+
+        Args:
+          zone_id: Identifier.
+
+          fields: Comma-separated list of fields.
+
+          filter: Filters to drill down into specific events.
+
+          sample:
+              The sample parameter is the sample rate of the records set by the client:
+              "sample": 1 is 100% of records "sample": 10 is 10% and so on.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not zone_id:
+            raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
+        return self._post(
+            f"/zones/{zone_id}/logpush/edge",
+            body=maybe_transform(
+                {
+                    "fields": fields,
+                    "filter": filter,
+                    "sample": sample,
+                },
+                edge_create_params.EdgeCreateParams,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[InstantLogpushJob]]._unwrapper,
+            ),
+            cast_to=cast(Type[Optional[InstantLogpushJob]], ResultWrapper[InstantLogpushJob]),
+        )
+
+    def get(
+        self,
+        *,
+        zone_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> SyncSinglePage[Optional[InstantLogpushJob]]:
+        """
+        Lists Instant Logs jobs for a zone.
+
+        Args:
+          zone_id: Identifier.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not zone_id:
+            raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
+        return self._get_api_list(
+            f"/zones/{zone_id}/logpush/edge",
+            page=SyncSinglePage[Optional[InstantLogpushJob]],
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            model=InstantLogpushJob,
+        )
+
+
+class AsyncEdgeResource(AsyncAPIResource):
+    @cached_property
+    def with_raw_response(self) -> AsyncEdgeResourceWithRawResponse:
+        """
+        This property can be used as a prefix for any HTTP method call to return
+        the raw response object instead of the parsed content.
+
+        For more information, see https://www.github.com/cloudflare/cloudflare-python#accessing-raw-response-data-eg-headers
+        """
+        return AsyncEdgeResourceWithRawResponse(self)
+
+    @cached_property
+    def with_streaming_response(self) -> AsyncEdgeResourceWithStreamingResponse:
+        """
+        An alternative to `.with_raw_response` that doesn't eagerly read the response body.
+
+        For more information, see https://www.github.com/cloudflare/cloudflare-python#with_streaming_response
+        """
+        return AsyncEdgeResourceWithStreamingResponse(self)
+
+    async def create(
+        self,
+        *,
+        zone_id: str,
+        fields: str | NotGiven = NOT_GIVEN,
+        filter: str | NotGiven = NOT_GIVEN,
+        sample: int | NotGiven = NOT_GIVEN,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> Optional[InstantLogpushJob]:
+        """
+        Creates a new Instant Logs job for a zone.
+
+        Args:
+          zone_id: Identifier.
+
+          fields: Comma-separated list of fields.
+
+          filter: Filters to drill down into specific events.
+
+          sample:
+              The sample parameter is the sample rate of the records set by the client:
+              "sample": 1 is 100% of records "sample": 10 is 10% and so on.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not zone_id:
+            raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
+        return await self._post(
+            f"/zones/{zone_id}/logpush/edge",
+            body=await async_maybe_transform(
+                {
+                    "fields": fields,
+                    "filter": filter,
+                    "sample": sample,
+                },
+                edge_create_params.EdgeCreateParams,
+            ),
+            options=make_request_options(
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                post_parser=ResultWrapper[Optional[InstantLogpushJob]]._unwrapper,
+            ),
+            cast_to=cast(Type[Optional[InstantLogpushJob]], ResultWrapper[InstantLogpushJob]),
+        )
+
+    def get(
+        self,
+        *,
+        zone_id: str,
+        # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
+        # The extra values given here take precedence over values defined on the client or passed to this method.
+        extra_headers: Headers | None = None,
+        extra_query: Query | None = None,
+        extra_body: Body | None = None,
+        timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> AsyncPaginator[Optional[InstantLogpushJob], AsyncSinglePage[Optional[InstantLogpushJob]]]:
+        """
+        Lists Instant Logs jobs for a zone.
+
+        Args:
+          zone_id: Identifier.
+
+          extra_headers: Send extra headers
+
+          extra_query: Add additional query parameters to the request
+
+          extra_body: Add additional JSON properties to the request
+
+          timeout: Override the client-level default timeout for this request, in seconds
+        """
+        if not zone_id:
+            raise ValueError(f"Expected a non-empty value for `zone_id` but received {zone_id!r}")
+        return self._get_api_list(
+            f"/zones/{zone_id}/logpush/edge",
+            page=AsyncSinglePage[Optional[InstantLogpushJob]],
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            model=InstantLogpushJob,
+        )
+
+
+class EdgeResourceWithRawResponse:
+    def __init__(self, edge: EdgeResource) -> None:
+        self._edge = edge
+
+        self.create = to_raw_response_wrapper(
+            edge.create,
+        )
+        self.get = to_raw_response_wrapper(
+            edge.get,
+        )
+
+
+class AsyncEdgeResourceWithRawResponse:
+    def __init__(self, edge: AsyncEdgeResource) -> None:
+        self._edge = edge
+
+        self.create = async_to_raw_response_wrapper(
+            edge.create,
+        )
+        self.get = async_to_raw_response_wrapper(
+            edge.get,
+        )
+
+
+class EdgeResourceWithStreamingResponse:
+    def __init__(self, edge: EdgeResource) -> None:
+        self._edge = edge
+
+        self.create = to_streamed_response_wrapper(
+            edge.create,
+        )
+        self.get = to_streamed_response_wrapper(
+            edge.get,
+        )
+
+
+class AsyncEdgeResourceWithStreamingResponse:
+    def __init__(self, edge: AsyncEdgeResource) -> None:
+        self._edge = edge
+
+        self.create = async_to_streamed_response_wrapper(
+            edge.create,
+        )
+        self.get = async_to_streamed_response_wrapper(
+            edge.get,
+        )