Method updateCache

controller/mutators/etcd/enum_mutator.go:227–245

(cacheKey string, nodeID int, dict map[string]int)

}

func (e *enumMutator) updateCache(cacheKey string, nodeID int, dict map[string]int) {
	e.Lock()
	cache, ok := e.enumCacheMap[cacheKey]
	if !ok {
		cache = enumCache{
			enumCases: make(map[string]int),
		}
	}
	// update currentNodeID for cache
	cache.currentNodeID = nodeID
	// merge newEnumCaseDict to cache
	for enumCase, enumID := range dict {
		if _, exist := cache.enumCases[enumCase]; !exist {
			cache.enumCases[enumCase] = enumID
		}
	}
	e.enumCacheMap[cacheKey] = cache
	e.Unlock()
}

func (e *enumMutator) GetEnumCases(namespace, tableName, columnName string) ([]string, error) {
	schema, err := e.schemaMutator.GetTable(namespace, tableName)