Skip to content

Commit 4a634eb

Browse files
[9.3](backport #49838) idxmgmt: remove redundant beatPaths parameter (#50249)
* idxmgmt: remove redundant beatPaths parameter (#49838) NewESClientHandler and NewFileClientHandler accepted both beat.Info and *paths.Path. Now that Info carries Paths, drop the separate argument and pass info.Paths to the downstream template loaders. (cherry picked from commit 8b7236f) # Conflicts: # libbeat/cmd/export/ilm_policy.go # libbeat/cmd/export/template.go # libbeat/cmd/instance/beat.go * Resolve backport conflicts in libbeat/cmd --------- Co-authored-by: Orestis Floros <orestis.floros@elastic.co>
1 parent f637ed0 commit 4a634eb

4 files changed

Lines changed: 8 additions & 9 deletions

File tree

libbeat/cmd/export/ilm_policy.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ func GenGetILMPolicyCmd(settings instance.Settings) *cobra.Command {
4545
// the way this works, we decide to export ILM or DSL based on the user's config.
4646
// This means that if a user has no index management config, we'll default to ILM, regardless of what the user
4747
// is connected to. Might not be a problem since a user who doesn't have any custom lifecycle config has nothing to export?
48-
clientHandler, err := idxmgmt.NewFileClientHandler(newIdxmgmtClient(dir, version), b.Info, b.Info.Paths, b.Config.LifecycleConfig)
48+
clientHandler, err := idxmgmt.NewFileClientHandler(newIdxmgmtClient(dir, version), b.Info, b.Config.LifecycleConfig)
4949
if err != nil {
5050
fatalf("error creating file handler: %s", err)
5151
}

libbeat/cmd/export/template.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ func GenTemplateConfigCmd(settings instance.Settings) *cobra.Command {
4747
fatalfInitCmd(err)
4848
}
4949

50-
clientHandler, err := idxmgmt.NewFileClientHandler(newIdxmgmtClient(dir, version), b.Info, b.Info.Paths, b.Config.LifecycleConfig)
50+
clientHandler, err := idxmgmt.NewFileClientHandler(newIdxmgmtClient(dir, version), b.Info, b.Config.LifecycleConfig)
5151
if err != nil {
5252
fatalf("error creating file handler: %s", err)
5353
}

libbeat/cmd/instance/beat.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -690,7 +690,7 @@ func (b *Beat) Setup(settings Settings, bt beat.Creator, setup SetupSettings) er
690690
loadILM = idxmgmt.LoadModeEnabled
691691
}
692692

693-
mgmtHandler, err := idxmgmt.NewESClientHandler(esClient, b.Info, b.Info.Paths, b.Config.LifecycleConfig)
693+
mgmtHandler, err := idxmgmt.NewESClientHandler(esClient, b.Info, b.Config.LifecycleConfig)
694694
if err != nil {
695695
return fmt.Errorf("error creating index management handler: %w", err)
696696
}
@@ -1134,7 +1134,7 @@ func (b *Beat) registerESIndexManagement() error {
11341134

11351135
func (b *Beat) indexSetupCallback() elasticsearch.ConnectCallback {
11361136
return func(esClient *eslegclient.Connection, _ *logp.Logger) error {
1137-
mgmtHandler, err := idxmgmt.NewESClientHandler(esClient, b.Info, b.Info.Paths, b.Config.LifecycleConfig)
1137+
mgmtHandler, err := idxmgmt.NewESClientHandler(esClient, b.Info, b.Config.LifecycleConfig)
11381138
if err != nil {
11391139
return fmt.Errorf("error creating index management handler: %w", err)
11401140
}

libbeat/idxmgmt/client_handler.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ import (
2323
"github.com/elastic/beats/v7/libbeat/beat"
2424
"github.com/elastic/beats/v7/libbeat/idxmgmt/lifecycle"
2525
"github.com/elastic/beats/v7/libbeat/template"
26-
"github.com/elastic/elastic-agent-libs/paths"
2726
"github.com/elastic/elastic-agent-libs/version"
2827
)
2928

@@ -60,12 +59,12 @@ func NewClientHandler(ilm lifecycle.ClientHandler, template template.Loader) Cli
6059

6160
// NewESClientHandler returns a new ESLoader instance,
6261
// initialized with an ilm and template client handler based on the passed in client.
63-
func NewESClientHandler(client ESClient, info beat.Info, beatPaths *paths.Path, cfg lifecycle.RawConfig) (ClientHandler, error) {
62+
func NewESClientHandler(client ESClient, info beat.Info, cfg lifecycle.RawConfig) (ClientHandler, error) {
6463
esHandler, err := lifecycle.NewESClientHandler(client, info, cfg)
6564
if err != nil {
6665
return nil, fmt.Errorf("error creating ES handler: %w", err)
6766
}
68-
loader, err := template.NewESLoader(client, esHandler, info.Logger, beatPaths)
67+
loader, err := template.NewESLoader(client, esHandler, info.Logger, info.Paths)
6968
if err != nil {
7069
return nil, fmt.Errorf("error creating ES loader: %w", err)
7170
}
@@ -74,10 +73,10 @@ func NewESClientHandler(client ESClient, info beat.Info, beatPaths *paths.Path,
7473

7574
// NewFileClientHandler returns a new ESLoader instance,
7675
// initialized with an ilm and template client handler based on the passed in client.
77-
func NewFileClientHandler(client FileClient, info beat.Info, beatPaths *paths.Path, cfg lifecycle.RawConfig) (ClientHandler, error) {
76+
func NewFileClientHandler(client FileClient, info beat.Info, cfg lifecycle.RawConfig) (ClientHandler, error) {
7877
mgmt, err := lifecycle.NewFileClientHandler(client, info, cfg)
7978
if err != nil {
8079
return nil, fmt.Errorf("error creating client handler: %w", err)
8180
}
82-
return NewClientHandler(mgmt, template.NewFileLoader(client, mgmt.Mode() == lifecycle.DSL, info.Logger, beatPaths)), nil
81+
return NewClientHandler(mgmt, template.NewFileLoader(client, mgmt.Mode() == lifecycle.DSL, info.Logger, info.Paths)), nil
8382
}

0 commit comments

Comments
 (0)