kubekey/pkg/proxy/api_resources.go
liujian 348c9b2d15
feat: enhance precheck tasks for image registry and network validation (#2676)
* feat: enhance precheck tasks for image registry and network validation

- Added a task to ensure successful authentication to the image registry.
- Updated existing tasks to provide clearer failure messages for required configurations.
- Improved validation for network interfaces and CIDR configurations, ensuring dual-stack support.
- Enhanced error handling in the resource handler for playbook creation.

Signed-off-by: joyceliu <joyceliu@yunify.com>

* feat: enhance configuration and query handling

- Added `-trimpath` flag to Go build configuration for improved binary paths.
- Updated REST configuration to set QPS and Burst limits for better performance.
- Refactored query handling to use string types for field and value, improving type consistency.
- Enhanced error handling in resource configuration updates and improved parsing of request bodies.

Signed-off-by: joyceliu <joyceliu@yunify.com>

* feat: check inventory when it's changed

Signed-off-by: joyceliu <joyceliu@yunify.com>

* feat: enhance playbook execution and query handling

- Added a new optional query parameter `promise` to the playbook and inventory endpoints, allowing for asynchronous execution control.
- Introduced a new result state `ResultPending` to indicate ongoing operations.
- Refactored the executor function to handle the `promise` parameter, enabling conditional execution of playbooks.
- Improved error handling and logging during playbook execution.

Signed-off-by: joyceliu <joyceliu@yunify.com>

---------

Signed-off-by: joyceliu <joyceliu@yunify.com>
2025-08-04 15:27:22 +08:00

173 lines
5.4 KiB
Go

/*
Copyright 2024 The KubeSphere Authors.
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
http://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 proxy
import (
"net/http"
"reflect"
"strings"
"time"
"github.com/cockroachdb/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apiserver/pkg/admission"
"k8s.io/apiserver/pkg/endpoints/discovery"
"k8s.io/apiserver/pkg/endpoints/handlers/negotiation"
"k8s.io/apiserver/pkg/endpoints/handlers/responsewriters"
"k8s.io/apiserver/pkg/features"
apirest "k8s.io/apiserver/pkg/registry/rest"
utilfeature "k8s.io/apiserver/pkg/util/feature"
_const "github.com/kubesphere/kubekey/v4/pkg/const"
)
const defaultMinRequestTimeout = 1800 * time.Second
type apiResources struct {
gv schema.GroupVersion
prefix string
minRequestTimeout time.Duration
resourceOptions []resourceOptions
list []metav1.APIResource
typer runtime.ObjectTyper
serializer runtime.NegotiatedSerializer
}
type resourceOptions struct {
path string
resource string // generate by path
subresource string // generate by path
resourcePath string // generate by path
itemPath string // generate by path
storage apirest.Storage
admit admission.Interface
}
func (o *resourceOptions) init() error {
// prefix for resourcePath.
var prefix string
scoper, ok := o.storage.(apirest.Scoper)
if !ok {
return errors.Errorf("%q must implement scoper", o.path)
}
if scoper.NamespaceScoped() {
prefix = "/namespaces/{namespace}/"
} else {
prefix = "/"
}
// checks if the given storage path is the path of a subresource
switch parts := strings.Split(o.path, "/"); len(parts) {
case 2:
o.resource, o.subresource = parts[0], parts[1]
o.resourcePath = prefix + o.resource + "/{name}/" + o.subresource
o.itemPath = prefix + o.resource + "/{name}/" + o.subresource
case 1:
o.resource = parts[0]
o.resourcePath = prefix + o.resource
o.itemPath = prefix + o.resource + "/{name}"
default:
return errors.New("api_installer allows only one or two segment paths (resource or resource/subresource)")
}
if o.admit == nil {
// set default admit
o.admit = newAlwaysAdmit()
}
return nil
}
func newAPIIResources(gv schema.GroupVersion) *apiResources {
return &apiResources{
gv: gv,
prefix: "/apis/" + gv.String(),
minRequestTimeout: defaultMinRequestTimeout,
typer: _const.Scheme,
serializer: _const.CodecFactory,
}
}
// AddResource add a api-resources
func (r *apiResources) AddResource(o resourceOptions) error {
if err := o.init(); err != nil {
return err
}
r.resourceOptions = append(r.resourceOptions, o)
storageVersionProvider, isStorageVersionProvider := o.storage.(apirest.StorageVersionProvider)
var apiResource metav1.APIResource
if isStorageVersionProvider &&
utilfeature.DefaultFeatureGate.Enabled(features.StorageVersionHash) &&
storageVersionProvider.StorageVersion() != nil {
versioner := storageVersionProvider.StorageVersion()
gvk, err := getStorageVersionKind(versioner, o.storage, r.typer)
if err != nil {
return err
}
apiResource.Group = gvk.Group
apiResource.Version = gvk.Version
apiResource.Kind = gvk.Kind
apiResource.StorageVersionHash = discovery.StorageVersionHash(gvk.Group, gvk.Version, gvk.Kind)
}
apiResource.Name = o.path
apiResource.Namespaced = true
apiResource.Verbs = []string{"*"}
if shortNamesProvider, ok := o.storage.(apirest.ShortNamesProvider); ok {
apiResource.ShortNames = shortNamesProvider.ShortNames()
}
if categoriesProvider, ok := o.storage.(apirest.CategoriesProvider); ok {
apiResource.Categories = categoriesProvider.Categories()
}
if o.subresource == "" {
singularNameProvider, ok := o.storage.(apirest.SingularNameProvider)
if !ok {
return errors.Errorf("resource %s must implement SingularNameProvider", o.path)
}
apiResource.SingularName = singularNameProvider.GetSingularName()
}
r.list = append(r.list, apiResource)
return nil
}
func (r *apiResources) handlerAPIResources() http.HandlerFunc {
return func(writer http.ResponseWriter, request *http.Request) {
responsewriters.WriteObjectNegotiated(r.serializer, negotiation.DefaultEndpointRestrictions, schema.GroupVersion{}, writer, request, http.StatusOK,
&metav1.APIResourceList{GroupVersion: r.gv.String(), APIResources: r.list}, false)
}
}
// calculate the storage gvk, the gvk objects are converted to before persisted to the etcd.
func getStorageVersionKind(storageVersioner runtime.GroupVersioner, storage apirest.Storage, typer runtime.ObjectTyper) (schema.GroupVersionKind, error) {
object := storage.New()
fqKinds, _, err := typer.ObjectKinds(object)
if err != nil {
return schema.GroupVersionKind{}, errors.Wrap(err, "failed to get object kind")
}
gvk, ok := storageVersioner.KindForGroupVersionKinds(fqKinds)
if !ok {
return schema.GroupVersionKind{}, errors.Errorf("failed to find the storage version kind for %v", reflect.TypeOf(object))
}
return gvk, nil
}