|
| 1 | +# ------------------------------------------------------------------------- |
| 2 | +# Copyright (c) Microsoft Corporation. All rights reserved. |
| 3 | +# Licensed under the MIT License. See License.txt in the project root for |
| 4 | +# license information. |
| 5 | +# -------------------------------------------------------------------------- |
| 6 | +# pylint: skip-file |
| 7 | + |
| 8 | +from datetime import datetime |
| 9 | +from typing import Any, Dict, Optional, Union |
| 10 | +from typing_extensions import Self |
| 11 | + |
| 12 | +from azure.core.credentials import AzureNamedKeyCredential, AzureSasCredential, TokenCredential |
| 13 | +from azure.core.paging import ItemPaged |
| 14 | +from azure.core.tracing.decorator import distributed_trace |
| 15 | + |
| 16 | +class ChangeFeedClient: |
| 17 | + def __init__( |
| 18 | + self, |
| 19 | + account_url: str, |
| 20 | + credential: Optional[ |
| 21 | + Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, TokenCredential] |
| 22 | + ] = None, |
| 23 | + *, |
| 24 | + secondary_hostname: Optional[str] = None, |
| 25 | + max_single_get_size: Optional[int] = None, |
| 26 | + max_chunk_get_size: Optional[int] = None, |
| 27 | + api_version: Optional[str] = None, |
| 28 | + **kwargs: Any |
| 29 | + ) -> None: ... |
| 30 | + @classmethod |
| 31 | + def from_connection_string( |
| 32 | + cls, |
| 33 | + conn_str: str, |
| 34 | + credential: Optional[ |
| 35 | + Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, TokenCredential] |
| 36 | + ] = None, |
| 37 | + *, |
| 38 | + secondary_hostname: Optional[str] = None, |
| 39 | + max_single_get_size: Optional[int] = None, |
| 40 | + max_chunk_get_size: Optional[int] = None, |
| 41 | + api_version: Optional[str] = None, |
| 42 | + **kwargs: Any |
| 43 | + ) -> Self: ... |
| 44 | + @distributed_trace |
| 45 | + def list_changes( |
| 46 | + self, |
| 47 | + *, |
| 48 | + start_time: Optional[datetime] = None, |
| 49 | + end_time: Optional[datetime] = None, |
| 50 | + results_per_page: Optional[int] = None, |
| 51 | + **kwargs: Any |
| 52 | + ) -> ItemPaged[Dict[str, Any]]: ... |
0 commit comments