Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ def __init__(
super(KustoManagementClient, self).__init__(self.config.credentials, self.config)

client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
self.api_version = '2019-01-21'
self.api_version = '2019-05-15'
self._serialize = Serializer(client_models)
self._deserialize = Deserializer(client_models)

Expand Down
26 changes: 24 additions & 2 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,9 +11,13 @@

try:
from .trusted_external_tenant_py3 import TrustedExternalTenant
from .optimized_autoscale_py3 import OptimizedAutoscale
from .virtual_network_configuration_py3 import VirtualNetworkConfiguration
from .azure_sku_py3 import AzureSku
from .azure_capacity_py3 import AzureCapacity
from .azure_resource_sku_py3 import AzureResourceSku
from .sku_location_info_item_py3 import SkuLocationInfoItem
from .sku_description_py3 import SkuDescription
from .database_statistics_py3 import DatabaseStatistics
from .cluster_py3 import Cluster
from .cluster_update_py3 import ClusterUpdate
Expand All @@ -26,10 +30,12 @@
from .database_principal_list_request_py3 import DatabasePrincipalListRequest
from .data_connection_validation_py3 import DataConnectionValidation
from .event_hub_data_connection_py3 import EventHubDataConnection
from .iot_hub_data_connection_py3 import IotHubDataConnection
from .event_grid_data_connection_py3 import EventGridDataConnection
from .data_connection_validation_list_result_py3 import DataConnectionValidationListResult
from .cluster_check_name_request_py3 import ClusterCheckNameRequest
from .database_check_name_request_py3 import DatabaseCheckNameRequest
from .data_connection_check_name_request_py3 import DataConnectionCheckNameRequest
from .check_name_result_py3 import CheckNameResult
from .operation_display_py3 import OperationDisplay
from .operation_py3 import Operation
Expand All @@ -39,9 +45,13 @@
from .proxy_resource_py3 import ProxyResource
except (SyntaxError, ImportError):
from .trusted_external_tenant import TrustedExternalTenant
from .optimized_autoscale import OptimizedAutoscale
from .virtual_network_configuration import VirtualNetworkConfiguration
from .azure_sku import AzureSku
from .azure_capacity import AzureCapacity
from .azure_resource_sku import AzureResourceSku
from .sku_location_info_item import SkuLocationInfoItem
from .sku_description import SkuDescription
from .database_statistics import DatabaseStatistics
from .cluster import Cluster
from .cluster_update import ClusterUpdate
Expand All @@ -54,10 +64,12 @@
from .database_principal_list_request import DatabasePrincipalListRequest
from .data_connection_validation import DataConnectionValidation
from .event_hub_data_connection import EventHubDataConnection
from .iot_hub_data_connection import IotHubDataConnection
from .event_grid_data_connection import EventGridDataConnection
from .data_connection_validation_list_result import DataConnectionValidationListResult
from .cluster_check_name_request import ClusterCheckNameRequest
from .database_check_name_request import DatabaseCheckNameRequest
from .data_connection_check_name_request import DataConnectionCheckNameRequest
from .check_name_result import CheckNameResult
from .operation_display import OperationDisplay
from .operation import Operation
Expand All @@ -66,7 +78,7 @@
from .resource import Resource
from .proxy_resource import ProxyResource
from .cluster_paged import ClusterPaged
from .azure_sku_paged import AzureSkuPaged
from .sku_description_paged import SkuDescriptionPaged
from .azure_resource_sku_paged import AzureResourceSkuPaged
from .database_paged import DatabasePaged
from .database_principal_paged import DatabasePrincipalPaged
Expand All @@ -76,17 +88,23 @@
State,
ProvisioningState,
AzureSkuName,
AzureSkuTier,
AzureScaleType,
DataFormat,
DatabasePrincipalRole,
DatabasePrincipalType,
Reason,
)

