chore: fix function names in comment (#6076)

Signed-off-by: wanshuangcheng <wanshuangcheng@outlook.com>
This commit is contained in:
wanshuangcheng 2024-04-08 16:11:12 +08:00 committed by Aliaksandr Valialkin
parent e46150c3bf
commit 52a4ae0b28
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
4 changed files with 4 additions and 4 deletions

View file

@ -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 {

View file

@ -1216,7 +1216,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

View file

@ -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)

View file

@ -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) {