Refactor otel sub modules to SubModule class

example/client-server-with-otel/client/main.go

@@ -21,9 +21,10 @@ func main() {
 	app.Use(
 		client.Module(),
 		server.Module(),
-		otel.Module(),
-		otelclient.Module(),
-		otelserver.Module(),
+		otel.Module(
+			otelclient.WithClient(),
+			otelserver.WithServer(),
+		),
 	)
 
 	app.Provide(

example/client-server-with-otel/server/main.go

@@ -18,9 +18,10 @@ func main() {
 
 	app.Use(
 		server.Module(),
-		otel.Module(),
-		otelclient.Module(),
-		otelserver.Module(),
+		otel.Module(
+			otelclient.WithClient(),
+			otelserver.WithServer(),
+		),
 	)
 
 	app.Provide(

example/consumer-with-otel/main.go

@@ -17,8 +17,9 @@ func main() {
 	)
 
 	app.Use(
-		otel.Module(),
-		otelkafka.Module(),
+		otel.Module(
+			otelkafka.WithKafka(),
+		),
 		kafka.Module(),
 	)
 

example/server-with-newrelic/main.go

@@ -30,9 +30,10 @@ func main() {
 	)
 
 	app.Use(
-		otel.Module(),
+		otel.Module(
+			otelserver.WithServer(),
+		),
 		orm.Module(postgresdriver.New()),
-		otelserver.Module(),
 		server.Module(),
 		swagger.Module(),
 

example/server-with-otel/main.go

@@ -21,8 +21,9 @@ func main() {
 	)
 
 	app.Use(
-		otel.Module(),
-		otelserver.Module(),
+		otel.Module(
+			otelserver.WithServer(),
+		),
 		server.Module(),
 	)
 

example/server-with-postgres/main.go

@@ -24,9 +24,10 @@ func main() {
 	)
 
 	app.Use(
-		otel.Module(),
+		otel.Module(
+			otelserver.WithServer(),
+		),
 		orm.Module(postgresdriver.New()),
-		otelserver.Module(),
 		server.Module(),
 		swagger.Module(),
 	)

modules/otel/client/module.go

@@ -5,15 +5,15 @@ import (
 
 	"github.com/Trendyol/chaki/module"
 	clientcommon "github.com/Trendyol/chaki/modules/client/common"
+	otelmodule "github.com/Trendyol/chaki/modules/otel"
 	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
 	"go.opentelemetry.io/otel/propagation"
 	"go.opentelemetry.io/otel/trace"
 )
 
-const ModuleName = "chaki-otel-client"
-
-func Module() *module.Module {
-	return module.New(ModuleName).Provide(newClientRoundTripperWrapper)
+func WithClient() otelmodule.Option {
+	m := module.NewSubModule().Provide(newClientRoundTripperWrapper)
+	return otelmodule.WithSubModule(m)
 }
 
 func newClientRoundTripperWrapper(tp trace.TracerProvider, tmp propagation.TextMapPropagator) clientcommon.RoundTripperWrapper {

modules/otel/kafka/module.go

@@ -7,22 +7,19 @@ import (
 	"github.com/Trendyol/chaki/module"
 	"github.com/Trendyol/chaki/modules/kafka/consumer"
 	"github.com/Trendyol/chaki/modules/kafka/producer"
+	otelmodule "github.com/Trendyol/chaki/modules/otel"
 	"go.opentelemetry.io/otel/trace"
 )
 
-const moduleName = "chaki-otel-kafka"
-
-func Module() *module.Module {
-	m := module.New(moduleName)
-
-	m.Provide(
+func WithKafka() otelmodule.Option {
+	m := module.NewSubModule().Provide(
 		newSpanBuilder,
 		newConsumerInterceptor,
 		newProducerInterceptor,
 		newBatchConsumerInterceptor,
 	)
 
-	return m
+	return otelmodule.WithSubModule(m)
 }
 
 func newConsumerInterceptor(sb *spanBuilder) consumer.Interceptor {

modules/otel/module.go

@@ -21,6 +21,8 @@ func Module(opts ...Option) *module.Module {
 		startOtel,
 	)
 
+	m.Merge(o.subModules...)
+
 	return m
 }
 

modules/otel/option.go

@@ -1,39 +1,49 @@
 package otel
 
-import "context"
+import (
+	"context"
+
+	"github.com/Trendyol/chaki/module"
+)
 
 type CloseFunc func(context.Context) error
 
 type InitFunc func() CloseFunc
 
 type options struct {
-	initFunc InitFunc
+	initFunc   InitFunc
+	subModules []*module.SubModule
 }
 
 type Option interface {
-	Apply(*options) *options
+	Apply(*options)
 }
 
-type withOption func(*options) *options
+type withOption func(*options)
 
-func (wf withOption) Apply(opts *options) *options {
-	return wf(opts)
+func (wf withOption) Apply(opts *options) {
+	wf(opts)
 }
 
 var _ Option = withOption(nil)
 
 func WithInitFunc(f InitFunc) Option {
-	return withOption(func(o *options) *options {
+	return withOption(func(o *options) {
 		o.initFunc = f
-		return o
+	})
+}
+
+func WithSubModule(sub ...*module.SubModule) Option {
+	return withOption(func(o *options) {
+		o.subModules = append(o.subModules, sub...)
 	})
 }
 
 func applyOptions(opts ...Option) *options {
 	o := &options{}
 
 	for _, opt := range opts {
-		o = opt.Apply(o)
+		opt.Apply(o)
 	}
 
 	return o

modules/otel/server/module.go

@@ -2,17 +2,17 @@ package otelserver
 
 import (
 	"github.com/Trendyol/chaki/module"
+	otelmodule "github.com/Trendyol/chaki/modules/otel"
 	otelcommon "github.com/Trendyol/chaki/modules/otel/common"
 	servercommon "github.com/Trendyol/chaki/modules/server/common"
 	"github.com/gofiber/contrib/otelfiber/v2"
 	"github.com/gofiber/fiber/v2"
 	"go.opentelemetry.io/otel/trace"
 )
 
-const ModuleName = "chaki-otel-server"
-
-func Module() *module.Module {
-	return module.New(ModuleName).Provide(newMiddlewareGroup)
+func WithServer() otelmodule.Option {
+	m := module.NewSubModule().Provide(newMiddlewareGroup)
+	return otelmodule.WithSubModule(m)
 }
 
 func newMiddlewareGroup() servercommon.MiddlewareGroup {