0

我正在研究基于 CRD 自动创建命名空间、标签、注释的 Kubernetes 运算符。

我被fabric8io-kubernetes-client未公开的特定openshift对象ClusterResourceQuota （quota.openshift.io/v1）卡住了。

即使从文件加载，是否有任何替代方法可以创建此类对象...？

4

1 回答 1

3

我来自 Fabric8 团队。Fabric8 Kubernetes Client 支持两种方式创建自定义对象：

  • 类型化 API（需要提供自定义资源模型（POJO））
  • 无类型 API（将自定义资源作为普通 HashMap 处理）

类型化 API：

假设您已经拥有ClusterResourceQuota和的 POJO ClusterResourceQuotaList。您可以像这样为该特定自定义资源创建一个 kubernetes 客户端实例，并将其用于您的自定义资源操作：

try (KubernetesClient client = new DefaultKubernetesClient()) {
    // Create ClusterResourceQuota object
    ClusterResourceQuota clusterResourceQuota = getClusterResourceQuota();

    // ClusterResourceQuota Client
    MixedOperation<ClusterResourceQuota, ClusterResourceQuotaList, DoneableClusterResourceQuota, Resource<ClusterResourceQuota, DoneableClusterResourceQuota>> clusterResourceQuotaClient = null;
    CustomResourceDefinitionContext context = new CustomResourceDefinitionContext
            .Builder()
            .withGroup("quota.openshift.io")
            .withKind("ClusterResourceQuota")
            .withName("clusterresourcequota-crd")
            .withPlural("clusterresourcequotas")
            .withScope("Namespaced")
            .withVersion("v1")
            .build();

    // Initializing ClusterResourceQuota Client, POJOs to be provided
    clusterResourceQuotaClient = client.customResources(context, ClusterResourceQuota.class, ClusterResourceQuotaList.class, DoneableClusterResourceQuota.class);
    // Using ClusterResourceQuota Client to create ClusterResourceQuota resource
    clusterResourceQuotaClient.inNamespace("default").createOrReplace(clusterResourceQuota);
}

无类型 API

如果你没有 POJO，你可以使用 Fabric8 Kubernetes Client 的 Raw API 来处理自定义资源。以下是您的操作方法：

try (KubernetesClient client = new DefaultKubernetesClient()) {
    // Create Custom Resource Context
    CustomResourceDefinitionContext context = new CustomResourceDefinitionContext
            .Builder()
            .withGroup("quota.openshift.io")
            .withKind("ClusterResourceQuota")
            .withName("clusterresourcequota-crd")
            .withPlural("clusterresourcequotas")
            .withScope("Namespaced")
            .withVersion("v1")
            .build();

    // Load from Yaml
    Map<String, Object> clusterResourceQuota = client.customResource(context)
            .load(CustomResourceCreateDemoTypeless.class.getResourceAsStream("/clusterquota-cr.yml"));
    // Create Custom Resource
    client.customResource(context).create("default", clusterResourceQuota);
} catch (IOException e) {
    e.printStackTrace();
}

您还可以查看这些博客，详细了解有类型和无类型方法。

于 2020-08-06T15:10:36.733 回答