Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 28 of 28 for eventNames (0.07 sec)

  1. cmd/bucket-lifecycle.go

    	eventName := event.ObjectRemovedDelete
    	if oi.DeleteMarker {
    		eventName = event.ObjectRemovedDeleteMarkerCreated
    	}
    	objInfo := ObjectInfo{
    		Name:         oi.Name,
    		VersionID:    oi.VersionID,
    		DeleteMarker: oi.DeleteMarker,
    	}
    	// Notify object deleted event.
    	sendEvent(eventArgs{
    		EventName:  eventName,
    		BucketName: oi.Bucket,
    		Object:     objInfo,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. internal/event/target/postgresql.go

    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = conn.Do("HDEL", target.args.Key, key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. cmd/object-handlers-common.go

    			// Send audit for the lifecycle delete operation
    			auditLogLifecycle(
    				ctx,
    				oi,
    				ILMExpiry, tags, traceFn)
    
    			evArgs := eventArgs{
    				EventName:  event.ObjectRemovedDelete,
    				BucketName: bucket,
    				Object: ObjectInfo{
    					Name:      dobj.ObjectName,
    					VersionID: dobj.VersionID,
    				},
    				UserAgent: "Internal: [ILM-Expiry]",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 06:33:53 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  5. internal/event/target/mysql.go

    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    				return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  6. internal/event/target/elasticsearch.go

    				hh.Write([]byte(key))
    				hashBytes := hh.Sum(nil)
    				keyHash = base64.URLEncoding.EncodeToString(hashBytes)
    			} else {
    				keyHash = key
    			}
    		}
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			err = target.client.removeEntry(ctx, target.args.Index, keyHash)
    		} else {
    			err = target.client.updateEntry(ctx, target.args.Index, keyHash, eventData)
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    
    	// Notify object created event.
    	evt := eventArgs{
    		EventName:    event.ObjectCreatedCompleteMultipartUpload,
    		BucketName:   bucket,
    		Object:       objInfo,
    		ReqParams:    extractReqParams(r),
    		RespElements: extractRespElements(w),
    		UserAgent:    r.UserAgent(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    	fi.TransitionedObjName = destObj
    	fi.TransitionTier = opts.Transition.Tier
    	fi.TransitionVersionID = string(rv)
    	eventName := event.ObjectTransitionComplete
    
    	storageDisks := er.getDisks()
    
    	if err = er.deleteObjectVersion(ctx, bucket, object, fi, false); err != nil {
    		eventName = event.ObjectTransitionFailed
    	}
    
    	for _, disk := range storageDisks {
    		if disk != nil && disk.IsOnline() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top