- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for portCount (1.97 sec)
-
pkg/proxy/servicechangetracker.go
if reflect.DeepEqual(change.previous, change.current) { delete(sct.items, namespacedName) } else { klog.V(4).InfoS("Service updated ports", "service", klog.KObj(svc), "portCount", len(change.current)) } metrics.ServiceChangesPending.Set(float64(len(sct.items))) return len(sct.items) > 0 } // ServicePortMap maps a service to its ServicePort.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
0 -> { // "\r\n": We've found a new part. partCount++ break@afterBoundaryLoop } 1 -> { // "--": No more parts. if (whitespace) throw ProtocolException("unexpected characters after boundary") if (partCount == 0) throw ProtocolException("expected at least 1 part") noMoreParts = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
} setObjectLayer(obj) defer obj.Shutdown(context.Background()) defer removeRoots(disks) bucket := "bucket" object := "object" // make data with more than one part partCount := 3 data := bytes.Repeat([]byte("a"), 6*1024*1024*partCount) z := obj.(*erasureServerPools) s := z.serverPools[0].sets[0] erasureDisks := s.getDisks() err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{}) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
cmd/erasure-object_test.go
bucket := getRandomBucketName() var opts ObjectOptions // make data with more than one part partCount := 3 data := bytes.Repeat([]byte("a"), 6*1024*1024*partCount) z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] erasureDisks := xl.getDisks() ctx, cancel := context.WithCancel(GlobalContext) defer cancel()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0)