Method Add

kv/flusher.go:86–93

Add adds puts k/v pair. NOTICE: key must key in sort by desc

(key uint32, value []byte)

// Add adds puts k/v pair.
// NOTICE: key must key in sort by desc
func (sf *storeFlusher) Add(key uint32, value []byte) error {
	if err := sf.checkBuilder(); err != nil {
		metrics.FlushStatistics.Failure.Incr()
		return err
	}
	// TODO add file size limit
	return sf.builder.Add(key, value)
}

// Sequence sets write sequence number.
func (sf *storeFlusher) Sequence(leader int32, seq int64) {