mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-06 02:34:03 +00:00
KCM: CTB publisher: tolerate NotFound during discovery
This commit is contained in:
parent
24e8fa769b
commit
c36b1c901f
@ -25,6 +25,7 @@ import (
|
|||||||
|
|
||||||
certificatesv1alpha1 "k8s.io/api/certificates/v1alpha1"
|
certificatesv1alpha1 "k8s.io/api/certificates/v1alpha1"
|
||||||
certificatesv1beta1 "k8s.io/api/certificates/v1beta1"
|
certificatesv1beta1 "k8s.io/api/certificates/v1beta1"
|
||||||
|
"k8s.io/apimachinery/pkg/api/errors"
|
||||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||||
"k8s.io/apiserver/pkg/server/dynamiccertificates"
|
"k8s.io/apiserver/pkg/server/dynamiccertificates"
|
||||||
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
utilfeature "k8s.io/apiserver/pkg/util/feature"
|
||||||
@ -291,6 +292,9 @@ func newKubeAPIServerSignerClusterTrustBundledPublisherController(ctx context.Co
|
|||||||
|
|
||||||
func clusterTrustBundlesAvailable(client kubernetes.Interface, schemaVersion schema.GroupVersion) (bool, error) {
|
func clusterTrustBundlesAvailable(client kubernetes.Interface, schemaVersion schema.GroupVersion) (bool, error) {
|
||||||
resList, err := client.Discovery().ServerResourcesForGroupVersion(schemaVersion.String())
|
resList, err := client.Discovery().ServerResourcesForGroupVersion(schemaVersion.String())
|
||||||
|
if errors.IsNotFound(err) {
|
||||||
|
return false, nil
|
||||||
|
}
|
||||||
|
|
||||||
if resList != nil {
|
if resList != nil {
|
||||||
// even in case of an error above there might be a partial list for APIs that
|
// even in case of an error above there might be a partial list for APIs that
|
||||||
|
Loading…
Reference in New Issue
Block a user