chore: update examples to v0.2.0

Author: jochumdev

benchmarks/event/cmd/handler/wire.go

@@ -6,35 +6,17 @@ package main
 import (
 	"context"
 	"fmt"
-	"net/url"
 	"os"
 	"os/signal"
 	"syscall"
 
-	"github.com/go-orb/go-orb/config"
 	"github.com/go-orb/go-orb/event"
 	"github.com/go-orb/go-orb/log"
 	"github.com/go-orb/go-orb/types"
+	"github.com/go-orb/plugins/config/source/cli/urfave"
 	"github.com/go-orb/wire"
 )
 
-// provideConfigData reads the config from cli and returns it.
-func provideConfigData(
-	serviceName types.ServiceName,
-	serviceVersion types.ServiceVersion,
-) (types.ConfigData, error) {
-	u, err := url.Parse("cli://urfave")
-	if err != nil {
-		return nil, err
-	}
-
-	cfgSections := types.SplitServiceName(serviceName)
-
-	data, err := config.Read([]*url.URL{u}, cfgSections)
-
-	return data, err
-}
-
 // wireRunResult is here so "wire" has a type for the return value of wireRun.
 // wire needs a explicit type for each provider including "wireRun".
 type wireRunResult string
@@ -91,7 +73,7 @@ func run(
 	cb wireRunCallback,
 ) (wireRunResult, error) {
 	panic(wire.Build(
-		provideConfigData,
+		urfave.ProvideConfigData,
 		wire.Value([]log.Option{}),
 		log.Provide,
 		wire.Value([]event.Option{}),

benchmarks/event/cmd/handler/wire_gen.go

@@ -6,35 +6,17 @@ package main
 import (
 	"context"
 	"fmt"
-	"net/url"
 	"os"
 	"os/signal"
 	"syscall"
 
-	"github.com/go-orb/go-orb/config"
 	"github.com/go-orb/go-orb/event"
 	"github.com/go-orb/go-orb/log"
 	"github.com/go-orb/go-orb/types"
+	"github.com/go-orb/plugins/config/source/cli/urfave"
 	"github.com/go-orb/wire"
 )
 
-// provideConfigData reads the config from cli and returns it.
-func provideConfigData(
-	serviceName types.ServiceName,
-	serviceVersion types.ServiceVersion,
-) (types.ConfigData, error) {
-	u, err := url.Parse("cli://urfave")
-	if err != nil {
-		return nil, err
-	}
-
-	cfgSections := types.SplitServiceName(serviceName)
-
-	data, err := config.Read([]*url.URL{u}, cfgSections)
-
-	return data, err
-}
-
 // wireRunResult is here so "wire" has a type for the return value of wireRun.
 type wireRunResult string
 
@@ -90,7 +72,7 @@ func run(
 	cb wireRunCallback,
 ) (wireRunResult, error) {
 	panic(wire.Build(
-		provideConfigData,
+		urfave.ProvideConfigData,
 		wire.Value([]log.Option{}),
 		log.Provide,
 		wire.Value([]event.Option{}),

benchmarks/event/cmd/request/wire.go

@@ -17,6 +17,7 @@ import (
 	"github.com/go-orb/go-orb/log"
 	"github.com/go-orb/go-orb/registry"
 	"github.com/go-orb/go-orb/types"
+	"github.com/go-orb/plugins/config/source/cli/urfave"
 
 	"github.com/go-orb/wire"
 )
@@ -90,7 +91,7 @@ func run(
 	cb wireRunCallback,
 ) (wireRunResult, error) {
 	panic(wire.Build(
-		provideConfigData,
+		urfave.ProvideConfigData,
 		wire.Value([]log.Option{}),
 		log.Provide,
 		wire.Value([]registry.Option{}),

benchmarks/event/cmd/request/wire_gen.go

@@ -7,43 +7,25 @@ package main
 import (
 	"context"
 	"fmt"
-	"net/url"
 	"os"
 	"os/signal"
 	"syscall"
 
-	"github.com/go-orb/go-orb/config"
 	"github.com/go-orb/go-orb/log"
 	"github.com/go-orb/go-orb/registry"
 	"github.com/go-orb/go-orb/server"
 	"github.com/go-orb/go-orb/types"
 
 	"github.com/go-orb/examples/benchmarks/rps/handler/echo"
 	proto "github.com/go-orb/examples/benchmarks/rps/proto/echo"
+	"github.com/go-orb/plugins/config/source/cli/urfave"
 	"github.com/go-orb/plugins/server/drpc"
 	mgrpc "github.com/go-orb/plugins/server/grpc"
 	mhttp "github.com/go-orb/plugins/server/http"
 
 	"github.com/go-orb/wire"
 )
 
-// provideConfigData reads the config from cli and returns it.
-func provideConfigData(
-	serviceName types.ServiceName,
-	serviceVersion types.ServiceVersion,
-) (types.ConfigData, error) {
-	u, err := url.Parse("cli://urfave")
-	if err != nil {
-		return nil, err
-	}
-
-	cfgSections := types.SplitServiceName(serviceName)
-
-	data, err := config.Read([]*url.URL{u}, cfgSections)
-
-	return data, err
-}
-
 // provideServerOpts provides options for the go-orb server.
 func provideServerOpts() ([]server.ConfigOption, error) {
 
@@ -144,7 +126,7 @@ func run(
 	cb wireRunCallback,
 ) (wireRunResult, error) {
 	panic(wire.Build(
-		provideConfigData,
+		urfave.ProvideConfigData,
 		wire.Value([]log.Option{}),
 		log.Provide,
 		wire.Value([]registry.Option{}),

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

@@ -6,35 +6,17 @@ package main
 import (
 	"context"
 	"fmt"
-	"net/url"
 	"os"
 	"os/signal"
 	"syscall"
 
-	"github.com/go-orb/go-orb/config"
 	"github.com/go-orb/go-orb/event"
 	"github.com/go-orb/go-orb/log"
 	"github.com/go-orb/go-orb/types"
+	"github.com/go-orb/plugins/config/source/cli/urfave"
 	"github.com/go-orb/wire"
 )
 
-// provideConfigData reads the config from cli and returns it.
-func provideConfigData(
-	serviceName types.ServiceName,
-	serviceVersion types.ServiceVersion,
-) (types.ConfigData, error) {
-	u, err := url.Parse("cli://urfave")
-	if err != nil {
-		return nil, err
-	}
-
-	cfgSections := types.SplitServiceName(serviceName)
-
-	data, err := config.Read([]*url.URL{u}, cfgSections)
-
-	return data, err
-}
-
 type wireRunResult string
 
 type wireRunCallback func(
@@ -83,7 +65,7 @@ func run(
 	cb wireRunCallback,
 ) (wireRunResult, error) {
 	panic(wire.Build(
-		provideConfigData,
+		urfave.ProvideConfigData,
 		wire.Value([]log.Option{}),
 		log.Provide,
 		wire.Value([]event.Option{}),