Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for ToRulesMap (0.05 seconds)

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

  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.
    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/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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  3. 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 np, nerr
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
Back to Top