Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 90 for SetMode (0.29 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			t.Log("Verify")
    
    			p := pl.(*VolumeBinding)
    			nodeInfos := make([]*framework.NodeInfo, 0)
    			for _, node := range item.nodes {
    				nodeInfo := framework.NewNodeInfo()
    				nodeInfo.SetNode(node)
    				nodeInfos = append(nodeInfos, nodeInfo)
    			}
    			state := framework.NewCycleState()
    
    			t.Logf("Verify: call PreFilter and check status")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			node := v1.Node{ObjectMeta: metav1.ObjectMeta{
    				Name:   test.nodeName,
    				Labels: test.labels,
    			}}
    			nodeInfo := framework.NewNodeInfo()
    			nodeInfo.SetNode(&node)
    
    			p, err := New(ctx, &test.args, nil)
    			if err != nil {
    				t.Fatalf("Creating plugin: %v", err)
    			}
    
    			state := framework.NewCycleState()
    			var gotStatus *framework.Status
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
  3. pkg/kube/inject/inject.go

    		imageType = it
    	}
    
    	return imageURL(global.GetHub(), imageName, tag, imageType)
    }
    
    func InboundTrafficPolicyMode(meshConfig *meshconfig.MeshConfig) string {
    	switch meshConfig.GetInboundTrafficPolicy().GetMode() {
    	case meshconfig.MeshConfig_InboundTrafficPolicy_LOCALHOST:
    		return "localhost"
    	case meshconfig.MeshConfig_InboundTrafficPolicy_PASSTHROUGH:
    		return "passthrough"
    	}
    	return "passthrough"
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 20:35:11 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster.go

    		port := int(instance.Port.TargetPort)
    		clustersToBuild[port] = append(clustersToBuild[port], instance)
    	}
    
    	bind := actualLocalHosts[0]
    	if cb.req.Push.Mesh.GetInboundTrafficPolicy().GetMode() == meshconfig.MeshConfig_InboundTrafficPolicy_PASSTHROUGH {
    		bind = ""
    	}
    	// For each workload port, we will construct a cluster
    	for epPort, instances := range clustersToBuild {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/httproute.go

    		base.GenerateRequestID = proto.BoolFalse
    	}
    	if ph.EnvoyDebugHeaders.GetDisabled().GetValue() {
    		base.SuppressDebugHeaders = true
    	}
    	if ph.MetadataExchangeHeaders != nil && ph.MetadataExchangeHeaders.GetMode() == meshconfig.ProxyConfig_ProxyHeaders_IN_MESH {
    		base.SkipIstioMXHeaders = true
    	}
    	return base
    }
    
    func BuildSidecarOutboundVirtualHosts(node *model.Proxy, push *model.PushContext,
    	routeName string,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_node_status.go

    			kl.containerRuntimeReadyExpected = true
    		}
    	}()
    
    	if timeout {
    		klog.ErrorS(nil, "Node not becoming ready in time after startup")
    		return true
    	}
    
    	originalNode, err := kl.GetNode()
    	if err != nil {
    		klog.ErrorS(err, "Error getting the current node from lister")
    		return false
    	}
    
    	readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/types_test.go

    				t.Errorf("expected: %#v, got: %#v", test.expectedNodeInfo, ni)
    			}
    		})
    	}
    }
    
    func fakeNodeInfo(pods ...*v1.Pod) *NodeInfo {
    	ni := NewNodeInfo(pods...)
    	ni.SetNode(&v1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: "test-node",
    		},
    	})
    	return ni
    }
    
    type hostPortInfoParam struct {
    	protocol, ip string
    	port         int32
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  8. docs/fr/docs/alternatives.md

    Les routes sont déclarées à un seul endroit, en utilisant des fonctions déclarées à d'autres endroits (au lieu
    d'utiliser des décorateurs qui peuvent être placés juste au-dessus de la fonction qui gère l'endpoint). Cette
    méthode est plus proche de celle de Django que de celle de Flask (et Starlette). Il sépare dans le code des choses
    qui sont relativement fortement couplées.
    
    !!! check "A inspiré **FastAPI** à"
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Fri Mar 22 01:42:11 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/gateway.go

    		// based on the match port/server port and the gateway name
    		for _, tcp := range vsvc.Tcp {
    			if l4MultiMatch(tcp.Match, server, gateway) {
    				includeMx := server.GetTls().GetMode() == networking.ServerTLSSettings_ISTIO_MUTUAL
    				return lb.buildOutboundNetworkFilters(tcp.Route, port, v.Meta, includeMx)
    			}
    		}
    	}
    
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  10. docs/de/docs/deployment/docker.md

    Normalerweise befinden sich die **Paketanforderungen** für Ihre Anwendung in einer Datei.
    
    Dies hängt hauptsächlich von dem Tool ab, mit dem Sie diese Anforderungen **installieren**.
    
    Die gebräuchlichste Methode besteht darin, eine Datei `requirements.txt` mit den Namen der Packages und deren Versionen zu erstellen, eine pro Zeile.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 18:19:17 UTC 2024
    - 38.9K bytes
    - Viewed (0)
Back to top