Cинхронизация кэша через Redis для сервиса на Go

void GetEntity(string id)
{
    if (!_cache.TryGetValue(id, out var entity))
    {
        lock(_cacheLock)
        {
             if (!_cache.TryGetValue(id, out entity))
             {
//maybe put a placeholder for frequent entity that is not 
//in the database anymore and fail before taking lock 
//or hitting a database
                 entity = _dao.LoadEntity(id);
                 if (entity != null)
                 {
                      _cache[id] = entity;
                 }
             }
        }
    }
}

//Happens on every update
//Reload one entity at most.
//If entity is not in the cache - does nothing
//When NOTIFY("1", 1) arrive it could load entity with 
//version 10.
//This is ok, NOTIFY("1", 2)..NOTIY("1", 10) will be ignored
//since cache already has up-to-date data.
void OnNotify(string id, long version)
{
//assuming updates do not happen all the time
//then this is not contented lock, taking such lock cost 
//about 50 ns. Loading 4 bytes from RAM cost 200 ns.
    lock(_cacheLock)
    {
//is this something we are interested in?
        if (_cache.TryGetValue(id, out var entity))
        {           
//stop if we already loaded this update from the db.
            if (entity.Version >= version) return;
 
            var updatedEntity = _dao.LoadEntity(id);
            if (updatedEntity?.Version > entity.Version)
            {
                _cache[id] = updatedEntity;
            }
//deleted or marked as deleted if(updatedEntity.Deleted)
            else  
            {
//or mark as removed
                 _cache.Remove(id); 
            }
       }
    }
}

//happens at most once a week, probably once a year.
void OnReconnect()
{
    lock(_cacheLock)
    {
        _cache.Clear(); 
//or reload everything from cache
//or do nothing
//or reload hot entities as defined by your stats
//or do something else if that make sense
    }
}

void UpdateEntity(Entity entity)
{
    using var tx = StartTx();
//Atomically increment entity version
//Use proper TX isolation level!
//UPDATE ... SET version = version + 1 RETURNING version;
    UpdateEntity(tx, entity);
//NOTIFY cache_channel id, version;
    Notify(tx, entity.Id, entity.Version);
    Commit(tx);
}