- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 612 for Lange (0.18 sec)
-
internal/event/targetlist_test.go
} for i, testCase := range testCases { result := testCase.targetList.List() if len(result) != len(testCase.expectedResult) { t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result) } for _, targetID1 := range result { var found bool for _, targetID2 := range testCase.expectedResult { if reflect.DeepEqual(targetID1, targetID2) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 6.1K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0) -
internal/config/lambda/event/targetidset.go
setCopy := NewTargetIDSet() for k, v := range set { setCopy[k] = v } return setCopy } // add - adds TargetID to the set. func (set TargetIDSet) add(targetID TargetID) { set[targetID] = struct{}{} } // Union - returns union with given set as new set. func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet { nset := set.Clone() for k := range sset { nset.add(k) } return nset }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/batch-expire_gen.go
o = msgp.AppendArrayHeader(o, uint32(len(z.Tags))) for za0001 := range z.Tags { o, err = z.Tags[za0001].MarshalMsg(o) if err != nil { err = msgp.WrapError(err, "Tags", za0001) return } } // string "Metadata" o = append(o, 0xa8, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61) o = msgp.AppendArrayHeader(o, uint32(len(z.Metadata))) for za0002 := range z.Metadata { o, err = z.Metadata[za0002].MarshalMsg(o)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 02 10:51:33 GMT 2023 - 19.8K bytes - Viewed (0) -
cmd/erasure-multipart.go
var wg sync.WaitGroup for _, disk := range er.getLocalDisks() { if disk != nil { wg.Add(1) go func(disk StorageAPI) { defer wg.Done() er.cleanupStaleUploadsOnDisk(ctx, disk, expiry) }(disk) } } wg.Wait() } func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) { var wg sync.WaitGroup for _, disk := range er.getDisks() { if disk == nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/metacache-set.go
writes := make([]uint64, len(infos)) for index, di := range infos { deletes[index] = di.Metrics.TotalDeletes writes[index] = di.Metrics.TotalWrites } filter := func(list []uint64) (commonCount uint64) { max := 0 signatureMap := map[uint64]int{} for _, v := range list { signatureMap[v]++ } for ops, count := range signatureMap { if max < count && commonCount < ops { max = count
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/last-minute_gen.go
err = msgp.WrapError(err) return } for za0001 := range z { // map header, size 2 // write "Totals" err = en.Append(0x82, 0xa6, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x73) if err != nil { return } err = en.WriteArrayHeader(uint32(60)) if err != nil { err = msgp.WrapError(err, za0001, "Totals") return } for za0002 := range z[za0001].Totals { // map header, size 3
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jul 05 21:45:49 GMT 2022 - 17.2K bytes - Viewed (0) -
internal/bucket/object/lock/lock_test.go
expectedMode: RetGovernance, }, { value: "complIAnce", expectedMode: RetCompliance, }, { value: "gce", expectedMode: "", }, } for _, tc := range testCases { if parseRetMode(tc.value) != tc.expectedMode { t.Errorf("Expected Mode %s, got %s", tc.expectedMode, parseRetMode(tc.value)) } } } func TestParseLegalHoldStatus(t *testing.T) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 17.1K bytes - Viewed (0) -
cmd/admin-handlers_test.go
} // Body is always valid - we do not test JSON decoding. body := `{"recursive": false, "dryRun": true, "remove": false, "scanMode": 0}` // Test all combinations! for pIdx, params := range qParamsArr { for vIdx, vars := range varsArr { _, err := extractHealInitParams(vars, params, bytes.NewReader([]byte(body))) isErrCase := false if pIdx < 4 || vIdx < 1 { isErrCase = true }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/config/lambda/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 Mar 07 16:12:41 GMT 2023 - 3.9K bytes - Viewed (0)