Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ReleasePR storagesync] [StorageSync] Publish 2020-09-01 as stable API version #2755

Closed
wants to merge 1 commit into from
Closed

[ReleasePR storagesync] [StorageSync] Publish 2020-09-01 as stable API version #2755

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
40 changes: 29 additions & 11 deletions src/storagesync/azext_storagesync/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,32 +1,50 @@
# --------------------------------------------------------------------------------------------
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------------------------
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------

from azure.cli.core import AzCommandsLoader

from azext_storagesync._help import helps # pylint: disable=unused-import
from azext_storagesync.generated._help import helps # pylint: disable=unused-import
try:
from azext_storagesync.manual._help import helps # pylint: disable=reimported
except ImportError:
pass


class MicrosoftStorageSyncCommandsLoader(AzCommandsLoader):

def __init__(self, cli_ctx=None):
from azure.cli.core.commands import CliCommandType
from azext_storagesync._client_factory import cf_storagesync
from azext_storagesync.generated._client_factory import cf_storagesync_cl
storagesync_custom = CliCommandType(
operations_tmpl='azext_storagesync.custom#{}',
client_factory=cf_storagesync)
super(MicrosoftStorageSyncCommandsLoader, self).__init__(cli_ctx=cli_ctx,
custom_command_type=storagesync_custom)
client_factory=cf_storagesync_cl)
parent = super(MicrosoftStorageSyncCommandsLoader, self)
parent.__init__(cli_ctx=cli_ctx, custom_command_type=storagesync_custom)

def load_command_table(self, args):
from azext_storagesync.commands import load_command_table
from azext_storagesync.generated.commands import load_command_table
load_command_table(self, args)
try:
from azext_storagesync.manual.commands import load_command_table as load_command_table_manual
load_command_table_manual(self, args)
except ImportError:
pass
return self.command_table

def load_arguments(self, command):
from azext_storagesync._params import load_arguments
from azext_storagesync.generated._params import load_arguments
load_arguments(self, command)
try:
from azext_storagesync.manual._params import load_arguments as load_arguments_manual
load_arguments_manual(self, command)
except ImportError:
pass


COMMAND_LOADER_CLS = MicrosoftStorageSyncCommandsLoader
17 changes: 17 additions & 0 deletions src/storagesync/azext_storagesync/action.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------
# pylint: disable=wildcard-import
# pylint: disable=unused-wildcard-import

from .generated.action import * # noqa: F403
try:
from .manual.action import * # noqa: F403
except ImportError:
pass
2 changes: 1 addition & 1 deletion src/storagesync/azext_storagesync/azext_metadata.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
{
"azext.isExperimental": true,
"azext.minCliCoreVersion": "2.3.1"
"azext.minCliCoreVersion": "2.11.0"
}
216 changes: 16 additions & 200 deletions src/storagesync/azext_storagesync/custom.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,201 +1,17 @@
# --------------------------------------------------------------------------------------------
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------------------------
# pylint: disable=line-too-long
# pylint: disable=too-many-statements
# pylint: disable=too-many-lines
# pylint: disable=too-many-locals
# pylint: disable=unused-argument
from azure.cli.core.util import sdk_no_wait


def create_storagesync_storage_sync_service(client,
resource_group_name,
storage_sync_service_name,
tags=None,
location=None):
body = {}
body['location'] = location # str
body['tags'] = tags # dictionary
return client.create(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, parameters=body)


def delete_storagesync_storage_sync_service(client,
resource_group_name,
storage_sync_service_name):
return client.delete(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name)


def get_storagesync_storage_sync_service(client,
resource_group_name,
storage_sync_service_name):
return client.get(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name)


def list_storagesync_storage_sync_service(client,
resource_group_name=None):
if resource_group_name:
return client.list_by_resource_group(resource_group_name=resource_group_name)
return client.list_by_subscription()


def create_storagesync_sync_group(client,
resource_group_name,
storage_sync_service_name,
sync_group_name):
return client.create(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name)


def delete_storagesync_sync_group(client,
resource_group_name,
storage_sync_service_name,
sync_group_name):
return client.delete(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name)


def get_storagesync_sync_group(client,
resource_group_name,
storage_sync_service_name,
sync_group_name):
return client.get(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name)


def list_storagesync_sync_group(client,
resource_group_name,
storage_sync_service_name):
return client.list_by_storage_sync_service(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name)


def create_storagesync_cloud_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
cloud_endpoint_name,
storage_account_resource_id=None,
azure_file_share_name=None,
storage_account_tenant_id=None,
no_wait=False):
body = {}
body['storage_account_resource_id'] = storage_account_resource_id # str
body['azure_file_share_name'] = azure_file_share_name # str
body['storage_account_tenant_id'] = storage_account_tenant_id # str
return sdk_no_wait(no_wait, client.create, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, cloud_endpoint_name=cloud_endpoint_name, parameters=body)


