INNER CODE UNIT · Go

sendMetricToNewMetricChan

go-graphite/go-carbon · cache/cache.go:308

func sendMetricToNewMetricChan(c *Cache, metric string) {
	select {
	case c.newMetricsChan <- metric:
	default:
		atomic.AddUint32(&c.stat.droppedRealtimeIndex, 1)
	}
}

// Sets the given value under the specified key.
func (c *Cache) Add(p *points.Points) {
	s := c.settings.Load().(*cacheSettings)

	if s.xlog != nil {
		p.WriteTo(s.xlog)
		return
	}

	if s.tagsEnabled {

View source record →