Function bleveRuntimeConfigMap

pindex_bleve.go:912–1003

(bleveParams *BleveParams)

}

func bleveRuntimeConfigMap(bleveParams *BleveParams) (map[string]interface{},
	string, string) {
	// check the indexType
	bleveIndexType, ok := bleveParams.Store["indexType"].(string)
	if !ok || bleveIndexType == "" {
		bleveIndexType = bleve.Config.DefaultIndexType
	}

	kvConfig := map[string]interface{}{
		"create_if_missing":      true,
		"error_if_exists":        true,
		"unsafe_batch":           true,
		"eventCallbackName":      "scorchEventCallbacks",
		"asyncErrorCallbackName": "scorchAsyncErrorCallbacks",
		"numSnapshotsToKeep":     3,
		"forceSegmentType":       "zap",
		"bolt_timeout":           "30s",
	}
	for k, v := range bleveParams.Store {
		if k == "segmentVersion" {
			kvConfig["forceSegmentVersion"] = v
			continue
		}
		kvConfig[k] = v
	}

	kvStoreName := "scorch"
	if bleveIndexType != "scorch" {
		kvStoreName, ok = bleveParams.Store["kvStoreName"].(string)
		if !ok || kvStoreName == "" {
			if bleveIndexType == upsidedown.Name {
				kvStoreName = "mossStore"
			} else {
				kvStoreName = bleve.Config.DefaultKVStore
			}
		}

		// Use the "moss" wrapper KVStore if it's allowed, available
		// and also not already configured.
		kvStoreMossAllow := true
		ksmv, exists := kvConfig["kvStoreMossAllow"]
		if exists {
			var v bool
			v, ok = ksmv.(bool)
			if ok {
				kvStoreMossAllow = v
			}
		}

		if kvStoreMossAllow && BlevePIndexAllowMoss {
			_, exists = kvConfig["mossLowerLevelStoreName"]
			if !exists &&
				kvStoreName != "moss" &&
				bleveRegistry.KVStoreConstructorByName("moss") != nil {
				kvConfig["mossLowerLevelStoreName"] = kvStoreName
				kvStoreName = "moss"
			}