From 3bd26fde7a2b3c59fcb7762e748a2a61da8636e9 Mon Sep 17 00:00:00 2001 From: Thomas von Dein Date: Mon, 11 May 2026 10:21:43 +0200 Subject: [PATCH] fix coredump, register default cluster name --- cmd/cluster.go | 6 ++++++ pkg/cfg/config.go | 13 +++++++------ 2 files changed, 13 insertions(+), 6 deletions(-) diff --git a/cmd/cluster.go b/cmd/cluster.go index 7edd479..3c1ff75 100644 --- a/cmd/cluster.go +++ b/cmd/cluster.go @@ -194,6 +194,12 @@ func ClusterSettingsSet(conf *cfg.Config) *cli.Command { }, Action: func(ctx context.Context, cmd *cli.Command) error { + args := cmd.Args() + + if args.Len() == 0 { + return errors.New("at least one setting must be specified (format: setting:value)") + } + if err := es.ClusterSettingsSet(conf, cmd.Args()); err != nil { return err } diff --git a/pkg/cfg/config.go b/pkg/cfg/config.go index b6c34d6..44e86eb 100644 --- a/pkg/cfg/config.go +++ b/pkg/cfg/config.go @@ -24,7 +24,6 @@ import ( "net/http" "os" - "github.com/alecthomas/repr" "github.com/elastic/elastic-transport-go/v8/elastictransport" "github.com/elastic/go-elasticsearch/v9" "gopkg.in/yaml.v3" @@ -90,11 +89,12 @@ func (conf *Config) Init() error { } } else { if len(conf.Clusters) == 1 { - for _, cluster := range conf.Clusters { + for name, cluster := range conf.Clusters { conf.DefaultCluster = cluster + conf.CurrentCluster = name } } else { - for _, cluster := range conf.Clusters { + for name, cluster := range conf.Clusters { _, err := cluster.ES.Cluster.Health(). Header("content-type", "application/json"). Header("accept", "application/json"). @@ -102,14 +102,15 @@ func (conf *Config) Init() error { if err == nil { conf.DefaultCluster = cluster + conf.CurrentCluster = name } } } } - if conf.Debug { - repr.Println(conf) - } + // if conf.Debug { + // repr.Println(conf) + // } return nil }