github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-02-19 15:30:17 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix some typo (#3898)

Browse source
This commit is contained in:
Haleygo 2023-03-03 18:02:13 +08:00 committed by Aliaksandr Valialkin
parent 950abf7457
commit b301455150
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/promscrape/client.go
View file

@ -33,7 +33,7 @@ var (
"Note that disabling HTTP keep-alive may increase load on both vmagent and scrape targets") "Note that disabling HTTP keep-alive may increase load on both vmagent and scrape targets")
streamParse = flag.Bool("promscrape.streamParse", false, "Whether to enable stream parsing for metrics obtained from scrape targets. This may be useful "+ streamParse = flag.Bool("promscrape.streamParse", false, "Whether to enable stream parsing for metrics obtained from scrape targets. This may be useful "+
"for reducing memory usage when millions of metrics are exposed per each scrape target. "+ "for reducing memory usage when millions of metrics are exposed per each scrape target. "+
"It is posible to set 'stream_parse: true' individually per each 'scrape_config' section in '-promscrape.config' for fine grained control") "It is possible to set 'stream_parse: true' individually per each 'scrape_config' section in '-promscrape.config' for fine grained control")
) )
type client struct { type client struct {
@ -260,7 +260,7 @@ func (c *client) ReadData(dst []byte) ([]byte, error) {
swapResponseBodies := len(dst) == 0 swapResponseBodies := len(dst) == 0
if swapResponseBodies { if swapResponseBodies {
// An optimization: write response directly to dst. // An optimization: write response directly to dst.
// This should reduce memory uage when scraping big targets. // This should reduce memory usage when scraping big targets.
dst = resp.SwapBody(dst) dst = resp.SwapBody(dst)
} }

2
lib/protoparser/common/unmarshal_work.go
View file

@ -23,7 +23,7 @@ type UnmarshalWork interface {
// StartUnmarshalWorkers starts unmarshal workers. // StartUnmarshalWorkers starts unmarshal workers.
func StartUnmarshalWorkers() { func StartUnmarshalWorkers() {
if unmarshalWorkCh != nil { if unmarshalWorkCh != nil {
logger.Panicf("BUG: it looks like startUnmarshalWorkers() has been alread called without stopUnmarshalWorkers()") logger.Panicf("BUG: it looks like startUnmarshalWorkers() has been already called without stopUnmarshalWorkers()")
} }
gomaxprocs := cgroup.AvailableCPUs() gomaxprocs := cgroup.AvailableCPUs()
unmarshalWorkCh = make(chan UnmarshalWork, gomaxprocs) unmarshalWorkCh = make(chan UnmarshalWork, gomaxprocs)