Skip to content

Commit 0a73cc0

Browse files
committed
refactor(core): migrate comp/core/flare to V2 component architecture
Split comp/core/flare into def/impl/mock/fx sub-packages following the V2 component pattern, removing fx.In/fx.Out from impl and exporting Requires/Provides structs. Update all callers to import from the new sub-packages.
1 parent f5f54d6 commit 0a73cc0

64 files changed

Lines changed: 462 additions & 381 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

BUILD.bazel

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,8 +122,6 @@ exports_files(glob(
122122
# gazelle:exclude comp/core/diagnose/fx
123123
# gazelle:exclude comp/core/diagnose/impl
124124
# gazelle:exclude comp/core/diagnose/local
125-
# gazelle:exclude comp/core/flare/flareimpl
126-
# gazelle:exclude comp/core/flare/helpers
127125
# gazelle:exclude comp/core/gui/fx
128126
# gazelle:exclude comp/core/gui/impl
129127
# gazelle:exclude comp/core/hostname/remotehostnameimpl

cmd/agent/subcommands/flare/command.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@ import (
3434
"github.com/DataDog/datadog-agent/comp/core/diagnose/format"
3535
diagnosefx "github.com/DataDog/datadog-agent/comp/core/diagnose/fx"
3636
diagnoseLocal "github.com/DataDog/datadog-agent/comp/core/diagnose/local"
37-
"github.com/DataDog/datadog-agent/comp/core/flare"
38-
"github.com/DataDog/datadog-agent/comp/core/flare/helpers"
37+
flare "github.com/DataDog/datadog-agent/comp/core/flare/def"
38+
flarfx "github.com/DataDog/datadog-agent/comp/core/flare/fx"
3939
flaretypes "github.com/DataDog/datadog-agent/comp/core/flare/types"
4040
"github.com/DataDog/datadog-agent/comp/core/hostname/hostnameimpl"
4141
ipc "github.com/DataDog/datadog-agent/comp/core/ipc/def"
@@ -135,7 +135,7 @@ func Commands(globalParams *command.GlobalParams) []*cobra.Command {
135135
SysprobeConfigParams: sysprobeconfigimpl.NewParams(sysprobeconfigimpl.WithSysProbeConfFilePath(globalParams.SysProbeConfFilePath), sysprobeconfigimpl.WithFleetPoliciesDirPath(globalParams.FleetPoliciesDirPath)),
136136
LogParams: log.ForOneShot(command.LoggerName, cliParams.logLevelDefaultOff.Value(), false),
137137
}),
138-
flare.Module(flareParams),
138+
flarfx.Module(flareParams),
139139
flareprofilerfx.Module(),
140140
// workloadmeta setup
141141
wmcatalog.GetCatalog(),
@@ -320,7 +320,7 @@ func makeFlare(flareComp flare.Component,
320320
}
321321
}
322322

323-
response, e := flareComp.Send(filePath, caseID, customerEmail, helpers.NewLocalFlareSource())
323+
response, e := flareComp.Send(filePath, caseID, customerEmail, flaretypes.NewLocalFlareSource())
324324
fmt.Println(response)
325325
return e
326326
}

