Skip to content

Commit

Permalink
options/result rename
Browse files Browse the repository at this point in the history
  • Loading branch information
@l0lawrence
l0lawrence committed Apr 3, 2024
1 parent fe0623a commit 6d37422
Show file tree
Hide file tree
Showing 23 changed files with 246 additions and 357 deletions.
112 changes: 56 additions & 56 deletions sdk/eventgrid/azure-eventgrid/azure/eventgrid/_operations/_operations.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -649,47 +649,47 @@ def _receive_cloud_events( # pylint: disable=protected-access


@overload
def _acknowledge_cloud_events(
def _acknowledge_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
acknowledge_options: _models.AcknowledgeOptions,
acknowledge_options: _models._models.AcknowledgeOptions,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.AcknowledgeResult:
) -> _models._models.AcknowledgeResult:
...
@overload
def _acknowledge_cloud_events(
def _acknowledge_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
acknowledge_options: JSON,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.AcknowledgeResult:
) -> _models._models.AcknowledgeResult:
...
@overload
def _acknowledge_cloud_events(
def _acknowledge_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
acknowledge_options: IO[bytes],
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.AcknowledgeResult:
) -> _models._models.AcknowledgeResult:
...

@distributed_trace
def _acknowledge_cloud_events(
def _acknowledge_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
acknowledge_options: Union[_models.AcknowledgeOptions, JSON, IO[bytes]],
acknowledge_options: Union[_models._models.AcknowledgeOptions, JSON, IO[bytes]],
**kwargs: Any
) -> _models.AcknowledgeResult:
) -> _models._models.AcknowledgeResult:
"""Acknowledge batch of Cloud Events. The server responds with an HTTP 200 status code if the
request is successfully accepted. The response body will include the set of successfully
acknowledged lockTokens, along with other failed lockTokens with their corresponding error
Expand Down Expand Up @@ -754,7 +754,7 @@ def _acknowledge_cloud_events(
_params = kwargs.pop("params", {}) or {}

content_type: Optional[str] = kwargs.pop('content_type', _headers.pop('Content-Type', None))
cls: ClsType[_models.AcknowledgeResult] = kwargs.pop(
cls: ClsType[_models._models.AcknowledgeResult] = kwargs.pop( # pylint: disable=protected-access
'cls', None
)

Expand Down Expand Up @@ -798,7 +798,7 @@ def _acknowledge_cloud_events(
deserialized = response.iter_bytes()
else:
deserialized = _deserialize(
_models.AcknowledgeResult,
_models._models.AcknowledgeResult, # pylint: disable=protected-access
response.json()
)

Expand All @@ -812,23 +812,23 @@ def _acknowledge_cloud_events(
@overload
@api_version_validation(
params_added_on={'2023-10-01-preview': ['release_delay_in_seconds']},
)
def _release_cloud_events(
) # pylint: disable=protected-access
def _release_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
release_options: _models.ReleaseOptions,
release_options: _models._models.ReleaseOptions,
*,
release_delay_in_seconds: Optional[Union[int, _models.ReleaseDelay]] = None,
content_type: str = "application/json",
**kwargs: Any
) -> _models.ReleaseResult:
) -> _models._models.ReleaseResult:
...
@overload
@api_version_validation(
params_added_on={'2023-10-01-preview': ['release_delay_in_seconds']},
)
def _release_cloud_events(
) # pylint: disable=protected-access
def _release_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
Expand All @@ -837,13 +837,13 @@ def _release_cloud_events(
release_delay_in_seconds: Optional[Union[int, _models.ReleaseDelay]] = None,
content_type: str = "application/json",
**kwargs: Any
) -> _models.ReleaseResult:
) -> _models._models.ReleaseResult:
...
@overload
@api_version_validation(
params_added_on={'2023-10-01-preview': ['release_delay_in_seconds']},
)
def _release_cloud_events(
) # pylint: disable=protected-access
def _release_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
Expand All @@ -852,22 +852,22 @@ def _release_cloud_events(
release_delay_in_seconds: Optional[Union[int, _models.ReleaseDelay]] = None,
content_type: str = "application/json",
**kwargs: Any
) -> _models.ReleaseResult:
) -> _models._models.ReleaseResult:
...

@distributed_trace
@api_version_validation(
params_added_on={'2023-10-01-preview': ['release_delay_in_seconds']},
)
def _release_cloud_events(
) # pylint: disable=protected-access
def _release_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
release_options: Union[_models.ReleaseOptions, JSON, IO[bytes]],
release_options: Union[_models._models.ReleaseOptions, JSON, IO[bytes]],
*,
release_delay_in_seconds: Optional[Union[int, _models.ReleaseDelay]] = None,
**kwargs: Any
) -> _models.ReleaseResult:
) -> _models._models.ReleaseResult:
"""Release batch of Cloud Events. The server responds with an HTTP 200 status code if the request
is successfully accepted. The response body will include the set of successfully released
lockTokens, along with other failed lockTokens with their corresponding error information.
Expand Down Expand Up @@ -934,7 +934,7 @@ def _release_cloud_events(
_params = kwargs.pop("params", {}) or {}

content_type: Optional[str] = kwargs.pop('content_type', _headers.pop('Content-Type', None))
cls: ClsType[_models.ReleaseResult] = kwargs.pop(
cls: ClsType[_models._models.ReleaseResult] = kwargs.pop( # pylint: disable=protected-access
'cls', None
)

Expand Down Expand Up @@ -979,7 +979,7 @@ def _release_cloud_events(
deserialized = response.iter_bytes()
else:
deserialized = _deserialize(
_models.ReleaseResult,
_models._models.ReleaseResult, # pylint: disable=protected-access
response.json()
)

Expand All @@ -991,47 +991,47 @@ def _release_cloud_events(


@overload
def _reject_cloud_events(
def _reject_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
reject_options: _models.RejectOptions,
reject_options: _models._models.RejectOptions,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RejectResult:
) -> _models._models.RejectResult:
...
@overload
def _reject_cloud_events(
def _reject_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
reject_options: JSON,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RejectResult:
) -> _models._models.RejectResult:
...
@overload
def _reject_cloud_events(
def _reject_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
reject_options: IO[bytes],
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RejectResult:
) -> _models._models.RejectResult:
...

@distributed_trace
def _reject_cloud_events(
def _reject_cloud_events( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
reject_options: Union[_models.RejectOptions, JSON, IO[bytes]],
reject_options: Union[_models._models.RejectOptions, JSON, IO[bytes]],
**kwargs: Any
) -> _models.RejectResult:
) -> _models._models.RejectResult:
"""Reject batch of Cloud Events. The server responds with an HTTP 200 status code if the request
is successfully accepted. The response body will include the set of successfully rejected
lockTokens, along with other failed lockTokens with their corresponding error information.
Expand Down Expand Up @@ -1095,7 +1095,7 @@ def _reject_cloud_events(
_params = kwargs.pop("params", {}) or {}

content_type: Optional[str] = kwargs.pop('content_type', _headers.pop('Content-Type', None))
cls: ClsType[_models.RejectResult] = kwargs.pop(
cls: ClsType[_models._models.RejectResult] = kwargs.pop( # pylint: disable=protected-access
'cls', None
)

Expand Down Expand Up @@ -1139,7 +1139,7 @@ def _reject_cloud_events(
deserialized = response.iter_bytes()
else:
deserialized = _deserialize(
_models.RejectResult,
_models._models.RejectResult, # pylint: disable=protected-access
response.json()
)

Expand All @@ -1153,57 +1153,57 @@ def _reject_cloud_events(
@overload
@api_version_validation(
method_added_on="2023-10-01-preview",
)
def _renew_cloud_event_locks(
) # pylint: disable=protected-access
def _renew_cloud_event_locks( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
renew_lock_options: _models.RenewLockOptions,
renew_lock_options: _models._models.RenewLockOptions,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RenewCloudEventLocksResult:
) -> _models._models.RenewCloudEventLocksResult:
...
@overload
@api_version_validation(
method_added_on="2023-10-01-preview",
)
def _renew_cloud_event_locks(
) # pylint: disable=protected-access
def _renew_cloud_event_locks( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
renew_lock_options: JSON,
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RenewCloudEventLocksResult:
) -> _models._models.RenewCloudEventLocksResult:
...
@overload
@api_version_validation(
method_added_on="2023-10-01-preview",
)
def _renew_cloud_event_locks(
) # pylint: disable=protected-access
def _renew_cloud_event_locks( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
renew_lock_options: IO[bytes],
*,
content_type: str = "application/json",
**kwargs: Any
) -> _models.RenewCloudEventLocksResult:
) -> _models._models.RenewCloudEventLocksResult:
...

@distributed_trace
@api_version_validation(
method_added_on="2023-10-01-preview",
)
def _renew_cloud_event_locks(
) # pylint: disable=protected-access
def _renew_cloud_event_locks( # pylint: disable=protected-access
self,
topic_name: str,
event_subscription_name: str,
renew_lock_options: Union[_models.RenewLockOptions, JSON, IO[bytes]],
renew_lock_options: Union[_models._models.RenewLockOptions, JSON, IO[bytes]],
**kwargs: Any
) -> _models.RenewCloudEventLocksResult:
) -> _models._models.RenewCloudEventLocksResult:
"""Renew lock for batch of Cloud Events. The server responds with an HTTP 200 status code if the
request is successfully accepted. The response body will include the set of successfully
renewed lockTokens, along with other failed lockTokens with their corresponding error
Expand Down Expand Up @@ -1269,7 +1269,7 @@ def _renew_cloud_event_locks(
_params = kwargs.pop("params", {}) or {}

content_type: Optional[str] = kwargs.pop('content_type', _headers.pop('Content-Type', None))
cls: ClsType[_models.RenewCloudEventLocksResult] = kwargs.pop(
cls: ClsType[_models._models.RenewCloudEventLocksResult] = kwargs.pop( # pylint: disable=protected-access
'cls', None
)

Expand Down Expand Up @@ -1313,7 +1313,7 @@ def _renew_cloud_event_locks(
deserialized = response.iter_bytes()
else:
deserialized = _deserialize(
_models.RenewCloudEventLocksResult,
_models._models.RenewCloudEventLocksResult, # pylint: disable=protected-access
response.json()
)

Expand Down
Loading

0 comments on commit 6d37422

Please sign in to comment.