Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 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/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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/event/target/nsq.go

    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	return target.producer.Publish(target.args.Topic, data)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  9. internal/event/target/webhook.go

    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	req, err := http.NewRequest(http.MethodPost, target.args.Endpoint.String(), bytes.NewReader(data))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  10. internal/event/target/mqtt.go

    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	token := target.client.Publish(target.args.Topic, target.args.QoS, false, string(data))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top