fix function names in comments (grafana#9415)

clients/pkg/logentry/stages/multiline.go

@@ -80,7 +80,7 @@ type multilineState struct {
 	currentLines   uint64        // The number of lines of the current multiline block.
 }
 
-// newMulitlineStage creates a MulitlineStage from config
+// newMultilineStage creates a MulitlineStage from config
 func newMultilineStage(logger log.Logger, config interface{}) (Stage, error) {
 	cfg := &MultilineConfig{}
 	err := mapstructure.WeakDecode(config, cfg)

clients/pkg/promtail/wal/watcher.go

@@ -249,7 +249,7 @@ func (w *Watcher) Stop() {
 	w.metrics.watchersRunning.WithLabelValues().Dec()
 }
 
-// firstAndList finds the first and last segment number for a WAL directory.
+// firstAndLast finds the first and last segment number for a WAL directory.
 func (w *Watcher) firstAndLast() (int, int, error) {
 	refs, err := readSegmentNumbers(w.walDir)
 	if err != nil {

pkg/distributor/distributor_ring.go

@@ -58,7 +58,7 @@ func (cfg *RingConfig) RegisterFlags(f *flag.FlagSet) {
 	f.BoolVar(&cfg.EnableIPv6, "distributor.ring.instance-enable-ipv6", false, "Enable using a IPv6 instance address.")
 }
 
-// ToLifecyclerConfig returns a BasicLifecyclerConfig based on the distributor
+// ToBasicLifecyclerConfig returns a BasicLifecyclerConfig based on the distributor
 // ring config.
 func (cfg *RingConfig) ToBasicLifecyclerConfig(logger log.Logger) (ring.BasicLifecyclerConfig, error) {
 	instanceAddr, err := ring.GetInstanceAddr(cfg.InstanceAddr, cfg.InstanceInterfaceNames, logger, cfg.EnableIPv6)

pkg/iter/cache.go

@@ -118,7 +118,7 @@ type cachedSampleIterator struct {
 	iterErr  error
 }
 
-// newSampleCachedIterator creates an iterator that cache iteration result and can be iterated again
+// NewCachedSampleIterator creates an iterator that cache iteration result and can be iterated again
 // after closing it without re-using the underlaying iterator `it`.
 func NewCachedSampleIterator(it SampleIterator, cap int) CacheSampleIterator {
 	c := &cachedSampleIterator{

pkg/iter/sample_iterator.go

@@ -472,7 +472,7 @@ type QuerySampleClient interface {
 	CloseSend() error
 }
 
-// NewQueryClientIterator returns an iterator over a QueryClient.
+// NewSampleQueryClientIterator returns an iterator over a QueryClient.
 func NewSampleQueryClientIterator(client QuerySampleClient) SampleIterator {
 	return &sampleQueryClientIterator{
 		client: client,
@@ -706,7 +706,7 @@ func (i *timeRangedSampleIterator) Next() bool {
 	return ok
 }
 
-// ReadBatch reads a set of entries off an iterator.
+// ReadSampleBatch reads a set of entries off an iterator.
 func ReadSampleBatch(i SampleIterator, size uint32) (*logproto.SampleQueryResponse, uint32, error) {
 	var (
 		series      = map[uint64]map[string]*logproto.Series{}

pkg/loghttp/params.go

@@ -124,7 +124,7 @@ func parseInt(value string, def int) (int, error) {
 	return strconv.Atoi(value)
 }
 
-// parseUnixNano parses a ns unix timestamp from a string
+// parseTimestamp parses a ns unix timestamp from a string
 // if the value is empty it returns a default value passed as second parameter
 func parseTimestamp(value string, def time.Time) (time.Time, error) {
 	if value == "" {