- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 137 for getNodes (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)