def delete_storagesync_cloud_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
cloud_endpoint_name,
no_wait=False):
return sdk_no_wait(no_wait, client.delete, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, cloud_endpoint_name=cloud_endpoint_name)


def get_storagesync_cloud_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
cloud_endpoint_name):
return client.get(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, cloud_endpoint_name=cloud_endpoint_name)


def list_storagesync_cloud_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name):
return client.list_by_sync_group(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name)


def create_storagesync_server_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
server_endpoint_name,
server_resource_id,
server_local_path,
cloud_tiering=None,
volume_free_space_percent=None,
tier_files_older_than_days=None,
offline_data_transfer=None,
offline_data_transfer_share_name=None,
no_wait=False):
body = {}
body['server_resource_id'] = server_resource_id # str
body['server_local_path'] = server_local_path # str
body['cloud_tiering'] = cloud_tiering # str
body['volume_free_space_percent'] = volume_free_space_percent # int
body['tier_files_older_than_days'] = tier_files_older_than_days # int
body['offline_data_transfer'] = offline_data_transfer # str
body['offline_data_transfer_share_name'] = offline_data_transfer_share_name # str
return sdk_no_wait(no_wait, client.create, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, server_endpoint_name=server_endpoint_name, parameters=body)


def update_storagesync_server_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
server_endpoint_name,
cloud_tiering=None,
volume_free_space_percent=None,
tier_files_older_than_days=None,
offline_data_transfer=None,
offline_data_transfer_share_name=None,
no_wait=False):
body = {}
if cloud_tiering is not None:
body['cloud_tiering'] = cloud_tiering # str
if volume_free_space_percent is not None:
body['volume_free_space_percent'] = volume_free_space_percent # number
if tier_files_older_than_days is not None:
body['tier_files_older_than_days'] = tier_files_older_than_days # number
if offline_data_transfer is not None:
body['offline_data_transfer'] = offline_data_transfer # str
if offline_data_transfer_share_name is not None:
body['offline_data_transfer_share_name'] = offline_data_transfer_share_name # str
return sdk_no_wait(no_wait, client.update, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, server_endpoint_name=server_endpoint_name, parameters=body)


def delete_storagesync_server_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
server_endpoint_name,
no_wait=False):
return sdk_no_wait(no_wait, client.delete, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, server_endpoint_name=server_endpoint_name)


def get_storagesync_server_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name,
server_endpoint_name):
return client.get(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name, server_endpoint_name=server_endpoint_name)


def list_storagesync_server_endpoint(client,
resource_group_name,
storage_sync_service_name,
sync_group_name):
return client.list_by_sync_group(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, sync_group_name=sync_group_name)


def delete_storagesync_registered_server(client,
resource_group_name,
storage_sync_service_name,
server_id,
no_wait=False):
return sdk_no_wait(no_wait, client.delete, resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, server_id=server_id)


def get_storagesync_registered_server(client,
resource_group_name,
storage_sync_service_name,
server_id):
return client.get(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name, server_id=server_id)


def list_storagesync_registered_server(client,
resource_group_name,
storage_sync_service_name):
return client.list_by_storage_sync_service(resource_group_name=resource_group_name, storage_sync_service_name=storage_sync_service_name)
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------
# pylint: disable=wildcard-import
# pylint: disable=unused-wildcard-import

from .generated.custom import * # noqa: F403
try:
from .manual.custom import * # noqa: F403
except ImportError:
pass
12 changes: 12 additions & 0 deletions src/storagesync/azext_storagesync/generated/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
# coding=utf-8
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------

__path__ = __import__('pkgutil').extend_path(__path__, __name__)
52 changes: 52 additions & 0 deletions src/storagesync/azext_storagesync/generated/_client_factory.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,52 @@
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#
# Code generated by Microsoft (R) AutoRest Code Generator.
# Changes may cause incorrect behavior and will be lost if the code is
# regenerated.
# --------------------------------------------------------------------------


def cf_storagesync_cl(cli_ctx, *_):
from azure.cli.core.commands.client_factory import get_mgmt_service_client
from ..vendored_sdks.storagesync import MicrosoftStorageSync
return get_mgmt_service_client(cli_ctx,
MicrosoftStorageSync)


def cf_storage_sync_service(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).storage_sync_service


def cf_private_link_resource(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).private_link_resource


def cf_private_endpoint_connection(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).private_endpoint_connection


def cf_sync_group(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).sync_group


def cf_cloud_endpoint(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).cloud_endpoint


def cf_server_endpoint(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).server_endpoint


def cf_registered_server(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).registered_server


def cf_workflow(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).workflow


def cf_operation_status(cli_ctx, *_):
return cf_storagesync_cl(cli_ctx).operation_status
Loading