Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-15 08:23:34 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

lib/promscrape: show -promscrape.cluster.memberNum values for vmagent instances, which scrape the given dropped target at /service-discovery page

Browse Source 
The /service-discovery page contains the list of all the discovered targets
after the commit 487f6380d0 on all the vmagent instances
in cluster mode ( https://docs.victoriametrics.com/vmagent.html#scraping-big-number-of-targets ).

This commit improves debuggability of targets in cluster mode by providing a list of -promscrape.cluster.memberNum
values per each target at /service-discovery page, which has been dropped becasue of sharding,
e.g. if this target is scraped by other vmagent instances in the cluster.

Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5389
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/4018
This commit is contained in:
Aliaksandr Valialkin 2023-12-07 00:05:29 +02:00
parent 12e94f10cc
commit 896a0f32cd
No known key found for this signature in database
GPG Key ID: 52C003EE2BCDB9EB
8 changed files with 185 additions and 146 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/CHANGELOG.md
View File

@ -37,7 +37,7 @@ The sandbox cluster installation is running under the constant load generated by
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `-enableMultitenantHandlers` command-line flag, which allows receiving data via [VictoriaMetrics cluster urls](https://docs.victoriametrics.com/Cluster-VictoriaMetrics.html#url-format) at `vmagent` and converting [tenant ids](https://docs.victoriametrics.com/Cluster-VictoriaMetrics.html#multitenancy) to (`vm_account_id`, `vm_project_id`) labels before sending the data to the configured `-remoteWrite.url`. See [these docs](https://docs.victoriametrics.com/vmagent.html#multitenancy) for details. * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `-enableMultitenantHandlers` command-line flag, which allows receiving data via [VictoriaMetrics cluster urls](https://docs.victoriametrics.com/Cluster-VictoriaMetrics.html#url-format) at `vmagent` and converting [tenant ids](https://docs.victoriametrics.com/Cluster-VictoriaMetrics.html#multitenancy) to (`vm_account_id`, `vm_project_id`) labels before sending the data to the configured `-remoteWrite.url`. See [these docs](https://docs.victoriametrics.com/vmagent.html#multitenancy) for details.
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `-remoteWrite.disableOnDiskQueue` command-line flag, which can be used for disabling data queueing to disk when the remote storage cannot keep up with the data ingestion rate. See [these docs](https://docs.victoriametrics.com/vmagent.html#disabling-on-disk-persistence) and [this feature request](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2110). * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `-remoteWrite.disableOnDiskQueue` command-line flag, which can be used for disabling data queueing to disk when the remote storage cannot keep up with the data ingestion rate. See [these docs](https://docs.victoriametrics.com/vmagent.html#disabling-on-disk-persistence) and [this feature request](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2110).
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add support for reading and writing samples via [Google PubSub](https://cloud.google.com/pubsub). See [these docs](https://docs.victoriametrics.com/vmagent.html#google-pubsub-integration). * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add support for reading and writing samples via [Google PubSub](https://cloud.google.com/pubsub). See [these docs](https://docs.victoriametrics.com/vmagent.html#google-pubsub-integration).
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): show all the dropped targets together with the reason why they are dropped at `http://vmagent:8429/service-discovery` page. Previously targets, which were dropped because of [target sharding](https://docs.victoriametrics.com/vmagent.html#scraping-big-number-of-targets) weren't displayed on this page. This could complicate service discovery debugging. See [this issue](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5389). * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): show all the dropped targets together with the reason why they are dropped at `http://vmagent:8429/service-discovery` page. Previously targets, which were dropped because of [target sharding](https://docs.victoriametrics.com/vmagent.html#scraping-big-number-of-targets) weren't displayed on this page. This could complicate service discovery debugging. See [this issue](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5389) and [this feature request](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/4018).
* FEATURE: reduce the default value for `-import.maxLineLen` command-line flag from 100MB to 10MB in order to prevent excessive memory usage during data import via [/api/v1/import](https://docs.victoriametrics.com/#how-to-import-data-in-json-line-format). * FEATURE: reduce the default value for `-import.maxLineLen` command-line flag from 100MB to 10MB in order to prevent excessive memory usage during data import via [/api/v1/import](https://docs.victoriametrics.com/#how-to-import-data-in-json-line-format).
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `keep_if_contains` and `drop_if_contains` relabeling actions. See [these docs](https://docs.victoriametrics.com/vmagent.html#relabeling-enhancements) for details. * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): add `keep_if_contains` and `drop_if_contains` relabeling actions. See [these docs](https://docs.victoriametrics.com/vmagent.html#relabeling-enhancements) for details.
* FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): export `vm_promscrape_scrape_pool_targets` [metric](https://docs.victoriametrics.com/vmagent.html#monitoring) to track the number of targets each scrape job discovers. See [this feature request](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5311). * FEATURE: [vmagent](https://docs.victoriametrics.com/vmagent.html): export `vm_promscrape_scrape_pool_targets` [metric](https://docs.victoriametrics.com/vmagent.html#monitoring) to track the number of targets each scrape job discovers. See [this feature request](https://github.com/VictoriaMetrics/VictoriaMetrics/issues/5311).

5
docs/vmagent.md
View File

@ -810,6 +810,11 @@ start a cluster of three `vmagent` instances, where each target is scraped by tw
/path/to/vmagent -promscrape.cluster.membersCount=3 -promscrape.cluster.replicationFactor=2 -promscrape.cluster.memberNum=2 -promscrape.config=/path/to/config.yml ... /path/to/vmagent -promscrape.cluster.membersCount=3 -promscrape.cluster.replicationFactor=2 -promscrape.cluster.memberNum=2 -promscrape.config=/path/to/config.yml ...
``` ```
Every `vmagent` in the cluster exposes all the discovered targets at `http://vmagent:8429/service-discovery` page.
Each discovered target on this page contains its status (`UP`, `DOWN` or `DROPPED` with the reason why the target has been dropped).
If the target is dropped because of sharding to other `vmagent` instances in the cluster, then the status column contains
`-promscrape.cluster.memberNum` values for `vmagent` instances where the given target is scraped.
If each target is scraped by multiple `vmagent` instances, then data deduplication must be enabled at remote storage pointed by `-remoteWrite.url`. If each target is scraped by multiple `vmagent` instances, then data deduplication must be enabled at remote storage pointed by `-remoteWrite.url`.
The `-dedup.minScrapeInterval` must be set to the `scrape_interval` configured at `-promscrape.config`. The `-dedup.minScrapeInterval` must be set to the `scrape_interval` configured at `-promscrape.config`.
See [these docs](https://docs.victoriametrics.com/#deduplication) for details. See [these docs](https://docs.victoriametrics.com/#deduplication) for details.

22
lib/promscrape/config.go
View File

@ -6,6 +6,7 @@ import (
"fmt" "fmt"
"net/url" "net/url"
"path/filepath" "path/filepath"
"slices"
"sort" "sort"
"strconv" "strconv"
"strings" "strings"
@ -1020,25 +1021,24 @@ func appendScrapeWorkKey(dst []byte, labels *promutils.Labels) []byte {
return dst return dst
} }
func needSkipScrapeWork(key string, membersCount, replicasCount, memberNum int) bool { func getClusterMemberNumsForScrapeWork(key string, membersCount, replicasCount int) []int {
if membersCount <= 1 { if membersCount <= 1 {
return false return []int{0}
} }
h := xxhash.Sum64(bytesutil.ToUnsafeBytes(key)) h := xxhash.Sum64(bytesutil.ToUnsafeBytes(key))
idx := int(h % uint64(membersCount)) idx := int(h % uint64(membersCount))
if replicasCount < 1 { if replicasCount < 1 {
replicasCount = 1 replicasCount = 1
} }
memberNums := make([]int, replicasCount)
for i := 0; i < replicasCount; i++ { for i := 0; i < replicasCount; i++ {
if idx == memberNum { memberNums[i] = idx
return false
}
idx++ idx++
if idx >= membersCount { if idx >= membersCount {
idx = 0 idx = 0
} }
} }
return true return memberNums
} }
var scrapeWorkKeyBufPool bytesutil.ByteBufferPool var scrapeWorkKeyBufPool bytesutil.ByteBufferPool
@ -1056,7 +1056,7 @@ func (swc *scrapeWorkConfig) getScrapeWork(target string, extraLabels, metaLabel
if labels.Len() == 0 { if labels.Len() == 0 {
// Drop target without labels. // Drop target without labels.
originalLabels = sortOriginalLabelsIfNeeded(originalLabels) originalLabels = sortOriginalLabelsIfNeeded(originalLabels)
droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonRelabeling) droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonRelabeling, nil)
return nil, nil return nil, nil
} }
@ -1067,11 +1067,11 @@ func (swc *scrapeWorkConfig) getScrapeWork(target string, extraLabels, metaLabel
if *clusterMembersCount > 1 { if *clusterMembersCount > 1 {
bb := scrapeWorkKeyBufPool.Get() bb := scrapeWorkKeyBufPool.Get()
bb.B = appendScrapeWorkKey(bb.B[:0], labels) bb.B = appendScrapeWorkKey(bb.B[:0], labels)
needSkip := needSkipScrapeWork(bytesutil.ToUnsafeString(bb.B), *clusterMembersCount, *clusterReplicationFactor, clusterMemberID) memberNums := getClusterMemberNumsForScrapeWork(bytesutil.ToUnsafeString(bb.B), *clusterMembersCount, *clusterReplicationFactor)
scrapeWorkKeyBufPool.Put(bb) scrapeWorkKeyBufPool.Put(bb)
if needSkip { if !slices.Contains(memberNums, clusterMemberID) {
originalLabels = sortOriginalLabelsIfNeeded(originalLabels) originalLabels = sortOriginalLabelsIfNeeded(originalLabels)
droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonSharding) droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonSharding, memberNums)
return nil, nil return nil, nil
} }
} }
@ -1079,7 +1079,7 @@ func (swc *scrapeWorkConfig) getScrapeWork(target string, extraLabels, metaLabel
if scrapeURL == "" { if scrapeURL == "" {
// Drop target without URL. // Drop target without URL.
originalLabels = sortOriginalLabelsIfNeeded(originalLabels) originalLabels = sortOriginalLabelsIfNeeded(originalLabels)
droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonMissingScrapeURL) droppedTargetsMap.Register(originalLabels, swc.relabelConfigs, targetDropReasonMissingScrapeURL, nil)
return nil, nil return nil, nil
} }
if _, err := url.Parse(scrapeURL); err != nil { if _, err := url.Parse(scrapeURL); err != nil {

29
lib/promscrape/config_test.go
View File

@ -110,31 +110,30 @@ scrape_configs:
`) `)
} }
func TestNeedSkipScrapeWork(t *testing.T) { func TestGetClusterMemberNumsForScrapeWork(t *testing.T) {
f := func(key string, membersCount, replicationFactor, memberNum int, needSkipExpected bool) { f := func(key string, membersCount, replicationFactor int, expectedMemberNums []int) {
t.Helper() t.Helper()
needSkip := needSkipScrapeWork(key, membersCount, replicationFactor, memberNum) memberNums := getClusterMemberNumsForScrapeWork(key, membersCount, replicationFactor)
if needSkip != needSkipExpected { if !reflect.DeepEqual(memberNums, expectedMemberNums) {
t.Fatalf("unexpected needSkipScrapeWork(key=%q, membersCount=%d, replicationFactor=%d, memberNum=%d); got %v; want %v", t.Fatalf("unexpected memberNums; got %d; want %d", memberNums, expectedMemberNums)
key, membersCount, replicationFactor, memberNum, needSkip, needSkipExpected)
} }
} }
// Disabled clustering // Disabled clustering
f("foo", 0, 0, 0, false) f("foo", 0, 0, []int{0})
f("foo", 0, 0, 1, false) f("foo", 0, 0, []int{0})
// A cluster with 2 nodes with disabled replication // A cluster with 2 nodes with disabled replication
f("foo", 2, 0, 0, true) f("baz", 2, 0, []int{0})
f("foo", 2, 0, 1, false) f("foo", 2, 0, []int{1})
// A cluster with 2 nodes with replicationFactor=2 // A cluster with 2 nodes with replicationFactor=2
f("foo", 2, 2, 0, false) f("baz", 2, 2, []int{0, 1})
f("foo", 2, 2, 1, false) f("foo", 2, 2, []int{1, 0})
// A cluster with 3 nodes with replicationFactor=2 // A cluster with 3 nodes with replicationFactor=2
f("foo", 3, 2, 0, false) f("abc", 3, 2, []int{0, 1})
f("foo", 3, 2, 1, true) f("bar", 3, 2, []int{1, 2})
f("foo", 3, 2, 2, false) f("foo", 3, 2, []int{2, 0})
} }
func TestLoadStaticConfigs(t *testing.T) { func TestLoadStaticConfigs(t *testing.T) {

2
lib/promscrape/scraper.go
View File

@ -370,7 +370,7 @@ func (sg *scraperGroup) update(sws []*ScrapeWork) {
"original labels for target1: %s; original labels for target2: %s", "original labels for target1: %s; original labels for target2: %s",
sw.ScrapeURL, sw.Labels.String(), originalLabels.String(), sw.OriginalLabels.String()) sw.ScrapeURL, sw.Labels.String(), originalLabels.String(), sw.OriginalLabels.String())
} }
droppedTargetsMap.Register(sw.OriginalLabels, sw.RelabelConfigs, targetDropReasonDuplicate) droppedTargetsMap.Register(sw.OriginalLabels, sw.RelabelConfigs, targetDropReasonDuplicate, nil)
continue continue
} }
swsMap[key] = sw.OriginalLabels swsMap[key] = sw.OriginalLabels

30
lib/promscrape/targetstatus.go
View File

@ -318,9 +318,10 @@ type droppedTargets struct {
} }
type droppedTarget struct { type droppedTarget struct {
originalLabels *promutils.Labels originalLabels *promutils.Labels
relabelConfigs *promrelabel.ParsedConfigs relabelConfigs *promrelabel.ParsedConfigs
dropReason targetDropReason dropReason targetDropReason
clusterMemberNums []int
} }
type targetDropReason string type targetDropReason string
@ -352,7 +353,7 @@ func (dt *droppedTargets) getTargetsList() []droppedTarget {
// //
// The relabelConfigs must contain relabel configs, which were applied to originalLabels. // The relabelConfigs must contain relabel configs, which were applied to originalLabels.
// The reason must contain the reason why the target has been dropped. // The reason must contain the reason why the target has been dropped.
func (dt *droppedTargets) Register(originalLabels *promutils.Labels, relabelConfigs *promrelabel.ParsedConfigs, reason targetDropReason) { func (dt *droppedTargets) Register(originalLabels *promutils.Labels, relabelConfigs *promrelabel.ParsedConfigs, reason targetDropReason, clusterMemberNums []int) {
if originalLabels == nil { if originalLabels == nil {
// Do not register target without originalLabels. This is the case when *dropOriginalLabels is set to true. // Do not register target without originalLabels. This is the case when *dropOriginalLabels is set to true.
return return
@ -361,9 +362,10 @@ func (dt *droppedTargets) Register(originalLabels *promutils.Labels, relabelConf
key := labelsHash(originalLabels) key := labelsHash(originalLabels)
dt.mu.Lock() dt.mu.Lock()
dt.m[key] = droppedTarget{ dt.m[key] = droppedTarget{
originalLabels: originalLabels, originalLabels: originalLabels,
relabelConfigs: relabelConfigs, relabelConfigs: relabelConfigs,
dropReason: reason, dropReason: reason,
clusterMemberNums: clusterMemberNums,
} }
if len(dt.m) >= *maxDroppedTargets { if len(dt.m) >= *maxDroppedTargets {
for k := range dt.m { for k := range dt.m {
@ -588,10 +590,11 @@ type targetsStatusResult struct {
} }
type targetLabels struct { type targetLabels struct {
up bool up bool
originalLabels *promutils.Labels originalLabels *promutils.Labels
labels *promutils.Labels labels *promutils.Labels
dropReason targetDropReason dropReason targetDropReason
clusterMemberNums []int
} }
type targetLabelsByJob struct { type targetLabelsByJob struct {
jobName string jobName string
@ -681,8 +684,9 @@ func (tsr *targetsStatusResult) getTargetLabelsByJob() []*targetLabelsByJob {
} }
m.droppedTargets++ m.droppedTargets++
m.targets = append(m.targets, targetLabels{ m.targets = append(m.targets, targetLabels{
originalLabels: dt.originalLabels, originalLabels: dt.originalLabels,
dropReason: dt.dropReason, dropReason: dt.dropReason,
clusterMemberNums: dt.clusterMemberNums,
}) })
} }
a := make([]*targetLabelsByJob, 0, len(byJob)) a := make([]*targetLabelsByJob, 0, len(byJob))

9
lib/promscrape/targetstatus.qtpl
View File

@ -330,6 +330,15 @@
<span class="badge bg-danger">DOWN</span> <span class="badge bg-danger">DOWN</span>
{% else %} {% else %}
<span class="badge bg-warning">DROPPED ({%s string(t.dropReason) %})</span> <span class="badge bg-warning">DROPPED ({%s string(t.dropReason) %})</span>
{% if len(t.clusterMemberNums) > 0 %}
<br/>
<span title="The target exists at vmagent instances with the given -promscrape.cluster.memberNum values">
exists at{% space %}
{% for i, memberNum := range t.clusterMemberNums %}
{%d memberNum %}
{% if i+1 < len(t.clusterMemberNums) %},{% space %}{% endif %}
{% endfor %}
{% endif %}
{% endif %} {% endif %}
</td> </td>
<td class="labels"> <td class="labels">

232
lib/promscrape/targetstatus.qtpl.go
View File

@ -869,103 +869,125 @@ func streamdiscoveredJobTargets(qw422016 *qt422016.Writer, num int, tlj *targetL
//line lib/promscrape/targetstatus.qtpl:332 //line lib/promscrape/targetstatus.qtpl:332
qw422016.N().S(`)</span>`) qw422016.N().S(`)</span>`)
//line lib/promscrape/targetstatus.qtpl:333 //line lib/promscrape/targetstatus.qtpl:333
} if len(t.clusterMemberNums) > 0 {
//line lib/promscrape/targetstatus.qtpl:333 //line lib/promscrape/targetstatus.qtpl:333
qw422016.N().S(`</td><td class="labels">`) qw422016.N().S(`<br/><span title="The target exists at vmagent instances with the given -promscrape.cluster.memberNum values">exists at`)
//line lib/promscrape/targetstatus.qtpl:336 //line lib/promscrape/targetstatus.qtpl:336
streamformatLabels(qw422016, t.originalLabels) qw422016.N().S(` `)
//line lib/promscrape/targetstatus.qtpl:336 //line lib/promscrape/targetstatus.qtpl:337
qw422016.N().S(`</td><td class="labels">`) for i, memberNum := range t.clusterMemberNums {
//line lib/promscrape/targetstatus.qtpl:338
qw422016.N().D(memberNum)
//line lib/promscrape/targetstatus.qtpl:339 //line lib/promscrape/targetstatus.qtpl:339
streamformatLabels(qw422016, t.labels) if i+1 < len(t.clusterMemberNums) {
//line lib/promscrape/targetstatus.qtpl:339 //line lib/promscrape/targetstatus.qtpl:339
qw422016.N().S(`</td><td>`) qw422016.N().S(`,`)
//line lib/promscrape/targetstatus.qtpl:339
qw422016.N().S(` `)
//line lib/promscrape/targetstatus.qtpl:339
}
//line lib/promscrape/targetstatus.qtpl:340
}
//line lib/promscrape/targetstatus.qtpl:341
}
//line lib/promscrape/targetstatus.qtpl:342 //line lib/promscrape/targetstatus.qtpl:342
}
//line lib/promscrape/targetstatus.qtpl:342
qw422016.N().S(`</td><td class="labels">`)
//line lib/promscrape/targetstatus.qtpl:345
streamformatLabels(qw422016, t.originalLabels)
//line lib/promscrape/targetstatus.qtpl:345
qw422016.N().S(`</td><td class="labels">`)
//line lib/promscrape/targetstatus.qtpl:348
streamformatLabels(qw422016, t.labels)
//line lib/promscrape/targetstatus.qtpl:348
qw422016.N().S(`</td><td>`)
//line lib/promscrape/targetstatus.qtpl:351
targetID := getLabelsID(t.originalLabels) targetID := getLabelsID(t.originalLabels)
//line lib/promscrape/targetstatus.qtpl:342 //line lib/promscrape/targetstatus.qtpl:351
qw422016.N().S(`<a href="target-relabel-debug?id=`) qw422016.N().S(`<a href="target-relabel-debug?id=`)
//line lib/promscrape/targetstatus.qtpl:343 //line lib/promscrape/targetstatus.qtpl:352
qw422016.E().S(targetID) qw422016.E().S(targetID)
//line lib/promscrape/targetstatus.qtpl:343 //line lib/promscrape/targetstatus.qtpl:352
qw422016.N().S(`" target="_blank">debug</a></td></tr>`) qw422016.N().S(`" target="_blank">debug</a></td></tr>`)
//line lib/promscrape/targetstatus.qtpl:346 //line lib/promscrape/targetstatus.qtpl:355
} }
//line lib/promscrape/targetstatus.qtpl:346 //line lib/promscrape/targetstatus.qtpl:355
qw422016.N().S(`</tbody></table></div>`) qw422016.N().S(`</tbody></table></div>`)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
} }
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
func writediscoveredJobTargets(qq422016 qtio422016.Writer, num int, tlj *targetLabelsByJob) { func writediscoveredJobTargets(qq422016 qtio422016.Writer, num int, tlj *targetLabelsByJob) {
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
qw422016 := qt422016.AcquireWriter(qq422016) qw422016 := qt422016.AcquireWriter(qq422016)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
streamdiscoveredJobTargets(qw422016, num, tlj) streamdiscoveredJobTargets(qw422016, num, tlj)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
qt422016.ReleaseWriter(qw422016) qt422016.ReleaseWriter(qw422016)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
} }
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
func discoveredJobTargets(num int, tlj *targetLabelsByJob) string { func discoveredJobTargets(num int, tlj *targetLabelsByJob) string {
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
qb422016 := qt422016.AcquireByteBuffer() qb422016 := qt422016.AcquireByteBuffer()
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
writediscoveredJobTargets(qb422016, num, tlj) writediscoveredJobTargets(qb422016, num, tlj)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
qs422016 := string(qb422016.B) qs422016 := string(qb422016.B)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
qt422016.ReleaseByteBuffer(qb422016) qt422016.ReleaseByteBuffer(qb422016)
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
return qs422016 return qs422016
//line lib/promscrape/targetstatus.qtpl:350 //line lib/promscrape/targetstatus.qtpl:359
} }
//line lib/promscrape/targetstatus.qtpl:352 //line lib/promscrape/targetstatus.qtpl:361
func streamshowHideScrapeJobButtons(qw422016 *qt422016.Writer, num int) { func streamshowHideScrapeJobButtons(qw422016 *qt422016.Writer, num int) {
//line lib/promscrape/targetstatus.qtpl:352 //line lib/promscrape/targetstatus.qtpl:361
qw422016.N().S(`<button type="button" class="btn btn-primary btn-sm me-1"onclick="document.getElementById('scrape-job-`) qw422016.N().S(`<button type="button" class="btn btn-primary btn-sm me-1"onclick="document.getElementById('scrape-job-`)
//line lib/promscrape/targetstatus.qtpl:354
qw422016.N().D(num)
//line lib/promscrape/targetstatus.qtpl:354
qw422016.N().S(`').style.display='none'">collapse</button><button type="button" class="btn btn-secondary btn-sm me-1"onclick="document.getElementById('scrape-job-`)
//line lib/promscrape/targetstatus.qtpl:358
qw422016.N().D(num)
//line lib/promscrape/targetstatus.qtpl:358
qw422016.N().S(`').style.display='block'">expand</button>`)
//line lib/promscrape/targetstatus.qtpl:361
}
//line lib/promscrape/targetstatus.qtpl:361
func writeshowHideScrapeJobButtons(qq422016 qtio422016.Writer, num int) {
//line lib/promscrape/targetstatus.qtpl:361
qw422016 := qt422016.AcquireWriter(qq422016)
//line lib/promscrape/targetstatus.qtpl:361
streamshowHideScrapeJobButtons(qw422016, num)
//line lib/promscrape/targetstatus.qtpl:361
qt422016.ReleaseWriter(qw422016)
//line lib/promscrape/targetstatus.qtpl:361
}
//line lib/promscrape/targetstatus.qtpl:361
func showHideScrapeJobButtons(num int) string {
//line lib/promscrape/targetstatus.qtpl:361
qb422016 := qt422016.AcquireByteBuffer()
//line lib/promscrape/targetstatus.qtpl:361
writeshowHideScrapeJobButtons(qb422016, num)
//line lib/promscrape/targetstatus.qtpl:361
qs422016 := string(qb422016.B)
//line lib/promscrape/targetstatus.qtpl:361
qt422016.ReleaseByteBuffer(qb422016)
//line lib/promscrape/targetstatus.qtpl:361
return qs422016
//line lib/promscrape/targetstatus.qtpl:361
}
//line lib/promscrape/targetstatus.qtpl:363 //line lib/promscrape/targetstatus.qtpl:363
qw422016.N().D(num)
//line lib/promscrape/targetstatus.qtpl:363
qw422016.N().S(`').style.display='none'">collapse</button><button type="button" class="btn btn-secondary btn-sm me-1"onclick="document.getElementById('scrape-job-`)
//line lib/promscrape/targetstatus.qtpl:367
qw422016.N().D(num)
//line lib/promscrape/targetstatus.qtpl:367
qw422016.N().S(`').style.display='block'">expand</button>`)
//line lib/promscrape/targetstatus.qtpl:370
}
//line lib/promscrape/targetstatus.qtpl:370
func writeshowHideScrapeJobButtons(qq422016 qtio422016.Writer, num int) {
//line lib/promscrape/targetstatus.qtpl:370
qw422016 := qt422016.AcquireWriter(qq422016)
//line lib/promscrape/targetstatus.qtpl:370
streamshowHideScrapeJobButtons(qw422016, num)
//line lib/promscrape/targetstatus.qtpl:370
qt422016.ReleaseWriter(qw422016)
//line lib/promscrape/targetstatus.qtpl:370
}
//line lib/promscrape/targetstatus.qtpl:370
func showHideScrapeJobButtons(num int) string {
//line lib/promscrape/targetstatus.qtpl:370
qb422016 := qt422016.AcquireByteBuffer()
//line lib/promscrape/targetstatus.qtpl:370
writeshowHideScrapeJobButtons(qb422016, num)
//line lib/promscrape/targetstatus.qtpl:370
qs422016 := string(qb422016.B)
//line lib/promscrape/targetstatus.qtpl:370
qt422016.ReleaseByteBuffer(qb422016)
//line lib/promscrape/targetstatus.qtpl:370
return qs422016
//line lib/promscrape/targetstatus.qtpl:370
}
//line lib/promscrape/targetstatus.qtpl:372
func streamqueryArgs(qw422016 *qt422016.Writer, filter *requestFilter, override map[string]string) { func streamqueryArgs(qw422016 *qt422016.Writer, filter *requestFilter, override map[string]string) {
//line lib/promscrape/targetstatus.qtpl:365 //line lib/promscrape/targetstatus.qtpl:374
showOnlyUnhealthy := "false" showOnlyUnhealthy := "false"
if filter.showOnlyUnhealthy { if filter.showOnlyUnhealthy {
showOnlyUnhealthy = "true" showOnlyUnhealthy = "true"
@ -983,89 +1005,89 @@ func streamqueryArgs(qw422016 *qt422016.Writer, filter *requestFilter, override
qa[k] = []string{v} qa[k] = []string{v}
} }
//line lib/promscrape/targetstatus.qtpl:382 //line lib/promscrape/targetstatus.qtpl:391
qw422016.E().S(qa.Encode()) qw422016.E().S(qa.Encode())
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
} }
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
func writequeryArgs(qq422016 qtio422016.Writer, filter *requestFilter, override map[string]string) { func writequeryArgs(qq422016 qtio422016.Writer, filter *requestFilter, override map[string]string) {
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
qw422016 := qt422016.AcquireWriter(qq422016) qw422016 := qt422016.AcquireWriter(qq422016)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
streamqueryArgs(qw422016, filter, override) streamqueryArgs(qw422016, filter, override)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
qt422016.ReleaseWriter(qw422016) qt422016.ReleaseWriter(qw422016)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
} }
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
func queryArgs(filter *requestFilter, override map[string]string) string { func queryArgs(filter *requestFilter, override map[string]string) string {
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
qb422016 := qt422016.AcquireByteBuffer() qb422016 := qt422016.AcquireByteBuffer()
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
writequeryArgs(qb422016, filter, override) writequeryArgs(qb422016, filter, override)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
qs422016 := string(qb422016.B) qs422016 := string(qb422016.B)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
qt422016.ReleaseByteBuffer(qb422016) qt422016.ReleaseByteBuffer(qb422016)
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
return qs422016 return qs422016
//line lib/promscrape/targetstatus.qtpl:383 //line lib/promscrape/targetstatus.qtpl:392
} }
//line lib/promscrape/targetstatus.qtpl:385 //line lib/promscrape/targetstatus.qtpl:394
func streamformatLabels(qw422016 *qt422016.Writer, labels *promutils.Labels) { func streamformatLabels(qw422016 *qt422016.Writer, labels *promutils.Labels) {
//line lib/promscrape/targetstatus.qtpl:386 //line lib/promscrape/targetstatus.qtpl:395
labelsList := labels.GetLabels() labelsList := labels.GetLabels()
//line lib/promscrape/targetstatus.qtpl:386 //line lib/promscrape/targetstatus.qtpl:395
qw422016.N().S(`{`) qw422016.N().S(`{`)
//line lib/promscrape/targetstatus.qtpl:388 //line lib/promscrape/targetstatus.qtpl:397
for i, label := range labelsList { for i, label := range labelsList {
//line lib/promscrape/targetstatus.qtpl:389 //line lib/promscrape/targetstatus.qtpl:398
qw422016.E().S(label.Name) qw422016.E().S(label.Name)
//line lib/promscrape/targetstatus.qtpl:389 //line lib/promscrape/targetstatus.qtpl:398
qw422016.N().S(`=`) qw422016.N().S(`=`)
//line lib/promscrape/targetstatus.qtpl:389 //line lib/promscrape/targetstatus.qtpl:398
qw422016.E().Q(label.Value) qw422016.E().Q(label.Value)
//line lib/promscrape/targetstatus.qtpl:390 //line lib/promscrape/targetstatus.qtpl:399
if i+1 < len(labelsList) { if i+1 < len(labelsList) {
//line lib/promscrape/targetstatus.qtpl:390 //line lib/promscrape/targetstatus.qtpl:399
qw422016.N().S(`,`) qw422016.N().S(`,`)
//line lib/promscrape/targetstatus.qtpl:390 //line lib/promscrape/targetstatus.qtpl:399
qw422016.N().S(` `) qw422016.N().S(` `)
//line lib/promscrape/targetstatus.qtpl:390 //line lib/promscrape/targetstatus.qtpl:399
} }
//line lib/promscrape/targetstatus.qtpl:391 //line lib/promscrape/targetstatus.qtpl:400
} }
//line lib/promscrape/targetstatus.qtpl:391 //line lib/promscrape/targetstatus.qtpl:400
qw422016.N().S(`}`) qw422016.N().S(`}`)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
} }
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
func writeformatLabels(qq422016 qtio422016.Writer, labels *promutils.Labels) { func writeformatLabels(qq422016 qtio422016.Writer, labels *promutils.Labels) {
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
qw422016 := qt422016.AcquireWriter(qq422016) qw422016 := qt422016.AcquireWriter(qq422016)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
streamformatLabels(qw422016, labels) streamformatLabels(qw422016, labels)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
qt422016.ReleaseWriter(qw422016) qt422016.ReleaseWriter(qw422016)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
} }
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
func formatLabels(labels *promutils.Labels) string { func formatLabels(labels *promutils.Labels) string {
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
qb422016 := qt422016.AcquireByteBuffer() qb422016 := qt422016.AcquireByteBuffer()
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
writeformatLabels(qb422016, labels) writeformatLabels(qb422016, labels)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
qs422016 := string(qb422016.B) qs422016 := string(qb422016.B)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
qt422016.ReleaseByteBuffer(qb422016) qt422016.ReleaseByteBuffer(qb422016)
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
return qs422016 return qs422016
//line lib/promscrape/targetstatus.qtpl:393 //line lib/promscrape/targetstatus.qtpl:402
} }