Add an example to list events

Author: ityuhui

examples/Makefile

@@ -11,6 +11,7 @@ all:
 	cd exec_pod; make
 	cd list_secret; make
 	cd configmap; make
+	cd list_event; make
 
 clean:
 	cd create_pod; make clean
@@ -25,6 +26,7 @@ clean:
 	cd exec_pod; make clean
 	cd list_secret; make clean
 	cd configmap; make clean
+	cd list_event; make clean
 
 test:
 	cd create_pod; make test;
@@ -34,6 +36,7 @@ test:
 	kubectl wait --for=delete pod/test-pod-6 -n default --timeout=120s
 	cd list_secret; make test
 	cd configmap; make test
+	cd list_event; make test
 	cd generic; make test
 	cd multi_thread; make test;
 	kubectl wait --for=condition=ready pod/test-pod-8 -n default --timeout=60s
@@ -48,6 +51,7 @@ memcheck:
 	kubectl wait --for=delete pod/test-pod-6 -n default --timeout=120s
 	cd list_secret; make memcheck
 	cd configmap; make memcheck
+	cd list_event; make test
 	cd generic; make memcheck
 	cd multi_thread; make memcheck;
 	kubectl wait --for=condition=ready pod/test-pod-8 -n default --timeout=60s

examples/list_event/.gitignore

@@ -0,0 +1 @@
+list_event_bin

examples/list_event/Makefile

@@ -0,0 +1,17 @@
+INCLUDE:=-I../../kubernetes/
+LIBS:=-L../../kubernetes/build -lyaml -lwebsockets -lkubernetes -L/usr/local/lib
+CFLAGS:=-g
+BIN:=list_event_bin
+
+.PHONY : all clean test memcheck
+all:
+	gcc main.c $(CFLAGS) $(INCLUDE) $(LIBS) -o $(BIN)
+
+test:
+	./$(BIN)
+
+memcheck:
+	valgrind --tool=memcheck --leak-check=full ./$(BIN)
+
+clean:
+	rm ./$(BIN)

examples/list_event/main.c

@@ -0,0 +1,76 @@
+#include <config/kube_config.h>
+#include <api/CoreV1API.h>
+#include <stdio.h>
+
+#include <config/kube_config.h>
+#include <api/CoreV1API.h>
+#include <stdio.h>
+
+void list_event(apiClient_t * apiClient)
+{
+    core_v1_event_list_t *event_list = CoreV1API_listNamespacedEvent(apiClient, "default",  /*namespace */
+                                                                     "true",    /* pretty */
+                                                                     0, /* allowWatchBookmarks */
+                                                                     NULL,  /* continue */
+                                                                     NULL,  /* fieldSelector */
+                                                                     NULL,  /* labelSelector */
+                                                                     0, /* limit */
+                                                                     NULL,  /* resourceVersion */
+                                                                     NULL,  /* resourceVersionMatch */
+                                                                     0, /* timeoutSeconds */
+                                                                     0  /* watch */
+        );
+    printf("The return code of HTTP request=%ld\n", apiClient->response_code);
+    if (event_list) {
+        if (event_list->items) {
+            listEntry_t *listEntry = NULL;
+            core_v1_event_t *event = NULL;
+            list_ForEach(listEntry, event_list->items) {
+                event = listEntry->data;
+                if (event) {
+                    if (event->type) {
+                        printf("Event Type: %s\n", event->type);
+                    }
+                    if (event->message) {
+                        printf("Event Message: %s\n", event->message);
+                    }
+                }
+            }
+        } else {
+            fprintf(stderr, "There are no events in event list.\n");
+        }
+        core_v1_event_list_free(event_list);
+        event_list = NULL;
+    } else {
+        fprintf(stderr, "Cannot get event list.\n");
+    }
+}
+
+int main()
+{
+    char *basePath = NULL;
+    sslConfig_t *sslConfig = NULL;
+    list_t *apiKeys = NULL;
+    int rc = load_kube_config(&basePath, &sslConfig, &apiKeys, NULL);   /* NULL means loading configuration from $HOME/.kube/config */
+    if (rc != 0) {
+        fprintf(stderr, "Cannot load kubernetes configuration.\n");
+        return -1;
+    }
+    apiClient_t *apiClient = apiClient_create_with_base_path(basePath, sslConfig, apiKeys);
+    if (!apiClient) {
+        fprintf(stderr, "Cannot create a kubernetes client.\n");
+        return -1;
+    }
+
+    list_event(apiClient);
+
+    apiClient_free(apiClient);
+    apiClient = NULL;
+    free_client_config(basePath, sslConfig, apiKeys);
+    basePath = NULL;
+    sslConfig = NULL;
+    apiKeys = NULL;
+    apiClient_unsetupGlobalEnv();
+
+    return 0;
+}