Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 252 for Franke (0.35 sec)

  1. cmd/object-api-listobjects_test.go

    		{"test-bucket-list-object", "Asia", "A", "", 1, resultCases[4], nil, true},
    		// Setting a non-existing directory to be prefix (12-13).
    		{"empty-bucket", "europe/france/", "", "", 1, ListObjectsInfo{}, nil, true},
    		{"empty-bucket", "africa/tunisia/", "", "", 1, ListObjectsInfo{}, nil, true},
    		// Testing on empty bucket, that is, bucket without any objects in it (14).
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    				perPoolErrs = append(perPoolErrs, errs[i])
    			}
    		}
    		quorum := len(perPoolErrs) / 2
    		if poolErr := reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum); poolErr != nil {
    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	for i, err := range errs {
    		if err == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    	policies := make(map[string]MappedPolicy, m.Size())
    	m.Range(func(k string, v MappedPolicy) bool {
    		policies[k] = v
    		return true
    	})
    	return policies
    }
    
    // converts a mapped policy into a slice of distinct policies
    func (mp MappedPolicy) toSlice() []string {
    	var policies []string
    	for _, policy := range strings.Split(mp.Policies, ",") {
    		if strings.TrimSpace(policy) == "" {
    			continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  4. scan.go

    	if db.Statement.Schema != nil {
    		for idx, name := range columns {
    			if field := db.Statement.Schema.LookUpField(name); field != nil {
    				values[idx] = reflect.New(reflect.PtrTo(field.FieldType)).Interface()
    				continue
    			}
    			values[idx] = new(interface{})
    		}
    	} else if len(columnTypes) > 0 {
    		for idx, columnType := range columnTypes {
    			if columnType.ScanType() != nil {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Apr 26 09:53:11 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  5. cmd/data-usage.go

    		// No need to fail upon Update() error, fallback to old value.
    		cachevalue.Opts{ReturnLastGood: true, NoWait: true},
    		func() (map[string]uint64, error) {
    			m := make(map[string]uint64)
    			for _, pool := range z.serverPools {
    				for _, er := range pool.sets {
    					// Load bucket usage prefixes
    					ctx, done := context.WithTimeout(context.Background(), 2*time.Second)
    					ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  6. cmd/format-erasure.go

    	newFormats := make([][]*formatErasureV3, setCount)
    	for i := range refFormat.Erasure.Sets {
    		newFormats[i] = make([]*formatErasureV3, setDriveCount)
    	}
    	currentDisksInfo := make([][]DiskInfo, setCount)
    	for i := range refFormat.Erasure.Sets {
    		currentDisksInfo[i] = make([]DiskInfo, setDriveCount)
    	}
    	for i := range refFormat.Erasure.Sets {
    		for j := range refFormat.Erasure.Sets[i] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top