Watch Events

import gitpod.v1.event_pb2 as event_pb2
from ona_sdk import create_client_from_env

ona = create_client_from_env()
request = event_pb2.WatchEventsRequest(
    organization=True,
)
for response in ona.services.event.watch_events(request):
    print(response)

import { create } from "@bufbuild/protobuf";
import { createClientFromEnv } from "@gitpod/sdk";
import { WatchEventsRequestSchema } from "@gitpod/sdk/gitpod/v1/event_pb";

async function main() {
  const ona = createClientFromEnv();
  const request = create(WatchEventsRequestSchema, {
    scope: {
      case: "organization",
      value: true,
    },
  });
  for await (const response of ona.services.event.watchEvents(request)) {
    console.log(response);
  }
}

main().catch(console.error);

package main

import (
	"context"
	"fmt"
	"log"

	"connectrpc.com/connect"
	"github.com/gitpod-io/gitpod-sdk-go/sdk"
	gitpodpb "github.com/gitpod-io/gitpod-sdk-go/v1"
)

func main() {
	ona, err := sdk.NewFromEnv()
	if err != nil {
		log.Fatal(err)
	}

	request := connect.NewRequest(&gitpodpb.WatchEventsRequest{
		Scope: &gitpodpb.WatchEventsRequest_Organization{
			Organization: true,
		},
	})
	stream, err := ona.Services.Event.WatchEvents(context.Background(), request)
	if err != nil {
		log.Fatal(err)
	}
	for stream.Receive() {
		fmt.Println(stream.Msg())
	}
	if err := stream.Err(); err != nil {
		log.Fatal(err)
	}
}

{
  "organization": true
}