Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 48 for eventName (0.1 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/event-notification.go

    	}
    
    	newEvent := event.Event{
    		EventVersion:      "2.0",
    		EventSource:       "minio:s3",
    		AwsRegion:         args.ReqParams["region"],
    		EventTime:         eventTime.Format(event.AMZTimeFormat),
    		EventName:         args.EventName,
    		UserIdentity:      event.Identity{PrincipalID: args.ReqParams["principalId"]},
    		RequestParameters: args.ReqParams,
    		ResponseElements:  respElements,
    		S3: event.Metadata{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. internal/event/event.go

    	EventVersion      string            `json:"eventVersion"`
    	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"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  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/rulesmap_test.go

    	rulesMapCase4.add([]Name{ObjectCreatedAll}, "*", TargetID{"2", "amqp"})
    
    	testCases := []struct {
    		rulesMap       RulesMap
    		eventName      Name
    		objectName     string
    		expectedResult TargetIDSet
    	}{
    		{rulesMapCase1, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet()},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top