Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 137 for getNodes (0.2 sec)

  1. 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)
  2. pkg/workloadapi/workload.pb.go

    }
    
    func (x *LoadBalancing) GetRoutingPreference() []LoadBalancing_Scope {
    	if x != nil {
    		return x.RoutingPreference
    	}
    	return nil
    }
    
    func (x *LoadBalancing) GetMode() LoadBalancing_Mode {
    	if x != nil {
    		return x.Mode
    	}
    	return LoadBalancing_UNSPECIFIED_MODE
    }
    
    // Workload represents a workload - an endpoint (or collection behind a hostname).
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 18:02:35 UTC 2024
    - 65.9K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. tensorflow/compiler/mlir/lite/flatbuffer_import.cc

      if (nullptr == model_ptr) {
        return emitError(base_loc, "couldn't parse flatbuffer"), nullptr;
      }
    
      std::unique_ptr<ModelT> model(model_ptr->GetModel()->UnPack());
    
      auto builder = Builder(context);
    
      tflite::ModelControlDependencies model_control_dependencies(
          model->subgraphs.size());
    
      bool use_stablehlo_constant = false;
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue May 21 18:21:50 UTC 2024
    - 66.8K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc

    - link:{javadocPath}/org/gradle/api/file/CopyProcessingSpec.html#setDirMode-java.lang.Integer-[CopyProcessingSpec.setDirMode]
    - link:{javadocPath}/org/gradle/api/file/FileTreeElement.html#getMode--[FileTreeElement.getMode]
    - link:{javadocPath}/org/gradle/api/file/FileCopyDetails.html#setMode-int-[FileCopyDetails.setMode]
    
    [[directory_build_cache_retention_deprecated]]
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 17:01:07 UTC 2024
    - 90.7K bytes
    - Viewed (0)
  8. maven-core/src/test/java/org/apache/maven/project/PomConstructionTest.java

            PomTestWrapper pom = buildPom("inherited-properties-interpolation/active-profile/sub");
    
            assertEquals(1, pom.getMavenProject().getModel().getProfiles().size());
    
            buildPom("inherited-properties-interpolation/active-profile/sub", "it-parent", "it-child");
            assertEquals("CHILD", pom.getValue("properties/overridden"));
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Apr 12 10:50:18 UTC 2024
    - 93.2K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_node_status_test.go

    			defer testKubelet.Cleanup()
    			kubelet := testKubelet.kubelet
    			// Ensure we capture actions on the heartbeat client only.
    			// We don't set it to nil or GetNode() doesn't read from nodeLister.
    			kubelet.kubeClient = &fake.Clientset{}
    			kubeClient := testKubelet.fakeKubeClient
    
    			node := &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tensorflow/ir/tf_ops_n_z.cc

        new_result_types.push_back(valid_output_type);
    
        auto nmsv4 = CreateTfOp<TF::NonMaxSuppressionV4Op>(
            rewriter, nms_op, new_result_types, nms_op.getBoxes(),
            nms_op.getScores(), nms_op.getMaxOutputSize(), nms_op.getIouThreshold(),
            nms_op.getScoreThreshold());
        // Cannot replace the NMSv3 Op with NMSv4 since the outputs between the
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 09 22:07:10 UTC 2024
    - 170.8K bytes
    - Viewed (0)
Back to top