- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 612 for Lange (0.19 sec)
-
internal/event/targetidset_test.go
{NewTargetIDSet(TargetID{"1", "webhook"}), TargetID{"2", "webhook"}}, {NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"}), TargetID{"2", "webhook"}}, } for i, testCase := range testCases { result := testCase.set.Clone() if !reflect.DeepEqual(result, testCase.set) { t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.set, result) } result.add(testCase.targetIDToAdd)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 3.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
} // Validate all the rules in the lifecycle config for _, r := range lc.Rules { if err := r.Validate(); err != nil { return err } } // Make sure Rule ID is unique for i := range lc.Rules { if i == len(lc.Rules)-1 { break } otherRules := lc.Rules[i+1:] for _, otherRule := range otherRules { if lc.Rules[i].ID == otherRule.ID { return errLifecycleDuplicateID
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
if len(e.And) == 1 { // In this case, result is not required to be boolean // type. return e.And[0].evalNode(r, tableAlias) } // Compute OR of conditions result := false for _, ex := range e.And { res, err := ex.evalNode(r, tableAlias) if err != nil { return nil, err } b, ok := res.ToBool() if !ok { return nil, errExpectedBool } if b { return FromBool(true), nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
sys.Lock() for _, bucket := range buckets { delete(sys.metadataMap, bucket) globalBucketMonitor.DeleteBucket(bucket) } sys.Unlock() } // RemoveStaleBuckets removes all stale buckets in memory that are not on disk. func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) { sys.Lock() defer sys.Unlock() for bucket := range sys.metadataMap { if diskBuckets.Contains(bucket) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
cmd/batch-handlers.go
} tagMap = t.ToMap() } for _, kv := range r.Flags.Filter.Tags { for t, v := range tagMap { if kv.Match(BatchJobKV{Key: t, Value: v}) { return true } } } // None of the provided tags filter match skip the object return false } for _, kv := range r.Flags.Filter.Metadata { for k, v := range oi.UserDefined {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/xl-storage-format-utils.go
if err != nil { return fivs, err } n := 0 for _, fi := range fivs.Versions { // Filter our tier object delete marker if !fi.TierFreeVersion() { fivs.Versions[n] = fi n++ } else { fivs.FreeVersions = append(fivs.FreeVersions, fi) } } fivs.Versions = fivs.Versions[:n] // Update numversions for i := range fivs.Versions { fivs.Versions[i].NumVersions = n } return fivs, nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
for za0003, za0004 := range z.PurgeTargets { o = msgp.AppendString(o, za0003) o = msgp.AppendString(o, string(za0004)) } // string "ResetStatusesMap" o = append(o, 0xb0, 0x52, 0x65, 0x73, 0x65, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x65, 0x73, 0x4d, 0x61, 0x70) o = msgp.AppendMapHeader(o, uint32(len(z.ResetStatusesMap))) for za0005, za0006 := range z.ResetStatusesMap {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0) -
internal/dsync/drwmutex.go
wg.Wait() xioutil.SafeClose(ch) for range ch { } }() noQuorum := lockNotFound > len(restClnts)-quorum return noQuorum, nil } // lock tries to acquire the distributed lock, returning true or false. func lock(ctx context.Context, ds *Dsync, locks *[]string, id, source string, isReadLock bool, tolerance, quorum int, names ...string) bool { for i := range *locks { (*locks)[i] = "" }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/generic-handlers.go
// header is larger than 8 KB or the user-defined metadata // is larger than 2 KB. func isHTTPHeaderSizeTooLarge(header http.Header) bool { var size, usersize int for key := range header { length := len(key) + len(header.Get(key)) size += length for _, prefix := range userMetadataKeyPrefixes { if stringsHasPrefixFold(key, prefix) { usersize += length break } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/sftp-server-driver.go
opts := minio.ListObjectsOptions{ Prefix: prefix, Recursive: true, } for object := range clnt.ListObjects(cctx, bucket, opts) { if object.Err != nil { return } objectsCh <- object } }() // Call RemoveObjects API for err := range clnt.RemoveObjects(context.Background(), bucket, objectsCh, minio.RemoveObjectsOptions{}) { if err.Err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0)