cmd/agent/subcommands/run/command.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,8 @@ import (
8080
configstreamfx "github.com/DataDog/datadog-agent/comp/core/configstream/fx"
8181
diagnose "github.com/DataDog/datadog-agent/comp/core/diagnose/def"
8282
diagnosefx "github.com/DataDog/datadog-agent/comp/core/diagnose/fx"
83-
"github.com/DataDog/datadog-agent/comp/core/flare"
83+
flare "github.com/DataDog/datadog-agent/comp/core/flare/def"
84+
flarfx "github.com/DataDog/datadog-agent/comp/core/flare/fx"
8485
flaretypes "github.com/DataDog/datadog-agent/comp/core/flare/types"
8586
guidef "github.com/DataDog/datadog-agent/comp/core/gui/def"
8687
guifx "github.com/DataDog/datadog-agent/comp/core/gui/fx"
@@ -411,7 +412,7 @@ func run(log log.Component,
411412

412413
func getSharedFxOption() fx.Option {
413414
return fx.Options(
414-
flare.Module(flare.NewParams(
415+
flarfx.Module(flare.NewParams(
415416
defaultpaths.GetDistPath(),
416417
defaultpaths.PyChecksPath,
417418
defaultpaths.LogFile,

cmd/agent/subcommands/run/command_windows.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ import (
4949
agenttelemetry "github.com/DataDog/datadog-agent/comp/core/agenttelemetry/def"
5050
autodiscovery "github.com/DataDog/datadog-agent/comp/core/autodiscovery/def"
5151
"github.com/DataDog/datadog-agent/comp/core/config"
52-
"github.com/DataDog/datadog-agent/comp/core/flare"
52+
flare "github.com/DataDog/datadog-agent/comp/core/flare/def"
5353
guidef "github.com/DataDog/datadog-agent/comp/core/gui/def"
5454
"github.com/DataDog/datadog-agent/comp/core/hostname/hostnameinterface/def"
5555
ipc "github.com/DataDog/datadog-agent/comp/core/ipc/def"

cmd/otel-agent/subcommands/flare/command.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,9 @@ import (
3232
"github.com/DataDog/datadog-agent/cmd/otel-agent/subcommands"
3333
"github.com/DataDog/datadog-agent/comp/core"
3434
"github.com/DataDog/datadog-agent/comp/core/config"
35-
"github.com/DataDog/datadog-agent/comp/core/flare"
36-
"github.com/DataDog/datadog-agent/comp/core/flare/helpers"
35+
flare "github.com/DataDog/datadog-agent/comp/core/flare/def"
36+
flarfx "github.com/DataDog/datadog-agent/comp/core/flare/fx"
37+
flaretypes "github.com/DataDog/datadog-agent/comp/core/flare/types"
3738
ipcfx "github.com/DataDog/datadog-agent/comp/core/ipc/fx"
3839
log "github.com/DataDog/datadog-agent/comp/core/log/def"
3940
workloadmeta "github.com/DataDog/datadog-agent/comp/core/workloadmeta/def"
@@ -85,7 +86,7 @@ func MakeCommand(globalConfGetter func() *subcommands.GlobalParams) *cobra.Comma
8586
ConfigParams: config.NewAgentParams("", config.WithConfigName(globalParams.ConfigName)),
8687
LogParams: log.ForOneShot(globalParams.LoggerName, "info", false),
8788
}),
88-
flare.Module(flareParams),
89+
flarfx.Module(flareParams),
8990
core.Bundle(),
9091
// Provide empty option for workloadmeta (optional dependency)
9192
fx.Supply(option.None[workloadmeta.Component]()),
@@ -150,7 +151,7 @@ func makeFlare(
150151
}
151152

152153
// Upload flare
153-
response, e := flareComp.Send(filePath, caseID, customerEmail, helpers.NewLocalFlareSource())
154+
response, e := flareComp.Send(filePath, caseID, customerEmail, flaretypes.NewLocalFlareSource())
154155
fmt.Println(response)
155156
return e
156157
}

cmd/security-agent/subcommands/flare/command.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,8 @@ import (
1717
"github.com/DataDog/datadog-agent/cmd/security-agent/command"
1818
"github.com/DataDog/datadog-agent/comp/core"
1919
"github.com/DataDog/datadog-agent/comp/core/config"
20-
"github.com/DataDog/datadog-agent/comp/core/flare/helpers"
20+
flareimpl "github.com/DataDog/datadog-agent/comp/core/flare/impl"
21+
flaretypes "github.com/DataDog/datadog-agent/comp/core/flare/types"
2122
ipc "github.com/DataDog/datadog-agent/comp/core/ipc/def"
2223
ipcfx "github.com/DataDog/datadog-agent/comp/core/ipc/fx"
2324
log "github.com/DataDog/datadog-agent/comp/core/log/def"
@@ -117,7 +118,7 @@ func requestFlare(_ log.Component, config config.Component, _ secrets.Component,
117118
}
118119
}
119120

120-
response, e := helpers.SendFlare(config, filePath, params.caseID, params.customerEmail, helpers.NewLocalFlareSource())
121+
response, e := flareimpl.SendFlare(config, filePath, params.caseID, params.customerEmail, flaretypes.NewLocalFlareSource())
121122
fmt.Println(response)
122123
if e != nil {
123124
return e

cmd/systray/command/command.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@ import (
2121
"github.com/DataDog/datadog-agent/comp/core"
2222
"github.com/DataDog/datadog-agent/comp/core/config"
2323
diagnosefx "github.com/DataDog/datadog-agent/comp/core/diagnose/fx"
24-
"github.com/DataDog/datadog-agent/comp/core/flare"
24+
flare "github.com/DataDog/datadog-agent/comp/core/flare/def"
25+
flarfx "github.com/DataDog/datadog-agent/comp/core/flare/fx"
2526
"github.com/DataDog/datadog-agent/comp/core/hostname/hostnameimpl"
2627
ipcfx "github.com/DataDog/datadog-agent/comp/core/ipc/fx"
2728
log "github.com/DataDog/datadog-agent/comp/core/log/def"
@@ -100,7 +101,7 @@ func MakeCommand() *cobra.Command {
100101
core.Bundle(),
101102
hostnameimpl.Module(),
102103
// flare
103-
flare.Module(flare.NewParams(
104+
flarfx.Module(flare.NewParams(
104105
defaultpaths.GetDistPath(),
105106
defaultpaths.PyChecksPath,
106107
defaultpaths.LogFile,

comp/core/diagnose/impl/diagnose_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ import (
1616
"github.com/stretchr/testify/assert"
1717

1818
diagnose "github.com/DataDog/datadog-agent/comp/core/diagnose/def"
19-
flarehelpers "github.com/DataDog/datadog-agent/comp/core/flare/helpers"
19+
flarehelpers "github.com/DataDog/datadog-agent/comp/core/flare/impl"
2020
)
2121

2222
const runSuitetextresult = `=== Starting diagnose ===

comp/core/flare/BUILD.bazel

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,8 @@
1-
# gazelle:ignore
1+
load("@rules_go//go:def.bzl", "go_library")
2+
3+
go_library(
4+
name = "flare",
5+
srcs = ["doc.go"],
6+
importpath = "github.com/DataDog/datadog-agent/comp/core/flare",
7+
visibility = ["//visibility:public"],
8+
)

comp/core/flare/component.go

Lines changed: 0 additions & 43 deletions
This file was deleted.

0 commit comments

Comments
 (0)