Skip to content

Commit

Permalink
add messages to deletions
Browse files Browse the repository at this point in the history
  • Loading branch information
mabulgu committed Nov 7, 2023
1 parent 11e0c8c commit 03d8738
Showing 1 changed file with 5 additions and 15 deletions.
20 changes: 5 additions & 15 deletions kfk/kubernetes_commons.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,22 +22,10 @@ def inner(k8s_api, yml_object, kind, **kwargs):
return inner


def delete_object(name, kind, namespace):
def delete_object(name, resource_type, namespace):
k8s_api = client.CoreV1Api(api_client)
_delete_object(k8s_api, name, kind, namespace=namespace)


def delete_custom_object(name, kind_plural, namespace):
k8s_api = client.CustomObjectsApi(api_client)
_delete_object(
k8s_api,
name,
"custom_object",
namespace=namespace,
group="kafka.strimzi.io",
version="v1beta2",
plural=kind_plural,
)
_delete_object(k8s_api, name, resource_type, namespace=namespace)
print(f"{resource_type.capitalize()} `{name}` deleted.")


def create_registry_secret(
Expand Down Expand Up @@ -76,6 +64,8 @@ def create_registry_secret(
),
)

print(f"Registry Secret `{name}` created.")


def create_using_yaml(file_path, namespace):
_operate_using_yaml(
Expand Down

0 comments on commit 03d8738

Please sign in to comment.