- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 83 for Langen (0.14 sec)
-
internal/event/config.go
return err } // Empty queue list means user wants to delete the notification configuration. if len(parsedConfig.QueueList) > 0 { for i, q1 := range parsedConfig.QueueList[:len(parsedConfig.QueueList)-1] { for _, q2 := range parsedConfig.QueueList[i+1:] { // Removes the region from ARN if server region is not set if q2.ARN.region != "" && q1.ARN.region == "" { q2.ARN.region = "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
cmd/data-usage-cache_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Jan 13 07:51:08 GMT 2024 - 2.6K bytes - Viewed (0) -
internal/event/name_test.go
}}, {ObjectRemovedAll, []Name{ObjectRemovedDelete, ObjectRemovedDeleteMarkerCreated, ObjectRemovedNoOP, ObjectRemovedDeleteAllVersions}}, {ObjectAccessedHead, []Name{ObjectAccessedHead}}, } for i, testCase := range testCases { result := testCase.name.Expand() if !reflect.DeepEqual(result, testCase.expectedResult) { t.Errorf("test %v: result: expected: %v, got: %v", i+1, testCase.expectedResult, result) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} return false } func (pd *PoolDecommissionInfo) isBucketDecommissioned(bucket string) bool { for _, b := range pd.DecommissionedBuckets { if b == bucket { return true } } return false } func (pd *PoolDecommissionInfo) bucketPush(bucket decomBucketInfo) { for _, b := range pd.QueuedBuckets { if pd.isBucketDecommissioned(b) { return } if b == bucket.String() { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
internal/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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.9K bytes - Viewed (0) -
internal/event/targetlist.go
list.RLock() defer list.RUnlock() targets := []Target{} for _, tgt := range list.targets { targets = append(targets, tgt) } return targets } // List - returns available target IDs. func (list *TargetList) List() []TargetID { list.RLock() defer list.RUnlock() keys := []TargetID{} for k := range list.targets { keys = append(keys, k) } return keys }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/erasure_test.go
} decoded := encoded if !test.shouldFail { if test.reconstructParity { for j := range decoded { if decoded[j] == nil { t.Errorf("Test %d: failed to reconstruct shard %d", i, j) } } } else { for j := range decoded[:test.dataBlocks] { if decoded[j] == nil { t.Errorf("Test %d: failed to reconstruct data shard %d", i, j) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 4.8K bytes - Viewed (0) -
internal/auth/credentials_test.go
{uint(1574812326), false}, {uint64(1574812326), false}, {json.Number("1574812326"), false}, {1574812326.000, false}, {time.Duration(3) * time.Minute, false}, } for _, testCase := range testCases { testCase := testCase t.Run("", func(t *testing.T) { _, err := ExpToInt64(testCase.exp) if err != nil && !testCase.expectedFailure { t.Errorf("Expected success but got failure %s", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/handler-utils.go
return errInvalidArgument } nv := make(textproto.MIMEHeader, len(v)) for k, kv := range v { // Canonicalize all headers, to remove any duplicates. nv[http.CanonicalHeaderKey(k)] = kv } // Save all supported headers. for _, supportedHeader := range supportedHeaders { value, ok := nv[http.CanonicalHeaderKey(supportedHeader)] if ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
cmd/bucket-lifecycle_test.go
restoreHdr: `ongoing-request="false"`, expectedStatus: restoreObjStatus{}, expectedErr: errRestoreHDRMalformed, }, } for i, tc := range testCases { actual, err := parseRestoreObjStatus(tc.restoreHdr) if err != tc.expectedErr { t.Fatalf("Test %d: got %v expected %v", i+1, err, tc.expectedErr) } if actual != tc.expectedStatus {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 31 09:57:57 GMT 2022 - 7K bytes - Viewed (0)