github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-06 03:36:26 +00:00
Code Issues Projects Releases Wiki Activity

use constant NamespaceDefault instead of variable namespace

Browse Source 
Kubernetes-commit: 4bdca5689f65597f28a99f3610dd4e43fbc9cd7c
This commit is contained in:
0xff-dev 2022-08-04 14:18:47 +08:00 committed by Kubernetes Publisher
parent 4faffa8644
commit c94a539bfb
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
examples/dynamic-create-update-delete-deployment/main.go
View File

@ -53,8 +53,6 @@ func main() {
} }
flag.Parse() flag.Parse()
namespace := "default"
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig) config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil { if err != nil {
panic(err) panic(err)
@ -109,7 +107,7 @@ func main() {
// Create Deployment // Create Deployment
fmt.Println("Creating deployment...") fmt.Println("Creating deployment...")
result, err := client.Resource(deploymentRes).Namespace(namespace).Create(context.TODO(), deployment, metav1.CreateOptions{}) result, err := client.Resource(deploymentRes).Namespace(apiv1.NamespaceDefault).Create(context.TODO(), deployment, metav1.CreateOptions{})
if err != nil { if err != nil {
panic(err) panic(err)
} }
@ -134,7 +132,7 @@ func main() {
retryErr := retry.RetryOnConflict(retry.DefaultRetry, func() error { retryErr := retry.RetryOnConflict(retry.DefaultRetry, func() error {
// Retrieve the latest version of Deployment before attempting update // Retrieve the latest version of Deployment before attempting update
// RetryOnConflict uses exponential backoff to avoid exhausting the apiserver // RetryOnConflict uses exponential backoff to avoid exhausting the apiserver
result, getErr := client.Resource(deploymentRes).Namespace(namespace).Get(context.TODO(), "demo-deployment", metav1.GetOptions{}) result, getErr := client.Resource(deploymentRes).Namespace(apiv1.NamespaceDefault).Get(context.TODO(), "demo-deployment", metav1.GetOptions{})
if getErr != nil { if getErr != nil {
panic(fmt.Errorf("failed to get latest version of Deployment: %v", getErr)) panic(fmt.Errorf("failed to get latest version of Deployment: %v", getErr))
} }
@ -158,7 +156,7 @@ func main() {
panic(err) panic(err)
} }
_, updateErr := client.Resource(deploymentRes).Namespace(namespace).Update(context.TODO(), result, metav1.UpdateOptions{}) _, updateErr := client.Resource(deploymentRes).Namespace(apiv1.NamespaceDefault).Update(context.TODO(), result, metav1.UpdateOptions{})
return updateErr return updateErr
}) })
if retryErr != nil { if retryErr != nil {
@ -169,7 +167,7 @@ func main() {
// List Deployments // List Deployments
prompt() prompt()
fmt.Printf("Listing deployments in namespace %q:\n", apiv1.NamespaceDefault) fmt.Printf("Listing deployments in namespace %q:\n", apiv1.NamespaceDefault)
list, err := client.Resource(deploymentRes).Namespace(namespace).List(context.TODO(), metav1.ListOptions{}) list, err := client.Resource(deploymentRes).Namespace(apiv1.NamespaceDefault).List(context.TODO(), metav1.ListOptions{})
if err != nil { if err != nil {
panic(err) panic(err)
} }
@ -189,7 +187,7 @@ func main() {
deleteOptions := metav1.DeleteOptions{ deleteOptions := metav1.DeleteOptions{
PropagationPolicy: &deletePolicy, PropagationPolicy: &deletePolicy,
} }
if err := client.Resource(deploymentRes).Namespace(namespace).Delete(context.TODO(), "demo-deployment", deleteOptions); err != nil { if err := client.Resource(deploymentRes).Namespace(apiv1.NamespaceDefault).Delete(context.TODO(), "demo-deployment", deleteOptions); err != nil {
panic(err) panic(err)
} }