- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Lc (0.55 sec)
-
internal/bucket/lifecycle/lifecycle.go
func ParseLifecycleConfigWithID(r io.Reader) (*Lifecycle, error) { var lc Lifecycle if err := xml.NewDecoder(r).Decode(&lc); err != nil { return nil, err } // assign a unique id for rules with empty ID for i := range lc.Rules { if lc.Rules[i].ID == "" { lc.Rules[i].ID = uuid.New().String() } } return &lc, nil } // ParseLifecycleConfig - parses data in given reader to Lifecycle.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
cmd/data-scanner_test.go
expired = append(expired, t.versions...) } } }() lc := lifecycle.Lifecycle{ Rules: []lifecycle.Rule{ { ID: "max-versions", Status: "Enabled", NoncurrentVersionExpiration: lifecycle.NoncurrentVersionExpiration{ NewerNoncurrentVersions: 1, }, }, }, } lcXML, err := xml.Marshal(lc) if err != nil { t.Fatalf("Failed to marshal lifecycle config: %v", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
NumVersions: 1, }, want: 0, lc: lc, }, } for i, tc := range tests { t.Run(fmt.Sprintf("test-%d", i+1), func(t *testing.T) { if got := tc.lc.FilterRules(tc.opts); len(got) != tc.want { t.Fatalf("Expected %d rules to match but got %d", tc.want, len(got)) } w := httptest.NewRecorder() tc.lc.SetPredictionHeaders(w, tc.opts)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 45.6K bytes - Viewed (0) -
cmd/global-heal.go
var ( vc *versioning.Versioning lc *lifecycle.Lifecycle lr objectlock.Retention rcfg *replication.Config ) if !isMinioMetaBucketName(bucket) { vc, err = globalBucketVersioningSys.Get(bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bucket)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/bucket-policy.go
func NewPolicySys() *PolicySys { return &PolicySys{} } func getSTSConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string { m := make(map[string][]string) if d := r.Form.Get("DurationSeconds"); d != "" { m["DurationSeconds"] = []string{d} } return m } func getConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string { currTime := UTCNow() var (
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
type LifecycleSys struct{} // Get - gets lifecycle config associated to a given bucket name. func (sys *LifecycleSys) Get(bucketName string) (lc *lifecycle.Lifecycle, err error) { lc, _, err = globalBucketMetadataSys.GetLifecycleConfig(bucketName) return lc, err } // NewLifecycleSys - creates new lifecycle system. func NewLifecycleSys() *LifecycleSys { return &LifecycleSys{} }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return err } var vc *versioning.Versioning var lc *lifecycle.Lifecycle var lr objectlock.Retention var rcfg *replication.Config if bi.Name != minioMetaBucket { vc, err = globalBucketVersioningSys.Get(bi.Name) if err != nil { return err } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bi.Name)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.3K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
var vc *versioning.Versioning var lc *lifecycle.Lifecycle var lr objectlock.Retention var rcfg *replication.Config if bucket != minioMetaBucket { vc, err = globalBucketVersioningSys.Get(bucket) if err != nil { return err } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bucket)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/api-headers.go
// https://docs.aws.amazon.com/AmazonS3/latest/API/API_HeadObject.html#API_HeadObject_ResponseSyntax w.Header()[xhttp.AmzStorageClass] = []string{objInfo.TransitionedObject.Tier} } if lc, err := globalLifecycleSys.Get(objInfo.Bucket); err == nil { lc.SetPredictionHeaders(w, objInfo.ToLifecycleOpts()) } if v, ok := objInfo.UserDefined[ReservedMetadataPrefix+"compression"]; ok { if i := strings.LastIndexByte(v, '/'); i >= 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
cmd/object-handlers-common.go
w.Header()[xhttp.AmzDeleteMarker] = []string{strconv.FormatBool(objInfo.DeleteMarker)} } } if objInfo.Bucket != "" && objInfo.Name != "" { if lc, err := globalLifecycleSys.Get(objInfo.Bucket); err == nil && !delete { lc.SetPredictionHeaders(w, objInfo.ToLifecycleOpts()) } } hash.AddChecksumHeader(w, objInfo.decryptChecksums(0)) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0)