mirror of
https://codeberg.org/scip/esctl.git
synced 2026-08-24 18:14:18 +02:00
Compare commits
3 Commits
0.0.27
...
feature/he
| Author | SHA1 | Date | |
|---|---|---|---|
| 0902b44780 | |||
| 5e569b91fc | |||
| 82c6d2e7bb |
@@ -75,10 +75,10 @@ func IndexList(conf *cfg.Config) *cli.Command {
|
|||||||
Aliases: []string{"H"},
|
Aliases: []string{"H"},
|
||||||
},
|
},
|
||||||
&cli.BoolFlag{
|
&cli.BoolFlag{
|
||||||
Name: "reds",
|
Name: "failed",
|
||||||
Usage: "include only red failed indicies",
|
Usage: "include only red failed indicies",
|
||||||
Destination: &conf.Failed,
|
Destination: &conf.Failed,
|
||||||
Aliases: []string{"r"},
|
Aliases: []string{"f"},
|
||||||
},
|
},
|
||||||
&cli.StringSliceFlag{
|
&cli.StringSliceFlag{
|
||||||
Name: "filter",
|
Name: "filter",
|
||||||
|
|||||||
@@ -82,8 +82,9 @@ type Config struct {
|
|||||||
SortBy string // sort: -k
|
SortBy string // sort: -k
|
||||||
Ascending bool // sort: -a
|
Ascending bool // sort: -a
|
||||||
|
|
||||||
|
All bool // doc + node ls: -a
|
||||||
Exclude string // cluster compare: -e (regexp)
|
Exclude string // cluster compare: -e (regexp)
|
||||||
All, Verbose bool // cluster status: -a -v
|
Verbose bool // cluster status: -v
|
||||||
Persistent, Transient, Default bool // cluster settings set: -p -t -D
|
Persistent, Transient, Default bool // cluster settings set: -p -t -D
|
||||||
|
|
||||||
Force bool // ccr follower renew: -f
|
Force bool // ccr follower renew: -f
|
||||||
|
|||||||
@@ -53,10 +53,7 @@ func (t *DebugTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
|||||||
contentline = buf.String()
|
contentline = buf.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
if req.Header.Get("Accept") != "" {
|
req = fixRequestHeaders(req)
|
||||||
req.Header.Del("Accept")
|
|
||||||
req.Header.Add("Accept", "application/json")
|
|
||||||
}
|
|
||||||
|
|
||||||
slog.Info("req", "host", req.URL.Host, "uri", req.URL.Path,
|
slog.Info("req", "host", req.URL.Host, "uri", req.URL.Path,
|
||||||
"body", content, "bodyline", contentline,
|
"body", content, "bodyline", contentline,
|
||||||
@@ -66,20 +63,31 @@ func (t *DebugTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
|||||||
return t.Transport.RoundTrip(req)
|
return t.Transport.RoundTrip(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Fixes https://codeberg.org/scip/esctl/issues/79:
|
|
||||||
// the API client has this Accept header hardcoded everywhere:
|
|
||||||
// req.Header.Set("Accept", "application/vnd.elasticsearch+json;compatible-with=9")
|
|
||||||
// While this works pretty well with ES9, it doesn't with ES8. So, we replace
|
|
||||||
// this header with a new one without the compatibility part.
|
|
||||||
type CompatibilityTransport struct {
|
type CompatibilityTransport struct {
|
||||||
Transport http.RoundTripper
|
Transport http.RoundTripper
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *CompatibilityTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
func (t *CompatibilityTransport) RoundTrip(req *http.Request) (*http.Response, error) {
|
||||||
|
req = fixRequestHeaders(req)
|
||||||
|
|
||||||
|
return t.Transport.RoundTrip(req)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Fixes https://codeberg.org/scip/esctl/issues/79:
|
||||||
|
// the API client has this Accept header hardcoded everywhere:
|
||||||
|
// req.Header.Set("Accept", "application/vnd.elasticsearch+json;compatible-with=9")
|
||||||
|
// While this works pretty well with ES9, it doesn't with ES8. So, we replace
|
||||||
|
// this header with a new one without the compatibility part.
|
||||||
|
func fixRequestHeaders(req *http.Request) *http.Request {
|
||||||
if req.Header.Get("Accept") != "" {
|
if req.Header.Get("Accept") != "" {
|
||||||
req.Header.Del("Accept")
|
req.Header.Del("Accept")
|
||||||
req.Header.Add("Accept", "application/json")
|
req.Header.Add("Accept", "application/json")
|
||||||
}
|
}
|
||||||
|
|
||||||
return t.Transport.RoundTrip(req)
|
if req.Header.Get("Content-Type") != "" {
|
||||||
|
req.Header.Del("Content-Type")
|
||||||
|
req.Header.Add("Content-Type", "application/json")
|
||||||
|
}
|
||||||
|
|
||||||
|
return req
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -174,11 +174,16 @@ func ClusterStatus(conf *cfg.Config) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// look for red indices, if any
|
// look for red indices, if any
|
||||||
redindices := 0
|
failedIndices := 0
|
||||||
|
greenIndices := 0
|
||||||
|
|
||||||
for _, index := range *res.indices {
|
for _, index := range *res.indices {
|
||||||
if *index.Health == "red" {
|
switch {
|
||||||
redindices++
|
case *index.Health != "green":
|
||||||
|
failedIndices++
|
||||||
|
case !strings.HasPrefix(*index.Index, "."):
|
||||||
|
// don't count internal indices
|
||||||
|
greenIndices++
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -205,7 +210,8 @@ func ClusterStatus(conf *cfg.Config) error {
|
|||||||
{"Unassigned Primary Shards", res.health.UnassignedPrimaryShards},
|
{"Unassigned Primary Shards", res.health.UnassignedPrimaryShards},
|
||||||
{"Pending Tasks", res.health.NumberOfPendingTasks},
|
{"Pending Tasks", res.health.NumberOfPendingTasks},
|
||||||
{"Nodes", res.health.NumberOfNodes},
|
{"Nodes", res.health.NumberOfNodes},
|
||||||
{"Red Indices", redindices},
|
{"Green Indices", greenIndices},
|
||||||
|
{"Failed Indices", failedIndices},
|
||||||
{"Long Running Tasks", longtasks},
|
{"Long Running Tasks", longtasks},
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -233,6 +239,10 @@ func ClusterStatus(conf *cfg.Config) error {
|
|||||||
for resource, items := range diag.AffectedResources {
|
for resource, items := range diag.AffectedResources {
|
||||||
table.Entries = append(table.Entries, []any{" -> affected " + resource, strings.Join(items, ",")})
|
table.Entries = append(table.Entries, []any{" -> affected " + resource, strings.Join(items, ",")})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if diag.Action != "" {
|
||||||
|
table.AddRow(" -> suggested action to fix", diag.Action)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user