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

[k8s-extension] Develop Update function for containerinsights arc extension #278

Open
wants to merge 2 commits into
base: k8s-extension/public
Choose a base branch
from
Open

[k8s-extension] Develop Update function for containerinsights arc extension #278

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
01bf794
develop Update function for containerinsights arc extension
wanlonghenry Mar 25, 2024
724087e
Merge branch 'AzureArcForKubernetes:k8s-extension/public' into k8s-ex…
wanlonghenry Mar 26, 2024
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
38 changes: 35 additions & 3 deletions src/k8s-extension/azext_k8s_extension/partner_extensions/ContainerInsights.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,12 @@
from msrestazure.tools import parse_resource_id, is_valid_resource_id
from azure.core.exceptions import HttpResponseError

from ..vendored_sdks.models import Extension
from ..vendored_sdks.models import ScopeCluster
from ..vendored_sdks.models import Scope
from ..vendored_sdks.models import (
Extension,
Scope,
ScopeCluster,
PatchExtension
)

from .DefaultExtension import DefaultExtension

Expand Down Expand Up @@ -79,6 +82,35 @@ def Create(self, cmd, client, resource_group_name, cluster_name, name, cluster_t
)
return extension, name, create_identity

def Update(self, cmd, client, resource_group_name, cluster_name, name, cluster_type,
extension_type, scope, auto_upgrade_minor_version, release_train, version, target_namespace,
release_namespace, configuration_settings, configuration_protected_settings,
configuration_settings_file, configuration_protected_settings_file,
plan_name, plan_publisher, plan_product):
cluster_rp, _ = get_cluster_rp_api_version(cluster_type=cluster_type, cluster_rp=cluster_rp)
try:
extension = client.get(resource_group_name, cluster_rp, cluster_type, cluster_name, name)
except Exception as e:
pass

current_config_settings = extension.configuration_settings
current_protected_settings = extension.configuration_protected_settings

new_config_settings = configuration_settings if configuration_settings else current_config_settings
new_protected_settings = configuration_protected_settings if configuration_protected_settings else current_protected_settings

is_ci_extension_type = True
if not is_skip_prerequisites_specified(configuration_settings):
_get_container_insights_settings(cmd, resource_group_name, cluster_rp, cluster_type, cluster_name, new_config_settings, new_protected_settings, is_ci_extension_type)
else:
logger.info("Provisioning of prerequisites is skipped")

return PatchExtension(auto_upgrade_minor_version=auto_upgrade_minor_version,
release_train=release_train,
version=version,
configuration_settings=new_config_settings,
configuration_protected_settings=new_protected_settings)

def Delete(self, cmd, client, resource_group_name, cluster_name, name, cluster_type, cluster_rp, yes):
# Delete DCR-A if it exists incase of MSI Auth
useAADAuth = False
Expand Down
Loading