Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for getRegion (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/config.go

    		if err := queue.Validate(region, targetList); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    // SetRegion - sets region to all queue configuration.
    func (conf *Config) SetRegion(region string) {
    	for i := range conf.QueueList {
    		conf.QueueList[i].SetRegion(region)
    	}
    }
    
    // ToRulesMap - converts all queue configuration to RulesMap.
    func (conf *Config) ToRulesMap() RulesMap {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  2. cmd/config-migrate.go

    		// V31 -> V32
    		cfg.Notify.NSQ = make(map[string]target.NSQArgs)
    		cfg.Notify.NSQ["1"] = target.NSQArgs{}
    	}
    
    	// Move to latest.
    	cfg.Version = "33"
    
    	newCfg := newServerConfig()
    
    	config.SetRegion(newCfg, cfg.Region)
    	storageclass.SetStorageClass(newCfg, cfg.StorageClass)
    
    	for k, loggerArgs := range cfg.Logger.HTTP {
    		logger.SetLoggerHTTP(newCfg, k, loggerArgs)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  3. cmd/test-utils_test.go

    func newTestConfig(bucketLocation string, obj ObjectLayer) (err error) {
    	// Initialize server config.
    	if err = newSrvConfig(obj); err != nil {
    		return err
    	}
    
    	// Set a default region.
    	config.SetRegion(globalServerConfig, bucketLocation)
    
    	applyDynamicConfigForSubSys(context.Background(), obj, globalServerConfig, config.StorageClassSubSys)
    
    	// Save config.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
Back to Top