- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 66 for i$ (0.11 sec)
-
pkg/config/validation/validation.go
} bind := i.GetBind() errs = AppendValidation(errs, validateSidecarIngressPortAndBind(i.Port, bind)) if portMap.Contains(i.Port.Number) { errs = AppendValidation(errs, fmt.Errorf("sidecar: ports on IP bound listeners must be unique")) } portMap.Insert(i.Port.Number) if len(i.DefaultEndpoint) != 0 { if strings.HasPrefix(i.DefaultEndpoint, UnixAddressPrefix) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go
} // Remove prefix from all tabs, fail otherwise. for i := range lines { line := lines[i] // It's OK for the last line to be blank (trailing \n) if i == len(lines)-1 && len(line) <= len(prefix) && bytes.TrimSpace(line) == nil { lines[i] = []byte{} break } if !bytes.HasPrefix(line, prefix) { minRange := i - 5 maxRange := i + 5 if minRange < 0 { minRange = 0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 17:14:10 UTC 2024 - 159.9K bytes - Viewed (0) -
cmd/site-replication.go
var wg sync.WaitGroup wg.Add(len(depIDs)) for i := range depIDs { go func(i int) { defer wg.Done() if depIDs[i] == globalDeploymentID() { if selfActionFn != nil { errs[i] = selfActionFn() } } else { errs[i] = peerActionFn(depIDs[i], c.state.Peers[depIDs[i]]) } }(i) } wg.Wait() errMap := make(map[string]error, len(c.state.Peers))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
src/crypto/x509/verify_test.go
parent, parentKey, err := generateCert("Root CA", true, nil, nil) if err != nil { t.Fatal(err) } roots.AddCert(parent) for i := 1; i < 15; i++ { name := fmt.Sprintf("Intermediate CA #%d", i) parent, parentKey, err = generateCert(name, true, parent, parentKey) if err != nil { t.Fatal(err) } intermediates.AddCert(parent) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 110.2K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
if err == nil && len(data) > len(id) { stats := strings.Split(string(data[:len(data)-len(id)]), "\x00") if len(stats)%2 != 0 { goto Miss } for i := 0; i+2 <= len(stats); i++ { info, err := os.Stat(stats[i]) if err != nil || statString(info) != stats[i+1] { goto Miss } } copy(id[:], data[len(data)-len(id):]) return id, true Miss: }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
expected := []bool{true, true, true} for i, pod := range pods { if result := manager.Admit(&lifecycle.PodAdmitAttributes{Pod: pod}); expected[i] != result.Admit { t.Errorf("Admit pod: %v, expected: %v, actual: %v", pod, expected[i], result.Admit) } } manager.nodeConditions = []v1.NodeConditionType{v1.NodeMemoryPressure} expected = []bool{true, true, false} for i, pod := range pods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) err = xml.Unmarshal(delRespBytes, &deleteResp) c.Assert(err, nil) for i := 0; i < 10; i++ { // All the objects should be under deleted list (including non-existent object) c.Assert(deleteResp.DeletedObjects[i], DeletedObject{ ObjectName: delObjReq.Objects[i].ObjectName, VersionID: delObjReq.Objects[i].VersionID, }) } c.Assert(len(deleteResp.Errors), 0)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
src/database/sql/sql.go
// in reverse order to minimise the work needed. idleSince := nowFunc().Add(-db.maxIdleTime) last := len(db.freeConn) - 1 for i := last; i >= 0; i-- { c := db.freeConn[i] if c.returnedAt.Before(idleSince) { i++ closing = db.freeConn[:i:i] db.freeConn = db.freeConn[i:] idleClosing = int64(len(closing)) db.maxIdleTimeClosed += idleClosing break } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
cluster/gce/util.sh
KUBE_NODE_IP_ADDRESSES=() for (( i=0; i<${#NODE_NAMES[@]}; i++)); do local node_ip node_ip=$(gcloud compute instances describe --project "${PROJECT}" --zone "${ZONE}" \ "${NODE_NAMES[$i]}" --format='value(networkInterfaces[0].accessConfigs[0].natIP)') if [[ -z "${node_ip-}" ]] ; then echo "Did not find ${NODE_NAMES[$i]}" >&2 else echo "Found ${NODE_NAMES[$i]} at ${node_ip}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
cmd/bucket-replication.go
func (p *ReplicationPool) AddLargeWorkers() { for i := 0; i < LargeWorkerCount; i++ { p.lrgworkers = append(p.lrgworkers, make(chan ReplicationWorkerOperation, 100000)) i := i go p.AddLargeWorker(p.lrgworkers[i]) } go func() { <-p.ctx.Done() for i := 0; i < LargeWorkerCount; i++ { xioutil.SafeClose(p.lrgworkers[i]) } }() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0)