__all__ = [
'TrustedExternalTenant',
'OptimizedAutoscale',
'VirtualNetworkConfiguration',
'AzureSku',
'AzureCapacity',
'AzureResourceSku',
'SkuLocationInfoItem',
'SkuDescription',
'DatabaseStatistics',
'Cluster',
'ClusterUpdate',
Expand All @@ -99,10 +117,12 @@
'DatabasePrincipalListRequest',
'DataConnectionValidation',
'EventHubDataConnection',
'IotHubDataConnection',
'EventGridDataConnection',
'DataConnectionValidationListResult',
'ClusterCheckNameRequest',
'DatabaseCheckNameRequest',
'DataConnectionCheckNameRequest',
'CheckNameResult',
'OperationDisplay',
'Operation',
Expand All @@ -111,7 +131,7 @@
'Resource',
'ProxyResource',
'ClusterPaged',
'AzureSkuPaged',
'SkuDescriptionPaged',
'AzureResourceSkuPaged',
'DatabasePaged',
'DatabasePrincipalPaged',
Expand All @@ -120,8 +140,10 @@
'State',
'ProvisioningState',
'AzureSkuName',
'AzureSkuTier',
'AzureScaleType',
'DataFormat',
'DatabasePrincipalRole',
'DatabasePrincipalType',
'Reason',
]
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ class AzureResourceSku(Model):
:type resource_type: str
:param sku: The SKU details.
:type sku: ~azure.mgmt.kusto.models.AzureSku
:param capacity: The SKU capacity.
:param capacity: The number of instances of the cluster.
:type capacity: ~azure.mgmt.kusto.models.AzureCapacity
"""

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ class AzureResourceSku(Model):
:type resource_type: str
:param sku: The SKU details.
:type sku: ~azure.mgmt.kusto.models.AzureSku
:param capacity: The SKU capacity.
:param capacity: The number of instances of the cluster.
:type capacity: ~azure.mgmt.kusto.models.AzureCapacity
"""

Expand Down
22 changes: 11 additions & 11 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,23 +15,24 @@
class AzureSku(Model):
"""Azure SKU definition.

Variables are only populated by the server, and will be ignored when
sending a request.

All required parameters must be populated in order to send to Azure.

:param name: Required. SKU name. Possible values include: 'D13_v2',
'D14_v2', 'L8', 'L16', 'D11_v2', 'D12_v2', 'L4'
:param name: Required. SKU name. Possible values include:
'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
:type name: str or ~azure.mgmt.kusto.models.AzureSkuName
:param capacity: SKU capacity.
:param capacity: The number of instances of the cluster.
:type capacity: int
:ivar tier: Required. SKU tier. Default value: "Standard" .
:vartype tier: str
:param tier: Required. SKU tier. Possible values include: 'Basic',
'Standard'
:type tier: str or ~azure.mgmt.kusto.models.AzureSkuTier
"""

_validation = {
'name': {'required': True},
'tier': {'required': True, 'constant': True},
'tier': {'required': True},
}

_attribute_map = {
Expand All @@ -40,9 +41,8 @@ class AzureSku(Model):
'tier': {'key': 'tier', 'type': 'str'},
}

tier = "Standard"

def __init__(self, **kwargs):
super(AzureSku, self).__init__(**kwargs)
self.name = kwargs.get('name', None)
self.capacity = kwargs.get('capacity', None)
self.tier = kwargs.get('tier', None)
24 changes: 12 additions & 12 deletions sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_py3.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,23 +15,24 @@
class AzureSku(Model):
"""Azure SKU definition.

Variables are only populated by the server, and will be ignored when
sending a request.

All required parameters must be populated in order to send to Azure.

:param name: Required. SKU name. Possible values include: 'D13_v2',
'D14_v2', 'L8', 'L16', 'D11_v2', 'D12_v2', 'L4'
:param name: Required. SKU name. Possible values include:
'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
:type name: str or ~azure.mgmt.kusto.models.AzureSkuName
:param capacity: SKU capacity.
:param capacity: The number of instances of the cluster.
:type capacity: int
:ivar tier: Required. SKU tier. Default value: "Standard" .
:vartype tier: str
:param tier: Required. SKU tier. Possible values include: 'Basic',
'Standard'
:type tier: str or ~azure.mgmt.kusto.models.AzureSkuTier
"""

_validation = {
'name': {'required': True},
'tier': {'required': True, 'constant': True},
'tier': {'required': True},
}

_attribute_map = {
Expand All @@ -40,9 +41,8 @@ class AzureSku(Model):
'tier': {'key': 'tier', 'type': 'str'},
}

tier = "Standard"

