Add example

Author: MrAlias

export/otelsdk/example_test.go

@@ -0,0 +1,42 @@
+package otelsdk_test
+
+import (
+	"context"
+	"os/signal"
+	"sync"
+	"syscall"
+
+	"go.opentelemetry.io/auto"
+	"go.opentelemetry.io/auto/export/otelsdk"
+)
+
+func Example_multiplex() {
+	ctx := context.Background()
+	m, err := otelsdk.NewMultiplexer(ctx)
+	if err != nil {
+		panic(err)
+	}
+
+	pids := []int{1297, 1331, 9827} // Simulated PIDs
+
+	var wg sync.WaitGroup
+	for _, pid := range pids {
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+
+			ctx, stop := signal.NotifyContext(ctx, syscall.SIGTERM)
+			defer stop()
+
+			// Note: do not ignore errors in normal use.
+			inst, _ := auto.NewInstrumentation(
+				ctx, auto.WithPID(pid), auto.WithHandler(m.Handler(pid)),
+			)
+			_ = inst.Load(ctx)
+			_ = inst.Run(ctx)
+		}()
+	}
+
+	wg.Wait()
+	_ = m.Shutdown(ctx)
+}

export/otelsdk/multiplex.go

@@ -77,3 +77,7 @@ func (m Multiplexer) withProcResAttrs(pid int) (c config) {
 
 	return c
 }
+
+func (m Multiplexer) Shutdown(ctx context.Context) error {
+	return m.cfg.spanProcessor.Shutdown(ctx)
+}