GetIndexComparer returns the registered index comparer for the given engine.
(engine storepb.Engine)
| 64 | |
| 65 | // GetIndexComparer returns the registered index comparer for the given engine. |
| 66 | func GetIndexComparer(engine storepb.Engine) IndexComparer { |
| 67 | indexComparerMutex.RLock() |
| 68 | defer indexComparerMutex.RUnlock() |
| 69 | |
| 70 | if comparer, exists := indexComparers[engine]; exists { |
| 71 | return comparer |
| 72 | } |
| 73 | |
| 74 | // Return default comparer if no specific comparer is registered |
| 75 | return &DefaultIndexComparer{} |
| 76 | } |
| 77 | |
| 78 | func init() { |
| 79 | // Register default comparers for engines that don't have specific implementations |