Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for eventNames (1.45 sec)

  1. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K 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 Dec 28 19:28:13 UTC 2025
    - 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  6. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/monitor/event/EventMonitor.java

     */
    package org.apache.maven.monitor.event;
    
    /**
     */
    @Deprecated
    public interface EventMonitor {
    
        void startEvent(String eventName, String target, long timestamp);
    
        void endEvent(String eventName, String target, long timestamp);
    
        void errorEvent(String eventName, String target, long timestamp, Throwable cause);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  9. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    	auditLogLifecycle(ctx, dobj, ILMExpiry, tags, traceFn)
    
    	eventName := event.ObjectRemovedDelete
    	if obj.DeleteMarker {
    		eventName = event.ObjectRemovedDeleteMarkerCreated
    	}
    	switch lcEvent.Action {
    	case lifecycle.DeleteAllVersionsAction:
    		eventName = event.ObjectRemovedDeleteAllVersions
    	case lifecycle.DelMarkerDeleteAllVersionsAction:
    		eventName = event.ILMDelMarkerExpirationDelete
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
Back to top