claudio-benfatto

0

claudio-benfatto

func (listener *CarbonserverListener) updateAccessedMetrics(details map[string]*pb.MetricDetails) map[string]struct{} {
	fidx := listener.CurrentFileIndex()
	accessedMetrics := make(map[string]struct{})
	if fidx != nil {
		fidx.Lock()
		defer fidx.Unlock()
		for m := range fidx.accessedMetrics {
			accessedMetrics[m] = struct{}{}
		}

claudio-benfatto

package main_test

import (
	"time"

	. "github.com/onsi/ginkgo"
	. "github.com/onsi/gomega"

	. "github.com/jriguera/metron-throughput/receiver"