def __init__(self, *, name, capacity: int=None, **kwargs) -> None:
def __init__(self, *, name, tier, capacity: int=None, **kwargs) -> None:
super(AzureSku, self).__init__(**kwargs)
self.name = name
self.capacity = capacity
self.tier = tier
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,21 @@ class CheckNameResult(Model):
:param message: Message indicating an unavailable name due to a conflict,
or a description of the naming rules that are violated.
:type message: str
:param reason: Message providing the reason why the given name is invalid.
Possible values include: 'Invalid', 'AlreadyExists'
:type reason: str or ~azure.mgmt.kusto.models.Reason
"""

_attribute_map = {
'name_available': {'key': 'nameAvailable', 'type': 'bool'},
'name': {'key': 'name', 'type': 'str'},
'message': {'key': 'message', 'type': 'str'},
'reason': {'key': 'reason', 'type': 'str'},
}

def __init__(self, **kwargs):
super(CheckNameResult, self).__init__(**kwargs)
self.name_available = kwargs.get('name_available', None)
self.name = kwargs.get('name', None)
self.message = kwargs.get('message', None)
self.reason = kwargs.get('reason', None)
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,21 @@ class CheckNameResult(Model):
:param message: Message indicating an unavailable name due to a conflict,
or a description of the naming rules that are violated.
:type message: str
:param reason: Message providing the reason why the given name is invalid.
Possible values include: 'Invalid', 'AlreadyExists'
:type reason: str or ~azure.mgmt.kusto.models.Reason
"""

_attribute_map = {
'name_available': {'key': 'nameAvailable', 'type': 'bool'},
'name': {'key': 'name', 'type': 'str'},
'message': {'key': 'message', 'type': 'str'},
'reason': {'key': 'reason', 'type': 'str'},
}

def __init__(self, *, name_available: bool=None, name: str=None, message: str=None, **kwargs) -> None:
def __init__(self, *, name_available: bool=None, name: str=None, message: str=None, reason=None, **kwargs) -> None:
super(CheckNameResult, self).__init__(**kwargs)
self.name_available = name_available
self.name = name
self.message = message
self.reason = reason
26 changes: 25 additions & 1 deletion sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,12 +34,15 @@ class Cluster(TrackedResource):
:type location: str
:param sku: Required. The SKU of the cluster.
:type sku: ~azure.mgmt.kusto.models.AzureSku
:param zones: The availability zones of the cluster.
:type zones: list[str]
:ivar state: The state of the resource. Possible values include:
'Creating', 'Unavailable', 'Running', 'Deleting', 'Deleted', 'Stopping',
'Stopped', 'Starting', 'Updating'
:vartype state: str or ~azure.mgmt.kusto.models.State
:ivar provisioning_state: The provisioned state of the resource. Possible
values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
'Moving'
:vartype provisioning_state: str or
~azure.mgmt.kusto.models.ProvisioningState
:ivar uri: The cluster URI.
Expand All @@ -49,6 +52,17 @@ class Cluster(TrackedResource):
:param trusted_external_tenants: The cluster's external tenants.
:type trusted_external_tenants:
list[~azure.mgmt.kusto.models.TrustedExternalTenant]
:param optimized_autoscale: Optimized auto scale definition.
:type optimized_autoscale: ~azure.mgmt.kusto.models.OptimizedAutoscale
:param enable_disk_encryption: A boolean value that indicates if the
cluster's disks are encrypted.
:type enable_disk_encryption: bool
:param enable_streaming_ingest: A boolean value that indicates if the
streaming ingest is enabled. Default value: False .
:type enable_streaming_ingest: bool
:param virtual_network_configuration: Virtual network definition.
:type virtual_network_configuration:
~azure.mgmt.kusto.models.VirtualNetworkConfiguration
"""

_validation = {
Expand All @@ -70,18 +84,28 @@ class Cluster(TrackedResource):
'tags': {'key': 'tags', 'type': '{str}'},
'location': {'key': 'location', 'type': 'str'},
'sku': {'key': 'sku', 'type': 'AzureSku'},
'zones': {'key': 'zones', 'type': '[str]'},
'state': {'key': 'properties.state', 'type': 'str'},
'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
'uri': {'key': 'properties.uri', 'type': 'str'},
'data_ingestion_uri': {'key': 'properties.dataIngestionUri', 'type': 'str'},
'trusted_external_tenants': {'key': 'properties.trustedExternalTenants', 'type': '[TrustedExternalTenant]'},
'optimized_autoscale': {'key': 'properties.optimizedAutoscale', 'type': 'OptimizedAutoscale'},
'enable_disk_encryption': {'key': 'properties.enableDiskEncryption', 'type': 'bool'},
'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
}

def __init__(self, **kwargs):
super(Cluster, self).__init__(**kwargs)
self.sku = kwargs.get('sku', None)
self.zones = kwargs.get('zones', None)
self.state = None
self.provisioning_state = None
self.uri = None
self.data_ingestion_uri = None
self.trusted_external_tenants = kwargs.get('trusted_external_tenants', None)
self.optimized_autoscale = kwargs.get('optimized_autoscale', None)
self.enable_disk_encryption = kwargs.get('enable_disk_encryption', None)
self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False)
self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None)
Loading