feat: add WithAltTransporter option for parallel monitoring

cloudwego · Dec 28, 2022 · 5c93ee7 · 5c93ee7
1 parent f34912c
commit 5c93ee7
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/pkg/app/server/option.go b/pkg/app/server/option.go
@@ -259,6 +259,13 @@ func WithTransport(transporter func(options *config.Options) network.Transporter
 	}}
 }
 
+// WithAltTransport sets which network library to use as an alternative transporter(need to be implemented by specific transporter).
+func WithAltTransport(transporter func(options *config.Options) network.Transporter) config.Option {
+	return config.Option{F: func(o *config.Options) {
+		o.AltTransporterNewer = transporter
+	}}
+}
+
 // WithH2C sets whether enable H2C.
 func WithH2C(enable bool) config.Option {
 	return config.Option{F: func(o *config.Options) {

diff --git a/pkg/common/config/option.go b/pkg/common/config/option.go
@@ -74,7 +74,8 @@ type Options struct {
 	ListenConfig                 *net.ListenConfig
 
 	// TransporterNewer is the function to create a transporter.
-	TransporterNewer func(opt *Options) network.Transporter
+	TransporterNewer    func(opt *Options) network.Transporter
+	AltTransporterNewer func(opt *Options) network.Transporter
 
 	// In netpoll library, OnAccept is called after connection accepted
 	// but before adding it to epoll. OnConnect is called after adding it to epoll.