diff --git a/app/vmalert/rule/group.go b/app/vmalert/rule/group.go index bf0c24e0d..f4e6cd0dd 100644 --- a/app/vmalert/rule/group.go +++ b/app/vmalert/rule/group.go @@ -724,7 +724,7 @@ func (e *executor) exec(ctx context.Context, r Rule, ts time.Time, resolveDurati return errGr.Err() } -// getStaledSeries checks whether there are stale series from previously sent ones. +// getStaleSeries checks whether there are stale series from previously sent ones. func (e *executor) getStaleSeries(r Rule, tss []prompbmarshal.TimeSeries, timestamp time.Time) []prompbmarshal.TimeSeries { ruleLabels := make(map[string][]prompbmarshal.Label, len(tss)) for _, ts := range tss { diff --git a/app/vmselect/prometheus/prometheus.go b/app/vmselect/prometheus/prometheus.go index 947df907b..7a7e72c16 100644 --- a/app/vmselect/prometheus/prometheus.go +++ b/app/vmselect/prometheus/prometheus.go @@ -1113,7 +1113,7 @@ func (cp *commonParams) IsDefaultTimeRange() bool { return cp.start == 0 && cp.currentTimestamp-cp.end < 1000 } -// getCommonParams obtains common params from r, which are used in /api/v1/export* handlers +// getExportParams obtains common params from r, which are used in /api/v1/export* handlers // // - timeout // - start diff --git a/lib/logstorage/block_stream_writer.go b/lib/logstorage/block_stream_writer.go index c16740b81..b37f1337b 100644 --- a/lib/logstorage/block_stream_writer.go +++ b/lib/logstorage/block_stream_writer.go @@ -177,7 +177,7 @@ func (bsw *blockStreamWriter) reset() { bsw.indexBlockHeader.reset() } -// MustInitFromInmemoryPart initializes bsw from mp +// MustInitForInmemoryPart initializes bsw from mp func (bsw *blockStreamWriter) MustInitForInmemoryPart(mp *inmemoryPart) { bsw.reset() bsw.streamWriters.init(&mp.metaindex, &mp.index, &mp.columnsHeader, &mp.timestamps, &mp.fieldValues, &mp.fieldBloomFilter, &mp.messageValues, &mp.messageBloomFilter) diff --git a/lib/promscrape/discovery/nomad/watch.go b/lib/promscrape/discovery/nomad/watch.go index ac0718819..d477e98bf 100644 --- a/lib/promscrape/discovery/nomad/watch.go +++ b/lib/promscrape/discovery/nomad/watch.go @@ -239,7 +239,7 @@ func (cw *nomadWatcher) getServiceSnapshot() map[string][]Service { return sns } -// watchForServiceNodesUpdates watches for Nomad serviceNode changes for the given serviceName. +// watchForServiceAddressUpdates watches for Nomad serviceNode changes for the given serviceName. // // watchForServiceNodesUpdates calls initWG.Done() once the initialization is complete and the first discovery iteration is done. func (sw *serviceWatcher) watchForServiceAddressUpdates(nw *nomadWatcher, initWG *sync.WaitGroup) {