MCPcopy
hub / github.com/lindb/lindb / Add

Method Add

kv/flusher.go:39–39  ·  view source on GitHub ↗

Add puts k/v pair

(key uint32, value []byte)

Source from the content-addressed store, hash-verified

37 StreamWriter() (table.StreamWriter, error)
38 // Add puts k/v pair
39 Add(key uint32, value []byte) error
40 // Sequence sets write sequence number.
41 Sequence(leader int32, seq int64)
42 // Commit flushes data and commits metadata.

Callers 15

TestFamily_Data_Write_ReadFunction · 0.95
TestStore_CompactFunction · 0.95
TestDataLoadContext_IterateLowSeriesIDsFunction · 0.65
ScanTagValueIDsMethod · 0.65
collectGroupingTagValueIDsMethod · 0.65
TestFlusher_AddFunction · 0.65
rollupMethod · 0.65
AddMethod · 0.65
NewFlusherMethod · 0.65
compactMethod · 0.65
MergeMethod · 0.65
TestCompactJob_output_failFunction · 0.65

Calls

no outgoing calls

Tested by 15

TestFamily_Data_Write_ReadFunction · 0.76
TestStore_CompactFunction · 0.76
TestDataLoadContext_IterateLowSeriesIDsFunction · 0.52
TestFlusher_AddFunction · 0.52
MergeMethod · 0.52
TestCompactJob_output_failFunction · 0.52
TestCompactJob_merge_rollupFunction · 0.52
TestCompactFlusherFunction · 0.52
TestShard_WaitFlushIndexCompletedFunction · 0.52
TestDatabase_WaitFlushMetaCompletedFunction · 0.52
TestIndexDatabase_handleRowFunction · 0.52
Benchmark_syncMapFunction · 0.52