parse mossLowerLevelMaxBatchSize only when lower-level-store exists
This commit is contained in:
parent
76b9365928
commit
1d63c55f7c
@ -92,6 +92,20 @@ func New(mo store.MergeOperator, config map[string]interface{}) (
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var llStore store.KVStore
|
||||||
|
if options.LowerLevelInit == nil &&
|
||||||
|
options.LowerLevelUpdate == nil &&
|
||||||
|
mossLowerLevelStoreName != "" {
|
||||||
|
mossLowerLevelStoreConfig := map[string]interface{}{}
|
||||||
|
v, ok := config["mossLowerLevelStoreConfig"]
|
||||||
|
if ok {
|
||||||
|
mossLowerLevelStoreConfig, ok = v.(map[string]interface{})
|
||||||
|
if !ok {
|
||||||
|
return nil, fmt.Errorf("moss store, initLowerLevelStore,"+
|
||||||
|
" could parse mossLowerLevelStoreConfig: %v", v)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
mossLowerLevelMaxBatchSize := uint64(0)
|
mossLowerLevelMaxBatchSize := uint64(0)
|
||||||
v, ok = config["mossLowerLevelMaxBatchSize"]
|
v, ok = config["mossLowerLevelMaxBatchSize"]
|
||||||
if ok {
|
if ok {
|
||||||
@ -104,23 +118,6 @@ func New(mo store.MergeOperator, config map[string]interface{}) (
|
|||||||
mossLowerLevelMaxBatchSize = uint64(mossLowerLevelMaxBatchSizeF)
|
mossLowerLevelMaxBatchSize = uint64(mossLowerLevelMaxBatchSizeF)
|
||||||
}
|
}
|
||||||
|
|
||||||
// --------------------------------------------------
|
|
||||||
|
|
||||||
var llStore store.KVStore
|
|
||||||
if options.LowerLevelInit == nil &&
|
|
||||||
options.LowerLevelUpdate == nil &&
|
|
||||||
mossLowerLevelStoreName != "" {
|
|
||||||
mossLowerLevelStoreConfig := map[string]interface{}{}
|
|
||||||
|
|
||||||
v, ok := config["mossLowerLevelStoreConfig"]
|
|
||||||
if ok {
|
|
||||||
mossLowerLevelStoreConfig, ok = v.(map[string]interface{})
|
|
||||||
if !ok {
|
|
||||||
return nil, fmt.Errorf("moss store, initLowerLevelStore,"+
|
|
||||||
" could parse mossLowerLevelStoreConfig: %v", v)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
lowerLevelInit, lowerLevelUpdate, lowerLevelStore, err :=
|
lowerLevelInit, lowerLevelUpdate, lowerLevelStore, err :=
|
||||||
initLowerLevelStore(mo, config,
|
initLowerLevelStore(mo, config,
|
||||||
mossLowerLevelStoreName,
|
mossLowerLevelStoreName,
|
||||||
|
Loading…
Reference in New Issue
Block a user