Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for lcEvent (0.06 sec)

  1. cmd/data-scanner.go

    	return true
    }
    
    func applyExpiryOnTransitionedObject(ctx context.Context, objLayer ObjectLayer, obj ObjectInfo, lcEvent lifecycle.Event, src lcEventSrc) (ok bool) {
    	timeILM := globalScannerMetrics.timeILM(lcEvent.Action)
    	if err := expireTransitionedObject(ctx, objLayer, &obj, lcEvent, src); err != nil {
    		if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    			return false
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  2. cmd/object-handlers-common.go

    		}
    	}
    	cs, _ := objInfo.decryptChecksums(0, h)
    	hash.AddChecksumHeader(w, cs)
    }
    
    func deleteObjectVersions(ctx context.Context, o ObjectLayer, bucket string, toDel []ObjectToDelete, lcEvent []lifecycle.Event) {
    	for remaining := toDel; len(remaining) > 0; toDel = remaining {
    		if len(toDel) > maxDeleteList {
    			remaining = toDel[maxDeleteList:]
    			toDel = toDel[:maxDeleteList]
    		} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jul 23 12:36:06 UTC 2025
    - 15.2K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    func expireTransitionedObject(ctx context.Context, objectAPI ObjectLayer, oi *ObjectInfo, lcEvent lifecycle.Event, src lcEventSrc) error {
    	traceFn := globalLifecycleSys.trace(*oi)
    	opts := ObjectOptions{
    		Versioned:  globalBucketVersioningSys.PrefixEnabled(oi.Bucket, oi.Name),
    		Expiration: ExpirationOptions{Expire: true},
    	}
    	if lcEvent.Action.DeleteVersioned() {
    		opts.VersionID = oi.VersionID
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  4. cmd/object-lambda-handlers_test.go

    				return levent.Event{
    					GetObjectContext: &levent.GetObjectContext{
    						OutputRoute: functionID,
    						OutputToken: functionToken,
    						InputS3URL:  "http://localhost/dummy",
    					},
    					UserRequest: levent.UserRequest{
    						Headers: map[string][]string{},
    					},
    					UserIdentity: levent.Identity{
    						PrincipalID: "test-user",
    					},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 18 21:56:31 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  5. cmd/object-lambda-handlers.go

    	if err != nil {
    		return levent.Event{}, err
    	}
    
    	ckSum := sha256.Sum256([]byte(cred.AccessKey + u.RawQuery))
    
    	eventData := levent.Event{
    		GetObjectContext: &levent.GetObjectContext{
    			InputS3URL:  u.String(),
    			OutputRoute: shortuuid.New(),
    			OutputToken: hex.EncodeToString(ckSum[:]),
    		},
    		UserRequest: levent.UserRequest{
    			URL:     r.URL.String(),
    			Headers: r.Header.Clone(),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 18 21:56:31 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. cmd/globals.go

    	"github.com/minio/minio/internal/config/storageclass"
    	"github.com/minio/minio/internal/config/subnet"
    	xhttp "github.com/minio/minio/internal/http"
    	etcd "go.etcd.io/etcd/client/v3"
    
    	levent "github.com/minio/minio/internal/config/lambda/event"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/pubsub"
    	"github.com/minio/pkg/v3/certs"
    	"github.com/minio/pkg/v3/env"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  7. cmd/api-errors.go

    		apiErr = ErrEventNotification
    	case *event.ErrInvalidARN:
    		apiErr = ErrARNNotification
    	case *event.ErrARNNotFound:
    		apiErr = ErrARNNotification
    	case *levent.ErrInvalidARN:
    		apiErr = ErrLambdaARNInvalid
    	case *levent.ErrARNNotFound:
    		apiErr = ErrLambdaARNNotFound
    	case *event.ErrUnknownRegion:
    		apiErr = ErrRegionNotification
    	case *event.ErrInvalidFilterName:
    		apiErr = ErrFilterNameInvalid
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
Back to top