refreshMetaFieldValCache updates the metaFieldValCache with the latest index definitions.
(indexDefs *cbgt.IndexDefs)
| 49 | // refreshMetaFieldValCache updates the metaFieldValCache with |
| 50 | // the latest index definitions. |
| 51 | func refreshMetaFieldValCache(indexDefs *cbgt.IndexDefs) { |
| 52 | if indexDefs == nil || metaFieldValCache == nil { |
| 53 | return |
| 54 | } |
| 55 | |
| 56 | bleveParams := NewBleveParams() |
| 57 | for _, indexDef := range indexDefs.IndexDefs { |
| 58 | err := json.Unmarshal([]byte(indexDef.Params), bleveParams) |
| 59 | if err != nil { |
| 60 | log.Printf("collection_utils: refreshMetaFieldValCache,"+ |
| 61 | " indexName: %v, err: %v", indexDef.Name, err) |
| 62 | continue |
| 63 | } |
| 64 | if strings.HasPrefix(bleveParams.DocConfig.Mode, ConfigModeCollPrefix) { |
| 65 | if im, ok := bleveParams.Mapping.(*mapping.IndexMappingImpl); ok { |
| 66 | _ = initMetaFieldValCache(indexDef.Name, indexDef.SourceName, im) |
| 67 | } |
| 68 | } |
| 69 | } |
| 70 | } |
| 71 | |
| 72 | func (c *collMetaFieldCache) getMetaFieldValue(indexName, collName string) string { |
| 73 | c.m.RLock() |
no test coverage detected