Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ToRulesMap (0.23 sec)

  1. internal/event/config.go

    	for i := range conf.QueueList {
    		conf.QueueList[i].SetRegion(region)
    	}
    }
    
    // ToRulesMap - converts all queue configuration to RulesMap.
    func (conf *Config) ToRulesMap() RulesMap {
    	rulesMap := make(RulesMap)
    
    	for _, queue := range conf.QueueList {
    		rulesMap.Add(queue.ToRulesMap())
    	}
    
    	return rulesMap
    }
    
    // ParseConfig - parses data in reader to notification configuration.
    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. cmd/bucket-notification-handlers.go

    	}
    
    	if _, err = globalBucketMetadataSys.Update(ctx, bucketName, bucketNotificationConfig, configData); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	rulesMap := config.ToRulesMap()
    	globalEventNotifier.AddRulesMap(bucketName, rulesMap)
    
    	writeSuccessResponseHeadersOnly(w)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  3. cmd/event-notification.go

    	if err := config.Validate(region, globalEventNotifier.targetList); err != nil {
    		if _, ok := err.(*event.ErrARNNotFound); !ok {
    			internalLogIf(GlobalContext, err)
    		}
    	}
    	evnot.AddRulesMap(bucket, config.ToRulesMap())
    }
    
    // Targets returns all the registered targets
    func (evnot *EventNotifier) Targets() []event.Target {
    	return evnot.targetList.Targets()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. internal/event/config_test.go

    		queue          *Queue
    		expectedResult RulesMap
    	}{
    		{queueCase1, rulesMapCase1},
    		{queueCase2, rulesMapCase2},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.queue.ToRulesMap()
    
    		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)
  5. cmd/peer-rest-server.go

    		return np, grid.NewRemoteErr(err)
    	}
    
    	globalBucketMetadataSys.Set(bucketName, meta)
    
    	if meta.notificationConfig != nil {
    		globalEventNotifier.AddRulesMap(bucketName, meta.notificationConfig.ToRulesMap())
    	}
    
    	if meta.bucketTargetConfig != nil {
    		globalBucketTargetSys.UpdateAllTargets(bucketName, meta.bucketTargetConfig)
    	}
    
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top