Обработка ошибок во время загрузки файла в карте данных

Описание проблемы:

Этот фрагмент кода загружает данные из файлов в карта во время запуска. Однако возникает проблема при возникновении ошибок во время загрузки файла. Проблема возникает из-за того, что код очищает карту перед загрузкой каждого нового файла, что может привести к потере данных в случае возникновения ошибки и не сохранения предыдущего состояния карты.

Предлагаемое решение:

Чтобы решить эту проблему, можно использовать более простой подход:

1. Загрузка конфигурации без сохранения состояния: Определите структуру CustomerConfig для инкапсуляции данных, подлежащих кэшированию.
2. Загрузить функцию конфигурации: Создайте функцию loadConfig(), отвечающую за загрузку конфигурации из файлов.
3. Диспетчер кэша: Введите структуру ConfigCache для управления конфигурацию, обеспечивая безопасный одновременный доступ и возможность отслеживать изменения с помощью обновляемой горутины.
4. Горутина обновления: Эта горутина периодически проверяет наличие изменений и загружает новые конфигурации, гарантируя, что кеш находится в рабочем состоянии. date.
5. Доступ к конфигурации: Метод GetConfig() обеспечивает доступ к самой последней конфигурации, гарантируя, что самые последние данные всегда доступны.

Реализация:

type CustomerConfig struct {
    Data map[string]bool
    LoadedAt time.Time
}

func loadConfig() (*CustomerConfig, error) {
    cfg := &CustomerConfig{
        Data: map[string]bool{},
        LoadedAt: time.Now(),
    }
    // Load files and populate cfg.Data
    // Return error if encountered
    return cfg, nil
}

type ConfigCache struct {
    configMu sync.RWMutex
    config   *CustomerConfig
    closeCh  chan struct{}
}

func NewConfigCache() (*ConfigCache, error) {
    cfg, err := loadConfig()
    if err != nil {
        return nil, err
    }
    cc := &ConfigCache{
        config:  cfg,
        closeCh: make(chan struct{}),
    }
    go cc.refresher()
    return cc, nil
}

func (cc *ConfigCache) refresher() {
    ticker := time.NewTicker(1 * time.Minute)
    defer ticker.Stop()
    for {
        select {
        case <-ticker.C:
            // Check for changes
            changes := false // Implement logic to detect changes
            if !changes {
                continue
            }
            cfg, err := loadConfig()
            if err != nil {
                log.Printf("Failed to load config: %v", err)
                continue
            }
            cc.configMu.Lock()
            cc.config = cfg
            cc.configMu.Unlock()
        case <-cc.closeCh:
            return
        }
    }
}

func (cc *ConfigCache) Stop() {
    close(cc.closeCh)
}

func (cc *ConfigCache) GetConfig() *CustomerConfig {
    cc.configMu.RLock()
    defer cc.configMu.RUnlock()
    return cc.config
}

Использование:

cc, err := NewConfigCache()
if err != nil {
    // Handle error
}
cfg := cc.GetConfig() // Access the latest configuration