Method garbageCollect

replica/channel_database.go:111–123

garbageCollect recycles write families which is expired.

()

// garbageCollect recycles write families which is expired.
func (dc *databaseChannel) garbageCollect() {
	dc.shardChannels.mu.Lock()
	defer func() {
		dc.shardChannels.mu.Unlock()
	}()

	channels := dc.shardChannels.value.Load().(shard2Channel)
	ahead := dc.ahead.Load()
	behind := dc.behind.Load()
	for _, channel := range channels {
		channel.garbageCollect(ahead, behind)
	}
}

// Write writes the metric data into shardChannel's buffer
func (dc *databaseChannel) Write(ctx context.Context, brokerBatchRows *metric.BrokerBatchRows) error {