Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for eventNames (0.13 sec)

  1. internal/event/rulesmap.go

    	for eventName, rules := range rulesMap {
    		if nr := rules.Difference(rulesMap2[eventName]); len(nr) != 0 {
    			rulesMap[eventName] = nr
    		} else {
    			delete(rulesMap, eventName)
    		}
    	}
    }
    
    // MatchSimple - returns true if matching object name and event name in rules map.
    func (rulesMap RulesMap) MatchSimple(eventName Name, objectName string) bool {
    	return rulesMap[eventName].MatchSimple(objectName)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    	}
    
    	pattern := event.NewPattern(prefix, suffix)
    
    	var eventNames []event.Name
    	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 != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/event/rulesmap_test.go

    	}, "*", TargetID{"1", "webhook"})
    
    	rulesMapCase3 := make(RulesMap)
    	rulesMapCase3.add([]Name{ObjectRemovedDelete}, "2010*.jpg", TargetID{"1", "webhook"})
    
    	testCases := []struct {
    		eventNames     []Name
    		pattern        string
    		targetID       TargetID
    		expectedResult RulesMap
    	}{
    		{[]Name{ObjectAccessedAll}, "", TargetID{"1", "webhook"}, rulesMapCase1},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  4. cmd/peer-rest-server.go

    	pattern := event.NewPattern(prefix, suffix)
    
    	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()})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  5. cmd/event-notification.go

    			},
    		},
    		Source: event.Source{
    			Host:      args.Host,
    			UserAgent: args.UserAgent,
    		},
    	}
    
    	isRemovedEvent := args.EventName == event.ObjectRemovedDelete ||
    		args.EventName == event.ObjectRemovedDeleteMarkerCreated ||
    		args.EventName == event.ObjectRemovedNoOP
    
    	if !isRemovedEvent {
    		newEvent.S3.Object.ETag = args.Object.ETag
    		newEvent.S3.Object.Size = args.Object.Size
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. internal/event/event.go

    	EventSource       string            `json:"eventSource"`
    	AwsRegion         string            `json:"awsRegion"`
    	EventTime         string            `json:"eventTime"`
    	EventName         Name              `json:"eventName"`
    	UserIdentity      Identity          `json:"userIdentity"`
    	RequestParameters map[string]string `json:"requestParameters"`
    	ResponseElements  map[string]string `json:"responseElements"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  7. internal/event/name.go

    func (name *Name) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	eventName, err := ParseName(s)
    	if err != nil {
    		return err
    	}
    
    	*name = eventName
    	return nil
    }
    
    // MarshalJSON - encodes to JSON data.
    func (name Name) MarshalJSON() ([]byte, error) {
    	return json.Marshal(name.String())
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. internal/event/errors.go

    }
    
    // ErrDuplicateEventName - duplicate event name error.
    type ErrDuplicateEventName struct {
    	EventName Name
    }
    
    func (err ErrDuplicateEventName) Error() string {
    	return fmt.Sprintf("duplicate event name '%v' found", err.EventName)
    }
    
    // ErrUnsupportedConfiguration - unsupported configuration error.
    type ErrUnsupportedConfiguration struct{}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 4.1K bytes
    - Viewed (0)
  9. internal/event/config.go

    		return errors.New("missing event name(s)")
    	}
    
    	eventStringSet := set.NewStringSet()
    	for _, eventName := range parsedQueue.Events {
    		if eventStringSet.Contains(eventName.String()) {
    			return &ErrDuplicateEventName{eventName}
    		}
    
    		eventStringSet.Add(eventName.String())
    	}
    
    	*q = Queue(parsedQueue)
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    			},
    			UserAgent: "Internal: [Replication]",
    			Host:      globalLocalNodeName,
    			EventName: eventName,
    		})
    	} else {
    		sendEvent(eventArgs{
    			BucketName: bucket,
    			Object:     dobjInfo,
    			UserAgent:  "Internal: [Replication]",
    			Host:       globalLocalNodeName,
    			EventName:  eventName,
    		})
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top