- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for rulesMap (0.08 sec)
-
internal/event/config.go
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.4K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
} if bucketName != "" { if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
cmd/peer-rest-server.go
return } var rulesMap event.RulesMap if r.ContentLength < 0 { s.writeErrorResponse(w, errInvalidArgument) return } err := gob.NewDecoder(r.Body).Decode(&rulesMap) if err != nil { s.writeErrorResponse(w, err) return } globalEventNotifier.AddRulesMap(bucketName, rulesMap) } // HealthHandler - returns true of health
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 53.6K bytes - Viewed (0) -
internal/event/config_test.go
rulesMapCase2 := NewRulesMap([]Name{ObjectCreatedPut}, "images/*jpg", TargetID{"1", "webhook"}) testCases := []struct { queue *Queue expectedResult RulesMap }{ {queueCase1, rulesMapCase1}, {queueCase2, rulesMapCase2}, } for i, testCase := range testCases { result := testCase.queue.ToRulesMap()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 28.9K bytes - Viewed (0) -
cmd/iam.go
sys.Lock() sys.initStore(objAPI, etcdClient) // Initialize RoleARNs sys.rolesMap = make(map[arn.ARN]string) // From OpenID maps.Copy(sys.rolesMap, sys.OpenIDConfig.GetRoleInfo()) // From AuthN plugin if enabled. if authn := newGlobalAuthNPluginFn(); authn != nil { maps.Copy(sys.rolesMap, authn.GetRoleInfo()) } sys.printIAMRoles() sys.Unlock()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 15 17:00:45 UTC 2025 - 76.5K bytes - Viewed (0)