eventbus supports configurable

Signed-off-by: jyjiangkai <[email protected]>

Author: hwjiangkai

observability/tracing/exporter/event_trace_exporter.go

@@ -30,11 +30,13 @@ type Option func(*Options)
 
 type Options struct {
 	Endpoints string
+	Eventbus  string
 }
 
 func defaultOptions() *Options {
 	return &Options{
 		Endpoints: "127.0.0.1:8080",
+		Eventbus:  "event-tracing",
 	}
 }
 
@@ -44,6 +46,12 @@ func WithEndpoint(endpoint string) Option {
 	}
 }
 
+func WithEventbus(eventbus string) Option {
+	return func(options *Options) {
+		options.Eventbus = eventbus
+	}
+}
+
 // Exporter exports trace data in the OTLP wire format.
 type Exporter struct {
 	endpoints string

observability/tracing/tracing.go

@@ -47,6 +47,7 @@ type Config struct {
 	OtelCollector      string `yaml:"otel_collector"`
 	EventTracingEnable bool   `yaml:"event_tracing_enable"`
 	EventCollector     string `yaml:"event_collector"`
+	Eventbus           string `yaml:"eventbus"`
 }
 
 var tp *tracerProvider
@@ -188,7 +189,9 @@ func newTracerProvider(serviceName string, cfg Config) (*trace.TracerProvider, e
 
 	if cfg.EventTracingEnable && cfg.EventCollector != "" {
 		// Set up a event exporter
-		eventExporter, err := exporter.New(ctx, exporter.WithEndpoint(cfg.EventCollector))
+		endpoint := exporter.WithEndpoint(cfg.EventCollector)
+		eventbus := exporter.WithEventbus(cfg.Eventbus)
+		eventExporter, err := exporter.New(ctx, endpoint, eventbus)
 		if err != nil {
 			return nil, fmt.Errorf("failed to create event exporter: %w", err)
 		}