- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 88 for cluster0 (0.15 sec)
-
istioctl/pkg/describe/describe.go
if err != nil { return "", err } for _, dac := range dump.DynamicActiveClusters { clusterTyped := &cluster.Cluster{} // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. dac.Cluster.TypeUrl = v3.ClusterType err = dac.Cluster.UnmarshalTo(clusterTyped) if err != nil { return "", err } if filter.Verify(clusterTyped) { metadata := clusterTyped.Metadata
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 50.4K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_test.go
for i, expectResult := range expectResults { cluster := weightedCluster.GetClusters()[i] g.Expect(cluster.RequestHeadersToAdd).To(Equal(expectResult.reqAdd)) g.Expect(cluster.RequestHeadersToRemove).To(Equal(expectResult.reqRemove)) g.Expect(cluster.ResponseHeadersToAdd).To(Equal(expectResult.respAdd)) g.Expect(cluster.RequestHeadersToRemove).To(Equal(expectResult.reqRemove))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0) -
pkg/workloadapi/workload.pb.go
// For k8s resources, it is recommended to use the more readable format: // // cluster/group/kind/namespace/name/section-name // // As an example, a ServiceEntry with two WorkloadEntries inlined could become // two Workloads with the following UIDs: // - cluster1/networking.istio.io/v1alpha3/ServiceEntry/default/external-svc/endpoint1 // - cluster1/networking.istio.io/v1alpha3/ServiceEntry/default/external-svc/endpoint2 //
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/model/telemetry_logging_test.go
assert.Equal(t, first, second) }) } } func TestBuildOpenTelemetryAccessLogConfig(t *testing.T) { fakeCluster := "outbound|55680||otel-collector.monitoring.svc.cluster.local" fakeAuthority := "otel-collector.monitoring.svc.cluster.local" for _, tc := range []struct { name string logName string clusterName string hostname string body string labels *structpb.Struct
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 54K bytes - Viewed (0) -
pkg/apis/networking/validation/validation_test.go
}, "namespace is forbidden when scope is Cluster": { ingressClass: makeValidIngressClass("test123", "foo.co/bar", setParams(makeIngressClassParams(nil, "foo", "bar", utilpointer.String("Cluster"), utilpointer.String("foo-ns"))), ), expectedErrs: field.ErrorList{field.Forbidden(field.NewPath("spec.parameters.namespace"), "`parameters.scope` is set to 'Cluster'")}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 73.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
externalTrafficFilterVerdict = "drop" serviceNoLocalEndpointsTotalExternal++ } } // Capture the clusterIP. tx.Add(&knftables.Element{ Set: clusterIPsSet, Key: []string{svcInfo.ClusterIP().String()}, }) if hasInternalEndpoints { tx.Add(&knftables.Element{ Map: serviceIPsMap, Key: []string{ svcInfo.ClusterIP().String(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
name: "v4 service, in a single stack cluster", ipFamilies: ipv4only, service: v1.Service{ Spec: v1.ServiceSpec{ ClusterIP: "10.0.0.1", }, }, expectedEndpointFamily: ipv4, }, { name: "v4 service, in a dual stack cluster", ipFamilies: ipv4ipv6, service: v1.Service{ Spec: v1.ServiceSpec{ ClusterIP: "10.0.0.1", }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
} } } }) } } func TestProxyK8sHostnameLabel(t *testing.T) { clusterID := cluster.ID("fakeCluster") controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{ ClusterID: clusterID, }) pod := generatePod("128.0.0.1", "pod1", "nsa", "foo", "node1", map[string]string{"app": "test-app"}, map[string]string{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/output/sidecar_template.golden.yaml
- mountPath: /var/run/secrets/tokens name: istio-token {{- end }} {{- if .Values.global.mountMtlsCerts }} # Use the key and cert mounted to /etc/certs/ for the in-cluster mTLS communications. - mountPath: /etc/certs/ name: istio-certs readOnly: true {{- end }} - name: istio-podinfo mountPath: /etc/istio/pod
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 05:10:03 UTC 2024 - 86.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
try { final ClusterHealthResponse response = client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute() .actionGet(fessConfig.getIndexHealthTimeout()); if (logger.isDebugEnabled()) { logger.debug("Fesen Cluster Status: {}", response.getStatus()); } return;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 84.1K bytes - Viewed (0)