- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for ToRulesMap (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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)