mirror of
https://codeberg.org/scip/esctl.git
synced 2026-08-24 20:54:18 +02:00
Compare commits
1 Commits
feature/re
...
fix/crashe
| Author | SHA1 | Date | |
|---|---|---|---|
| 54610cdbb4 |
9
Makefile
9
Makefile
@@ -110,12 +110,3 @@ profile: buildlocal
|
|||||||
./esctl api ls --profile-file cpu.profile
|
./esctl api ls --profile-file cpu.profile
|
||||||
go tool pprof -text esctl cpu.profile
|
go tool pprof -text esctl cpu.profile
|
||||||
go tool pprof --http localhost:8888 ./esctl cpu.profile
|
go tool pprof --http localhost:8888 ./esctl cpu.profile
|
||||||
|
|
||||||
docker-up:
|
|
||||||
make -C t up
|
|
||||||
|
|
||||||
docker-waitup:
|
|
||||||
make -C t up
|
|
||||||
|
|
||||||
docker-down:
|
|
||||||
make -C t down
|
|
||||||
|
|||||||
10
README.md
10
README.md
@@ -216,7 +216,7 @@ Pending Tasks 0
|
|||||||
Nodes 3
|
Nodes 3
|
||||||
Red Indices 0
|
Red Indices 0
|
||||||
Long Running Tasks 2
|
Long Running Tasks 2
|
||||||
indices 221
|
Indicies 221
|
||||||
Docs 9854777
|
Docs 9854777
|
||||||
Total Size 3.4 GB
|
Total Size 3.4 GB
|
||||||
Total Queries 4210411
|
Total Queries 4210411
|
||||||
@@ -534,7 +534,7 @@ cluster - manage cluster[s]
|
|||||||
allocate-empty-primary - allocate an empty primary shard to a node
|
allocate-empty-primary - allocate an empty primary shard to a node
|
||||||
allocate-stale-primary - allocate a stale primary shard to a node
|
allocate-stale-primary - allocate a stale primary shard to a node
|
||||||
datastream - manage data streams
|
datastream - manage data streams
|
||||||
list - list indices
|
list - list indicies
|
||||||
show - show details about an data stream
|
show - show details about an data stream
|
||||||
create - create a new data stream
|
create - create a new data stream
|
||||||
delete - delete a data stream
|
delete - delete a data stream
|
||||||
@@ -554,8 +554,8 @@ ilm - manage index lifecycle
|
|||||||
list - list index rollover config
|
list - list index rollover config
|
||||||
show - show rollover forecast over all indices
|
show - show rollover forecast over all indices
|
||||||
explain - explain ilm condition of an index
|
explain - explain ilm condition of an index
|
||||||
index - manage indices
|
index - manage indicies
|
||||||
list - list indices
|
list - list indicies
|
||||||
show - show details about an index
|
show - show details about an index
|
||||||
create - create a new index
|
create - create a new index
|
||||||
update - update an index
|
update - update an index
|
||||||
@@ -564,7 +564,6 @@ index - manage indices
|
|||||||
fields - show info about field capabilities
|
fields - show info about field capabilities
|
||||||
ilm - show ilm status
|
ilm - show ilm status
|
||||||
du - show index disk usage
|
du - show index disk usage
|
||||||
copy - copy (reindex) documents from one index to another
|
|
||||||
alias - manage index aliases
|
alias - manage index aliases
|
||||||
create - create an index alias
|
create - create an index alias
|
||||||
list - list index aliases
|
list - list index aliases
|
||||||
@@ -588,7 +587,6 @@ role - manage roles
|
|||||||
show - show details about a role
|
show - show details about a role
|
||||||
diff - show differences between roles and CSV baseline
|
diff - show differences between roles and CSV baseline
|
||||||
search - search within an index
|
search - search within an index
|
||||||
searchql - search using ES/QL language
|
|
||||||
shard - manage shards
|
shard - manage shards
|
||||||
list - list shards
|
list - list shards
|
||||||
show - show details about a shard
|
show - show details about a shard
|
||||||
|
|||||||
1
TODO.md
1
TODO.md
@@ -6,3 +6,4 @@
|
|||||||
- add datastream support:
|
- add datastream support:
|
||||||
https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-indices-get-data-stream
|
https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-indices-get-data-stream
|
||||||
|
|
||||||
|
also exclude data stream backing indices from index ls
|
||||||
|
|||||||
@@ -52,7 +52,7 @@ func CcrStatus(conf *cfg.Config) *cli.Command {
|
|||||||
Flags: []cli.Flag{
|
Flags: []cli.Flag{
|
||||||
&cli.StringFlag{
|
&cli.StringFlag{
|
||||||
Name: "exclude",
|
Name: "exclude",
|
||||||
Usage: "regexp of indices to exclude",
|
Usage: "regexp of indicies to exclude",
|
||||||
Destination: &conf.Exclude,
|
Destination: &conf.Exclude,
|
||||||
Aliases: []string{"e"},
|
Aliases: []string{"e"},
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -34,7 +34,6 @@ const (
|
|||||||
Cilm
|
Cilm
|
||||||
Cnode
|
Cnode
|
||||||
Cclustersettings
|
Cclustersettings
|
||||||
Cindextemplate
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func complete(conf *cfg.Config, cmd *cli.Command, what int) {
|
func complete(conf *cfg.Config, cmd *cli.Command, what int) {
|
||||||
@@ -66,8 +65,6 @@ func complete(conf *cfg.Config, cmd *cli.Command, what int) {
|
|||||||
list, err = es.NodeNames(conf)
|
list, err = es.NodeNames(conf)
|
||||||
case Cclustersettings:
|
case Cclustersettings:
|
||||||
list, err = es.ClusterSettingsNames(conf)
|
list, err = es.ClusterSettingsNames(conf)
|
||||||
case Cindextemplate:
|
|
||||||
list, err = es.IndexTemplateNames(conf)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -46,7 +46,7 @@ func DatastreamList(conf *cfg.Config) *cli.Command {
|
|||||||
return &cli.Command{
|
return &cli.Command{
|
||||||
Name: "list",
|
Name: "list",
|
||||||
Aliases: []string{"ls"},
|
Aliases: []string{"ls"},
|
||||||
Usage: "list indices",
|
Usage: "list indicies",
|
||||||
|
|
||||||
Flags: []cli.Flag{
|
Flags: []cli.Flag{
|
||||||
&cli.IntFlag{
|
&cli.IntFlag{
|
||||||
@@ -169,7 +169,7 @@ func DatastreamRollover(conf *cfg.Config) *cli.Command {
|
|||||||
Usage: "roll over after max age (eg: 7d, 2m, 8h)",
|
Usage: "roll over after max age (eg: 7d, 2m, 8h)",
|
||||||
Destination: &conf.MaxAge,
|
Destination: &conf.MaxAge,
|
||||||
},
|
},
|
||||||
&cli.Int64Flag{
|
&cli.IntFlag{
|
||||||
Name: "max-docs",
|
Name: "max-docs",
|
||||||
Usage: "roll over after max docs",
|
Usage: "roll over after max docs",
|
||||||
Destination: &conf.MaxDocs,
|
Destination: &conf.MaxDocs,
|
||||||
|
|||||||
@@ -89,7 +89,7 @@ func IlmForecastList(conf *cfg.Config) *cli.Command {
|
|||||||
},
|
},
|
||||||
&cli.BoolFlag{
|
&cli.BoolFlag{
|
||||||
Name: "hidden",
|
Name: "hidden",
|
||||||
Usage: "include hidden indices",
|
Usage: "include hidden indicies",
|
||||||
Destination: &conf.Hidden,
|
Destination: &conf.Hidden,
|
||||||
Aliases: []string{"H"},
|
Aliases: []string{"H"},
|
||||||
},
|
},
|
||||||
|
|||||||
92
cmd/index.go
92
cmd/index.go
@@ -30,7 +30,7 @@ func Index(conf *cfg.Config) *cli.Command {
|
|||||||
return &cli.Command{
|
return &cli.Command{
|
||||||
Name: "index",
|
Name: "index",
|
||||||
Aliases: []string{"i"},
|
Aliases: []string{"i"},
|
||||||
Usage: "manage indices",
|
Usage: "manage indicies",
|
||||||
|
|
||||||
Commands: []*cli.Command{
|
Commands: []*cli.Command{
|
||||||
IndexList(conf),
|
IndexList(conf),
|
||||||
@@ -42,7 +42,6 @@ func Index(conf *cfg.Config) *cli.Command {
|
|||||||
IndexFields(conf),
|
IndexFields(conf),
|
||||||
IndexIlm(conf),
|
IndexIlm(conf),
|
||||||
IndexDu(conf),
|
IndexDu(conf),
|
||||||
IndexCopy(conf),
|
|
||||||
|
|
||||||
// sub commands
|
// sub commands
|
||||||
IndexAlias(conf),
|
IndexAlias(conf),
|
||||||
@@ -55,7 +54,7 @@ func IndexList(conf *cfg.Config) *cli.Command {
|
|||||||
return &cli.Command{
|
return &cli.Command{
|
||||||
Name: "list",
|
Name: "list",
|
||||||
Aliases: []string{"ls"},
|
Aliases: []string{"ls"},
|
||||||
Usage: "list indices",
|
Usage: "list indicies",
|
||||||
|
|
||||||
Flags: []cli.Flag{
|
Flags: []cli.Flag{
|
||||||
&cli.IntFlag{
|
&cli.IntFlag{
|
||||||
@@ -66,25 +65,25 @@ func IndexList(conf *cfg.Config) *cli.Command {
|
|||||||
},
|
},
|
||||||
&cli.BoolFlag{
|
&cli.BoolFlag{
|
||||||
Name: "partials",
|
Name: "partials",
|
||||||
Usage: "include partial indices",
|
Usage: "include partial indicies",
|
||||||
Destination: &conf.Partials,
|
Destination: &conf.Partials,
|
||||||
Aliases: []string{"p"},
|
Aliases: []string{"p"},
|
||||||
},
|
},
|
||||||
&cli.BoolFlag{
|
&cli.BoolFlag{
|
||||||
Name: "hidden",
|
Name: "hidden",
|
||||||
Usage: "include hidden indices",
|
Usage: "include hidden indicies",
|
||||||
Destination: &conf.Hidden,
|
Destination: &conf.Hidden,
|
||||||
Aliases: []string{"H"},
|
Aliases: []string{"H"},
|
||||||
},
|
},
|
||||||
&cli.BoolFlag{
|
&cli.BoolFlag{
|
||||||
Name: "failed",
|
Name: "failed",
|
||||||
Usage: "include only red failed indices",
|
Usage: "include only red failed indicies",
|
||||||
Destination: &conf.Failed,
|
Destination: &conf.Failed,
|
||||||
Aliases: []string{"f"},
|
Aliases: []string{"f"},
|
||||||
},
|
},
|
||||||
&cli.StringSliceFlag{
|
&cli.StringSliceFlag{
|
||||||
Name: "filter",
|
Name: "filter",
|
||||||
Usage: "show only indices matching the filter",
|
Usage: "show only indicies matching the filter",
|
||||||
Destination: &conf.Filter,
|
Destination: &conf.Filter,
|
||||||
Aliases: []string{"F"},
|
Aliases: []string{"F"},
|
||||||
},
|
},
|
||||||
@@ -300,82 +299,3 @@ func IndexDu(conf *cfg.Config) *cli.Command {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func IndexCopy(conf *cfg.Config) *cli.Command {
|
|
||||||
return &cli.Command{
|
|
||||||
Name: "copy",
|
|
||||||
Aliases: []string{"alias", "cp"},
|
|
||||||
Usage: "copy (reindex) documents from one index to another",
|
|
||||||
UsageText: "index copy [options] -s <source-index> -t <dest-index>",
|
|
||||||
|
|
||||||
Flags: []cli.Flag{
|
|
||||||
// FIXME: not implemented by typed API
|
|
||||||
// &cli.BoolFlag{
|
|
||||||
// Name: "missing", // op_type
|
|
||||||
// Usage: "copy only missing docs",
|
|
||||||
// Destination: &conf.Missing,
|
|
||||||
// Aliases: []string{"m"},
|
|
||||||
// },
|
|
||||||
// &cli.BoolFlag{
|
|
||||||
// Name: "sync", // version_type to external
|
|
||||||
// Usage: "create missing docs and update outdated docs",
|
|
||||||
// Destination: &conf.Sync,
|
|
||||||
// Aliases: []string{"S"},
|
|
||||||
// },
|
|
||||||
&cli.BoolFlag{
|
|
||||||
Name: "force", // conflicts to proceed
|
|
||||||
Usage: "continue reindexing even when conflicts happen",
|
|
||||||
Destination: &conf.Force,
|
|
||||||
Aliases: []string{"f"},
|
|
||||||
},
|
|
||||||
&cli.Float64Flag{
|
|
||||||
Name: "requests-per-second",
|
|
||||||
Usage: "the maximum number of documents to index per second (-1 turns off throttling)",
|
|
||||||
Destination: &conf.RequestsPerSecond,
|
|
||||||
Aliases: []string{"R"},
|
|
||||||
},
|
|
||||||
&cli.Int64Flag{
|
|
||||||
Name: "max-docs",
|
|
||||||
Usage: "the maximum number of documents to reindex",
|
|
||||||
Destination: &conf.MaxDocs,
|
|
||||||
Aliases: []string{"m"},
|
|
||||||
},
|
|
||||||
&cli.DurationFlag{
|
|
||||||
Name: "timeout",
|
|
||||||
Usage: "timeout for write operations (e.g. 300m or 120s)",
|
|
||||||
Destination: &conf.Timeout,
|
|
||||||
Aliases: []string{"T"},
|
|
||||||
},
|
|
||||||
&cli.BoolFlag{
|
|
||||||
Name: "refresh",
|
|
||||||
Usage: "refresh affected shards to make this operation visible to search",
|
|
||||||
Destination: &conf.Refresh,
|
|
||||||
Aliases: []string{"r"},
|
|
||||||
},
|
|
||||||
&cli.BoolFlag{
|
|
||||||
Name: "wait",
|
|
||||||
Usage: "wait for active shards",
|
|
||||||
Destination: &conf.Wait,
|
|
||||||
Aliases: []string{"w"},
|
|
||||||
},
|
|
||||||
&cli.StringSliceFlag{
|
|
||||||
Name: "source",
|
|
||||||
Usage: "source index (multiple supported)",
|
|
||||||
Destination: &conf.SourceIndices,
|
|
||||||
Aliases: []string{"s"},
|
|
||||||
Required: true,
|
|
||||||
},
|
|
||||||
&cli.StringFlag{
|
|
||||||
Name: "target",
|
|
||||||
Usage: "target index",
|
|
||||||
Destination: &conf.Index,
|
|
||||||
Aliases: []string{"t"},
|
|
||||||
Required: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
|
|
||||||
Action: func(ctx context.Context, cmd *cli.Command) error {
|
|
||||||
return es.IndexCopy(conf)
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -121,7 +121,7 @@ func IndexAliasRollover(conf *cfg.Config) *cli.Command {
|
|||||||
Usage: "roll over after max age (eg: 7d, 2m, 8h)",
|
Usage: "roll over after max age (eg: 7d, 2m, 8h)",
|
||||||
Destination: &conf.MaxAge,
|
Destination: &conf.MaxAge,
|
||||||
},
|
},
|
||||||
&cli.Int64Flag{
|
&cli.IntFlag{
|
||||||
Name: "max-docs",
|
Name: "max-docs",
|
||||||
Usage: "roll over after max docs",
|
Usage: "roll over after max docs",
|
||||||
Destination: &conf.MaxDocs,
|
Destination: &conf.MaxDocs,
|
||||||
@@ -159,7 +159,7 @@ func IndexAliasList(conf *cfg.Config) *cli.Command {
|
|||||||
Flags: []cli.Flag{
|
Flags: []cli.Flag{
|
||||||
&cli.StringSliceFlag{
|
&cli.StringSliceFlag{
|
||||||
Name: "filter",
|
Name: "filter",
|
||||||
Usage: "show only aliases for indices matching the filter",
|
Usage: "show only aliases for indicies matching the filter",
|
||||||
Destination: &conf.Filter,
|
Destination: &conf.Filter,
|
||||||
Aliases: []string{"F"},
|
Aliases: []string{"F"},
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -49,23 +49,8 @@ func IndexTemplateList(conf *cfg.Config) *cli.Command {
|
|||||||
Aliases: []string{"ls"},
|
Aliases: []string{"ls"},
|
||||||
Usage: "list index templates",
|
Usage: "list index templates",
|
||||||
|
|
||||||
Flags: []cli.Flag{
|
|
||||||
&cli.StringSliceFlag{
|
|
||||||
Name: "filter-index-pattern",
|
|
||||||
Usage: "show only index templates which use patterns, which match the filter",
|
|
||||||
Destination: &conf.Filter,
|
|
||||||
Aliases: []string{"F"},
|
|
||||||
},
|
|
||||||
&cli.BoolFlag{
|
|
||||||
Name: "hidden",
|
|
||||||
Usage: "show hidden index templates as well",
|
|
||||||
Destination: &conf.Hidden,
|
|
||||||
Aliases: []string{"H"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
|
|
||||||
Action: func(ctx context.Context, cmd *cli.Command) error {
|
Action: func(ctx context.Context, cmd *cli.Command) error {
|
||||||
return es.IndexTemplateList(conf, cmd.Args().Get(0))
|
return es.IndexTemplateList(conf)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -86,7 +71,7 @@ func IndexTemplateShow(conf *cfg.Config) *cli.Command {
|
|||||||
},
|
},
|
||||||
|
|
||||||
ShellComplete: func(ctx context.Context, cmd *cli.Command) {
|
ShellComplete: func(ctx context.Context, cmd *cli.Command) {
|
||||||
complete(conf, cmd, Cindextemplate)
|
complete(conf, cmd, Cindex)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -230,7 +215,7 @@ func IndexTemplateDelete(conf *cfg.Config) *cli.Command {
|
|||||||
},
|
},
|
||||||
|
|
||||||
ShellComplete: func(ctx context.Context, cmd *cli.Command) {
|
ShellComplete: func(ctx context.Context, cmd *cli.Command) {
|
||||||
complete(conf, cmd, Cindextemplate)
|
complete(conf, cmd, Cindex)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
3
go.mod
3
go.mod
@@ -18,7 +18,7 @@ go 1.26
|
|||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/MichaelMure/go-term-markdown v0.1.4
|
github.com/MichaelMure/go-term-markdown v0.1.4
|
||||||
github.com/alecthomas/repr v0.5.3
|
github.com/alecthomas/repr v0.5.2
|
||||||
github.com/charmbracelet/bubbles v1.0.0
|
github.com/charmbracelet/bubbles v1.0.0
|
||||||
github.com/charmbracelet/bubbletea v1.3.10
|
github.com/charmbracelet/bubbletea v1.3.10
|
||||||
github.com/charmbracelet/lipgloss v1.1.0
|
github.com/charmbracelet/lipgloss v1.1.0
|
||||||
@@ -40,7 +40,6 @@ require (
|
|||||||
)
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
codeberg.org/scip/mapmap v0.0.2 // indirect
|
|
||||||
github.com/MichaelMure/go-term-text v0.3.1 // indirect
|
github.com/MichaelMure/go-term-text v0.3.1 // indirect
|
||||||
github.com/alecthomas/chroma v0.7.1 // indirect
|
github.com/alecthomas/chroma v0.7.1 // indirect
|
||||||
github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
|
github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
|
||||||
|
|||||||
8
go.sum
8
go.sum
@@ -1,7 +1,3 @@
|
|||||||
codeberg.org/scip/mapmap v0.0.1 h1:L1jMBo/UNp19MXUF/ONjc1XKVGeuF1x05z0pEhjgkzA=
|
|
||||||
codeberg.org/scip/mapmap v0.0.1/go.mod h1:/ojYo2P7dMA2FWEu+jHKmsKPeq5yDcCvXeHevqZd5OI=
|
|
||||||
codeberg.org/scip/mapmap v0.0.2 h1:0i61jOUwFmGVwPukrMzrx0Fi4T9Qru2nlmibuaJimBo=
|
|
||||||
codeberg.org/scip/mapmap v0.0.2/go.mod h1:/ojYo2P7dMA2FWEu+jHKmsKPeq5yDcCvXeHevqZd5OI=
|
|
||||||
github.com/MichaelMure/go-term-markdown v0.1.4 h1:Ir3kBXDUtOX7dEv0EaQV8CNPpH+T7AfTh0eniMOtNcs=
|
github.com/MichaelMure/go-term-markdown v0.1.4 h1:Ir3kBXDUtOX7dEv0EaQV8CNPpH+T7AfTh0eniMOtNcs=
|
||||||
github.com/MichaelMure/go-term-markdown v0.1.4/go.mod h1:EhcA3+pKYnlUsxYKBJ5Sn1cTQmmBMjeNlpV8nRb+JxA=
|
github.com/MichaelMure/go-term-markdown v0.1.4/go.mod h1:EhcA3+pKYnlUsxYKBJ5Sn1cTQmmBMjeNlpV8nRb+JxA=
|
||||||
github.com/MichaelMure/go-term-text v0.3.1 h1:Kw9kZanyZWiCHOYu9v/8pWEgDQ6UVN9/ix2Vd2zzWf0=
|
github.com/MichaelMure/go-term-text v0.3.1 h1:Kw9kZanyZWiCHOYu9v/8pWEgDQ6UVN9/ix2Vd2zzWf0=
|
||||||
@@ -14,8 +10,8 @@ github.com/alecthomas/colour v0.0.0-20160524082231-60882d9e2721 h1:JHZL0hZKJ1VEN
|
|||||||
github.com/alecthomas/colour v0.0.0-20160524082231-60882d9e2721/go.mod h1:QO9JBoKquHd+jz9nshCh40fOfO+JzsoXy8qTHF68zU0=
|
github.com/alecthomas/colour v0.0.0-20160524082231-60882d9e2721/go.mod h1:QO9JBoKquHd+jz9nshCh40fOfO+JzsoXy8qTHF68zU0=
|
||||||
github.com/alecthomas/kong v0.2.1-0.20190708041108-0548c6b1afae/go.mod h1:+inYUSluD+p4L8KdviBSgzcqEjUQOfC5fQDRFuc36lI=
|
github.com/alecthomas/kong v0.2.1-0.20190708041108-0548c6b1afae/go.mod h1:+inYUSluD+p4L8KdviBSgzcqEjUQOfC5fQDRFuc36lI=
|
||||||
github.com/alecthomas/repr v0.0.0-20180818092828-117648cd9897/go.mod h1:xTS7Pm1pD1mvyM075QCDSRqH6qRLXylzS24ZTpRiSzQ=
|
github.com/alecthomas/repr v0.0.0-20180818092828-117648cd9897/go.mod h1:xTS7Pm1pD1mvyM075QCDSRqH6qRLXylzS24ZTpRiSzQ=
|
||||||
github.com/alecthomas/repr v0.5.3 h1:Ebk3yZ0kvrHC7TkTHLDJGDq1LxKeu9sQBQREFMcesS8=
|
github.com/alecthomas/repr v0.5.2 h1:SU73FTI9D1P5UNtvseffFSGmdNci/O6RsqzeXJtP0Qs=
|
||||||
github.com/alecthomas/repr v0.5.3/go.mod h1:Fr0507jx4eOXV7AlPV6AVZLYrLIuIeSOWtW57eE/O/4=
|
github.com/alecthomas/repr v0.5.2/go.mod h1:Fr0507jx4eOXV7AlPV6AVZLYrLIuIeSOWtW57eE/O/4=
|
||||||
github.com/aymanbagabas/go-osc52/v2 v2.0.1 h1:HwpRHbFMcZLEVr42D4p7XBqjyuxQH5SMiErDT4WkJ2k=
|
github.com/aymanbagabas/go-osc52/v2 v2.0.1 h1:HwpRHbFMcZLEVr42D4p7XBqjyuxQH5SMiErDT4WkJ2k=
|
||||||
github.com/aymanbagabas/go-osc52/v2 v2.0.1/go.mod h1:uYgXzlJ7ZpABp8OJ+exZzJJhRNQ2ASbcXHWsFqH8hp8=
|
github.com/aymanbagabas/go-osc52/v2 v2.0.1/go.mod h1:uYgXzlJ7ZpABp8OJ+exZzJJhRNQ2ASbcXHWsFqH8hp8=
|
||||||
github.com/charmbracelet/bubbles v1.0.0 h1:12J8/ak/uCZEMQ6KU7pcfwceyjLlWsDLAxB5fXonfvc=
|
github.com/charmbracelet/bubbles v1.0.0 h1:12J8/ak/uCZEMQ6KU7pcfwceyjLlWsDLAxB5fXonfvc=
|
||||||
|
|||||||
@@ -22,7 +22,6 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"reflect"
|
"reflect"
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/alecthomas/repr"
|
"github.com/alecthomas/repr"
|
||||||
"gopkg.in/yaml.v3"
|
"gopkg.in/yaml.v3"
|
||||||
@@ -69,13 +68,6 @@ type Config struct {
|
|||||||
Retention string // index template create: -r
|
Retention string // index template create: -r
|
||||||
Rollover bool // index template create: -R
|
Rollover bool // index template create: -R
|
||||||
|
|
||||||
Missing bool // index copy: -m
|
|
||||||
Sync bool // index copy: -S
|
|
||||||
RequestsPerSecond float64 // index copy: -R
|
|
||||||
Timeout time.Duration // index copy: -T
|
|
||||||
Refresh bool // index copy: -r
|
|
||||||
SourceIndices []string // index copy: -s
|
|
||||||
|
|
||||||
From, To, MaxItems int // search: flags
|
From, To, MaxItems int // search: flags
|
||||||
Filter []string // search: -F
|
Filter []string // search: -F
|
||||||
Path string // search+doc sh: -p
|
Path string // search+doc sh: -p
|
||||||
@@ -107,8 +99,7 @@ type Config struct {
|
|||||||
|
|
||||||
// rollover
|
// rollover
|
||||||
MaxAge string
|
MaxAge string
|
||||||
MaxDocs int64 // roll over, plus others
|
MaxDocs, MaxShardSize, MaxShardDocs int // roll over
|
||||||
MaxShardSize, MaxShardDocs int // roll over
|
|
||||||
DryRun bool // rollover: -n
|
DryRun bool // rollover: -n
|
||||||
|
|
||||||
Tag string // api ls: -t
|
Tag string // api ls: -t
|
||||||
|
|||||||
@@ -57,7 +57,7 @@ func CcrStatus(conf *cfg.Config, leader, follower string) error {
|
|||||||
res, err := conf.Clusters[alias].ES().Cat.Indices().
|
res, err := conf.Clusters[alias].ES().Cat.Indices().
|
||||||
Do(context.Background())
|
Do(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to get indices on %s: %w", alias, esErrorString(err))
|
return fmt.Errorf("failed to get indicies on %s: %w", alias, esErrorString(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
indices[alias] = make(map[string]*types.IndicesRecord, len(res))
|
indices[alias] = make(map[string]*types.IndicesRecord, len(res))
|
||||||
|
|||||||
@@ -288,7 +288,7 @@ func gatherClusterStats(clusterstats *clusterstats.Response, table *printer.Tabl
|
|||||||
}
|
}
|
||||||
|
|
||||||
table.Entries = append(table.Entries, [][]any{
|
table.Entries = append(table.Entries, [][]any{
|
||||||
{"indices", clusterstats.Indices.Count},
|
{"Indicies", clusterstats.Indices.Count},
|
||||||
{"Docs", clusterstats.Indices.Docs.Count},
|
{"Docs", clusterstats.Indices.Docs.Count},
|
||||||
{"Total Size", printer.Bytes(clusterstats.Indices.Docs.TotalSizeInBytes)},
|
{"Total Size", printer.Bytes(clusterstats.Indices.Docs.TotalSizeInBytes)},
|
||||||
{"Total Queries", "%d", querycount},
|
{"Total Queries", "%d", querycount},
|
||||||
|
|||||||
@@ -89,7 +89,7 @@ func checkClusterStatus(conf *cfg.Config, leader, follower string) bool {
|
|||||||
status[leader].ActivePrimaryShards,
|
status[leader].ActivePrimaryShards,
|
||||||
status[follower].ActivePrimaryShards,
|
status[follower].ActivePrimaryShards,
|
||||||
},
|
},
|
||||||
{"indices",
|
{"Indicies",
|
||||||
len(status[leader].Indices),
|
len(status[leader].Indices),
|
||||||
len(status[follower].Indices),
|
len(status[follower].Indices),
|
||||||
},
|
},
|
||||||
@@ -172,7 +172,7 @@ func findIlmErrors(conf *cfg.Config, leader, follower string) bool {
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
// find unsynchronized indices only present on leader
|
// find unsynchronized indicies only present on leader
|
||||||
func findIndicesOnlyOnLeader(conf *cfg.Config, indices ClusterIndices, leader, follower string) bool {
|
func findIndicesOnlyOnLeader(conf *cfg.Config, indices ClusterIndices, leader, follower string) bool {
|
||||||
exclude := regexp.MustCompile(DefaultExclude)
|
exclude := regexp.MustCompile(DefaultExclude)
|
||||||
if conf.Exclude != "" {
|
if conf.Exclude != "" {
|
||||||
|
|||||||
@@ -30,11 +30,9 @@ import (
|
|||||||
|
|
||||||
"codeberg.org/scip/esctl/pkg/cfg"
|
"codeberg.org/scip/esctl/pkg/cfg"
|
||||||
"codeberg.org/scip/esctl/pkg/printer"
|
"codeberg.org/scip/esctl/pkg/printer"
|
||||||
"codeberg.org/scip/mapmap"
|
|
||||||
"github.com/charmbracelet/lipgloss"
|
"github.com/charmbracelet/lipgloss"
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/cat/indices"
|
"github.com/elastic/go-elasticsearch/v9/typedapi/cat/indices"
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/esdsl"
|
"github.com/elastic/go-elasticsearch/v9/typedapi/esdsl"
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/types"
|
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/types/enums/healthstatus"
|
"github.com/elastic/go-elasticsearch/v9/typedapi/types/enums/healthstatus"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -43,7 +41,7 @@ func IndexNames(conf *cfg.Config) ([]string, error) {
|
|||||||
res, err := conf.DefaultCluster.ES().Cat.Indices().
|
res, err := conf.DefaultCluster.ES().Cat.Indices().
|
||||||
Do(context.Background())
|
Do(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("failed to get indices: %w", esErrorString(err))
|
return nil, fmt.Errorf("failed to get indicies: %w", esErrorString(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
indices := make([]string, len(res))
|
indices := make([]string, len(res))
|
||||||
@@ -55,29 +53,41 @@ func IndexNames(conf *cfg.Config) ([]string, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func filterIndices(conf *cfg.Config, list indices.Response) indices.Response {
|
func filterIndices(conf *cfg.Config, list indices.Response) indices.Response {
|
||||||
var filter *regexp.Regexp
|
// apply partials filter first
|
||||||
|
selectedlist := indices.Response{}
|
||||||
|
|
||||||
if len(conf.Filter) > 0 {
|
for _, index := range list {
|
||||||
filter = regexp.MustCompile(conf.Filter[0])
|
|
||||||
}
|
|
||||||
|
|
||||||
return mapmap.NewSlicer(list).MapSliceValuesImmutable(func(index types.IndicesRecord) bool {
|
|
||||||
if !conf.Partials && strings.HasPrefix(*index.Index, "partial-") {
|
if !conf.Partials && strings.HasPrefix(*index.Index, "partial-") {
|
||||||
return false
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
if !conf.Hidden && strings.HasPrefix(*index.Index, ".") {
|
if !conf.Hidden && strings.HasPrefix(*index.Index, ".") {
|
||||||
return false
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(conf.Filter) > 0 {
|
if strings.HasPrefix(*index.Index, ".ds-") {
|
||||||
if !filter.MatchString(*index.Index) {
|
// ignore data stream backing indicies
|
||||||
return false
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
selectedlist = append(selectedlist, index)
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(conf.Filter) == 0 {
|
||||||
|
return selectedlist
|
||||||
|
}
|
||||||
|
|
||||||
|
// we support just one filter here, for now
|
||||||
|
filter := *regexp.MustCompile(conf.Filter[0])
|
||||||
|
newlist := indices.Response{}
|
||||||
|
|
||||||
|
for _, index := range selectedlist {
|
||||||
|
if filter.MatchString(*index.Index) {
|
||||||
|
newlist = append(newlist, index)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return true
|
return newlist
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func IndexList(conf *cfg.Config) error {
|
func IndexList(conf *cfg.Config) error {
|
||||||
@@ -89,10 +99,10 @@ func IndexList(conf *cfg.Config) error {
|
|||||||
|
|
||||||
res, err := cat.Do(context.Background())
|
res, err := cat.Do(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to get indices: %w", esErrorString(err))
|
return fmt.Errorf("failed to get indicies: %w", esErrorString(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
slog.Debug("ES result", "indices", res)
|
slog.Debug("ES result", "indicies", res)
|
||||||
|
|
||||||
list := filterIndices(conf, res)
|
list := filterIndices(conf, res)
|
||||||
|
|
||||||
|
|||||||
@@ -1,83 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright © 2026 Thomas von Dein
|
|
||||||
|
|
||||||
This program is free software: you can redistribute it and/or modify
|
|
||||||
it under the terms of the GNU General Public License as published by
|
|
||||||
the Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
package es
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"fmt"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"codeberg.org/scip/esctl/pkg/cfg"
|
|
||||||
"codeberg.org/scip/esctl/pkg/printer"
|
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/esdsl"
|
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/types/enums/conflicts"
|
|
||||||
)
|
|
||||||
|
|
||||||
func IndexCopy(conf *cfg.Config) error {
|
|
||||||
copy := conf.DefaultCluster.ES().Reindex()
|
|
||||||
|
|
||||||
if conf.Force {
|
|
||||||
copy.Conflicts(conflicts.Proceed)
|
|
||||||
}
|
|
||||||
|
|
||||||
if conf.RequestsPerSecond != 0 {
|
|
||||||
copy.RequestsPerSecond(fmt.Sprintf("%.2f", conf.RequestsPerSecond))
|
|
||||||
}
|
|
||||||
|
|
||||||
if conf.MaxDocs > 0 {
|
|
||||||
copy.MaxDocs(conf.MaxDocs)
|
|
||||||
}
|
|
||||||
|
|
||||||
if conf.Timeout > 0 {
|
|
||||||
copy.Timeout(formatDuration(conf.Timeout))
|
|
||||||
}
|
|
||||||
|
|
||||||
if conf.Wait {
|
|
||||||
copy.WaitForActiveShards("all")
|
|
||||||
}
|
|
||||||
|
|
||||||
if conf.Refresh {
|
|
||||||
copy.Refresh(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
copy.Source(esdsl.NewReindexSource().Index(conf.SourceIndices...))
|
|
||||||
copy.Dest(esdsl.NewReindexDestination().Index(conf.Index))
|
|
||||||
|
|
||||||
res, err := copy.Do(context.Background())
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("failed to copy indices: %w", esErrorString(err))
|
|
||||||
}
|
|
||||||
|
|
||||||
table := printer.NewTable(conf, 2, 0).
|
|
||||||
WithHeaders("Reindex metrtic", "value")
|
|
||||||
|
|
||||||
table.Entries = [][]any{
|
|
||||||
{"Source indices", conf.SourceIndices},
|
|
||||||
{"Target index", conf.Index},
|
|
||||||
{"Batches", *res.Batches},
|
|
||||||
{"Documents total", *res.Total},
|
|
||||||
{"Documents created", *res.Created},
|
|
||||||
{"Documents deleted", *res.Deleted},
|
|
||||||
{"Documents updated", *res.Updated},
|
|
||||||
{"Requests/s", *res.RequestsPerSecond},
|
|
||||||
{"Timed out", *res.TimedOut},
|
|
||||||
{"Time elapsed", time.Duration(*res.Took) * time.Millisecond},
|
|
||||||
{"Version conflicts", *res.VersionConflicts},
|
|
||||||
}
|
|
||||||
|
|
||||||
return table.Print()
|
|
||||||
}
|
|
||||||
@@ -28,29 +28,12 @@ import (
|
|||||||
|
|
||||||
"codeberg.org/scip/esctl/pkg/cfg"
|
"codeberg.org/scip/esctl/pkg/cfg"
|
||||||
"codeberg.org/scip/esctl/pkg/printer"
|
"codeberg.org/scip/esctl/pkg/printer"
|
||||||
"codeberg.org/scip/mapmap"
|
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/esdsl"
|
"github.com/elastic/go-elasticsearch/v9/typedapi/esdsl"
|
||||||
"github.com/elastic/go-elasticsearch/v9/typedapi/types"
|
"github.com/elastic/go-elasticsearch/v9/typedapi/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
// used for completion
|
// used for completion
|
||||||
func IndexTemplateNames(conf *cfg.Config) ([]string, error) {
|
func IndexTemplateList(conf *cfg.Config) error {
|
||||||
res, err := conf.DefaultCluster.ES().Indices.GetIndexTemplate().
|
|
||||||
Do(context.Background())
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("failed to get index templates: %w", esErrorString(err))
|
|
||||||
}
|
|
||||||
|
|
||||||
names := make([]string, len(res.IndexTemplates))
|
|
||||||
|
|
||||||
for idx, tpl := range res.IndexTemplates {
|
|
||||||
names[idx] = tpl.Name
|
|
||||||
}
|
|
||||||
|
|
||||||
return names, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func IndexTemplateList(conf *cfg.Config, filter string) error {
|
|
||||||
res, err := conf.DefaultCluster.ES().Indices.GetIndexTemplate().
|
res, err := conf.DefaultCluster.ES().Indices.GetIndexTemplate().
|
||||||
Do(context.Background())
|
Do(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -59,20 +42,20 @@ func IndexTemplateList(conf *cfg.Config, filter string) error {
|
|||||||
|
|
||||||
slog.Debug("res", "index templates", res)
|
slog.Debug("res", "index templates", res)
|
||||||
|
|
||||||
table := printer.NewTable(conf, 5, 0)
|
table := printer.NewTable(conf, 5, len(res.IndexTemplates))
|
||||||
table.Addheaders("name", "description", "index patterns", "priority")
|
table.Addheaders("name", "description", "priority")
|
||||||
|
|
||||||
tplList := filterIndexTemplates(conf, filter, res.IndexTemplates)
|
for idx, tpl := range res.IndexTemplates {
|
||||||
|
desc, err := json.Marshal(tpl.IndexTemplate.Meta_["description"])
|
||||||
for _, tpl := range tplList {
|
if err != nil {
|
||||||
desc := strings.TrimPrefix(strings.TrimSuffix(string(tpl.IndexTemplate.Meta_["description"]), `"`), `"`)
|
return fmt.Errorf("failed to unmarshal meta json data: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
var prio int64
|
var prio int64
|
||||||
if tpl.IndexTemplate.Priority != nil {
|
if tpl.IndexTemplate.Priority != nil {
|
||||||
prio = *tpl.IndexTemplate.Priority
|
prio = *tpl.IndexTemplate.Priority
|
||||||
}
|
}
|
||||||
|
table.Entries[idx] = []any{tpl.Name, desc, prio}
|
||||||
table.AddRow(tpl.Name, desc, tpl.IndexTemplate.IndexPatterns, prio)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
table.Sort()
|
table.Sort()
|
||||||
@@ -80,30 +63,6 @@ func IndexTemplateList(conf *cfg.Config, filter string) error {
|
|||||||
return table.Print()
|
return table.Print()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Filter index templates by name, index pattern or hidden flag, using
|
|
||||||
// mapmap.Slicer
|
|
||||||
func filterIndexTemplates(conf *cfg.Config, nameFilter string,
|
|
||||||
templates []types.IndexTemplateItem) []types.IndexTemplateItem {
|
|
||||||
return mapmap.NewSlicer(templates).MapSliceValuesImmutable(func(tpl types.IndexTemplateItem) bool {
|
|
||||||
if !conf.Hidden && strings.HasPrefix(tpl.Name, ".") {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
if nameFilter != "" && !strings.Contains(tpl.Name, nameFilter) {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(conf.Filter) > 0 {
|
|
||||||
if !mapmap.NewSlicer(tpl.IndexTemplate.IndexPatterns).
|
|
||||||
FindSliceInSlice(conf.Filter, strings.Contains) {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
func IndexTemplateShow(conf *cfg.Config, tplname string) error {
|
func IndexTemplateShow(conf *cfg.Config, tplname string) error {
|
||||||
res, err := conf.DefaultCluster.ES().Indices.GetIndexTemplate().
|
res, err := conf.DefaultCluster.ES().Indices.GetIndexTemplate().
|
||||||
Name(tplname).
|
Name(tplname).
|
||||||
|
|||||||
@@ -33,7 +33,7 @@ func RolloverConditions(conf *cfg.Config) types.RolloverConditionsVariant {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if conf.MaxDocs > 0 {
|
if conf.MaxDocs > 0 {
|
||||||
cond.MaxDocs(conf.MaxDocs)
|
cond.MaxDocs(int64(conf.MaxDocs))
|
||||||
}
|
}
|
||||||
|
|
||||||
if conf.MaxShardSize > 0 {
|
if conf.MaxShardSize > 0 {
|
||||||
|
|||||||
@@ -42,17 +42,17 @@ type Snapshot struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func SnapshotList(conf *cfg.Config) error {
|
func SnapshotList(conf *cfg.Config) error {
|
||||||
// get partial indices
|
// get partial indicies
|
||||||
ires, err := conf.DefaultCluster.ES().Cat.Indices().Do(context.Background())
|
ires, err := conf.DefaultCluster.ES().Cat.Indices().Do(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to get indices: %w", esErrorString(err))
|
return fmt.Errorf("failed to get indicies: %w", esErrorString(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
indices := map[string]int{}
|
indicies := map[string]int{}
|
||||||
|
|
||||||
for _, index := range ires {
|
for _, index := range ires {
|
||||||
name := strings.ReplaceAll(*index.Index, "partial-", "")
|
name := strings.ReplaceAll(*index.Index, "partial-", "")
|
||||||
indices[name] = 1
|
indicies[name] = 1
|
||||||
}
|
}
|
||||||
|
|
||||||
// get snapshots
|
// get snapshots
|
||||||
@@ -61,7 +61,7 @@ func SnapshotList(conf *cfg.Config) error {
|
|||||||
return fmt.Errorf("failed to get snapshots: %w", esErrorString(err))
|
return fmt.Errorf("failed to get snapshots: %w", esErrorString(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
slog.Debug("ES result", "indices", sres)
|
slog.Debug("ES result", "indicies", sres)
|
||||||
|
|
||||||
snapshots := []*Snapshot{} // original snapshot names
|
snapshots := []*Snapshot{} // original snapshot names
|
||||||
|
|
||||||
@@ -74,7 +74,7 @@ func SnapshotList(conf *cfg.Config) error {
|
|||||||
Orphaned: "no",
|
Orphaned: "no",
|
||||||
})
|
})
|
||||||
|
|
||||||
_, exists := indices[snap.Forindex]
|
_, exists := indicies[snap.Forindex]
|
||||||
if !exists {
|
if !exists {
|
||||||
snap.Orphaned = "orphaned"
|
snap.Orphaned = "orphaned"
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,55 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright © 2026 Thomas von Dein
|
|
||||||
|
|
||||||
This program is free software: you can redistribute it and/or modify
|
|
||||||
it under the terms of the GNU General Public License as published by
|
|
||||||
the Free Software Foundation, either version 3 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
|
|
||||||
This program is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/
|
|
||||||
package printer
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"runtime/metrics"
|
|
||||||
"strconv"
|
|
||||||
)
|
|
||||||
|
|
||||||
func printGoRoutineMetrics() {
|
|
||||||
fmt.Println("\nGoroutine metrics:")
|
|
||||||
printMetric("/sched/goroutines-created:goroutines", "Created")
|
|
||||||
printMetric("/sched/goroutines:goroutines", "Live")
|
|
||||||
printMetric("/sched/goroutines/not-in-go:goroutines", "Syscall/CGO")
|
|
||||||
printMetric("/sched/goroutines/runnable:goroutines", "Runnable")
|
|
||||||
printMetric("/sched/goroutines/running:goroutines", "Running")
|
|
||||||
printMetric("/sched/goroutines/waiting:goroutines", "Waiting")
|
|
||||||
|
|
||||||
fmt.Println("Thread metrics:")
|
|
||||||
printMetric("/sched/gomaxprocs:threads", "Max")
|
|
||||||
printMetric("/sched/threads/total:threads", "Live")
|
|
||||||
}
|
|
||||||
|
|
||||||
func printMetric(name string, descr string) {
|
|
||||||
sample := []metrics.Sample{{Name: name}}
|
|
||||||
metrics.Read(sample)
|
|
||||||
|
|
||||||
var val string
|
|
||||||
|
|
||||||
switch sample[0].Value.Kind() {
|
|
||||||
case metrics.KindFloat64, metrics.KindFloat64Histogram:
|
|
||||||
val = fmt.Sprintf("%.2f", sample[0].Value.Float64())
|
|
||||||
case metrics.KindUint64:
|
|
||||||
val = strconv.FormatUint(sample[0].Value.Uint64(), 10)
|
|
||||||
case metrics.KindBad:
|
|
||||||
val = "n/a"
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Printf(" %s: %v\n", descr, val)
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user