MCPcopy
hub / github.com/lindb/lindb / Merger

Interface Merger

kv/merger.go:40–47  ·  view source on GitHub ↗

Merger represents merger values of same key when do compaction job(compact/rollup etc.)

Source from the content-addressed store, hash-verified

38
39// Merger represents merger values of same key when do compaction job(compact/rollup etc.)
40type Merger interface {
41 // Init initializes merger params or context, before does merge operation
42 Init(params map[string]interface{})
43 // Merge merges values for same key,
44 // merged data will be written into Flusher directly
45 // return err if failure
46 Merge(key uint32, values [][]byte) error
47}

Callers 16

TestMerger_Rollup_MergeFunction · 0.95
doMergeMethod · 0.65
PurgeMethod · 0.65
initQueueMethod · 0.65
DecodeToMethod · 0.65
FromBlockMethod · 0.65
UnmarshalMethod · 0.65
initMethod · 0.65
TestMerger_Compact_MergeFunction · 0.95
TestMerger_Rollup_MergeFunction · 0.95
doMergeMethod · 0.65

Implementers 6

mockAppendMergerkv/compact_job_test.go
mergertsdb/tblstore/metricsdata/merger.go
forwardIndexMergerindex/v1/forward_merger.go
invertedIndexMergerindex/v1/inverted_merger.go
indexKVMergerindex/v1/index_kv_merger.go
metricSchemaMergerindex/v1/metric_schema_merger.go

Calls

no outgoing calls

Tested by

no test coverage detected