Add a simple stream example

Signed-off-by: Djordje Lukic <djordje.lukic@docker.com>

Author: rumpl

examples/golibrary/stream/main.go

@@ -0,0 +1,65 @@
+package main
+
+import (
+	"context"
+	"log"
+
+	"github.com/docker/cagent/pkg/agent"
+	latest "github.com/docker/cagent/pkg/config/v2"
+	"github.com/docker/cagent/pkg/environment"
+	"github.com/docker/cagent/pkg/model/provider/openai"
+	"github.com/docker/cagent/pkg/runtime"
+	"github.com/docker/cagent/pkg/session"
+	"github.com/docker/cagent/pkg/team"
+)
+
+func main() {
+	ctx := context.Background()
+
+	llm, err := openai.NewClient(
+		ctx,
+		&latest.ModelConfig{
+			Provider: "openai",
+			Model:    "gpt-4o",
+		},
+		environment.NewDefaultProvider(ctx),
+	)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	human := agent.New(
+		"root",
+		"You are a human, with feelings and emotions.",
+		agent.WithModel(llm),
+		agent.WithDescription("A human."),
+	)
+
+	humanTeam := team.New(team.WithAgents(human))
+
+	rt, err := runtime.New(humanTeam)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	sess := session.New(session.WithUserMessage("", "How are you doing?"))
+
+	events := rt.RunStream(ctx, sess)
+	for event := range events {
+		switch e := event.(type) {
+		case *runtime.AgentChoiceEvent:
+			log.Printf("Agent %s: %s\n", e.AgentName, e.Content)
+		case *runtime.StreamStartedEvent:
+			log.Println("Stream started for session")
+		case *runtime.StreamStoppedEvent:
+			log.Println("Stream stopped for session")
+		case *runtime.ToolCallConfirmationEvent:
+			rt.Resume(ctx, "approve-session")
+		case *runtime.ToolCallEvent:
+			log.Printf("Tool call: %s\n", e.ToolCall.Function.Name)
+		case *runtime.ToolCallResponseEvent:
+			log.Printf("Tool call response: %s\n", e.Response)
+			// etc...
+		}
+	}
+}