From 944b56751d6c6efb249c4cb8c12adbbb76c27f24 Mon Sep 17 00:00:00 2001 From: Daniel Valdivia <18384552+dvaldivia@users.noreply.github.com> Date: Thu, 5 Jan 2023 15:54:12 -0800 Subject: [PATCH] Remove GKE Integration (#2552) Signed-off-by: Daniel Valdivia <18384552+dvaldivia@users.noreply.github.com> --- cmd/console/operator.go | 55 ----- operatorapi/integrations.go | 226 ------------------ operatorapi/tenant_add.go | 8 - pkg/apis/networking.gke.io/v1beta1/doc.go | 21 -- .../networking.gke.io/v1beta1/register.go | 54 ----- pkg/apis/networking.gke.io/v1beta1/types.go | 87 ------- .../v1beta1/zz_generated.deepcopy.go | 145 ----------- pkg/apis/networking.gke.io/v1beta2/doc.go | 21 -- .../networking.gke.io/v1beta2/register.go | 56 ----- pkg/apis/networking.gke.io/v1beta2/types.go | 87 ------- .../v1beta2/zz_generated.deepcopy.go | 145 ----------- pkg/auth/idp/oauth2/const.go | 1 - .../clientset/versioned/clientset.go | 97 -------- pkg/clientgen/clientset/versioned/doc.go | 20 -- .../versioned/fake/clientset_generated.go | 82 ------- pkg/clientgen/clientset/versioned/fake/doc.go | 20 -- .../clientset/versioned/fake/register.go | 56 ----- .../clientset/versioned/scheme/doc.go | 20 -- .../clientset/versioned/scheme/register.go | 56 ----- .../typed/networking.gke.io/v1beta2/doc.go | 20 -- .../networking.gke.io/v1beta2/fake/doc.go | 20 -- .../v1beta2/fake/fake_managedcertificate.go | 142 ----------- .../fake/fake_networking.gke.io_client.go | 40 ---- .../v1beta2/generated_expansion.go | 21 -- .../v1beta2/managedcertificate.go | 195 --------------- .../v1beta2/networking.gke.io_client.go | 89 ------- .../informers/externalversions/factory.go | 180 -------------- .../informers/externalversions/generic.go | 62 ----- .../internalinterfaces/factory_interfaces.go | 40 ---- .../networking.gke.io/interface.go | 46 ---- .../networking.gke.io/v1beta2/interface.go | 45 ---- .../v1beta2/managedcertificate.go | 90 ------- .../v1beta2/expansion_generated.go | 27 --- .../v1beta2/managedcertificate.go | 94 -------- pkg/logger/config/config.go | 2 - pkg/logger/console.go | 3 - pkg/logger/logger.go | 5 - restapi/admin_config_test.go | 18 +- 38 files changed, 6 insertions(+), 2390 deletions(-) delete mode 100644 operatorapi/integrations.go delete mode 100644 pkg/apis/networking.gke.io/v1beta1/doc.go delete mode 100644 pkg/apis/networking.gke.io/v1beta1/register.go delete mode 100644 pkg/apis/networking.gke.io/v1beta1/types.go delete mode 100644 pkg/apis/networking.gke.io/v1beta1/zz_generated.deepcopy.go delete mode 100644 pkg/apis/networking.gke.io/v1beta2/doc.go delete mode 100644 pkg/apis/networking.gke.io/v1beta2/register.go delete mode 100644 pkg/apis/networking.gke.io/v1beta2/types.go delete mode 100644 pkg/apis/networking.gke.io/v1beta2/zz_generated.deepcopy.go delete mode 100644 pkg/clientgen/clientset/versioned/clientset.go delete mode 100644 pkg/clientgen/clientset/versioned/doc.go delete mode 100644 pkg/clientgen/clientset/versioned/fake/clientset_generated.go delete mode 100644 pkg/clientgen/clientset/versioned/fake/doc.go delete mode 100644 pkg/clientgen/clientset/versioned/fake/register.go delete mode 100644 pkg/clientgen/clientset/versioned/scheme/doc.go delete mode 100644 pkg/clientgen/clientset/versioned/scheme/register.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/doc.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/doc.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_managedcertificate.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_networking.gke.io_client.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/generated_expansion.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/managedcertificate.go delete mode 100644 pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/networking.gke.io_client.go delete mode 100644 pkg/clientgen/informers/externalversions/factory.go delete mode 100644 pkg/clientgen/informers/externalversions/generic.go delete mode 100644 pkg/clientgen/informers/externalversions/internalinterfaces/factory_interfaces.go delete mode 100644 pkg/clientgen/informers/externalversions/networking.gke.io/interface.go delete mode 100644 pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/interface.go delete mode 100644 pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/managedcertificate.go delete mode 100644 pkg/clientgen/listers/networking.gke.io/v1beta2/expansion_generated.go delete mode 100644 pkg/clientgen/listers/networking.gke.io/v1beta2/managedcertificate.go diff --git a/cmd/console/operator.go b/cmd/console/operator.go index 6a2242499..b2ea4b0ad 100644 --- a/cmd/console/operator.go +++ b/cmd/console/operator.go @@ -22,10 +22,7 @@ package main import ( "context" "fmt" - "io/ioutil" - "path/filepath" "strconv" - "syscall" "time" "github.com/minio/console/pkg/logger" @@ -135,58 +132,6 @@ func buildOperatorServer() (*operatorapi.Server, error) { return server, nil } -func loadOperatorAllCerts(ctx *cli.Context) error { - var err error - // Set all certs and CAs directories path - certs.GlobalCertsDir, _, err = certs.NewConfigDirFromCtx(ctx, "certs-dir", certs.DefaultCertsDir.Get) - if err != nil { - return err - } - - certs.GlobalCertsCADir = &certs.ConfigDir{Path: filepath.Join(certs.GlobalCertsDir.Get(), certs.CertsCADir)} - // check if certs and CAs directories exists or can be created - if err = certs.MkdirAllIgnorePerm(certs.GlobalCertsCADir.Get()); err != nil { - return fmt.Errorf("unable to create certs CA directory at %s: failed with %w", certs.GlobalCertsCADir.Get(), err) - } - - // load the certificates and the CAs - restapi.GlobalRootCAs, restapi.GlobalPublicCerts, restapi.GlobalTLSCertsManager, err = certs.GetAllCertificatesAndCAs() - if err != nil { - return fmt.Errorf("unable to load certificates at %s: failed with %w", certs.GlobalCertsDir.Get(), err) - } - - { - // TLS flags from swagger server, used to support VMware vsphere operator version. - swaggerServerCertificate := ctx.String("tls-certificate") - swaggerServerCertificateKey := ctx.String("tls-key") - swaggerServerCACertificate := ctx.String("tls-ca") - // load tls cert and key from swagger server tls-certificate and tls-key flags - if swaggerServerCertificate != "" && swaggerServerCertificateKey != "" { - if err = restapi.GlobalTLSCertsManager.AddCertificate(swaggerServerCertificate, swaggerServerCertificateKey); err != nil { - return err - } - x509Certs, err := certs.ParsePublicCertFile(swaggerServerCertificate) - if err == nil { - restapi.GlobalPublicCerts = append(restapi.GlobalPublicCerts, x509Certs...) - } - } - - // load ca cert from swagger server tls-ca flag - if swaggerServerCACertificate != "" { - caCert, caCertErr := ioutil.ReadFile(swaggerServerCACertificate) - if caCertErr == nil { - restapi.GlobalRootCAs.AppendCertsFromPEM(caCert) - } - } - } - - if restapi.GlobalTLSCertsManager != nil { - restapi.GlobalTLSCertsManager.ReloadOnSignal(syscall.SIGHUP) - } - - return nil -} - // StartServer starts the console service func startOperatorServer(ctx *cli.Context) error { if err := loadAllCerts(ctx); err != nil { diff --git a/operatorapi/integrations.go b/operatorapi/integrations.go deleted file mode 100644 index 27e5ce768..000000000 --- a/operatorapi/integrations.go +++ /dev/null @@ -1,226 +0,0 @@ -// This file is part of MinIO Console Server -// Copyright (c) 2021 MinIO, Inc. -// -// This program is free software: you can redistribute it and/or modify -// it under the terms of the GNU Affero General Public License as published by -// the Free Software Foundation, either version 3 of the License, or -// (at your option) any later version. -// -// This program is distributed in the hope that it will be useful, -// but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -// GNU Affero General Public License for more details. -// -// You should have received a copy of the GNU Affero General Public License -// along with this program. If not, see . - -package operatorapi - -import ( - "context" - "fmt" - "strings" - "time" - - "github.com/minio/console/cluster" - gkev1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - gkeClientset "github.com/minio/console/pkg/clientgen/clientset/versioned" - corev1 "k8s.io/api/core/v1" - extensionsBeta1 "k8s.io/api/extensions/v1beta1" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/util/intstr" - "k8s.io/client-go/informers" - "k8s.io/client-go/kubernetes" - "k8s.io/client-go/tools/cache" -) - -func gkeIntegration(clientset *kubernetes.Clientset, tenantName string, namespace string, k8sToken string) error { - // wait for the first pod to be created - doneCh := make(chan struct{}) - factory := informers.NewSharedInformerFactory(clientset, 0) - - informerClosed := false - - go func() { - time.Sleep(time.Second * 15) - if !informerClosed { - informerClosed = true - close(doneCh) - } - }() - - podInformer := factory.Core().V1().Pods().Informer() - podInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{ - AddFunc: func(obj interface{}) { - pod := obj.(*corev1.Pod) - // monitor for pods with v1.min.io/instance annotation - if strings.HasPrefix(pod.Name, tenantName) { - if !informerClosed { - informerClosed = true - close(doneCh) - } - } - }, - }) - - go podInformer.Run(doneCh) - // block until the informer exits - <-doneCh - - tenantDomain := fmt.Sprintf("%s.cloud.min.dev", tenantName) - tenantConsoleDomain := fmt.Sprintf("console.%s.cloud.min.dev", tenantName) - - // customization for demo, add the ingress for this new tenant - // create ManagedCertificate - manCertName := fmt.Sprintf("%s-cert", tenantName) - managedCert := gkev1beta2.ManagedCertificate{ - ObjectMeta: metav1.ObjectMeta{ - Name: manCertName, - }, - Spec: gkev1beta2.ManagedCertificateSpec{ - Domains: []string{ - tenantDomain, - tenantConsoleDomain, - }, - }, - Status: gkev1beta2.ManagedCertificateStatus{ - DomainStatus: []gkev1beta2.DomainStatus{}, - }, - } - - mkClientSet, err := gkeClientset.NewForConfig(cluster.GetK8sConfig(k8sToken)) - if err != nil { - return err - } - - _, err = mkClientSet.NetworkingV1beta2().ManagedCertificates(namespace).Create(context.Background(), &managedCert, metav1.CreateOptions{}) - if err != nil { - return err - } - - // get a nodeport port for this tenant and create a nodeport for it - tenantNodePort := 9000 - - targetPort := intstr.IntOrString{ - Type: intstr.Int, - IntVal: 9000, - } - - tenantNpSvc := fmt.Sprintf("%s-np", tenantName) - npSvc := corev1.Service{ - ObjectMeta: metav1.ObjectMeta{ - Name: tenantNpSvc, - }, - Spec: corev1.ServiceSpec{ - Selector: map[string]string{ - "v1.min.io/instance": tenantName, - }, - Type: corev1.ServiceTypeNodePort, - Ports: []corev1.ServicePort{ - { - Protocol: corev1.ProtocolTCP, - Port: int32(tenantNodePort), - TargetPort: targetPort, - }, - }, - }, - } - - _, err = clientset.CoreV1().Services(namespace).Create(context.Background(), &npSvc, metav1.CreateOptions{}) - if err != nil { - return err - } - - // NOW FOR Console - // create consoleManagedCertificate - - // get a nodeport port for this tenant and create a nodeport for it - tenantConsoleNodePort := 9090 - - targetConsolePort := intstr.IntOrString{ - Type: intstr.Int, - IntVal: 9090, - } - - tenantNpConsoleSvc := fmt.Sprintf("%s-console-np", tenantName) - npConsoleSvc := corev1.Service{ - ObjectMeta: metav1.ObjectMeta{ - Name: tenantNpConsoleSvc, - }, - Spec: corev1.ServiceSpec{ - Selector: map[string]string{ - "v1.min.io/console": fmt.Sprintf("%s-console", tenantName), - }, - Type: corev1.ServiceTypeNodePort, - Ports: []corev1.ServicePort{ - { - Protocol: corev1.ProtocolTCP, - Port: int32(tenantConsoleNodePort), - TargetPort: targetConsolePort, - }, - }, - }, - } - - _, err = clientset.CoreV1().Services(namespace).Create(context.Background(), &npConsoleSvc, metav1.CreateOptions{}) - if err != nil { - return err - } - // udpate ingress with this new service - consoleIngress, err := clientset.ExtensionsV1beta1().Ingresses(namespace).Get(context.Background(), "console-ingress", metav1.GetOptions{}) - if err != nil { - return err - } - - certsInIngress := consoleIngress.ObjectMeta.Annotations["networking.gke.io/managed-certificates"] - allCerts := strings.Split(certsInIngress, ",") - allCerts = append(allCerts, manCertName) - consoleIngress.ObjectMeta.Annotations["networking.gke.io/managed-certificates"] = strings.Join(allCerts, ",") - - tenantNodePortIoS := intstr.IntOrString{ - Type: intstr.Int, - IntVal: int32(tenantNodePort), - } - - tenantConsoleNodePortIoS := intstr.IntOrString{ - Type: intstr.Int, - IntVal: int32(tenantConsoleNodePort), - } - - consoleIngress.Spec.Rules = append(consoleIngress.Spec.Rules, extensionsBeta1.IngressRule{ - Host: tenantDomain, - IngressRuleValue: extensionsBeta1.IngressRuleValue{ - HTTP: &extensionsBeta1.HTTPIngressRuleValue{ - Paths: []extensionsBeta1.HTTPIngressPath{ - { - Backend: extensionsBeta1.IngressBackend{ - ServiceName: tenantNpSvc, - ServicePort: tenantNodePortIoS, - }, - }, - }, - }, - }, - }) - consoleIngress.Spec.Rules = append(consoleIngress.Spec.Rules, extensionsBeta1.IngressRule{ - Host: tenantConsoleDomain, - IngressRuleValue: extensionsBeta1.IngressRuleValue{ - HTTP: &extensionsBeta1.HTTPIngressRuleValue{ - Paths: []extensionsBeta1.HTTPIngressPath{ - { - Backend: extensionsBeta1.IngressBackend{ - ServiceName: tenantNpConsoleSvc, - ServicePort: tenantConsoleNodePortIoS, - }, - }, - }, - }, - }, - }) - - _, err = clientset.ExtensionsV1beta1().Ingresses(namespace).Update(context.Background(), consoleIngress, metav1.UpdateOptions{}) - if err != nil { - return err - } - return nil -} diff --git a/operatorapi/tenant_add.go b/operatorapi/tenant_add.go index f2fc00960..e3d0e5cdd 100644 --- a/operatorapi/tenant_add.go +++ b/operatorapi/tenant_add.go @@ -20,7 +20,6 @@ import ( "context" "encoding/base64" "fmt" - "os" "github.com/dustin/go-humanize" @@ -586,13 +585,6 @@ func getTenantCreatedResponse(session *models.Principal, params operator_api.Cre return nil, restapi.ErrorWithContext(ctx, err) } - // Integrations - if os.Getenv("GKE_INTEGRATION") != "" { - err := gkeIntegration(clientSet, tenantName, ns, session.STSSessionToken) - if err != nil { - return nil, restapi.ErrorWithContext(ctx, err) - } - } response = &models.CreateTenantResponse{ ExternalIDP: tenantExternalIDPConfigured, } diff --git a/pkg/apis/networking.gke.io/v1beta1/doc.go b/pkg/apis/networking.gke.io/v1beta1/doc.go deleted file mode 100644 index 131fbff4e..000000000 --- a/pkg/apis/networking.gke.io/v1beta1/doc.go +++ /dev/null @@ -1,21 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// +k8s:deepcopy-gen=package,register - -// Package v1beta1 is v1beta1 version of the API. -// +groupName=networking.gke.io -package v1beta1 diff --git a/pkg/apis/networking.gke.io/v1beta1/register.go b/pkg/apis/networking.gke.io/v1beta1/register.go deleted file mode 100644 index 1affd874a..000000000 --- a/pkg/apis/networking.gke.io/v1beta1/register.go +++ /dev/null @@ -1,54 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package v1beta1 - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" -) - -// SchemeGroupVersion is group version used to register these objects -var SchemeGroupVersion = schema.GroupVersion{Group: "networking.gke.io", Version: "v1beta1"} - -// Resource takes an unqualified resource and returns a Group qualified GroupResource -func Resource(resource string) schema.GroupResource { - return SchemeGroupVersion.WithResource(resource).GroupResource() -} - -var ( - // SchemeBuilder points to a list of functions added to Scheme. - SchemeBuilder runtime.SchemeBuilder - localSchemeBuilder = &SchemeBuilder -) - -func init() { - // We only register manually written functions here. The registration of the - // generated functions takes place in the generated files. The separation - // makes the code compile even when the generated files are missing. - localSchemeBuilder.Register(addKnownTypes) -} - -// Adds the list of known types to api.Scheme. -func addKnownTypes(scheme *runtime.Scheme) error { - scheme.AddKnownTypes(SchemeGroupVersion, - &ManagedCertificate{}, - &ManagedCertificateList{}, - ) - v1.AddToGroupVersion(scheme, SchemeGroupVersion) - return nil -} diff --git a/pkg/apis/networking.gke.io/v1beta1/types.go b/pkg/apis/networking.gke.io/v1beta1/types.go deleted file mode 100644 index b00d0c2b8..000000000 --- a/pkg/apis/networking.gke.io/v1beta1/types.go +++ /dev/null @@ -1,87 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package v1beta1 - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" -) - -// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object - -// ManagedCertificateList is a list of ManagedCertificate objects. -type ManagedCertificateList struct { - metav1.TypeMeta `json:",inline"` - // metdata is the standard list metadata. - // +optional - metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` - - // items is the list of managed certificate objects. - Items []ManagedCertificate `json:"items" protobuf:"bytes,2,rep,name=items"` -} - -// +genclient -// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object - -// ManagedCertificate configures the domains for which client requests a managed certificate. It also provides the current status of the certficate. -type ManagedCertificate struct { - metav1.TypeMeta `json:",inline"` - // Standard object metadata. More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#metadata - // +optional - metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` - - // Specification of the managed certificate. - // More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#spec-and-status. - // +optional - Spec ManagedCertificateSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"` - - // Current information about the managed certificate. - // +optional - Status ManagedCertificateStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` -} - -// ManagedCertificateSpec configures the domains for which client requests a managed certificate. -type ManagedCertificateSpec struct { - // Specifies a list of domains populated by the user for which he requests a managed certificate. - Domains []string `json:"domains" protobuf:"bytes,2,rep,name=domains"` -} - -// ManagedCertificateStatus provides the current state of the certificate. -type ManagedCertificateStatus struct { - // Specifies the status of the managed certificate. - // +optional - CertificateStatus string `json:"certificateStatus,omitempty" protobuf:"bytes,2,opt,name=certificateStatus"` - - // Specifies the status of certificate provisioning for domains selected by the user. - DomainStatus []DomainStatus `json:"domainStatus" protobuf:"bytes,3,rep,name=domainStatus"` - - // Specifies the name of the provisioned managed certificate. - // +optional - CertificateName string `json:"certificateName,omitempty" protobuf:"bytes,4,opt,name=certificateName"` - - // Specifies the expire time of the provisioned managed certificate. - // +optional - ExpireTime string `json:"expireTime,omitempty" protobuf:"bytes,5,opt,name=expireTime"` -} - -// DomainStatus is a pair which associates domain name with status of certificate provisioning for this domain. -type DomainStatus struct { - // The domain name. - Domain string `json:"domain" protobuf:"bytes,1,name=domain"` - - // The status. - Status string `json:"status" protobuf:"bytes,2,name=status"` -} diff --git a/pkg/apis/networking.gke.io/v1beta1/zz_generated.deepcopy.go b/pkg/apis/networking.gke.io/v1beta1/zz_generated.deepcopy.go deleted file mode 100644 index 4c28cd7da..000000000 --- a/pkg/apis/networking.gke.io/v1beta1/zz_generated.deepcopy.go +++ /dev/null @@ -1,145 +0,0 @@ -//go:build !ignore_autogenerated -// +build !ignore_autogenerated - -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by deepcopy-gen. DO NOT EDIT. - -package v1beta1 - -import ( - runtime "k8s.io/apimachinery/pkg/runtime" -) - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *DomainStatus) DeepCopyInto(out *DomainStatus) { - *out = *in - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DomainStatus. -func (in *DomainStatus) DeepCopy() *DomainStatus { - if in == nil { - return nil - } - out := new(DomainStatus) - in.DeepCopyInto(out) - return out -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificate) DeepCopyInto(out *ManagedCertificate) { - *out = *in - out.TypeMeta = in.TypeMeta - in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) - in.Spec.DeepCopyInto(&out.Spec) - in.Status.DeepCopyInto(&out.Status) - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificate. -func (in *ManagedCertificate) DeepCopy() *ManagedCertificate { - if in == nil { - return nil - } - out := new(ManagedCertificate) - in.DeepCopyInto(out) - return out -} - -// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. -func (in *ManagedCertificate) DeepCopyObject() runtime.Object { - if c := in.DeepCopy(); c != nil { - return c - } - return nil -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateList) DeepCopyInto(out *ManagedCertificateList) { - *out = *in - out.TypeMeta = in.TypeMeta - in.ListMeta.DeepCopyInto(&out.ListMeta) - if in.Items != nil { - in, out := &in.Items, &out.Items - *out = make([]ManagedCertificate, len(*in)) - for i := range *in { - (*in)[i].DeepCopyInto(&(*out)[i]) - } - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateList. -func (in *ManagedCertificateList) DeepCopy() *ManagedCertificateList { - if in == nil { - return nil - } - out := new(ManagedCertificateList) - in.DeepCopyInto(out) - return out -} - -// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. -func (in *ManagedCertificateList) DeepCopyObject() runtime.Object { - if c := in.DeepCopy(); c != nil { - return c - } - return nil -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateSpec) DeepCopyInto(out *ManagedCertificateSpec) { - *out = *in - if in.Domains != nil { - in, out := &in.Domains, &out.Domains - *out = make([]string, len(*in)) - copy(*out, *in) - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateSpec. -func (in *ManagedCertificateSpec) DeepCopy() *ManagedCertificateSpec { - if in == nil { - return nil - } - out := new(ManagedCertificateSpec) - in.DeepCopyInto(out) - return out -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateStatus) DeepCopyInto(out *ManagedCertificateStatus) { - *out = *in - if in.DomainStatus != nil { - in, out := &in.DomainStatus, &out.DomainStatus - *out = make([]DomainStatus, len(*in)) - copy(*out, *in) - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateStatus. -func (in *ManagedCertificateStatus) DeepCopy() *ManagedCertificateStatus { - if in == nil { - return nil - } - out := new(ManagedCertificateStatus) - in.DeepCopyInto(out) - return out -} diff --git a/pkg/apis/networking.gke.io/v1beta2/doc.go b/pkg/apis/networking.gke.io/v1beta2/doc.go deleted file mode 100644 index 238931c0a..000000000 --- a/pkg/apis/networking.gke.io/v1beta2/doc.go +++ /dev/null @@ -1,21 +0,0 @@ -/* -Copyright 2019 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// +k8s:deepcopy-gen=package,register - -// Package v1beta2 is v1beta2 version of the API. -// +groupName=networking.gke.io -package v1beta2 diff --git a/pkg/apis/networking.gke.io/v1beta2/register.go b/pkg/apis/networking.gke.io/v1beta2/register.go deleted file mode 100644 index 7f984ab1b..000000000 --- a/pkg/apis/networking.gke.io/v1beta2/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 2019 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package v1beta2 - -import ( - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" -) - -// SchemeGroupVersion is group version used to register these objects -var SchemeGroupVersion = schema.GroupVersion{Group: "networking.gke.io", Version: "v1beta2"} - -// Resource takes an unqualified resource and returns a Group qualified GroupResource -func Resource(resource string) schema.GroupResource { - return SchemeGroupVersion.WithResource(resource).GroupResource() -} - -var ( - // SchemeBuilder points to a list of functions added to Scheme. - SchemeBuilder runtime.SchemeBuilder - localSchemeBuilder = &SchemeBuilder - // AddToScheme applies all stored functions to Scheme. - AddToScheme = localSchemeBuilder.AddToScheme -) - -func init() { - // We only register manually written functions here. The registration of the - // generated functions takes place in the generated files. The separation - // makes the code compile even when the generated files are missing. - localSchemeBuilder.Register(addKnownTypes) -} - -// Adds the list of known types to api.Scheme. -func addKnownTypes(scheme *runtime.Scheme) error { - scheme.AddKnownTypes(SchemeGroupVersion, - &ManagedCertificate{}, - &ManagedCertificateList{}, - ) - v1.AddToGroupVersion(scheme, SchemeGroupVersion) - return nil -} diff --git a/pkg/apis/networking.gke.io/v1beta2/types.go b/pkg/apis/networking.gke.io/v1beta2/types.go deleted file mode 100644 index 375a65538..000000000 --- a/pkg/apis/networking.gke.io/v1beta2/types.go +++ /dev/null @@ -1,87 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package v1beta2 - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" -) - -// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object - -// ManagedCertificateList is a list of ManagedCertificate objects. -type ManagedCertificateList struct { - metav1.TypeMeta `json:",inline"` - // metdata is the standard list metadata. - // +optional - metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` - - // items is the list of managed certificate objects. - Items []ManagedCertificate `json:"items" protobuf:"bytes,2,rep,name=items"` -} - -// +genclient -// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object - -// ManagedCertificate configures the domains for which client requests a managed certificate. It also provides the current status of the certficate. -type ManagedCertificate struct { - metav1.TypeMeta `json:",inline"` - // Standard object metadata. More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#metadata - // +optional - metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` - - // Specification of the managed certificate. - // More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#spec-and-status. - // +optional - Spec ManagedCertificateSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"` - - // Current information about the managed certificate. - // +optional - Status ManagedCertificateStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` -} - -// ManagedCertificateSpec configures the domains for which client requests a managed certificate. -type ManagedCertificateSpec struct { - // Specifies a list of domains populated by the user for which he requests a managed certificate. - Domains []string `json:"domains" protobuf:"bytes,2,rep,name=domains"` -} - -// ManagedCertificateStatus provides the current state of the certificate. -type ManagedCertificateStatus struct { - // Specifies the status of the managed certificate. - // +optional - CertificateStatus string `json:"certificateStatus,omitempty" protobuf:"bytes,2,opt,name=certificateStatus"` - - // Specifies the status of certificate provisioning for domains selected by the user. - DomainStatus []DomainStatus `json:"domainStatus" protobuf:"bytes,3,rep,name=domainStatus"` - - // Specifies the name of the provisioned managed certificate. - // +optional - CertificateName string `json:"certificateName,omitempty" protobuf:"bytes,4,opt,name=certificateName"` - - // Specifies the expire time of the provisioned managed certificate. - // +optional - ExpireTime string `json:"expireTime,omitempty" protobuf:"bytes,5,opt,name=expireTime"` -} - -// DomainStatus is a pair which associates domain name with status of certificate provisioning for this domain. -type DomainStatus struct { - // The domain name. - Domain string `json:"domain" protobuf:"bytes,1,name=domain"` - - // The status. - Status string `json:"status" protobuf:"bytes,2,name=status"` -} diff --git a/pkg/apis/networking.gke.io/v1beta2/zz_generated.deepcopy.go b/pkg/apis/networking.gke.io/v1beta2/zz_generated.deepcopy.go deleted file mode 100644 index ea5676623..000000000 --- a/pkg/apis/networking.gke.io/v1beta2/zz_generated.deepcopy.go +++ /dev/null @@ -1,145 +0,0 @@ -//go:build !ignore_autogenerated -// +build !ignore_autogenerated - -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by deepcopy-gen. DO NOT EDIT. - -package v1beta2 - -import ( - runtime "k8s.io/apimachinery/pkg/runtime" -) - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *DomainStatus) DeepCopyInto(out *DomainStatus) { - *out = *in - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DomainStatus. -func (in *DomainStatus) DeepCopy() *DomainStatus { - if in == nil { - return nil - } - out := new(DomainStatus) - in.DeepCopyInto(out) - return out -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificate) DeepCopyInto(out *ManagedCertificate) { - *out = *in - out.TypeMeta = in.TypeMeta - in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) - in.Spec.DeepCopyInto(&out.Spec) - in.Status.DeepCopyInto(&out.Status) - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificate. -func (in *ManagedCertificate) DeepCopy() *ManagedCertificate { - if in == nil { - return nil - } - out := new(ManagedCertificate) - in.DeepCopyInto(out) - return out -} - -// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. -func (in *ManagedCertificate) DeepCopyObject() runtime.Object { - if c := in.DeepCopy(); c != nil { - return c - } - return nil -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateList) DeepCopyInto(out *ManagedCertificateList) { - *out = *in - out.TypeMeta = in.TypeMeta - in.ListMeta.DeepCopyInto(&out.ListMeta) - if in.Items != nil { - in, out := &in.Items, &out.Items - *out = make([]ManagedCertificate, len(*in)) - for i := range *in { - (*in)[i].DeepCopyInto(&(*out)[i]) - } - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateList. -func (in *ManagedCertificateList) DeepCopy() *ManagedCertificateList { - if in == nil { - return nil - } - out := new(ManagedCertificateList) - in.DeepCopyInto(out) - return out -} - -// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. -func (in *ManagedCertificateList) DeepCopyObject() runtime.Object { - if c := in.DeepCopy(); c != nil { - return c - } - return nil -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateSpec) DeepCopyInto(out *ManagedCertificateSpec) { - *out = *in - if in.Domains != nil { - in, out := &in.Domains, &out.Domains - *out = make([]string, len(*in)) - copy(*out, *in) - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateSpec. -func (in *ManagedCertificateSpec) DeepCopy() *ManagedCertificateSpec { - if in == nil { - return nil - } - out := new(ManagedCertificateSpec) - in.DeepCopyInto(out) - return out -} - -// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil. -func (in *ManagedCertificateStatus) DeepCopyInto(out *ManagedCertificateStatus) { - *out = *in - if in.DomainStatus != nil { - in, out := &in.DomainStatus, &out.DomainStatus - *out = make([]DomainStatus, len(*in)) - copy(*out, *in) - } - return -} - -// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ManagedCertificateStatus. -func (in *ManagedCertificateStatus) DeepCopy() *ManagedCertificateStatus { - if in == nil { - return nil - } - out := new(ManagedCertificateStatus) - in.DeepCopyInto(out) - return out -} diff --git a/pkg/auth/idp/oauth2/const.go b/pkg/auth/idp/oauth2/const.go index a4d57d4ad..6fe1971a2 100644 --- a/pkg/auth/idp/oauth2/const.go +++ b/pkg/auth/idp/oauth2/const.go @@ -29,5 +29,4 @@ const ( ConsoleIDPScopes = "CONSOLE_IDP_SCOPES" ConsoleIDPUserInfo = "CONSOLE_IDP_USERINFO" ConsoleIDPTokenExpiration = "CONSOLE_IDP_TOKEN_EXPIRATION" - ConsoleIDPRoleARN = "CONSOLE_IDP_ROLE_ARN" ) diff --git a/pkg/clientgen/clientset/versioned/clientset.go b/pkg/clientgen/clientset/versioned/clientset.go deleted file mode 100644 index 4d075bc94..000000000 --- a/pkg/clientgen/clientset/versioned/clientset.go +++ /dev/null @@ -1,97 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package versioned - -import ( - "fmt" - - networkingv1beta2 "github.com/minio/console/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2" - discovery "k8s.io/client-go/discovery" - rest "k8s.io/client-go/rest" - flowcontrol "k8s.io/client-go/util/flowcontrol" -) - -type Interface interface { - Discovery() discovery.DiscoveryInterface - NetworkingV1beta2() networkingv1beta2.NetworkingV1beta2Interface -} - -// Clientset contains the clients for groups. Each group has exactly one -// version included in a Clientset. -type Clientset struct { - *discovery.DiscoveryClient - networkingV1beta2 *networkingv1beta2.NetworkingV1beta2Client -} - -// NetworkingV1beta2 retrieves the NetworkingV1beta2Client -func (c *Clientset) NetworkingV1beta2() networkingv1beta2.NetworkingV1beta2Interface { - return c.networkingV1beta2 -} - -// Discovery retrieves the DiscoveryClient -func (c *Clientset) Discovery() discovery.DiscoveryInterface { - if c == nil { - return nil - } - return c.DiscoveryClient -} - -// NewForConfig creates a new Clientset for the given config. -// If config's RateLimiter is not set and QPS and Burst are acceptable, -// NewForConfig will generate a rate-limiter in configShallowCopy. -func NewForConfig(c *rest.Config) (*Clientset, error) { - configShallowCopy := *c - if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 { - if configShallowCopy.Burst <= 0 { - return nil, fmt.Errorf("burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0") - } - configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst) - } - var cs Clientset - var err error - cs.networkingV1beta2, err = networkingv1beta2.NewForConfig(&configShallowCopy) - if err != nil { - return nil, err - } - - cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy) - if err != nil { - return nil, err - } - return &cs, nil -} - -// NewForConfigOrDie creates a new Clientset for the given config and -// panics if there is an error in the config. -func NewForConfigOrDie(c *rest.Config) *Clientset { - var cs Clientset - cs.networkingV1beta2 = networkingv1beta2.NewForConfigOrDie(c) - - cs.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c) - return &cs -} - -// New creates a new Clientset for the given RESTClient. -func New(c rest.Interface) *Clientset { - var cs Clientset - cs.networkingV1beta2 = networkingv1beta2.New(c) - - cs.DiscoveryClient = discovery.NewDiscoveryClient(c) - return &cs -} diff --git a/pkg/clientgen/clientset/versioned/doc.go b/pkg/clientgen/clientset/versioned/doc.go deleted file mode 100644 index a1dc38fa5..000000000 --- a/pkg/clientgen/clientset/versioned/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated clientset. -package versioned diff --git a/pkg/clientgen/clientset/versioned/fake/clientset_generated.go b/pkg/clientgen/clientset/versioned/fake/clientset_generated.go deleted file mode 100644 index e655dc15e..000000000 --- a/pkg/clientgen/clientset/versioned/fake/clientset_generated.go +++ /dev/null @@ -1,82 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - clientset "github.com/minio/console/pkg/clientgen/clientset/versioned" - networkingv1beta2 "github.com/minio/console/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2" - fakenetworkingv1beta2 "github.com/minio/console/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/watch" - "k8s.io/client-go/discovery" - fakediscovery "k8s.io/client-go/discovery/fake" - "k8s.io/client-go/testing" -) - -// NewSimpleClientset returns a clientset that will respond with the provided objects. -// It's backed by a very simple object tracker that processes creates, updates and deletions as-is, -// without applying any validations and/or defaults. It shouldn't be considered a replacement -// for a real clientset and is mostly useful in simple unit tests. -func NewSimpleClientset(objects ...runtime.Object) *Clientset { - o := testing.NewObjectTracker(scheme, codecs.UniversalDecoder()) - for _, obj := range objects { - if err := o.Add(obj); err != nil { - panic(err) - } - } - - cs := &Clientset{tracker: o} - cs.discovery = &fakediscovery.FakeDiscovery{Fake: &cs.Fake} - cs.AddReactor("*", "*", testing.ObjectReaction(o)) - cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { - gvr := action.GetResource() - ns := action.GetNamespace() - watch, err := o.Watch(gvr, ns) - if err != nil { - return false, nil, err - } - return true, watch, nil - }) - - return cs -} - -// Clientset implements clientset.Interface. Meant to be embedded into a -// struct to get a default implementation. This makes faking out just the method -// you want to test easier. -type Clientset struct { - testing.Fake - discovery *fakediscovery.FakeDiscovery - tracker testing.ObjectTracker -} - -func (c *Clientset) Discovery() discovery.DiscoveryInterface { - return c.discovery -} - -func (c *Clientset) Tracker() testing.ObjectTracker { - return c.tracker -} - -var _ clientset.Interface = &Clientset{} - -// NetworkingV1beta2 retrieves the NetworkingV1beta2Client -func (c *Clientset) NetworkingV1beta2() networkingv1beta2.NetworkingV1beta2Interface { - return &fakenetworkingv1beta2.FakeNetworkingV1beta2{Fake: &c.Fake} -} diff --git a/pkg/clientgen/clientset/versioned/fake/doc.go b/pkg/clientgen/clientset/versioned/fake/doc.go deleted file mode 100644 index 134534214..000000000 --- a/pkg/clientgen/clientset/versioned/fake/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated fake clientset. -package fake diff --git a/pkg/clientgen/clientset/versioned/fake/register.go b/pkg/clientgen/clientset/versioned/fake/register.go deleted file mode 100644 index 7f62f0922..000000000 --- a/pkg/clientgen/clientset/versioned/fake/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - networkingv1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - serializer "k8s.io/apimachinery/pkg/runtime/serializer" - utilruntime "k8s.io/apimachinery/pkg/util/runtime" -) - -var scheme = runtime.NewScheme() -var codecs = serializer.NewCodecFactory(scheme) -var parameterCodec = runtime.NewParameterCodec(scheme) -var localSchemeBuilder = runtime.SchemeBuilder{ - networkingv1beta2.AddToScheme, -} - -// AddToScheme adds all types of this clientset into the given scheme. This allows composition -// of clientsets, like in: -// -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) -// -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) -// -// After this, RawExtensions in Kubernetes types will serialize kube-aggregator types -// correctly. -var AddToScheme = localSchemeBuilder.AddToScheme - -func init() { - v1.AddToGroupVersion(scheme, schema.GroupVersion{Version: "v1"}) - utilruntime.Must(AddToScheme(scheme)) -} diff --git a/pkg/clientgen/clientset/versioned/scheme/doc.go b/pkg/clientgen/clientset/versioned/scheme/doc.go deleted file mode 100644 index 3affeace9..000000000 --- a/pkg/clientgen/clientset/versioned/scheme/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package contains the scheme of the automatically generated clientset. -package scheme diff --git a/pkg/clientgen/clientset/versioned/scheme/register.go b/pkg/clientgen/clientset/versioned/scheme/register.go deleted file mode 100644 index 6ab37de9a..000000000 --- a/pkg/clientgen/clientset/versioned/scheme/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package scheme - -import ( - networkingv1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - serializer "k8s.io/apimachinery/pkg/runtime/serializer" - utilruntime "k8s.io/apimachinery/pkg/util/runtime" -) - -var Scheme = runtime.NewScheme() -var Codecs = serializer.NewCodecFactory(Scheme) -var ParameterCodec = runtime.NewParameterCodec(Scheme) -var localSchemeBuilder = runtime.SchemeBuilder{ - networkingv1beta2.AddToScheme, -} - -// AddToScheme adds all types of this clientset into the given scheme. This allows composition -// of clientsets, like in: -// -// import ( -// "k8s.io/client-go/kubernetes" -// clientsetscheme "k8s.io/client-go/kubernetes/scheme" -// aggregatorclientsetscheme "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/scheme" -// ) -// -// kclientset, _ := kubernetes.NewForConfig(c) -// _ = aggregatorclientsetscheme.AddToScheme(clientsetscheme.Scheme) -// -// After this, RawExtensions in Kubernetes types will serialize kube-aggregator types -// correctly. -var AddToScheme = localSchemeBuilder.AddToScheme - -func init() { - v1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"}) - utilruntime.Must(AddToScheme(Scheme)) -} diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/doc.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/doc.go deleted file mode 100644 index 932158143..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// This package has the automatically generated typed clients. -package v1beta2 diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/doc.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/doc.go deleted file mode 100644 index 972dfcb64..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/doc.go +++ /dev/null @@ -1,20 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -// Package fake has the automatically generated clients. -package fake diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_managedcertificate.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_managedcertificate.go deleted file mode 100644 index 464a1f9c6..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_managedcertificate.go +++ /dev/null @@ -1,142 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - "context" - - v1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - labels "k8s.io/apimachinery/pkg/labels" - schema "k8s.io/apimachinery/pkg/runtime/schema" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - testing "k8s.io/client-go/testing" -) - -// FakeManagedCertificates implements ManagedCertificateInterface -type FakeManagedCertificates struct { - Fake *FakeNetworkingV1beta2 - ns string -} - -var managedcertificatesResource = schema.GroupVersionResource{Group: "networking.gke.io", Version: "v1beta2", Resource: "managedcertificates"} - -var managedcertificatesKind = schema.GroupVersionKind{Group: "networking.gke.io", Version: "v1beta2", Kind: "ManagedCertificate"} - -// Get takes name of the managedCertificate, and returns the corresponding managedCertificate object, and an error if there is any. -func (c *FakeManagedCertificates) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.ManagedCertificate, err error) { - obj, err := c.Fake. - Invokes(testing.NewGetAction(managedcertificatesResource, c.ns, name), &v1beta2.ManagedCertificate{}) - - if obj == nil { - return nil, err - } - return obj.(*v1beta2.ManagedCertificate), err -} - -// List takes label and field selectors, and returns the list of ManagedCertificates that match those selectors. -func (c *FakeManagedCertificates) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.ManagedCertificateList, err error) { - obj, err := c.Fake. - Invokes(testing.NewListAction(managedcertificatesResource, managedcertificatesKind, c.ns, opts), &v1beta2.ManagedCertificateList{}) - - if obj == nil { - return nil, err - } - - label, _, _ := testing.ExtractFromListOptions(opts) - if label == nil { - label = labels.Everything() - } - list := &v1beta2.ManagedCertificateList{ListMeta: obj.(*v1beta2.ManagedCertificateList).ListMeta} - for _, item := range obj.(*v1beta2.ManagedCertificateList).Items { - if label.Matches(labels.Set(item.Labels)) { - list.Items = append(list.Items, item) - } - } - return list, err -} - -// Watch returns a watch.Interface that watches the requested managedCertificates. -func (c *FakeManagedCertificates) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { - return c.Fake. - InvokesWatch(testing.NewWatchAction(managedcertificatesResource, c.ns, opts)) - -} - -// Create takes the representation of a managedCertificate and creates it. Returns the server's representation of the managedCertificate, and an error, if there is any. -func (c *FakeManagedCertificates) Create(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.CreateOptions) (result *v1beta2.ManagedCertificate, err error) { - obj, err := c.Fake. - Invokes(testing.NewCreateAction(managedcertificatesResource, c.ns, managedCertificate), &v1beta2.ManagedCertificate{}) - - if obj == nil { - return nil, err - } - return obj.(*v1beta2.ManagedCertificate), err -} - -// Update takes the representation of a managedCertificate and updates it. Returns the server's representation of the managedCertificate, and an error, if there is any. -func (c *FakeManagedCertificates) Update(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (result *v1beta2.ManagedCertificate, err error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateAction(managedcertificatesResource, c.ns, managedCertificate), &v1beta2.ManagedCertificate{}) - - if obj == nil { - return nil, err - } - return obj.(*v1beta2.ManagedCertificate), err -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *FakeManagedCertificates) UpdateStatus(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (*v1beta2.ManagedCertificate, error) { - obj, err := c.Fake. - Invokes(testing.NewUpdateSubresourceAction(managedcertificatesResource, "status", c.ns, managedCertificate), &v1beta2.ManagedCertificate{}) - - if obj == nil { - return nil, err - } - return obj.(*v1beta2.ManagedCertificate), err -} - -// Delete takes name of the managedCertificate and deletes it. Returns an error if one occurs. -func (c *FakeManagedCertificates) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { - _, err := c.Fake. - Invokes(testing.NewDeleteAction(managedcertificatesResource, c.ns, name), &v1beta2.ManagedCertificate{}) - - return err -} - -// DeleteCollection deletes a collection of objects. -func (c *FakeManagedCertificates) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error { - action := testing.NewDeleteCollectionAction(managedcertificatesResource, c.ns, listOpts) - - _, err := c.Fake.Invokes(action, &v1beta2.ManagedCertificateList{}) - return err -} - -// Patch applies the patch and returns the patched managedCertificate. -func (c *FakeManagedCertificates) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.ManagedCertificate, err error) { - obj, err := c.Fake. - Invokes(testing.NewPatchSubresourceAction(managedcertificatesResource, c.ns, name, pt, data, subresources...), &v1beta2.ManagedCertificate{}) - - if obj == nil { - return nil, err - } - return obj.(*v1beta2.ManagedCertificate), err -} diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_networking.gke.io_client.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_networking.gke.io_client.go deleted file mode 100644 index ee2eb698e..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/fake/fake_networking.gke.io_client.go +++ /dev/null @@ -1,40 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package fake - -import ( - v1beta2 "github.com/minio/console/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2" - rest "k8s.io/client-go/rest" - testing "k8s.io/client-go/testing" -) - -type FakeNetworkingV1beta2 struct { - *testing.Fake -} - -func (c *FakeNetworkingV1beta2) ManagedCertificates(namespace string) v1beta2.ManagedCertificateInterface { - return &FakeManagedCertificates{c, namespace} -} - -// RESTClient returns a RESTClient that is used to communicate -// with API server by this client implementation. -func (c *FakeNetworkingV1beta2) RESTClient() rest.Interface { - var ret *rest.RESTClient - return ret -} diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/generated_expansion.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/generated_expansion.go deleted file mode 100644 index 4b1dc91f7..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/generated_expansion.go +++ /dev/null @@ -1,21 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1beta2 - -type ManagedCertificateExpansion interface{} diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/managedcertificate.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/managedcertificate.go deleted file mode 100644 index ae3b70df6..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/managedcertificate.go +++ /dev/null @@ -1,195 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1beta2 - -import ( - "context" - "time" - - v1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - scheme "github.com/minio/console/pkg/clientgen/clientset/versioned/scheme" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - types "k8s.io/apimachinery/pkg/types" - watch "k8s.io/apimachinery/pkg/watch" - rest "k8s.io/client-go/rest" -) - -// ManagedCertificatesGetter has a method to return a ManagedCertificateInterface. -// A group's client should implement this interface. -type ManagedCertificatesGetter interface { - ManagedCertificates(namespace string) ManagedCertificateInterface -} - -// ManagedCertificateInterface has methods to work with ManagedCertificate resources. -type ManagedCertificateInterface interface { - Create(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.CreateOptions) (*v1beta2.ManagedCertificate, error) - Update(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (*v1beta2.ManagedCertificate, error) - UpdateStatus(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (*v1beta2.ManagedCertificate, error) - Delete(ctx context.Context, name string, opts v1.DeleteOptions) error - DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error - Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta2.ManagedCertificate, error) - List(ctx context.Context, opts v1.ListOptions) (*v1beta2.ManagedCertificateList, error) - Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) - Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.ManagedCertificate, err error) - ManagedCertificateExpansion -} - -// managedCertificates implements ManagedCertificateInterface -type managedCertificates struct { - client rest.Interface - ns string -} - -// newManagedCertificates returns a ManagedCertificates -func newManagedCertificates(c *NetworkingV1beta2Client, namespace string) *managedCertificates { - return &managedCertificates{ - client: c.RESTClient(), - ns: namespace, - } -} - -// Get takes name of the managedCertificate, and returns the corresponding managedCertificate object, and an error if there is any. -func (c *managedCertificates) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1beta2.ManagedCertificate, err error) { - result = &v1beta2.ManagedCertificate{} - err = c.client.Get(). - Namespace(c.ns). - Resource("managedcertificates"). - Name(name). - VersionedParams(&options, scheme.ParameterCodec). - Do(ctx). - Into(result) - return -} - -// List takes label and field selectors, and returns the list of ManagedCertificates that match those selectors. -func (c *managedCertificates) List(ctx context.Context, opts v1.ListOptions) (result *v1beta2.ManagedCertificateList, err error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeout = time.Duration(*opts.TimeoutSeconds) * time.Second - } - result = &v1beta2.ManagedCertificateList{} - err = c.client.Get(). - Namespace(c.ns). - Resource("managedcertificates"). - VersionedParams(&opts, scheme.ParameterCodec). - Timeout(timeout). - Do(ctx). - Into(result) - return -} - -// Watch returns a watch.Interface that watches the requested managedCertificates. -func (c *managedCertificates) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) { - var timeout time.Duration - if opts.TimeoutSeconds != nil { - timeout = time.Duration(*opts.TimeoutSeconds) * time.Second - } - opts.Watch = true - return c.client.Get(). - Namespace(c.ns). - Resource("managedcertificates"). - VersionedParams(&opts, scheme.ParameterCodec). - Timeout(timeout). - Watch(ctx) -} - -// Create takes the representation of a managedCertificate and creates it. Returns the server's representation of the managedCertificate, and an error, if there is any. -func (c *managedCertificates) Create(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.CreateOptions) (result *v1beta2.ManagedCertificate, err error) { - result = &v1beta2.ManagedCertificate{} - err = c.client.Post(). - Namespace(c.ns). - Resource("managedcertificates"). - VersionedParams(&opts, scheme.ParameterCodec). - Body(managedCertificate). - Do(ctx). - Into(result) - return -} - -// Update takes the representation of a managedCertificate and updates it. Returns the server's representation of the managedCertificate, and an error, if there is any. -func (c *managedCertificates) Update(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (result *v1beta2.ManagedCertificate, err error) { - result = &v1beta2.ManagedCertificate{} - err = c.client.Put(). - Namespace(c.ns). - Resource("managedcertificates"). - Name(managedCertificate.Name). - VersionedParams(&opts, scheme.ParameterCodec). - Body(managedCertificate). - Do(ctx). - Into(result) - return -} - -// UpdateStatus was generated because the type contains a Status member. -// Add a +genclient:noStatus comment above the type to avoid generating UpdateStatus(). -func (c *managedCertificates) UpdateStatus(ctx context.Context, managedCertificate *v1beta2.ManagedCertificate, opts v1.UpdateOptions) (result *v1beta2.ManagedCertificate, err error) { - result = &v1beta2.ManagedCertificate{} - err = c.client.Put(). - Namespace(c.ns). - Resource("managedcertificates"). - Name(managedCertificate.Name). - SubResource("status"). - VersionedParams(&opts, scheme.ParameterCodec). - Body(managedCertificate). - Do(ctx). - Into(result) - return -} - -// Delete takes name of the managedCertificate and deletes it. Returns an error if one occurs. -func (c *managedCertificates) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error { - return c.client.Delete(). - Namespace(c.ns). - Resource("managedcertificates"). - Name(name). - Body(&opts). - Do(ctx). - Error() -} - -// DeleteCollection deletes a collection of objects. -func (c *managedCertificates) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error { - var timeout time.Duration - if listOpts.TimeoutSeconds != nil { - timeout = time.Duration(*listOpts.TimeoutSeconds) * time.Second - } - return c.client.Delete(). - Namespace(c.ns). - Resource("managedcertificates"). - VersionedParams(&listOpts, scheme.ParameterCodec). - Timeout(timeout). - Body(&opts). - Do(ctx). - Error() -} - -// Patch applies the patch and returns the patched managedCertificate. -func (c *managedCertificates) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.ManagedCertificate, err error) { - result = &v1beta2.ManagedCertificate{} - err = c.client.Patch(pt). - Namespace(c.ns). - Resource("managedcertificates"). - Name(name). - SubResource(subresources...). - VersionedParams(&opts, scheme.ParameterCodec). - Body(data). - Do(ctx). - Into(result) - return -} diff --git a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/networking.gke.io_client.go b/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/networking.gke.io_client.go deleted file mode 100644 index fc81687f9..000000000 --- a/pkg/clientgen/clientset/versioned/typed/networking.gke.io/v1beta2/networking.gke.io_client.go +++ /dev/null @@ -1,89 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by client-gen. DO NOT EDIT. - -package v1beta2 - -import ( - v1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - "github.com/minio/console/pkg/clientgen/clientset/versioned/scheme" - rest "k8s.io/client-go/rest" -) - -type NetworkingV1beta2Interface interface { - RESTClient() rest.Interface - ManagedCertificatesGetter -} - -// NetworkingV1beta2Client is used to interact with features provided by the networking.gke.io group. -type NetworkingV1beta2Client struct { - restClient rest.Interface -} - -func (c *NetworkingV1beta2Client) ManagedCertificates(namespace string) ManagedCertificateInterface { - return newManagedCertificates(c, namespace) -} - -// NewForConfig creates a new NetworkingV1beta2Client for the given config. -func NewForConfig(c *rest.Config) (*NetworkingV1beta2Client, error) { - config := *c - if err := setConfigDefaults(&config); err != nil { - return nil, err - } - client, err := rest.RESTClientFor(&config) - if err != nil { - return nil, err - } - return &NetworkingV1beta2Client{client}, nil -} - -// NewForConfigOrDie creates a new NetworkingV1beta2Client for the given config and -// panics if there is an error in the config. -func NewForConfigOrDie(c *rest.Config) *NetworkingV1beta2Client { - client, err := NewForConfig(c) - if err != nil { - panic(err) - } - return client -} - -// New creates a new NetworkingV1beta2Client for the given RESTClient. -func New(c rest.Interface) *NetworkingV1beta2Client { - return &NetworkingV1beta2Client{c} -} - -func setConfigDefaults(config *rest.Config) error { - gv := v1beta2.SchemeGroupVersion - config.GroupVersion = &gv - config.APIPath = "/apis" - config.NegotiatedSerializer = scheme.Codecs.WithoutConversion() - - if config.UserAgent == "" { - config.UserAgent = rest.DefaultKubernetesUserAgent() - } - - return nil -} - -// RESTClient returns a RESTClient that is used to communicate -// with API server by this client implementation. -func (c *NetworkingV1beta2Client) RESTClient() rest.Interface { - if c == nil { - return nil - } - return c.restClient -} diff --git a/pkg/clientgen/informers/externalversions/factory.go b/pkg/clientgen/informers/externalversions/factory.go deleted file mode 100644 index 53be6c316..000000000 --- a/pkg/clientgen/informers/externalversions/factory.go +++ /dev/null @@ -1,180 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package externalversions - -import ( - reflect "reflect" - sync "sync" - time "time" - - versioned "github.com/minio/console/pkg/clientgen/clientset/versioned" - internalinterfaces "github.com/minio/console/pkg/clientgen/informers/externalversions/internalinterfaces" - networkinggkeio "github.com/minio/console/pkg/clientgen/informers/externalversions/networking.gke.io" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - schema "k8s.io/apimachinery/pkg/runtime/schema" - cache "k8s.io/client-go/tools/cache" -) - -// SharedInformerOption defines the functional option type for SharedInformerFactory. -type SharedInformerOption func(*sharedInformerFactory) *sharedInformerFactory - -type sharedInformerFactory struct { - client versioned.Interface - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc - lock sync.Mutex - defaultResync time.Duration - customResync map[reflect.Type]time.Duration - - informers map[reflect.Type]cache.SharedIndexInformer - // startedInformers is used for tracking which informers have been started. - // This allows Start() to be called multiple times safely. - startedInformers map[reflect.Type]bool -} - -// WithCustomResyncConfig sets a custom resync period for the specified informer types. -func WithCustomResyncConfig(resyncConfig map[v1.Object]time.Duration) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - for k, v := range resyncConfig { - factory.customResync[reflect.TypeOf(k)] = v - } - return factory - } -} - -// WithTweakListOptions sets a custom filter on all listers of the configured SharedInformerFactory. -func WithTweakListOptions(tweakListOptions internalinterfaces.TweakListOptionsFunc) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - factory.tweakListOptions = tweakListOptions - return factory - } -} - -// WithNamespace limits the SharedInformerFactory to the specified namespace. -func WithNamespace(namespace string) SharedInformerOption { - return func(factory *sharedInformerFactory) *sharedInformerFactory { - factory.namespace = namespace - return factory - } -} - -// NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces. -func NewSharedInformerFactory(client versioned.Interface, defaultResync time.Duration) SharedInformerFactory { - return NewSharedInformerFactoryWithOptions(client, defaultResync) -} - -// NewFilteredSharedInformerFactory constructs a new instance of sharedInformerFactory. -// Listers obtained via this SharedInformerFactory will be subject to the same filters -// as specified here. -// Deprecated: Please use NewSharedInformerFactoryWithOptions instead -func NewFilteredSharedInformerFactory(client versioned.Interface, defaultResync time.Duration, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) SharedInformerFactory { - return NewSharedInformerFactoryWithOptions(client, defaultResync, WithNamespace(namespace), WithTweakListOptions(tweakListOptions)) -} - -// NewSharedInformerFactoryWithOptions constructs a new instance of a SharedInformerFactory with additional options. -func NewSharedInformerFactoryWithOptions(client versioned.Interface, defaultResync time.Duration, options ...SharedInformerOption) SharedInformerFactory { - factory := &sharedInformerFactory{ - client: client, - namespace: v1.NamespaceAll, - defaultResync: defaultResync, - informers: make(map[reflect.Type]cache.SharedIndexInformer), - startedInformers: make(map[reflect.Type]bool), - customResync: make(map[reflect.Type]time.Duration), - } - - // Apply all options - for _, opt := range options { - factory = opt(factory) - } - - return factory -} - -// Start initializes all requested informers. -func (f *sharedInformerFactory) Start(stopCh <-chan struct{}) { - f.lock.Lock() - defer f.lock.Unlock() - - for informerType, informer := range f.informers { - if !f.startedInformers[informerType] { - go informer.Run(stopCh) - f.startedInformers[informerType] = true - } - } -} - -// WaitForCacheSync waits for all started informers' cache were synced. -func (f *sharedInformerFactory) WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool { - informers := func() map[reflect.Type]cache.SharedIndexInformer { - f.lock.Lock() - defer f.lock.Unlock() - - informers := map[reflect.Type]cache.SharedIndexInformer{} - for informerType, informer := range f.informers { - if f.startedInformers[informerType] { - informers[informerType] = informer - } - } - return informers - }() - - res := map[reflect.Type]bool{} - for informType, informer := range informers { - res[informType] = cache.WaitForCacheSync(stopCh, informer.HasSynced) - } - return res -} - -// InternalInformerFor returns the SharedIndexInformer for obj using an internal -// client. -func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer { - f.lock.Lock() - defer f.lock.Unlock() - - informerType := reflect.TypeOf(obj) - informer, exists := f.informers[informerType] - if exists { - return informer - } - - resyncPeriod, exists := f.customResync[informerType] - if !exists { - resyncPeriod = f.defaultResync - } - - informer = newFunc(f.client, resyncPeriod) - f.informers[informerType] = informer - - return informer -} - -// SharedInformerFactory provides shared informers for resources in all known -// API group versions. -type SharedInformerFactory interface { - internalinterfaces.SharedInformerFactory - ForResource(resource schema.GroupVersionResource) (GenericInformer, error) - WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool - - Networking() networkinggkeio.Interface -} - -func (f *sharedInformerFactory) Networking() networkinggkeio.Interface { - return networkinggkeio.New(f, f.namespace, f.tweakListOptions) -} diff --git a/pkg/clientgen/informers/externalversions/generic.go b/pkg/clientgen/informers/externalversions/generic.go deleted file mode 100644 index ff4aff1cc..000000000 --- a/pkg/clientgen/informers/externalversions/generic.go +++ /dev/null @@ -1,62 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package externalversions - -import ( - "fmt" - - v1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - schema "k8s.io/apimachinery/pkg/runtime/schema" - cache "k8s.io/client-go/tools/cache" -) - -// GenericInformer is type of SharedIndexInformer which will locate and delegate to other -// sharedInformers based on type -type GenericInformer interface { - Informer() cache.SharedIndexInformer - Lister() cache.GenericLister -} - -type genericInformer struct { - informer cache.SharedIndexInformer - resource schema.GroupResource -} - -// Informer returns the SharedIndexInformer. -func (f *genericInformer) Informer() cache.SharedIndexInformer { - return f.informer -} - -// Lister returns the GenericLister. -func (f *genericInformer) Lister() cache.GenericLister { - return cache.NewGenericLister(f.Informer().GetIndexer(), f.resource) -} - -// ForResource gives generic access to a shared informer of the matching type -// TODO extend this to unknown resources with a client pool -func (f *sharedInformerFactory) ForResource(resource schema.GroupVersionResource) (GenericInformer, error) { - switch resource { - // Group=networking.gke.io, Version=v1beta2 - case v1beta2.SchemeGroupVersion.WithResource("managedcertificates"): - return &genericInformer{resource: resource.GroupResource(), informer: f.Networking().V1beta2().ManagedCertificates().Informer()}, nil - - } - - return nil, fmt.Errorf("no informer found for %v", resource) -} diff --git a/pkg/clientgen/informers/externalversions/internalinterfaces/factory_interfaces.go b/pkg/clientgen/informers/externalversions/internalinterfaces/factory_interfaces.go deleted file mode 100644 index 4a543285b..000000000 --- a/pkg/clientgen/informers/externalversions/internalinterfaces/factory_interfaces.go +++ /dev/null @@ -1,40 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package internalinterfaces - -import ( - time "time" - - versioned "github.com/minio/console/pkg/clientgen/clientset/versioned" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - cache "k8s.io/client-go/tools/cache" -) - -// NewInformerFunc takes versioned.Interface and time.Duration to return a SharedIndexInformer. -type NewInformerFunc func(versioned.Interface, time.Duration) cache.SharedIndexInformer - -// SharedInformerFactory a small interface to allow for adding an informer without an import cycle -type SharedInformerFactory interface { - Start(stopCh <-chan struct{}) - InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer -} - -// TweakListOptionsFunc is a function that transforms a v1.ListOptions. -type TweakListOptionsFunc func(*v1.ListOptions) diff --git a/pkg/clientgen/informers/externalversions/networking.gke.io/interface.go b/pkg/clientgen/informers/externalversions/networking.gke.io/interface.go deleted file mode 100644 index 990da18ca..000000000 --- a/pkg/clientgen/informers/externalversions/networking.gke.io/interface.go +++ /dev/null @@ -1,46 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package networking - -import ( - internalinterfaces "github.com/minio/console/pkg/clientgen/informers/externalversions/internalinterfaces" - v1beta2 "github.com/minio/console/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2" -) - -// Interface provides access to each of this group's versions. -type Interface interface { - // V1beta2 provides access to shared informers for resources in V1beta2. - V1beta2() v1beta2.Interface -} - -type group struct { - factory internalinterfaces.SharedInformerFactory - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc -} - -// New returns a new Interface. -func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface { - return &group{factory: f, namespace: namespace, tweakListOptions: tweakListOptions} -} - -// V1beta2 returns a new v1beta2.Interface. -func (g *group) V1beta2() v1beta2.Interface { - return v1beta2.New(g.factory, g.namespace, g.tweakListOptions) -} diff --git a/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/interface.go b/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/interface.go deleted file mode 100644 index 4e7bfd9bf..000000000 --- a/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/interface.go +++ /dev/null @@ -1,45 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package v1beta2 - -import ( - internalinterfaces "github.com/minio/console/pkg/clientgen/informers/externalversions/internalinterfaces" -) - -// Interface provides access to all the informers in this group version. -type Interface interface { - // ManagedCertificates returns a ManagedCertificateInformer. - ManagedCertificates() ManagedCertificateInformer -} - -type version struct { - factory internalinterfaces.SharedInformerFactory - namespace string - tweakListOptions internalinterfaces.TweakListOptionsFunc -} - -// New returns a new Interface. -func New(f internalinterfaces.SharedInformerFactory, namespace string, tweakListOptions internalinterfaces.TweakListOptionsFunc) Interface { - return &version{factory: f, namespace: namespace, tweakListOptions: tweakListOptions} -} - -// ManagedCertificates returns a ManagedCertificateInformer. -func (v *version) ManagedCertificates() ManagedCertificateInformer { - return &managedCertificateInformer{factory: v.factory, namespace: v.namespace, tweakListOptions: v.tweakListOptions} -} diff --git a/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/managedcertificate.go b/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/managedcertificate.go deleted file mode 100644 index ac491d1f1..000000000 --- a/pkg/clientgen/informers/externalversions/networking.gke.io/v1beta2/managedcertificate.go +++ /dev/null @@ -1,90 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by informer-gen. DO NOT EDIT. - -package v1beta2 - -import ( - "context" - time "time" - - networkinggkeiov1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - versioned "github.com/minio/console/pkg/clientgen/clientset/versioned" - internalinterfaces "github.com/minio/console/pkg/clientgen/informers/externalversions/internalinterfaces" - v1beta2 "github.com/minio/console/pkg/clientgen/listers/networking.gke.io/v1beta2" - v1 "k8s.io/apimachinery/pkg/apis/meta/v1" - runtime "k8s.io/apimachinery/pkg/runtime" - watch "k8s.io/apimachinery/pkg/watch" - cache "k8s.io/client-go/tools/cache" -) - -// ManagedCertificateInformer provides access to a shared informer and lister for -// ManagedCertificates. -type ManagedCertificateInformer interface { - Informer() cache.SharedIndexInformer - Lister() v1beta2.ManagedCertificateLister -} - -type managedCertificateInformer struct { - factory internalinterfaces.SharedInformerFactory - tweakListOptions internalinterfaces.TweakListOptionsFunc - namespace string -} - -// NewManagedCertificateInformer constructs a new informer for ManagedCertificate type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewManagedCertificateInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer { - return NewFilteredManagedCertificateInformer(client, namespace, resyncPeriod, indexers, nil) -} - -// NewFilteredManagedCertificateInformer constructs a new informer for ManagedCertificate type. -// Always prefer using an informer factory to get a shared informer instead of getting an independent -// one. This reduces memory footprint and number of connections to the server. -func NewFilteredManagedCertificateInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers, tweakListOptions internalinterfaces.TweakListOptionsFunc) cache.SharedIndexInformer { - return cache.NewSharedIndexInformer( - &cache.ListWatch{ - ListFunc: func(options v1.ListOptions) (runtime.Object, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.NetworkingV1beta2().ManagedCertificates(namespace).List(context.TODO(), options) - }, - WatchFunc: func(options v1.ListOptions) (watch.Interface, error) { - if tweakListOptions != nil { - tweakListOptions(&options) - } - return client.NetworkingV1beta2().ManagedCertificates(namespace).Watch(context.TODO(), options) - }, - }, - &networkinggkeiov1beta2.ManagedCertificate{}, - resyncPeriod, - indexers, - ) -} - -func (f *managedCertificateInformer) defaultInformer(client versioned.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { - return NewFilteredManagedCertificateInformer(client, f.namespace, resyncPeriod, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}, f.tweakListOptions) -} - -func (f *managedCertificateInformer) Informer() cache.SharedIndexInformer { - return f.factory.InformerFor(&networkinggkeiov1beta2.ManagedCertificate{}, f.defaultInformer) -} - -func (f *managedCertificateInformer) Lister() v1beta2.ManagedCertificateLister { - return v1beta2.NewManagedCertificateLister(f.Informer().GetIndexer()) -} diff --git a/pkg/clientgen/listers/networking.gke.io/v1beta2/expansion_generated.go b/pkg/clientgen/listers/networking.gke.io/v1beta2/expansion_generated.go deleted file mode 100644 index 18d5901b5..000000000 --- a/pkg/clientgen/listers/networking.gke.io/v1beta2/expansion_generated.go +++ /dev/null @@ -1,27 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by lister-gen. DO NOT EDIT. - -package v1beta2 - -// ManagedCertificateListerExpansion allows custom methods to be added to -// ManagedCertificateLister. -type ManagedCertificateListerExpansion interface{} - -// ManagedCertificateNamespaceListerExpansion allows custom methods to be added to -// ManagedCertificateNamespaceLister. -type ManagedCertificateNamespaceListerExpansion interface{} diff --git a/pkg/clientgen/listers/networking.gke.io/v1beta2/managedcertificate.go b/pkg/clientgen/listers/networking.gke.io/v1beta2/managedcertificate.go deleted file mode 100644 index 22649085f..000000000 --- a/pkg/clientgen/listers/networking.gke.io/v1beta2/managedcertificate.go +++ /dev/null @@ -1,94 +0,0 @@ -/* -Copyright 2020 Google LLC - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - https://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -// Code generated by lister-gen. DO NOT EDIT. - -package v1beta2 - -import ( - v1beta2 "github.com/minio/console/pkg/apis/networking.gke.io/v1beta2" - "k8s.io/apimachinery/pkg/api/errors" - "k8s.io/apimachinery/pkg/labels" - "k8s.io/client-go/tools/cache" -) - -// ManagedCertificateLister helps list ManagedCertificates. -type ManagedCertificateLister interface { - // List lists all ManagedCertificates in the indexer. - List(selector labels.Selector) (ret []*v1beta2.ManagedCertificate, err error) - // ManagedCertificates returns an object that can list and get ManagedCertificates. - ManagedCertificates(namespace string) ManagedCertificateNamespaceLister - ManagedCertificateListerExpansion -} - -// managedCertificateLister implements the ManagedCertificateLister interface. -type managedCertificateLister struct { - indexer cache.Indexer -} - -// NewManagedCertificateLister returns a new ManagedCertificateLister. -func NewManagedCertificateLister(indexer cache.Indexer) ManagedCertificateLister { - return &managedCertificateLister{indexer: indexer} -} - -// List lists all ManagedCertificates in the indexer. -func (s *managedCertificateLister) List(selector labels.Selector) (ret []*v1beta2.ManagedCertificate, err error) { - err = cache.ListAll(s.indexer, selector, func(m interface{}) { - ret = append(ret, m.(*v1beta2.ManagedCertificate)) - }) - return ret, err -} - -// ManagedCertificates returns an object that can list and get ManagedCertificates. -func (s *managedCertificateLister) ManagedCertificates(namespace string) ManagedCertificateNamespaceLister { - return managedCertificateNamespaceLister{indexer: s.indexer, namespace: namespace} -} - -// ManagedCertificateNamespaceLister helps list and get ManagedCertificates. -type ManagedCertificateNamespaceLister interface { - // List lists all ManagedCertificates in the indexer for a given namespace. - List(selector labels.Selector) (ret []*v1beta2.ManagedCertificate, err error) - // Get retrieves the ManagedCertificate from the indexer for a given namespace and name. - Get(name string) (*v1beta2.ManagedCertificate, error) - ManagedCertificateNamespaceListerExpansion -} - -// managedCertificateNamespaceLister implements the ManagedCertificateNamespaceLister -// interface. -type managedCertificateNamespaceLister struct { - indexer cache.Indexer - namespace string -} - -// List lists all ManagedCertificates in the indexer for a given namespace. -func (s managedCertificateNamespaceLister) List(selector labels.Selector) (ret []*v1beta2.ManagedCertificate, err error) { - err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) { - ret = append(ret, m.(*v1beta2.ManagedCertificate)) - }) - return ret, err -} - -// Get retrieves the ManagedCertificate from the indexer for a given namespace and name. -func (s managedCertificateNamespaceLister) Get(name string) (*v1beta2.ManagedCertificate, error) { - obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name) - if err != nil { - return nil, err - } - if !exists { - return nil, errors.NewNotFound(v1beta2.Resource("managedcertificate"), name) - } - return obj.(*v1beta2.ManagedCertificate), nil -} diff --git a/pkg/logger/config/config.go b/pkg/logger/config/config.go index 4d5264c62..3aa0f3fe5 100644 --- a/pkg/logger/config/config.go +++ b/pkg/logger/config/config.go @@ -23,8 +23,6 @@ import ( // Default keys const ( Default = madmin.Default - Enable = madmin.EnableKey - License = "license" // Deprecated Dec 2021 ) // Top level config constants. diff --git a/pkg/logger/console.go b/pkg/logger/console.go index ee9c44caf..7b522f514 100644 --- a/pkg/logger/console.go +++ b/pkg/logger/console.go @@ -28,9 +28,6 @@ import ( c "github.com/minio/pkg/console" ) -// ConsoleLoggerTgt is a stringified value to represent console logging -const ConsoleLoggerTgt = "console+http" - // Logger interface describes the methods that need to be implemented to satisfy the interface requirements. type Logger interface { json(msg string, args ...interface{}) diff --git a/pkg/logger/logger.go b/pkg/logger/logger.go index f53c4f449..961d1ecc5 100644 --- a/pkg/logger/logger.go +++ b/pkg/logger/logger.go @@ -60,9 +60,6 @@ const ( var trimStrings []string -// TimeFormat - logging time format. -const TimeFormat string = "15:04:05 MST 01/02/2006" - var matchingFuncNames = [...]string{ "http.HandlerFunc.ServeHTTP", "cmd.serverMain", @@ -254,8 +251,6 @@ type Kind string const ( // Minio errors Minio Kind = "CONSOLE" - // Application errors - Application Kind = "APPLICATION" // All errors All Kind = "ALL" ) diff --git a/restapi/admin_config_test.go b/restapi/admin_config_test.go index 403e9fc3e..d4e603c72 100644 --- a/restapi/admin_config_test.go +++ b/restapi/admin_config_test.go @@ -32,18 +32,12 @@ import ( ) const ( - NotifyPostgresSubSys = "notify_postgres" - PostgresFormat = "format" - PostgresConnectionString = "connection_string" - PostgresTable = "table" - PostgresHost = "host" - PostgresPort = "port" - PostgresUsername = "username" - PostgresPassword = "password" - PostgresDatabase = "database" - PostgresQueueDir = "queue_dir" - PostgresQueueLimit = "queue_limit" - PostgresMaxOpenConnections = "max_open_connections" + NotifyPostgresSubSys = "notify_postgres" + PostgresFormat = "format" + PostgresConnectionString = "connection_string" + PostgresTable = "table" + PostgresQueueDir = "queue_dir" + PostgresQueueLimit = "queue_limit" ) // assigning mock at runtime instead of compile time