Limiter extension API interfaces and implementation helpers (**draft 6**)

cmd/otelcorecol/builder-config.yaml

@@ -83,6 +83,7 @@
   - go.opentelemetry.io/collector/extension/extensioncapabilities => ../../extension/extensioncapabilities
   - go.opentelemetry.io/collector/extension/extensionmiddleware => ../../extension/extensionmiddleware
   - go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest => ../../extension/extensionmiddleware/extensionmiddlewaretest
+  - go.opentelemetry.io/collector/extension/extensionlimiter => ../../extension/extensionlimiter
   - go.opentelemetry.io/collector/extension/extensiontest => ../../extension/extensiontest
   - go.opentelemetry.io/collector/extension/memorylimiterextension => ../../extension/memorylimiterextension
   - go.opentelemetry.io/collector/extension/xextension => ../../extension/xextension

cmd/otelcorecol/go.mod

@@ -4,7 +4,7 @@ module go.opentelemetry.io/collector/cmd/otelcorecol
 
 go 1.23.0
 
-toolchain go1.23.10
+toolchain go1.24.1
 
 require (
 	go.opentelemetry.io/collector/component v1.34.0
@@ -111,7 +111,9 @@ require (
 	go.opentelemetry.io/collector/exporter/xexporter v0.128.0 // indirect
 	go.opentelemetry.io/collector/extension/extensionauth v1.34.0 // indirect
 	go.opentelemetry.io/collector/extension/extensioncapabilities v0.128.0 // indirect
-	go.opentelemetry.io/collector/extension/extensionmiddleware v0.128.0 // indirect
+	go.opentelemetry.io/collector/extension/extensionlimiter v0.0.0-00010101000000-000000000000 // indirect
+	go.opentelemetry.io/collector/extension/extensionmiddleware v1.30.0 // indirect
+	go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest v0.128.0 // indirect
 	go.opentelemetry.io/collector/extension/extensiontest v0.128.0 // indirect
 	go.opentelemetry.io/collector/extension/xextension v0.128.0 // indirect
 	go.opentelemetry.io/collector/featuregate v1.34.0 // indirect
@@ -266,6 +268,8 @@ replace go.opentelemetry.io/collector/extension/extensionmiddleware => ../../ext
 
 replace go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest => ../../extension/extensionmiddleware/extensionmiddlewaretest
 
+replace go.opentelemetry.io/collector/extension/extensionlimiter => ../../extension/extensionlimiter
+
 replace go.opentelemetry.io/collector/extension/extensiontest => ../../extension/extensiontest
 
 replace go.opentelemetry.io/collector/extension/memorylimiterextension => ../../extension/memorylimiterextension

component/component.go

@@ -77,6 +77,20 @@
 	return f(ctx)
 }
 
+type componentImpl struct {
+	StartFunc
+	ShutdownFunc
+}
+
+var _ Component = componentImpl{}
+
+func NewComponentImpl(sf StartFunc, shf ShutdownFunc) Component {
+	return componentImpl{
+		StartFunc: sf,
+		ShutdownFunc: shf,
+	}
+}
+
 // Kind represents component kinds.
 type Kind struct {
 	name string
@@ -110,6 +124,10 @@
 	StabilityLevelStable
 )
 
+func (sl *StabilityLevel) Self() StabilityLevel {
+	return *sl
+}
+
 func (sl *StabilityLevel) UnmarshalText(in []byte) error {
 	str := strings.ToLower(string(in))
 	switch str {
@@ -194,3 +212,17 @@
 func (f CreateDefaultConfigFunc) CreateDefaultConfig() Config {
 	return f()
 }
+
+type factoryImpl struct {
+	TypeFunc
+	CreateDefaultConfigFunc
+}
+
+var _ Factory = factoryImpl{}
+
+func NewFactoryImpl(tf TypeFunc, cf CreateDefaultConfigFunc) Factory {
+	return factoryImpl{
+		TypeFunc: tf,
+		CreateDefaultConfigFunc: cf,
+	}
+}

component/identifiable.go

@@ -38,6 +38,11 @@
 	return t.name
 }
 
+// Self returns itself.
+func (t Type) Self() Type {
+	return t
+}
+
 // MarshalText marshals returns the Type name.
 func (t Type) MarshalText() ([]byte, error) {
 	return []byte(t.name), nil
@@ -71,6 +76,16 @@
 	return ty
 }
 
+// TypeFunc is ...
+type TypeFunc func() Type
+
+// Type gets the type of the component created by this factory.
+func (f TypeFunc) Type() Type {
+	if f == nil {
+	}
+	return f()
+}
+
 // ID represents the identity for a component. It combines two values:
 // * type - the Type of the component.
 // * name - the name of that component.

config/configgrpc/client_middleware_test.go

@@ -31,9 +31,7 @@ type testClientMiddleware struct {
 }
 
 func newTestMiddlewareConfig(name string) configmiddleware.Config {
-	return configmiddleware.Config{
-		ID: component.MustNewID(name),
-	}
+	return configmiddleware.Config(component.MustNewID(name))
 }
 
 func newTestClientMiddleware(name string) extension.Extension {
@@ -162,9 +160,7 @@ func TestClientMiddlewareToClientErrors(t *testing.T) {
 					Insecure: true,
 				},
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -182,9 +178,7 @@ func TestClientMiddlewareToClientErrors(t *testing.T) {
 					Insecure: true,
 				},
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "get options failed",

config/configgrpc/configgrpc.go

@@ -207,7 +207,7 @@ type ServerConfig struct {
 	IncludeMetadata bool `mapstructure:"include_metadata,omitempty"`
 
 	// Middlewares for the gRPC server.
-	Middlewares []configmiddleware.Config `mapstructure:"middlewares,omitempty"`
+	Middlewares []configmiddleware.Config `mapstructure:"middleware,omitempty"`
 
 	// prevent unkeyed literal initialization
 	_ struct{}

config/configgrpc/go.mod

@@ -17,7 +17,7 @@ require (
 	go.opentelemetry.io/collector/extension v1.34.0
 	go.opentelemetry.io/collector/extension/extensionauth v1.34.0
 	go.opentelemetry.io/collector/extension/extensionauth/extensionauthtest v0.128.0
-	go.opentelemetry.io/collector/extension/extensionmiddleware v0.128.0
+	go.opentelemetry.io/collector/extension/extensionmiddleware v1.30.0
 	go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest v0.128.0
 	go.opentelemetry.io/collector/pdata v1.34.0
 	go.opentelemetry.io/collector/pdata/testdata v0.128.0
@@ -44,6 +44,7 @@ require (
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
+	go.opentelemetry.io/collector/extension/extensionlimiter v0.0.0-00010101000000-000000000000 // indirect
 	go.opentelemetry.io/collector/featuregate v1.34.0 // indirect
 	go.opentelemetry.io/collector/internal/telemetry v0.128.0 // indirect
 	go.opentelemetry.io/collector/pdata/pprofile v0.128.0 // indirect
@@ -59,6 +60,7 @@ require (
 	golang.org/x/net v0.40.0 // indirect
 	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.25.0 // indirect
+	golang.org/x/time v0.11.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20250519155744-55703ea1f237 // indirect
 	google.golang.org/protobuf v1.36.6 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
@@ -105,3 +107,7 @@ replace go.opentelemetry.io/collector/pipeline => ../../pipeline
 replace go.opentelemetry.io/collector/featuregate => ../../featuregate
 
 replace go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest => ../../extension/extensionmiddleware/extensionmiddlewaretest
+
+replace go.opentelemetry.io/collector/extension/extensionlimiter => ../../extension/extensionlimiter
+
+replace go.opentelemetry.io/collector/consumer/xconsumer => ../../consumer/xconsumer

config/configgrpc/server_middleware_test.go

@@ -122,9 +122,7 @@ func TestServerMiddlewareToServerErrors(t *testing.T) {
 					Transport: confignet.TransportTypeTCP,
 				},
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -142,9 +140,7 @@ func TestServerMiddlewareToServerErrors(t *testing.T) {
 					Transport: confignet.TransportTypeTCP,
 				},
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "get server options failed",

config/confighttp/client_middleware_test.go

@@ -61,9 +61,7 @@ func newTestClientMiddleware(name string) component.Component {
 }
 
 func newTestClientConfig(name string) configmiddleware.Config {
-	return configmiddleware.Config{
-		ID: component.MustNewID(name),
-	}
+	return configmiddleware.Config(component.MustNewID(name))
 }
 
 func TestClientMiddlewares(t *testing.T) {
@@ -162,9 +160,7 @@ func TestClientMiddlewareErrors(t *testing.T) {
 			config: ClientConfig{
 				Endpoint: server.URL,
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -179,9 +175,7 @@ func TestClientMiddlewareErrors(t *testing.T) {
 			config: ClientConfig{
 				Endpoint: server.URL,
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "http middleware error",
@@ -216,9 +210,7 @@ func TestGRPCClientMiddlewareErrors(t *testing.T) {
 			config: ClientConfig{
 				Endpoint: "localhost:1234",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -233,9 +225,7 @@ func TestGRPCClientMiddlewareErrors(t *testing.T) {
 			config: ClientConfig{
 				Endpoint: "localhost:1234",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "grpc middleware error",

config/confighttp/go.mod

@@ -19,7 +19,7 @@ require (
 	go.opentelemetry.io/collector/extension v1.34.0
 	go.opentelemetry.io/collector/extension/extensionauth v1.34.0
 	go.opentelemetry.io/collector/extension/extensionauth/extensionauthtest v0.128.0
-	go.opentelemetry.io/collector/extension/extensionmiddleware v0.128.0
+	go.opentelemetry.io/collector/extension/extensionmiddleware v1.30.0
 	go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest v0.128.0
 	go.opentelemetry.io/collector/featuregate v1.34.0
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.61.0
@@ -42,6 +42,7 @@ require (
 	github.com/hashicorp/go-version v1.7.0 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
+	go.opentelemetry.io/collector/extension/extensionlimiter v0.0.0-00010101000000-000000000000 // indirect
 	go.opentelemetry.io/collector/internal/telemetry v0.128.0 // indirect
 	go.opentelemetry.io/collector/pdata v1.34.0 // indirect
 	go.opentelemetry.io/contrib/bridges/otelzap v0.11.0 // indirect
@@ -72,6 +73,8 @@ replace go.opentelemetry.io/collector/config/configtls => ../configtls
 
 replace go.opentelemetry.io/collector/extension => ../../extension
 
+replace go.opentelemetry.io/collector/extension/extensionlimiter => ../../extension/extensionlimiter
+
 replace go.opentelemetry.io/collector/extension/extensionauth => ../../extension/extensionauth
 
 replace go.opentelemetry.io/collector/extension/extensionmiddleware => ../../extension/extensionmiddleware
@@ -95,3 +98,7 @@ replace go.opentelemetry.io/collector/pipeline => ../../pipeline
 replace go.opentelemetry.io/collector/featuregate => ../../featuregate
 
 replace go.opentelemetry.io/collector/extension/extensionmiddleware/extensionmiddlewaretest => ../../extension/extensionmiddleware/extensionmiddlewaretest
+
+replace go.opentelemetry.io/collector/consumer/xconsumer => ../../consumer/xconsumer
+
+replace go.opentelemetry.io/collector/pdata/pprofile => ../../pdata/pprofile

config/confighttp/server_middleware_test.go

@@ -47,9 +47,7 @@ func newTestServerMiddleware(name string) component.Component {
 }
 
 func newTestServerConfig(name string) configmiddleware.Config {
-	return configmiddleware.Config{
-		ID: component.MustNewID(name),
-	}
+	return configmiddleware.Config(component.MustNewID(name))
 }
 
 func TestServerMiddleware(t *testing.T) {
@@ -154,9 +152,7 @@ func TestServerMiddlewareErrors(t *testing.T) {
 			config: ServerConfig{
 				Endpoint: "localhost:0",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -171,9 +167,7 @@ func TestServerMiddlewareErrors(t *testing.T) {
 			config: ServerConfig{
 				Endpoint: "localhost:0",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "http middleware error",
@@ -209,9 +203,7 @@ func TestServerMiddlewareErrors(t *testing.T) {
 			config: ServerConfig{
 				Endpoint: "localhost:0",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("nonexistent"),
-					},
+					configmiddleware.Config(component.MustNewID("nonexistent")),
 				},
 			},
 			errText: "failed to resolve middleware \"nonexistent\": middleware not found",
@@ -226,9 +218,7 @@ func TestServerMiddlewareErrors(t *testing.T) {
 			config: ServerConfig{
 				Endpoint: "localhost:0",
 				Middlewares: []configmiddleware.Config{
-					{
-						ID: component.MustNewID("errormw"),
-					},
+					configmiddleware.Config(component.MustNewID("errormw")),
 				},
 			},
 			errText: "grpc middleware error",