Skip to content

Commit 72fcb61

Browse files
jochumdevjochumdev
committed
feat: Implement go-orb components changes.
1 parent a65337d commit 72fcb61

File tree

21 files changed

+202
-113
lines changed

21 files changed

+202
-113
lines changed

‎benchmarks/event/cmd/handler/wire.go‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,12 +33,13 @@ type wireRunCallback func(
3333
func wireRun(
3434
serviceName types.ServiceName,
3535
serviceVersion types.ServiceVersion,
36+
components *types.Components,
3637
logger log.Logger,
3738
event event.Handler,
3839
cb wireRunCallback,
3940
) (wireRunResult, error) {
4041
// Orb start
41-
for _, c := range types.Components.Iterate(false) {
42+
for _, c := range components.Iterate(false) {
4243
err := c.Start()
4344
if err != nil {
4445
logger.Error("Failed to start", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -56,7 +57,7 @@ func wireRun(
5657
// Orb shutdown.
5758
ctx := context.Background()
5859

59-
for _, c := range types.Components.Iterate(true) {
60+
for _, c := range components.Iterate(true) {
6061
err := c.Stop(ctx)
6162
if err != nil {
6263
logger.Error("Failed to stop", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -73,6 +74,7 @@ func run(
7374
cb wireRunCallback,
7475
) (wireRunResult, error) {
7576
panic(wire.Build(
77+
types.ProvideComponents,
7678
urfave.ProvideConfigData,
7779
wire.Value([]log.Option{}),
7880
log.Provide,

‎benchmarks/event/cmd/handler/wire_gen.go‎

Lines changed: 12 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎benchmarks/event/cmd/request/wire.go‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,13 @@ type wireRunCallback func(
3232
func wireRun(
3333
serviceName types.ServiceName,
3434
configs types.ConfigData,
35+
components *types.Components,
3536
logger log.Logger,
3637
event event.Handler,
3738
cb wireRunCallback,
3839
) (wireRunResult, error) {
3940
// Orb start
40-
for _, c := range types.Components.Iterate(false) {
41+
for _, c := range components.Iterate(false) {
4142
err := c.Start()
4243
if err != nil {
4344
logger.Error("Failed to start", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -55,7 +56,7 @@ func wireRun(
5556
// Orb shutdown.
5657
ctx := context.Background()
5758

58-
for _, c := range types.Components.Iterate(true) {
59+
for _, c := range components.Iterate(true) {
5960
err := c.Stop(ctx)
6061
if err != nil {
6162
logger.Error("Failed to stop", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -72,6 +73,7 @@ func run(
7273
cb wireRunCallback,
7374
) (wireRunResult, error) {
7475
panic(wire.Build(
76+
types.ProvideComponents,
7577
urfave.ProvideConfigData,
7678
wire.Value([]log.Option{}),
7779
log.Provide,

‎benchmarks/event/cmd/request/wire_gen.go‎

Lines changed: 12 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,12 +51,13 @@ type wireRunCallback func(
5151
func wireRun(
5252
serviceName types.ServiceName,
5353
configs types.ConfigData,
54+
components *types.Components,
5455
logger log.Logger,
5556
cli client.Type,
5657
cb wireRunCallback,
5758
) (wireRunResult, error) {
5859
// Orb start
59-
for _, c := range types.Components.Iterate(false) {
60+
for _, c := range components.Iterate(false) {
6061
err := c.Start()
6162
if err != nil {
6263
logger.Error("Failed to start", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -74,7 +75,7 @@ func wireRun(
7475
// Orb shutdown.
7576
ctx := context.Background()
7677

77-
for _, c := range types.Components.Iterate(true) {
78+
for _, c := range components.Iterate(true) {
7879
err := c.Stop(ctx)
7980
if err != nil {
8081
logger.Error("Failed to stop", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -91,6 +92,7 @@ func run(
9192
cb wireRunCallback,
9293
) (wireRunResult, error) {
9394
panic(wire.Build(
95+
types.ProvideComponents,
9496
urfave.ProvideConfigData,
9597
wire.Value([]log.Option{}),
9698
log.Provide,

‎benchmarks/rps/cmd/orb-rps-client/wire_gen.go‎

Lines changed: 14 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,12 +86,13 @@ type wireRunCallback func(
8686
func wireRun(
8787
serviceName types.ServiceName,
8888
serviceVersion types.ServiceVersion,
89+
components *types.Components,
8990
logger log.Logger,
9091
_ server.Server,
9192
cb wireRunCallback,
9293
) (wireRunResult, error) {
9394
// Orb start
94-
for _, c := range types.Components.Iterate(false) {
95+
for _, c := range components.Iterate(false) {
9596
err := c.Start()
9697
if err != nil {
9798
logger.Error("Failed to start", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -109,7 +110,7 @@ func wireRun(
109110
// Orb shutdown.
110111
ctx := context.Background()
111112

112-
for _, c := range types.Components.Iterate(true) {
113+
for _, c := range components.Iterate(true) {
113114
err := c.Stop(ctx)
114115
if err != nil {
115116
logger.Error("Failed to stop", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -126,6 +127,7 @@ func run(
126127
cb wireRunCallback,
127128
) (wireRunResult, error) {
128129
panic(wire.Build(
130+
types.ProvideComponents,
129131
urfave.ProvideConfigData,
130132
wire.Value([]log.Option{}),
131133
log.Provide,

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

Lines changed: 14 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎event/simple/cmd/handler/wire.go‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,11 @@ type wireRunCallback func(
2727
func wireRun(
2828
logger log.Logger,
2929
event event.Handler,
30+
components *types.Components,
3031
cb wireRunCallback,
3132
) (wireRunResult, error) {
3233
// Orb start
33-
for _, c := range types.Components.Iterate(false) {
34+
for _, c := range components.Iterate(false) {
3435
err := c.Start()
3536
if err != nil {
3637
logger.Error("Failed to start", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -48,7 +49,7 @@ func wireRun(
4849
// Orb shutdown.
4950
ctx := context.Background()
5051

51-
for _, c := range types.Components.Iterate(true) {
52+
for _, c := range components.Iterate(true) {
5253
err := c.Stop(ctx)
5354
if err != nil {
5455
logger.Error("Failed to stop", "error", err, "component", fmt.Sprintf("%s/%s", c.Type(), c.String()))
@@ -65,6 +66,7 @@ func run(
6566
cb wireRunCallback,
6667
) (wireRunResult, error) {
6768
panic(wire.Build(
69+
types.ProvideComponents,
6870
urfave.ProvideConfigData,
6971
wire.Value([]log.Option{}),
7072
log.Provide,

0 commit comments

Comments
 (0)