Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for SetRegion (0.08 sec)

  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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  2. internal/config/legacy.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package config
    
    // One time migration code section
    
    // SetRegion - One time migration code needed, for migrating from older config to new for server Region.
    func SetRegion(c Config, name string) {
    	if name == "" {
    		return
    	}
    	c[RegionSubSys][Default] = KVS{
    		KV{
    			Key:   RegionName,
    			Value: name,
    		},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Dec 19 20:27:06 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  3. cmd/config-current_test.go

    		t.Fatalf("Init Test config failed")
    	}
    
    	if globalSite.Region() != globalMinioDefaultRegion {
    		t.Errorf("Expecting region `us-east-1` found %s", globalSite.Region())
    	}
    
    	// Set new region and verify.
    	config.SetRegion(globalServerConfig, "us-west-1")
    	site, err := config.LookupSite(
    		globalServerConfig[config.SiteSubSys][config.Default],
    		globalServerConfig[config.RegionSubSys][config.Default],
    	)
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 2K bytes
    - Viewed (0)
  4. cmd/bucket-notification-handlers.go

    	}
    
    	config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	region := globalSite.Region()
    	config.SetRegion(region)
    	if err = config.Validate(region, globalEventNotifier.targetList); err != nil {
    		arnErr, ok := err.(*event.ErrARNNotFound)
    		if ok {
    			for i, queue := range config.QueueList {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. cmd/event-notification.go

    func (evnot *EventNotifier) set(bucket string, meta BucketMetadata) {
    	config := meta.notificationConfig
    	if config == nil {
    		return
    	}
    	region := globalSite.Region()
    	config.SetRegion(region)
    	if err := config.Validate(region, globalEventNotifier.targetList); err != nil {
    		if _, ok := err.(*event.ErrARNNotFound); !ok {
    			internalLogIf(GlobalContext, err)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. 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)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. internal/event/config_test.go

    		{queue2, "us-east-1", ARN{TargetID{"1", "webhook"}, "us-east-1"}},
    		{queue2, "", ARN{TargetID{"1", "webhook"}, ""}},
    	}
    
    	for i, testCase := range testCases {
    		testCase.queue.SetRegion(testCase.region)
    		result := testCase.queue.ARN
    
    		if !reflect.DeepEqual(result, testCase.expectedResult) {
    			t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result)
    		}
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  8. cmd/handler-utils_test.go

    		// Test case - 4
    		// In case of invalid XML request body ErrMalformedXML is returned.
    		{malformedReq, globalMinioDefaultRegion, ErrMalformedXML},
    	}
    
    	for i, testCase := range testCases {
    		config.SetRegion(globalServerConfig, testCase.serverConfigRegion)
    		_, actualCode := parseLocationConstraint(testCase.request)
    		if testCase.expectedCode != actualCode {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top