WIP: Add TCX support

pkg/beyla/config.go

@@ -16,6 +16,7 @@ import (
 	"github.com/grafana/beyla/pkg/export/instrumentations"
 	"github.com/grafana/beyla/pkg/export/otel"
 	"github.com/grafana/beyla/pkg/export/prom"
+	"github.com/grafana/beyla/pkg/internal/ebpf/tcmanager"
 	"github.com/grafana/beyla/pkg/internal/filter"
 	"github.com/grafana/beyla/pkg/internal/imetrics"
 	"github.com/grafana/beyla/pkg/internal/infraolly/process"
@@ -48,6 +49,7 @@ var DefaultConfig = Config{
 		BatchLength:        100,
 		BatchTimeout:       time.Second,
 		HTTPRequestTimeout: 30 * time.Second,
+		TCBackend:          tcmanager.TCBackendTC,
 	},
 	Grafana: otel.GrafanaConfig{
 		OTLP: otel.GrafanaOTLP{
@@ -243,6 +245,10 @@ func (c *Config) Validate() error {
 	if c.EBPF.BatchLength == 0 {
 		return ConfigError("BEYLA_BPF_BATCH_LENGTH must be at least 1")
 	}
+	if !c.EBPF.TCBackend.Valid() {
+		return ConfigError("Invalid BEYLA_BPF_TC_BACKEND value")
+	}
+
 	if c.Attributes.Kubernetes.InformersSyncTimeout == 0 {
 		return ConfigError("BEYLA_KUBE_INFORMERS_SYNC_TIMEOUT duration must be greater than 0s")
 	}

pkg/beyla/config_test.go

@@ -20,6 +20,7 @@ import (
 	"github.com/grafana/beyla/pkg/export/instrumentations"
 	"github.com/grafana/beyla/pkg/export/otel"
 	"github.com/grafana/beyla/pkg/export/prom"
+	"github.com/grafana/beyla/pkg/internal/ebpf/tcmanager"
 	"github.com/grafana/beyla/pkg/internal/imetrics"
 	"github.com/grafana/beyla/pkg/internal/infraolly/process"
 	"github.com/grafana/beyla/pkg/internal/kube"
@@ -124,6 +125,7 @@ network:
 			BatchLength:        100,
 			BatchTimeout:       time.Second,
 			HTTPRequestTimeout: 30 * time.Second,
+			TCBackend:          tcmanager.TCBackendTC,
 		},
 		Grafana: otel.GrafanaConfig{
 			OTLP: otel.GrafanaOTLP{

pkg/config/ebpf_tracer.go

@@ -1,6 +1,10 @@
 package config
 
-import "time"
+import (
+	"time"
+
+	"github.com/grafana/beyla/pkg/internal/ebpf/tcmanager"
+)
 
 // EBPFTracer configuration for eBPF programs
 type EBPFTracer struct {
@@ -31,6 +35,10 @@ type EBPFTracer struct {
 	// Enables Linux Traffic Control probes for context propagation
 	UseTCForL7CP bool `yaml:"traffic_control_l7_context_propagation" env:"BEYLA_BPF_TC_L7_CP"`
 
+	// Select the TC attachment backend: accepted values are 'tc' (netlink),
+	// and 'tcx'
+	TCBackend tcmanager.TCBackend `yaml:"traffic_control_backend" env:"BEYLA_BPF_TC_BACKEND"`
+
 	// Disables Beyla black-box context propagation. Used for testing purposes only.
 	DisableBlackBoxCP bool `yaml:"disable_black_box_cp" env:"BEYLA_BPF_DISABLE_BLACK_BOX_CP"`
 

pkg/internal/ebpf/common/common.go

@@ -43,16 +43,6 @@ var IntegrityModeOverride = false
 
 var ActiveNamespaces = make(map[uint32]uint32)
 
-// These represent unique traffic control (tc) handles to be supplied as
-// arguments to RegisterIngress, RegisterEgress or RegisterTC. They all start
-// from the 0xb310 offset in simplistic attempt to avoid collisions with
-// 3rdparty handles.
-const (
-	NetollyTCHandle = 0xb310 + iota
-	HTTPTracerTCHandle
-	TCTracerTCHandle
-)
-
 // ProbeDesc holds the information of the instrumentation points of a given
 // function/symbol
 type ProbeDesc struct {

pkg/internal/ebpf/generictracer/generictracer.go

@@ -481,9 +481,6 @@ func (p *Tracer) AlreadyInstrumentedLib(id uint64) bool {
 	return module != nil
 }
 
-func (p *Tracer) SetupTC() {
-}
-
 func (p *Tracer) Run(ctx context.Context, eventsChan chan<- []request.Span) {
 	// At this point we now have loaded the bpf objects, which means we should insert any
 	// pids that are allowed into the bpf map

pkg/internal/ebpf/generictracer/generictracer_notlinux.go

@@ -40,6 +40,5 @@ func (p *Tracer) UnlinkInstrumentedLib(_ uint64)                         {}
 func (p *Tracer) AlreadyInstrumentedLib(_ uint64) bool                   { return false }
 func (p *Tracer) Run(_ context.Context, _ chan<- []request.Span)         {}
 func (p *Tracer) Constants() map[string]any                              { return nil }
-func (p *Tracer) SetupTC()                                               {}
 func (p *Tracer) SetupTailCalls()                                        {}
 func (p *Tracer) RegisterOffsets(_ *exec.FileInfo, _ *goexec.Offsets)    {}

pkg/internal/ebpf/gotracer/gotracer.go

@@ -401,8 +401,6 @@ func (p *Tracer) AlreadyInstrumentedLib(_ uint64) bool {
 	return false
 }
 
-func (p *Tracer) SetupTC() {}
-
 func (p *Tracer) Run(ctx context.Context, eventsChan chan<- []request.Span) {
 	ebpfcommon.SharedRingbuf(
 		p.cfg,