- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NewRulesMap (0.07 sec)
-
internal/event/rulesmap_test.go
rulesMapCase1 := make(RulesMap) rulesMapToAddCase1 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"}) rulesMapCase2 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"}) rulesMapToAddCase2 := NewRulesMap([]Name{ObjectCreatedAll}, "2010*.jpg", TargetID{"1", "webhook"}) rulesMapCase3 := NewRulesMap([]Name{ObjectCreatedAll}, "2010*.jpg", TargetID{"1", "webhook"})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jan 05 18:43:06 UTC 2024 - 6.8K bytes - Viewed (0) -
internal/event/config_test.go
if err := xml.Unmarshal(data, config3); err != nil { panic(err) } rulesMapCase1 := NewRulesMap([]Name{ObjectAccessedAll, ObjectCreatedAll, ObjectRemovedAll}, "*", TargetID{"1", "webhook"}) rulesMapCase2 := NewRulesMap([]Name{ObjectCreatedPut}, "images/*jpg", TargetID{"1", "webhook"}) rulesMapCase3 := NewRulesMap([]Name{ObjectAccessedAll, ObjectCreatedAll, ObjectRemovedAll}, "*", TargetID{"1", "webhook"})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 29K bytes - Viewed (0) -
internal/event/rulesmap.go
func (rulesMap RulesMap) Match(eventName Name, objectName string) TargetIDSet { return rulesMap[eventName].Match(objectName) } // NewRulesMap - creates new rules map with given values. func NewRulesMap(eventNames []Name, pattern string, targetID TargetID) RulesMap { // If pattern is empty, add '*' wildcard to match all. if pattern == "" { pattern = "*" }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.6K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
internal/event/config.go
func (q *Queue) SetRegion(region string) { q.ARN.region = region } // ToRulesMap - converts Queue to RulesMap func (q Queue) ToRulesMap() RulesMap { pattern := q.Filter.RuleList.Pattern() return NewRulesMap(q.Events, pattern, q.ARN.TargetID) } // Unused. Available for completion. type lambda struct { ARN string `xml:"CloudFunction"` } // Unused. Available for completion. type topic struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 8.4K bytes - Viewed (0) -
cmd/peer-rest-server.go
eventName, err := event.ParseName(ev) if err != nil { return grid.NewRemoteErr(err) } mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) // Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0)