Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewRulesMap (0.04 sec)

  1. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
Back to top