Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 129 for Langen (0.16 sec)

  1. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  2. cmd/data-usage-cache_test.go

    				"BETWEEN_10_MB_AND_64_MB":  1,
    			},
    		},
    	}
    	for i, test := range tests {
    		t.Run(fmt.Sprintf("Test-%d", i), func(t *testing.T) {
    			var h sizeHistogram
    			for _, sz := range test.sizes {
    				h.add(sz)
    			}
    			got := h.toMap()
    			exp := test.want
    			// what is in exp is in got
    			for k := range exp {
    				if exp[k] != got[k] {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Jan 13 07:51:08 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  3. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  6. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  7. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  8. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  9. cmd/api-response.go

    	for index, commonPrefix := range multipartsInfo.CommonPrefixes {
    		listMultipartUploadsResponse.CommonPrefixes[index] = CommonPrefix{
    			Prefix: s3EncodeName(commonPrefix, encodingType),
    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    	for index, upload := range multipartsInfo.Uploads {
    		newUpload := Upload{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  10. istioctl/pkg/util/configdump/route.go

    	routeDump, err := w.GetRouteConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	drc := routeDump.GetDynamicRouteConfigs()
    
    	lastUpdated := time.Unix(0, 0) // get the oldest possible timestamp
    	for i := range drc {
    		if drc[i].LastUpdated != nil {
    			drLastUpdated := drc[i].LastUpdated.AsTime()
    			if drLastUpdated.After(lastUpdated) {
    				lastUpdated = drLastUpdated
    			}
    		}
    	}
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 3.2K bytes
    - Viewed (0)
Back to top