Skip to content

Commit

Permalink
name changes
Browse files Browse the repository at this point in the history
  • Loading branch information
@l0lawrence
l0lawrence committed Apr 3, 2024
1 parent bf35f7b commit bd4ea4e
Show file tree
Hide file tree
Showing 25 changed files with 277 additions and 1,587 deletions.
770 changes: 68 additions & 702 deletions sdk/eventgrid/azure-eventgrid/azure/eventgrid/_operations/_operations.py
View file

Large diffs are not rendered by default.

93 changes: 48 additions & 45 deletions sdk/eventgrid/azure-eventgrid/azure/eventgrid/_operations/_patch.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,10 @@

from ._operations import EventGridClientOperationsMixin as OperationsMixin
from .._model_base import _deserialize
from ..models._patch import ReceiveResult, ReceiveDetails
from ..models._patch import (
ReceiveResult,
ReceiveDetails,
)
from .. import models as _models
from .._validation import api_version_validation

Expand Down Expand Up @@ -393,7 +396,7 @@ def _publish(
def receive_cloud_events(
self,
topic_name: str,
event_subscription_name: str,
subscription_name: str,
*,
max_events: Optional[int] = None,
max_wait_time: Optional[int] = None,
Expand All @@ -403,8 +406,8 @@ def receive_cloud_events(
:param topic_name: Topic Name. Required.
:type topic_name: str
:param event_subscription_name: Event Subscription Name. Required.
:type event_subscription_name: str
:param subscription_name: Event Subscription Name. Required.
:type subscription_name: str
:keyword max_events: Max Events count to be received. Minimum value is 1, while maximum value
is 100 events. If not specified, the default value is 1. Default value is None.
:paramtype max_events: int
Expand All @@ -422,7 +425,7 @@ def receive_cloud_events(
detail_items = []
received_result = self._receive_cloud_events(
topic_name,
event_subscription_name,
subscription_name,
max_events=max_events,
max_wait_time=max_wait_time,
**kwargs,
Expand All @@ -444,8 +447,8 @@ def receive_cloud_events(
def acknowledge_cloud_events(
self,
topic_name: str,
event_subscription_name: str,
acknowledge_options: Union[_models.AcknowledgeOptions, JSON, IO],
subscription_name: str,
options: Union[_models.AcknowledgeOptions, JSON, IO],
**kwargs: Any,
) -> _models.AcknowledgeResult:
"""Acknowledge batch of Cloud Events. The server responds with an HTTP 200 status code if the
Expand All @@ -455,11 +458,11 @@ def acknowledge_cloud_events(
:param topic_name: Topic Name. Required.
:type topic_name: str
:param event_subscription_name: Event Subscription Name. Required.
:type event_subscription_name: str
:param acknowledge_options: AcknowledgeOptions. Is one of the following types:
:param subscription_name: Event Subscription Name. Required.
:type subscription_name: str
:param options: AcknowledgeOptions. Is one of the following types:
AcknowledgeOptions, JSON, IO[bytes] Required.
:type acknowledge_options: ~azure.eventgrid.models.AcknowledgeOptions or JSON or IO[bytes]
:type options: ~azure.eventgrid.models.AcknowledgeOptions or JSON or IO[bytes]
:return: AcknowledgeResult. The AcknowledgeResult is compatible with MutableMapping
:rtype: ~azure.eventgrid.models.AcknowledgeResult
:raises ~azure.core.exceptions.HttpResponseError:
Expand All @@ -468,7 +471,7 @@ def acknowledge_cloud_events(
.. code-block:: python
# JSON input template you can fill out and use as your body input.
acknowledge_options = {
options = {
"lockTokens": [
"str" # Array of lock tokens. Required.
]
Expand Down Expand Up @@ -503,10 +506,10 @@ def acknowledge_cloud_events(
]
}
"""
return super().acknowledge_cloud_events(
return super()._acknowledge_cloud_events(
topic_name=topic_name,
event_subscription_name=event_subscription_name,
acknowledge_options=acknowledge_options,
event_subscription_name=subscription_name,
acknowledge_options=options,
**kwargs,
)

Expand All @@ -518,8 +521,8 @@ def acknowledge_cloud_events(
def release_cloud_events(
self,
topic_name: str,
event_subscription_name: str,
release_options: Union[_models.ReleaseOptions, JSON, IO],
subscription_name: str,
options: Union[_models.ReleaseOptions, JSON, IO],
*,
release_delay_in_seconds: Optional[Union[int, _models.ReleaseDelay]] = None,
**kwargs: Any,
Expand All @@ -530,11 +533,11 @@ def release_cloud_events(
:param topic_name: Topic Name. Required.
:type topic_name: str
:param event_subscription_name: Event Subscription Name. Required.
:type event_subscription_name: str
:param release_options: ReleaseOptions. Is one of the following types: ReleaseOptions, JSON,
:param subscription_name: Event Subscription Name. Required.
:type subscription_name: str
:param options: ReleaseOptions. Is one of the following types: ReleaseOptions, JSON,
IO[bytes] Required.
:type release_options: ~azure.eventgrid.models.ReleaseOptions or JSON or IO[bytes]
:type options: ~azure.eventgrid.models.ReleaseOptions or JSON or IO[bytes]
:keyword release_delay_in_seconds: Release cloud events with the specified delay in seconds.
Known values are: 0, 10, 60, 600, and 3600. Default value is None.
:paramtype release_delay_in_seconds: int or ~azure.eventgrid.models.ReleaseDelay
Expand All @@ -546,7 +549,7 @@ def release_cloud_events(
.. code-block:: python
# JSON input template you can fill out and use as your body input.
release_options = {
options = {
"lockTokens": [
"str" # Array of lock tokens. Required.
]
Expand Down Expand Up @@ -581,10 +584,10 @@ def release_cloud_events(
]
}
"""
return super().release_cloud_events(
return super()._release_cloud_events(
topic_name=topic_name,
event_subscription_name=event_subscription_name,
release_options=release_options,
event_subscription_name=subscription_name,
release_options=options,
release_delay_in_seconds=release_delay_in_seconds,
**kwargs,
)
Expand All @@ -594,8 +597,8 @@ def release_cloud_events(
def reject_cloud_events(
self,
topic_name: str,
event_subscription_name: str,
reject_options: Union[_models.RejectOptions, JSON, IO],
subscription_name: str,
options: Union[_models.RejectOptions, JSON, IO],
**kwargs: Any,
) -> _models.RejectResult:
"""Reject batch of Cloud Events. The server responds with an HTTP 200 status code if the request
Expand All @@ -604,11 +607,11 @@ def reject_cloud_events(
:param topic_name: Topic Name. Required.
:type topic_name: str
:param event_subscription_name: Event Subscription Name. Required.
:type event_subscription_name: str
:param reject_options: RejectOptions. Is one of the following types: RejectOptions, JSON,
:param subscription_name: Event Subscription Name. Required.
:type subscription_name: str
:param options: RejectOptions. Is one of the following types: RejectOptions, JSON,
IO[bytes] Required.
:type reject_options: ~azure.eventgrid.models.RejectOptions or JSON or IO[bytes]
:type options: ~azure.eventgrid.models.RejectOptions or JSON or IO[bytes]
:return: RejectResult. The RejectResult is compatible with MutableMapping
:rtype: ~azure.eventgrid.models.RejectResult
:raises ~azure.core.exceptions.HttpResponseError:
Expand All @@ -617,7 +620,7 @@ def reject_cloud_events(
.. code-block:: python
# JSON input template you can fill out and use as your body input.
reject_options = {
options = {
"lockTokens": [
"str" # Array of lock tokens. Required.
]
Expand Down Expand Up @@ -652,10 +655,10 @@ def reject_cloud_events(
]
}
"""
return super().reject_cloud_events(
return super()._reject_cloud_events(
topic_name=topic_name,
event_subscription_name=event_subscription_name,
reject_options=reject_options,
event_subscription_name=subscription_name,
reject_options=options,
**kwargs,
)

Expand All @@ -667,8 +670,8 @@ def reject_cloud_events(
def renew_cloud_event_locks(
self,
topic_name: str,
event_subscription_name: str,
renew_lock_options: Union[_models.RenewLockOptions, JSON, IO],
subscription_name: str,
options: Union[_models.RenewLockOptions, JSON, IO],
**kwargs: Any,
) -> _models.RenewCloudEventLocksResult:
"""Renew lock for batch of Cloud Events. The server responds with an HTTP 200 status code if the
Expand All @@ -678,11 +681,11 @@ def renew_cloud_event_locks(
:param topic_name: Topic Name. Required.
:type topic_name: str
:param event_subscription_name: Event Subscription Name. Required.
:type event_subscription_name: str
:param renew_lock_options: RenewLockOptions. Is one of the following types: RenewLockOptions,
:param subscription_name: Event Subscription Name. Required.
:type subscription_name: str
:param options: RenewLockOptions. Is one of the following types: RenewLockOptions,
JSON, IO[bytes] Required.
:type renew_lock_options: ~azure.eventgrid.models.RenewLockOptions or JSON or IO[bytes]
:type options: ~azure.eventgrid.models.RenewLockOptions or JSON or IO[bytes]
:return: RenewCloudEventLocksResult. The RenewCloudEventLocksResult is compatible with
MutableMapping
:rtype: ~azure.eventgrid.models.RenewCloudEventLocksResult
Expand All @@ -692,7 +695,7 @@ def renew_cloud_event_locks(
.. code-block:: python
# JSON input template you can fill out and use as your body input.
renew_lock_options = {
options = {
"lockTokens": [
"str" # Array of lock tokens. Required.
]
Expand Down Expand Up @@ -728,10 +731,10 @@ def renew_cloud_event_locks(
}
"""

return super().renew_cloud_event_locks(
return super()._renew_cloud_event_locks(
topic_name=topic_name,
event_subscription_name=event_subscription_name,
renew_lock_options=renew_lock_options,
event_subscription_name=subscription_name,
renew_lock_options=options,
**kwargs,
)

Expand Down
Loading

0 comments on commit bd4ea4e

Please sign in to comment.