INNER CODE UNIT · Go

staticCrdChecker

kubermatic/kubermatic · cmd/http-prober/main.go:216

func staticCrdChecker(group, version, resource, namespace string, cfg *rest.Config) func() error {
	return func() error {
		client, err := dynamic.NewForConfig(cfg)
		if err != nil {
			return fmt.Errorf("failed to create kube client: %w", err)
		}

		gvr := schema.GroupVersionResource{
			Group:    group,
			Version:  version,
			Resource: resource,
		}

		listOpts := metav1.ListOptions{Limit: 1}

		if _, err := client.Resource(gvr).Namespace(namespace).List(context.Background(), listOpts); err != nil {
			return fmt.Errorf("failed to list %s/%s.%s %s: %w", namespace, group, version, resource, err)
		}

View source record →