version 6.3.1 and Custom Resource Definitions

[lirany1]

it seems that in version 6.3.1 of the fabric8-kubernetes-client library, it does not provide a direct way to interact with Custom Resource Definitions (CRDs)

i tried some of those options to list my CRD and nothing work :(

import io.fabric8.kubernetes.client.DefaultKubernetesClient
import io.fabric8.kubernetes.client.dsl.base.OperationSupport
import io.fabric8.kubernetes.client.utils.Serialization

fun main() {
    val client = DefaultKubernetesClient()
    val request = client.getClient().getHttpClient().newRequest("/apis/apiextensions.k8s.io/v1/customresourcedefinitions")
    request.method("GET")
    val response = request.send()
    val crdList = Serialization.unmarshal(response.getContent(), CustomResourceDefinitionList::class.java)
    for (crd in crdList.items) {
        println(crd.metadata.name)
    }
    client.close()
}

import io.fabric8.kubernetes.client.dsl.CoreV1Api
import io.fabric8.kubernetes.client.DefaultKubernetesClient

fun main() {
    val client = DefaultKubernetesClient()
    val crdApi = CoreV1Api(client)
    val crdList = crdApi.listCustomResourceDefinition()
    for (crd in crdList.items) {
        println(crd.metadata.name)
    }
    client.close()
}

import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition
import io.fabric8.kubernetes.client.dsl.CustomResourceApi
import io.fabric8.kubernetes.client.DefaultKubernetesClient

fun main() {
    val client = DefaultKubernetesClient()
    val crdApi: CustomResourceApi<CustomResourceDefinition> = client.customResources(CustomResourceDefinition.class, CustomResourceDefinition.class, "apiextensions.k8s.io", "v1", "customresourcedefinitions")
    val crdList = crdApi.list()
    for (crd in crdList.items) {
        println(crd.metadata.name)
    }
    client.close()
}

import io.fabric8.kubernetes.client.dsl.MixedOperation
import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinition
import io.fabric8.kubernetes.client.DefaultKubernetesClient

fun main() {
    val client = DefaultKubernetesClient()
    val crdClient: MixedOperation<CustomResourceDefinition, CustomResourceDefinitionList, DoneableCustomResourceDefinition, Resource<CustomResourceDefinition, DoneableCustomResourceDefinition>> = client.customResourceDefinitions()
    val crdList = crdClient.list()
    for (crd in crdList.items) {
        println(crd.metadata.name)
    }
    client.close()
}

import io.fabric8.kubernetes.client.CustomResourceDefinitionClient
import io.fabric8.kubernetes.client.DefaultKubernetesClient

fun main() {
    val client = DefaultKubernetesClient()
    val crdClient = CustomResourceDefinitionClient(client)
    val crdList = crdClient.list()
    for (crd in crdList.items) {
        println(crd.metadata.name)
    }
    client.close()
}

[shawkins]

KubernetesClient client = new KuberentesClientBuilder().build();

// this the main entry point for the fully type api
client.apiextensions().v1().customResourceDefinitions() 

// or you can just use the Resource api as there aren't any additional methods offered by customResourceDefinitions()
client.resources(CustomResourceDefintion.class) 

[lirany1]

@shawkins thanks one more thing
if i have a CRD called "peers.dr.test.com"
and i have the command kubectl get peer
how can i interact with the output of this kubectl get command?

[shawkins]

You do that as either typed (create Java classes representing you custom resource) or untyped, which the fabric8 client also calls generic.

See the java generator if you want to go the typed route.

For untyped you use the entry point:

client.genericKubernetesResources("dr.test.com/v1", "peers")