Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewRulesMap (0.25 sec)

  1. 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"})
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Jan 05 18:43:06 GMT 2024
    - 6.8K bytes
    - Viewed (0)
  2. 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 = "*"
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.6K bytes
    - Viewed (0)
  3. 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"})
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K bytes
    - Viewed (0)
  4. 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.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  5. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  6. 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()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
Back to top