Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for MergeMaskable (0.46 sec)

  1. internal/pubsub/mask.go

    func (t *Mask) FromUint64(m uint64) {
    	*t = Mask(m)
    }
    
    // Merge will merge other into t.
    func (t *Mask) Merge(other Mask) {
    	*t |= other
    }
    
    // MergeMaskable will merge other into t.
    func (t *Mask) MergeMaskable(other Maskable) {
    	*t |= Mask(other.Mask())
    }
    
    // SetIf will add other if b is true.
    func (t *Mask) SetIf(b bool, other Mask) {
    	if b {
    		*t |= other
    	}
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jul 05 21:45:49 GMT 2022
    - 1.3K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    	var mask pubsub.Mask
    	for _, s := range values[peerRESTListenEvents] {
    		eventName, err := event.ParseName(s)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	var eventNames []event.Name
    	var mask pubsub.Mask
    	for _, ev := range values[peerRESTListenEvents] {
    		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()})
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
Back to top