fix(realworld): memory client

Author: jochumdev

benchmarks/rps/cmd/orb-rps-server/wire.go

@@ -33,44 +33,36 @@ func provideServerOpts() ([]server.ConfigOption, error) {
 	hRegister := proto.RegisterEchoHandler(hInstance)
 
 	opts := []server.ConfigOption{}
-	opts = append(opts, server.WithEntrypointConfig(mgrpc.NewConfig(
-		mgrpc.WithName("grpc"),
+	opts = append(opts, server.WithEntrypointConfig("grpc", mgrpc.NewConfig(
 		mgrpc.WithInsecure(),
 		mgrpc.WithHandlers(hRegister),
 		mgrpc.WithReflection(true),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mgrpc.NewConfig(
-		mgrpc.WithName("grpcs"),
+	opts = append(opts, server.WithEntrypointConfig("grpcs", mgrpc.NewConfig(
 		mgrpc.WithHandlers(hRegister),
 		mgrpc.WithReflection(true),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mhttp.NewConfig(
-		mhttp.WithName("http"),
+	opts = append(opts, server.WithEntrypointConfig("http", mhttp.NewConfig(
 		mhttp.WithInsecure(),
 		mhttp.WithHandlers(hRegister),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mhttp.NewConfig(
-		mhttp.WithName("https"),
+	opts = append(opts, server.WithEntrypointConfig("https", mhttp.NewConfig(
 		mhttp.WithDisableHTTP2(),
 		mhttp.WithHandlers(hRegister),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mhttp.NewConfig(
-		mhttp.WithName("h2c"),
+	opts = append(opts, server.WithEntrypointConfig("h2c", mhttp.NewConfig(
 		mhttp.WithInsecure(),
 		mhttp.WithAllowH2C(),
 		mhttp.WithHandlers(hRegister),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mhttp.NewConfig(
-		mhttp.WithName("http2"),
+	opts = append(opts, server.WithEntrypointConfig("http2", mhttp.NewConfig(
 		mhttp.WithHandlers(hRegister),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(mhttp.NewConfig(
-		mhttp.WithName("http3"),
+	opts = append(opts, server.WithEntrypointConfig("http3", mhttp.NewConfig(
 		mhttp.WithHTTP3(),
 		mhttp.WithHandlers(hRegister),
 	)))
-	opts = append(opts, server.WithEntrypointConfig(drpc.NewConfig(
-		drpc.WithName("drpc"),
+	opts = append(opts, server.WithEntrypointConfig("drpc", drpc.NewConfig(
 		drpc.WithHandlers(hRegister),
 	)))
 

benchmarks/rps/cmd/orb-rps-server/wire_gen.go

@@ -15,6 +15,7 @@ import (
 	_ "github.com/go-orb/plugins/client/middleware/retry"
 	_ "github.com/go-orb/plugins/client/orb"
 	_ "github.com/go-orb/plugins/client/orb_transport/grpc"
+	_ "github.com/go-orb/plugins/client/orb_transport/memory"
 	_ "github.com/go-orb/plugins/codecs/goccyjson"
 	_ "github.com/go-orb/plugins/codecs/proto"
 	_ "github.com/go-orb/plugins/codecs/yaml"
@@ -47,8 +48,10 @@ func main() {
 				Usage:       "Set the registry plugin, one of mdns, consul, memory",
 			},
 		},
-		Commands:         []*cli.Command{},
-		HardcodedConfigs: []cli.HardcodedConfig{{Format: "yaml", Data: config}},
+		Commands: []*cli.Command{},
+
+		MultiServiceConfig: true,
+		HardcodedConfigs:   []cli.HardcodedConfig{{Format: "yaml", Data: config}},
 	}
 
 	app.Commands = append(app.Commands, monolith.MainCommands()...)

realworld/cmd/realworld/main.go

@@ -30,9 +30,7 @@ import (
 func provideServerOpts() ([]server.ConfigOption, error) {
 	opts := []server.ConfigOption{}
 
-	opts = append(opts, server.WithEntrypointConfig(mdrpc.NewConfig(
-		mdrpc.WithName("drpc"),
-	)))
+	opts = append(opts, server.WithEntrypointConfig("drpc", mdrpc.NewConfig()))
 
 	return opts, nil
 }