How to watch all events

[OscartGiles]

How can I watch all events (i.e. equivalent of kubectl get events --all-namespaces --watch)?

I have the following, but it only gets a single event, while the kubectl command gives me 7.

var watcher = _client.EventsV1.ListEventForAllNamespacesWithHttpMessagesAsync(watch: true, timeoutSeconds: 30);

await foreach (var (type, item) in watcher.WatchAsync<Eventsv1Event, Eventsv1EventList>())
{
    Console.WriteLine(JsonSerializer.Serialize(item, new JsonSerializerOptions { WriteIndented = true }));
}

Many thanks

[tg123]

theoretically they should be the same. any example of missing events

[OscartGiles]

I just made a quick example:

First I have a cluster created with kind:

kind create  cluster --name kind-test

Then I run this as a test:

   async public void ExampleEvents()
    {
        var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(kubeconfigPath: null, "kind-kind-test", null, true);
        var client = new Kubernetes(config);

        // Create a new namespace
        var ns = new V1Namespace { Metadata = new V1ObjectMeta { Name = "test-namespace" } };
        var result = client.CoreV1.CreateNamespace(ns);

        Thread.Sleep(6000);

        // Create a new job
        var job = new V1Job()
        {
            ApiVersion = "batch/v1",
            Kind = V1Job.KubeKind,
            Metadata = new V1ObjectMeta()
            {
                Name = "test",
                NamespaceProperty = "test-namespace"

            },
            Spec = new V1JobSpec()
            {
                Template = new V1PodTemplateSpec()
                {
                    Spec = new V1PodSpec()
                    {
                        Containers = new List<V1Container>()
                        {
                            new V1Container() {
                                Image = "ubuntu:latest",
                                Name = "test",
                                Command = new List<string> () {},
                                Args = new List<string>() {},
                            }
                        },
                        RestartPolicy = "Never"
                    }
                }
            }
        };


        await client.BatchV1.CreateNamespacedJobAsync(job, "test-namespace");


        // Watch for events
        var watcher = client.EventsV1.ListEventForAllNamespacesWithHttpMessagesAsync(watch: true, timeoutSeconds: 30);

        await foreach (var (type, item) in watcher.WatchAsync<Eventsv1Event, Eventsv1EventList>())
        {
            Console.WriteLine(JsonSerializer.Serialize(item, new JsonSerializerOptions { WriteIndented = true }));
        }

    }

What I expected:

This command:

kubectl get events --all-namespaces --watch

gives:

NAMESPACE        LAST SEEN   TYPE     REASON             OBJECT     MESSAGE
test-namespace   0s          Normal   SuccessfulCreate   job/test   Created pod: test-pnf4t
test-namespace   0s          Normal   Scheduled          pod/test-pnf4t   Successfully assigned test-namespace/test-pnf4t to kind-test-control-plane
test-namespace   0s          Normal   Pulling            pod/test-pnf4t   Pulling image "ubuntu:latest"
test-namespace   0s          Normal   Pulled             pod/test-pnf4t   Successfully pulled image "ubuntu:latest" in 1.030761709s
test-namespace   0s          Normal   Created            pod/test-pnf4t   Created container test
test-namespace   0s          Normal   Started            pod/test-pnf4t   Started container test
test-namespace   0s          Normal   Completed          job/test         Job completed

What I get

I seem to only get one event back:

{
  "action": "Binding",
  "apiVersion": "events.k8s.io/v1",
  "deprecatedCount": null,
  "deprecatedFirstTimestamp": null,
  "deprecatedLastTimestamp": null,
  "deprecatedSource": {
    "component": null,
    "host": null
  },
  "eventTime": "2022-11-23T19:43:44.92574Z",
  "kind": "Event",
  "metadata": {
    "annotations": null,
    "creationTimestamp": "2022-11-23T19:43:44Z",
    "deletionGracePeriodSeconds": null,
    "deletionTimestamp": null,
    "finalizers": null,
    "generateName": null,
    "generation": null,
    "labels": null,
    "managedFields": [
      {
        "apiVersion": "events.k8s.io/v1",
        "fieldsType": "FieldsV1",
        "fieldsV1": {
          "f:action": {},
          "f:eventTime": {},
          "f:note": {},
          "f:reason": {},
          "f:regarding": {},
          "f:reportingController": {},
          "f:reportingInstance": {},
          "f:type": {}
        },
        "manager": "kube-scheduler",
        "operation": "Update",
        "subresource": null,
        "time": "2022-11-23T19:43:44Z"
      }
    ],
    "name": "test-n2psp.172a4e3a78312186",
    "namespace": "test-namespace",
    "ownerReferences": null,
    "resourceVersion": "75176",
    "selfLink": null,
    "uid": "86cf2a7b-6a0e-47ce-adf2-cf470da89c71"
  },
  "note": "Successfully assigned test-namespace/test-n2psp to kind-test-control-plane",
  "reason": "Scheduled",
  "regarding": {
    "apiVersion": "v1",
    "fieldPath": null,
    "kind": "Pod",
    "name": "test-n2psp",
    "namespace": "test-namespace",
    "resourceVersion": "75172",
    "uid": "a5f4510d-fadc-482f-9f25-97cfc4850f54"
  },
  "related": null,
  "reportingController": "default-scheduler",
  "reportingInstance": "default-scheduler-kind-test-control-plane",
  "series": null,
  "type": "Normal"
}

[tg123]

i am looking into it

[justsomerandomcoding]

Any updates on this issue?
Im experience the same issue, with the command ´kubectl get events --all-namespaces --watch´ I get multiple events.
But with the code I get 0.

The only difference is that I'm running a cmctl command to renew a certificate as a test to get events.

[tg123]

kubectl get will list events first

you can list as well in sdk

[justsomerandomcoding]

But with the watch, shouldn't I get events continuously?
Running the code above (watching all namespaces for all events)
I can list them, but new events is not triggered.

Is that expected behaviour?

[tg123]

@OscartGiles @justsomerandomcoding could you please see if latest version works for you?

[justsomerandomcoding]

A quick test this morning, and I get the events properly in my application with the latest version! Great!!! :)
I'll try to write a GIST when i get some time over :)

[justsomerandomcoding]

@tg123 when running a certificates watcher we can not recieve events in code.

var watcher = await client.CertificatesV1.ListCertificateSigningRequestWithHttpMessagesAsync(watch:true); using (watcher.Watch<V1CertificateSigningRequest, V1CertificateSigningRequestList>( onEvent: (type, request) => Console.WriteLine("Event recieved"))) { Console.WriteLine("press ctrl + c to stop watching"); Console.CancelKeyPress += (sender, eventArgs) => new ManualResetEventSlim(false).Set(); new ManualResetEventSlim(false).Wait(); }

Though, running the all events like above, we get the CoreEvent, though not a CertificateSigningRequest, or am I using this api wrong?