MCPcopy
hub / github.com/lindb/lindb / StreamWriter

Method StreamWriter

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

StreamWriter creates a stream writer for flushing in stream.

()

Source from the content-addressed store, hash-verified

35type Flusher interface {
36 // StreamWriter creates a stream writer for flushing in stream.
37 StreamWriter() (table.StreamWriter, error)
38 // Add puts k/v pair
39 Add(key uint32, value []byte) error
40 // Sequence sets write sequence number.

Callers 15

StreamWriterMethod · 0.65
TestCompactFlusherFunction · 0.65
StreamWriterMethod · 0.65
Test_NewMergerFunction · 0.65
NewFlusherFunction · 0.65
NewInvertedIndexFlusherFunction · 0.65
NewForwardIndexFlusherFunction · 0.65
TestIndexKV_Merge_ErrorFunction · 0.65

Calls

no outgoing calls

Tested by 9

TestCompactFlusherFunction · 0.52
Test_NewMergerFunction · 0.52
TestIndexKV_Merge_ErrorFunction · 0.52