Function PrepareIndexDef

pindex_bleve.go:497–612

(mgr *cbgt.Manager, indexDef *cbgt.IndexDef)

}

func PrepareIndexDef(mgr *cbgt.Manager, indexDef *cbgt.IndexDef) (
	*cbgt.IndexDef, error) {
	if indexDef == nil {
		return nil, fmt.Errorf("bleve: Prepare, indexDef is nil")
	}

	if CurrentNodeDefsFetcher == nil {
		return limitIndexDef(indexDef)
	}

	nodeDefs, err := CurrentNodeDefsFetcher.Get()
	if err != nil {
		return nil, fmt.Errorf("bleve: Prepare, nodeDefs unavailable: err: %v", err)
	}

	var collectionsSupported bool
	if versionTracker != nil &&
		versionTracker.clusterCompatibleForVersion(FeatureCollectionVersion) {
		collectionsSupported =
			cbgt.IsFeatureSupportedByCluster(FeatureCollections, nodeDefs)
	}

	if collectionsSupported {
		// Use "gocbcore" for DCP streaming if cluster is 7.0+
		indexDef.SourceType = cbgt.SOURCE_GOCBCORE
	}

	bp := NewBleveParams()
	if len(indexDef.Params) > 0 {
		b, err := bleveMappingUI.CleanseJSON([]byte(indexDef.Params))
		if err != nil {
			return nil, fmt.Errorf("bleve: Prepare, CleanseJSON,"+
				" err: %v", err)
		}

		err = json.Unmarshal(b, bp)
		if err != nil {
			if typeErr, ok := err.(*json.UnmarshalTypeError); ok {
				if typeErr.Type.String() == "map[string]json.RawMessage" {
					return nil, fmt.Errorf("bleve: Prepare,"+
						" JSON parse was expecting a string key/field-name"+
						" but instead saw a %s", typeErr.Value)
				}
			}
			return nil, fmt.Errorf("bleve: Prepare, err: %v", err)
		}

		if indexType, ok := bp.Store["indexType"].(string); ok {
			if indexType == "scorch" {
				// If indexType were "scorch", the "kvStoreName" setting isn't
				// really applicable, so drop the setting.
				delete(bp.Store, "kvStoreName")
			}
		}

		// figure out the scope/collection details from mappings
		// and perform the validation checks.
		if strings.HasPrefix(bp.DocConfig.Mode, ConfigModeCollPrefix) {