Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 220 for Franke (0.24 sec)

  1. internal/grid/types.go

    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get().(map[string]string))
    	for k := range m {
    		delete(m, k)
    	}
    	return &m
    }
    
    // NewMSSWith returns a new MSS with the given map.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  2. cmd/bucket-targets.go

    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    				m := make(map[string]epHealth, len(eps))
    				start := time.Now()
    
    				for result := range sys.hcClient.Alive(cctx, madmin.AliveOpts{}, eps...) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  3. internal/config/identity/openid/openid.go

    		transport:          r.transport,
    		closeRespFn:        r.closeRespFn,
    	}
    	for k, v := range r.arnProviderCfgsMap {
    		cfg.arnProviderCfgsMap[k] = v
    	}
    	for k, v := range r.ProviderCfgs {
    		cfg.ProviderCfgs[k] = v
    	}
    	for k, v := range r.roleArnPolicyMap {
    		cfg.roleArnPolicyMap[k] = v
    	}
    	return cfg
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  4. cmd/metrics.go

    		float64(dur),
    	)
    	for k, v := range bgSeq.getScannedItemsMap() {
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(healMetricsNamespace, "objects", "scanned"),
    				"Objects scanned in current self healing run",
    				[]string{"type"}, nil),
    			prometheus.GaugeValue,
    			float64(v), string(k),
    		)
    	}
    	for k, v := range bgSeq.getHealedItemsMap() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 02 06:48:36 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  5. cmd/encryption-v1_test.go

    	},
    }
    
    func TestEncryptRequest(t *testing.T) {
    	defer func(flag bool) { globalIsTLS = flag }(globalIsTLS)
    	globalIsTLS = true
    	for i, test := range encryptRequestTests {
    		content := bytes.NewReader(make([]byte, 64))
    		req := &http.Request{Header: http.Header{}}
    		for k, v := range test.header {
    			req.Header.Set(k, v)
    		}
    		_, _, err := EncryptRequest(content, req, "bucket", "object", test.metadata)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  6. cmd/erasure-object_test.go

    		},
    	})
    
    	_, delErrs := obj.DeleteObjects(ctx, bucketName, names, ObjectOptions{
    		Versioned: true,
    	})
    	for i := range delErrs {
    		if delErrs[i] != nil {
    			t.Errorf("Failed to remove object `%v` with the error: `%v`", names[i], delErrs[i])
    		}
    	}
    
    	for i, test := range testCases {
    		_, statErr := obj.GetObjectInfo(ctx, test.bucket, test.object, ObjectOptions{
    			VersionID: names[i].ObjectV.VersionID,
    		})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  7. internal/crypto/metadata_test.go

    func TestRemoveInternalEntries(t *testing.T) {
    	isEqual := func(x, y map[string]string) bool {
    		if len(x) != len(y) {
    			return false
    		}
    		for k, v := range x {
    			if u, ok := y[k]; !ok || v != u {
    				return false
    			}
    		}
    		return true
    	}
    
    	for i, test := range removeInternalEntriesTests {
    		RemoveInternalEntries(test.Metadata)
    		if !isEqual(test.Metadata, test.Expected) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 00:13:57 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  8. docs/debugging/xl-meta/main.go

    			}
    			ok := len(splitFilled)
    			for i, sh := range splitFilled {
    				for _, v := range sh {
    					if v == 0 {
    						split[i] = nil
    						ok--
    						break
    					}
    				}
    			}
    			hasParity := 0
    			for idx, sh := range v {
    				split[idx] = sh
    				if idx >= k && len(v) > 0 {
    					hasParity++
    				}
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  9. internal/logger/config.go

    		envs := env.List(legacyEnvLoggerHTTPEndpoint)
    		for _, k := range envs {
    			target := strings.TrimPrefix(k, legacyEnvLoggerHTTPEndpoint+config.Default)
    			if target == legacyEnvLoggerHTTPEndpoint {
    				target = config.Default
    			}
    			loggerTargets = append(loggerTargets, target)
    		}
    
    		// Load HTTP logger from the environment if found
    		for _, target := range loggerTargets {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  10. cmd/metrics-v2_gen.go

    	if z.StaticLabels != nil {
    		for za0001, za0002 := range z.StaticLabels {
    			_ = za0002
    			s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    		}
    	}
    	s += 6 + msgp.Float64Size + 15 + msgp.MapHeaderSize
    	if z.VariableLabels != nil {
    		for za0003, za0004 := range z.VariableLabels {
    			_ = za0004
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 19.2K bytes
    - Viewed (0)
Back to top