Add the examples to demo listing/creating pods

2020-03-19 09:56:19 +08:00
parent 781aa24a97
commit cf3729b611
4 changed files with 245 additions and 0 deletions
--- a/examples/list_pod/main.c
+++ b/examples/list_pod/main.c
@@ -0,0 +1,111 @@
+#include <apiClient.h>
+#include <CoreV1API.h>
+#include <malloc.h>
+#include <stdio.h>
+#include <errno.h>
+
+#define K8S_APISERVER_BASEPATH "https://9.111.254.254:6443"
+#define K8S_TOKEN_FILE_IN_CLUSTER "/var/run/secrets/kubernetes.io/serviceaccount/token"
+#define K8S_TOKEN_BUF_SIZE 1024
+#define K8S_AUTH_KEY "Authorization"
+#define K8S_AUTH_VALUE_TEMPLATE "Bearer %s"
+
+apiClient_t *g_k8sAPIConnector;
+
+void list_pod(apiClient_t *apiClient)
+{
+    v1_pod_list_t *pod_list = NULL;
+    pod_list = CoreV1API_listNamespacedPod( apiClient ,
+                                            "default", /*namespace*/
+                                            NULL, /* pretty */
+                                            0, /* allowWatchBookmarks */
+                                            NULL, /* continue */
+                                            NULL, /* fieldSelector */
+                                            NULL, /* labelSelector */
+                                            0, /* limit */
+                                            NULL, /* resourceVersion */
+                                            0, /* timeoutSeconds */
+                                            0 /* watch */
+                    );
+    printf("return code=%ld\n", apiClient->response_code);
+    if(pod_list){
+        printf("Get pod list.\n");
+        listEntry_t *listEntry = NULL;
+        v1_pod_t *pod = NULL;
+        list_ForEach(listEntry, pod_list->items){
+            pod = listEntry->data;
+            printf("pod name=%s\n", pod->metadata->name);
+        }
+
+    }else{
+        printf("Cannot list any pod.\n");
+    }
+}
+
+int
+loadK8sConfigInCluster(char *token, int token_buf_size)
+{
+    static char fname[] = "loadK8sConfigInCluster()";
+
+    FILE *fp;
+    fp = fopen(K8S_TOKEN_FILE_IN_CLUSTER, "r");
+
+    if (fp == NULL) {
+        if (errno == ENOENT) {
+            printf("\
+%s: The file %s does not exist.",
+fname, K8S_TOKEN_FILE_IN_CLUSTER);
+            return (-1);
+        } else {
+            printf("\
+%s: Failed to open file %s (%m).",
+fname, K8S_TOKEN_FILE_IN_CLUSTER);
+            return (-1);
+        }
+    }
+
+    while (fgets(token, token_buf_size, fp) != NULL) {
+        ;
+    }
+
+    printf("%s\n", token);
+
+    fclose(fp);
+
+    return 0;
+}
+
+int
+init_k8s_connector(const char *token_out_of_cluster)
+{
+    list_t *apiKeys;
+    apiKeys = list_create();
+
+    char *keyToken = strdup(K8S_AUTH_KEY);
+    char token_in_cluster[K8S_TOKEN_BUF_SIZE];
+    memset(token_in_cluster, 0, sizeof(token_in_cluster));
+
+    //loadK8sConfigInCluster(token_in_cluster, K8S_TOKEN_BUF_SIZE); // in cluster
+
+    char valueToken[K8S_TOKEN_BUF_SIZE];
+    memset(valueToken, 0, sizeof(valueToken));
+    //sprintf(valueToken, K8S_AUTH_VALUE_TEMPLATE, token); // in cluster
+    
+    sprintf(valueToken, K8S_AUTH_VALUE_TEMPLATE, token_out_of_cluster); // out of cluster
+
+    keyValuePair_t *keyPairToken = keyValuePair_create(keyToken, valueToken);
+    list_addElement(apiKeys, keyPairToken);
+
+    g_k8sAPIConnector = apiClient_create_with_base_path(K8S_APISERVER_BASEPATH, NULL, apiKeys);
+}
+
+int main(int argc, char *argv[])
+{
+
+    init_k8s_connector(argv[1]);
+
+    list_pod(g_k8sAPIConnector);
+
+    apiClient_free(g_k8sAPIConnector);
+}
+