Home
last modified time | relevance | path

Searched refs:MaxSamplesPerSend (Results 1 – 25 of 35) sorted by relevance

12

/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager_test.go171 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
251 n := config.DefaultQueueConfig.MaxSamplesPerSend * 2
297 if m.queueLen() != config.DefaultQueueConfig.MaxSamplesPerSend {
313 for i := 0; i < config.DefaultQueueConfig.MaxSamplesPerSend; i++ {
H A Dqueue_manager.go488 if len(pendingSamples) >= s.qm.cfg.MaxSamplesPerSend {
489 s.sendSamples(pendingSamples[:s.qm.cfg.MaxSamplesPerSend])
490 pendingSamples = pendingSamples[s.qm.cfg.MaxSamplesPerSend:]
/dports/net-mgmt/prometheus1/prometheus-1.8.2/storage/remote/
H A Dqueue_manager_test.go121 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
198 n := config.DefaultQueueConfig.MaxSamplesPerSend * 2
244 if m.queueLen() != config.DefaultQueueConfig.MaxSamplesPerSend {
H A Dqueue_manager.go430 for len(pendingSamples) >= s.qm.cfg.MaxSamplesPerSend {
431 s.sendSamples(pendingSamples[:s.qm.cfg.MaxSamplesPerSend])
432 pendingSamples = pendingSamples[s.qm.cfg.MaxSamplesPerSend:]
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager_test.go49 n := config.DefaultQueueConfig.MaxSamplesPerSend * 2
108 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
150 samples, series := createTimeseries(2 * config.DefaultQueueConfig.MaxSamplesPerSend)
486 n := config.DefaultQueueConfig.MaxSamplesPerSend * 10
635 minShards := int(inputRate) / cfg.MaxSamplesPerSend / 10
643 …sout := int64(m.numShards*cfg.MaxSamplesPerSend) * int64(shardUpdateDuration/(100*time.Millisecond…
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go162 MaxSamplesPerSend: 500,
179 MaxSamplesPerSend: 500,
740 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
759 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go162 MaxSamplesPerSend: 500,
179 MaxSamplesPerSend: 500,
740 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
759 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go162 MaxSamplesPerSend: 500,
179 MaxSamplesPerSend: 500,
740 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
759 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/net-mgmt/prometheus2/prometheus-2.30.3/config/
H A Dconfig.go162 MaxSamplesPerSend: 500,
179 MaxSamplesPerSend: 500,
740 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
759 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager_test.go127 queueConfig.MaxSamplesPerSend = len(samples) / 2
217 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
271 n := 2 * config.DefaultQueueConfig.MaxSamplesPerSend
702 n := config.DefaultQueueConfig.MaxSamplesPerSend * 10
888 minShards := int(inputRate) / cfg.MaxSamplesPerSend / 10
896 …sout := int64(m.numShards*cfg.MaxSamplesPerSend) * int64(shardUpdateDuration/(100*time.Millisecond…
H A Dqueue_manager.go596 t.metrics.maxSamplesPerSend.Set(float64(t.cfg.MaxSamplesPerSend))
1019 max = s.qm.cfg.MaxSamplesPerSend
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager_test.go127 queueConfig.MaxSamplesPerSend = len(samples) / 2
186 require.Equal(t, numMetadata/mcfg.MaxSamplesPerSend+1, c.writesReceived)
226 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
280 n := 2 * config.DefaultQueueConfig.MaxSamplesPerSend
921 minShards := int(inputRate) / cfg.MaxSamplesPerSend / 10
929 …sout := int64(m.numShards*cfg.MaxSamplesPerSend) * int64(shardUpdateDuration/(100*time.Millisecond…
H A Dqueue_manager.go448 numSends := int(math.Ceil(float64(len(metadata)) / float64(t.mcfg.MaxSamplesPerSend)))
450 last := (i + 1) * t.mcfg.MaxSamplesPerSend
454 err := t.sendMetadataWithBackoff(ctx, mm[i*t.mcfg.MaxSamplesPerSend:last])
456 t.metrics.failedMetadataTotal.Add(float64(last - (i * t.mcfg.MaxSamplesPerSend)))
457 …-recoverable error while sending metadata", "count", last-(i*t.mcfg.MaxSamplesPerSend), "err", err)
604 t.metrics.maxSamplesPerSend.Set(float64(t.cfg.MaxSamplesPerSend))
1040 max = s.qm.cfg.MaxSamplesPerSend
/dports/net-mgmt/prometheus2/prometheus-2.30.3/storage/remote/
H A Dqueue_manager_test.go127 queueConfig.MaxSamplesPerSend = len(samples) / 2
186 require.Equal(t, numMetadata/mcfg.MaxSamplesPerSend+1, c.writesReceived)
226 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
280 n := 2 * config.DefaultQueueConfig.MaxSamplesPerSend
921 minShards := int(inputRate) / cfg.MaxSamplesPerSend / 10
929 …sout := int64(m.numShards*cfg.MaxSamplesPerSend) * int64(shardUpdateDuration/(100*time.Millisecond…
H A Dqueue_manager.go448 numSends := int(math.Ceil(float64(len(metadata)) / float64(t.mcfg.MaxSamplesPerSend)))
450 last := (i + 1) * t.mcfg.MaxSamplesPerSend
454 err := t.sendMetadataWithBackoff(ctx, mm[i*t.mcfg.MaxSamplesPerSend:last])
456 t.metrics.failedMetadataTotal.Add(float64(last - (i * t.mcfg.MaxSamplesPerSend)))
457 …-recoverable error while sending metadata", "count", last-(i*t.mcfg.MaxSamplesPerSend), "err", err)
604 t.metrics.maxSamplesPerSend.Set(float64(t.cfg.MaxSamplesPerSend))
1040 max = s.qm.cfg.MaxSamplesPerSend
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager.go448 numSends := int(math.Ceil(float64(len(metadata)) / float64(t.mcfg.MaxSamplesPerSend)))
450 last := (i + 1) * t.mcfg.MaxSamplesPerSend
454 err := t.sendMetadataWithBackoff(ctx, mm[i*t.mcfg.MaxSamplesPerSend:last])
456 t.metrics.failedMetadataTotal.Add(float64(last - (i * t.mcfg.MaxSamplesPerSend)))
457 …-recoverable error while sending metadata", "count", last-(i*t.mcfg.MaxSamplesPerSend), "err", err)
604 t.metrics.maxSamplesPerSend.Set(float64(t.cfg.MaxSamplesPerSend))
1040 max = s.qm.cfg.MaxSamplesPerSend
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager.go448 numSends := int(math.Ceil(float64(len(metadata)) / float64(t.mcfg.MaxSamplesPerSend)))
450 last := (i + 1) * t.mcfg.MaxSamplesPerSend
454 err := t.sendMetadataWithBackoff(ctx, mm[i*t.mcfg.MaxSamplesPerSend:last])
456 t.metrics.failedMetadataTotal.Add(float64(last - (i * t.mcfg.MaxSamplesPerSend)))
457 …-recoverable error while sending metadata", "count", last-(i*t.mcfg.MaxSamplesPerSend), "err", err)
604 t.metrics.maxSamplesPerSend.Set(float64(t.cfg.MaxSamplesPerSend))
1040 max = s.qm.cfg.MaxSamplesPerSend
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/storage/remote/
H A Dqueue_manager_test.go109 n := config.DefaultQueueConfig.MaxSamplesPerSend * ts
151 samples, series := createTimeseries(2 * config.DefaultQueueConfig.MaxSamplesPerSend)
434 n := config.DefaultQueueConfig.MaxSamplesPerSend * 10
H A Dqueue_manager.go636 max := s.qm.cfg.MaxSamplesPerSend
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go112 MaxSamplesPerSend: 100,
629 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go112 MaxSamplesPerSend: 100,
658 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go161 MaxSamplesPerSend: 500,
716 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/prometheus/prometheus/config/
H A Dconfig.go115 MaxSamplesPerSend: 100,
714 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/pkg/ruler/
H A Dregistry.go280 overrides.Client.QueueConfig.MaxSamplesPerSend = v
/dports/net-mgmt/prometheus1/prometheus-1.8.2/config/
H A Dconfig.go184 MaxSamplesPerSend: 100,
1471 MaxSamplesPerSend int `yaml:"max_samples_per_send,omitempty"` member

12