scip/esctl
1
0
Fork 0
mirror of https://codeberg.org/scip/esctl.git synced 2026-08-24 22:34:19 +02:00
Code Issues Packages Projects Releases Wiki Activity

started implementing auto config loader

Browse Source
This commit is contained in:
Thomas von Dein
2026-07-02 13:49:32 +02:00
parent b573d63c54
commit 489074da01
3 changed files with 214 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
pkg/cfg/cluster.go
View File

@@ -223,27 +223,35 @@ func (cluster *Cluster) IsReachable() (bool, error) {
return false, nil
}
func (conf *Config) SetupES() error {
func (conf *Config) SetupElasticClient(name string, cluster *Cluster) error {
cluster.Name = name
cluster.DebugHTTP = conf.DebugHTTP
opts := cluster.getDefaultOptions()
switch {
case cluster.Pass != "" && cluster.User != "":
opts = append(opts, elasticsearch.WithBasicAuth(cluster.User, cluster.Pass))
case cluster.Token != "":
opts = append(opts, elasticsearch.WithAPIKey(cluster.Token))
}
es, err := elasticsearch.NewTyped(opts...)
if err != nil {
return fmt.Errorf("failed to setup elasticsearch connection: %w", err)
}
cluster.SetClient(es)
return nil
}
func (conf *Config) SetupElasticClients() error {
for name, cluster := range conf.Clusters {
cluster.Name = name
cluster.DebugHTTP = conf.DebugHTTP
opts := cluster.getDefaultOptions()
switch {
case cluster.Pass != "" && cluster.User != "":
opts = append(opts, elasticsearch.WithBasicAuth(cluster.User, cluster.Pass))
case cluster.Token != "":
opts = append(opts, elasticsearch.WithAPIKey(cluster.Token))
if err := conf.SetupElasticClient(name, cluster); err != nil {
return err
}
es, err := elasticsearch.NewTyped(opts...)
if err != nil {
return fmt.Errorf("failed to setup elasticsearch connection: %w", err)
}
cluster.SetClient(es)
}
return nil