- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for lcEvent (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)