- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 132 for Messages (0.09 sec)
-
pkg/config/analysis/analyzers/service/portname.go
if util.IsIstioControlPlane(r) { return true } s.analyzeService(r, c) return true }) } func (s *PortNameAnalyzer) analyzeService(r *resource.Instance, c analysis.Context) { svc := r.Message.(*v1.ServiceSpec) // Skip gateway managed services, which are not created by users if v, ok := r.Metadata.Labels[constants.ManagedGatewayLabel]; ok && v == constants.ManagedGatewayControllerLabel ||
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 15 14:45:58 UTC 2023 - 2.6K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version.go
num := ver.Segments()[1] return num, nil } // IsK8VersionSupported checks minimum supported Kubernetes version for Istio. // If the K8s version is not at least the `MinK8SVersion`, it logs a message warning the user that they // may experience problems if they proceed with the install. func IsK8VersionSupported(c kube.Client, l clog.Logger) error { serverVersion, err := c.GetKubernetesVersion() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 22 02:07:51 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/config/mesh/watcher_test.go
} t.Cleanup(func() { _ = f.Close() }) path, err := filepath.Abs(f.Name()) if err != nil { t.Fatal(err) } return path } func writeMessage(t testing.TB, path string, msg proto.Message) { t.Helper() yml, err := protomarshal.ToYAML(msg) if err != nil { t.Fatal(err) } writeFile(t, path, yml) } func writeFile(t testing.TB, path, content string) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3K bytes - Viewed (0) -
pilot/pkg/credentials/kube/secrets.go
ret.Key = scrt.Data[TLSSecretKey] ret.Staple = scrt.Data[TLSSecretOcspStaple] ret.CRL = scrt.Data[TLSSecretCrl] return ret, nil } // No cert found. Try to generate a helpful error message if hasKeys(scrt.Data, GenericScrtCert, GenericScrtKey) { return nil, fmt.Errorf("found keys %q and %q, but they were empty", GenericScrtCert, GenericScrtKey) } if hasKeys(scrt.Data, TLSSecretCert, TLSSecretKey) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 10K bytes - Viewed (0) -
tools/certs/Makefile.k8s.mk
.DEFAULT_GOAL := help SELF_DIR := $(dir $(lastword $(MAKEFILE_LIST))) include $(SELF_DIR)common.mk #------------------------------------------------------------------------ ##help: print this help message .PHONY: help help: @fgrep -h "##" $(MAKEFILE_LIST) | fgrep -v fgrep | sed -e 's/##//' #------------------------------------------------------------------------
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 27 13:15:29 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/dns/proto/nds.pb.go
ms.StoreMessageInfo(mi) } } func (x *NameTable) String() string { return protoimpl.X.MessageStringOf(x) } func (*NameTable) ProtoMessage() {} func (x *NameTable) ProtoReflect() protoreflect.Message { mi := &file_dns_proto_nds_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 02:27:10 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) retry.UntilOrFail(t, func() bool { return store.Get(r.GroupVersionKind(), configMeta.Name, configMeta.Namespace) == nil }, retry.Message("expected no items returned for unknown CRD"), retry.Timeout(time.Second*5), retry.Converge(5)) } // Ensure that the client can run without CRDs present, but then added later func TestClientDelayedCRDs(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster_test.go
func verifyControllers(t *testing.T, m *Multicluster, expectedControllerCount int, timeoutName string) { t.Helper() assert.EventuallyEqual(t, func() int { return len(m.component.All()) }, expectedControllerCount, retry.Message(timeoutName), retry.Delay(time.Millisecond*10), retry.Timeout(time.Second*5)) } func initController(client kube.CLIClient, ns string, stop <-chan struct{}) *multicluster.Controller {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 6.7K bytes - Viewed (0) -
tests/integration/pilot/revisions/uninstall_test.go
} _, actualError, _ := istioCtl.Invoke(uninstallCmd) if !strings.Contains(actualError, revisionNotFound) { scopes.Framework.Errorf("istioctl uninstall command expects to fail with error message: %s, but got: %s", revisionNotFound, actualError) } }) }) } func TestUninstallWithSetFlag(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/config/validation/envoyfilter/envoyfilter_test.go
t.Fatalf("got warning=%v but wanted warning=%v", gotWarning, wantWarning) } } func TestValidateEnvoyFilter(t *testing.T) { tests := []struct { name string in proto.Message error string warning string }{ {name: "empty filters", in: &networking.EnvoyFilter{}, error: ""}, {name: "labels not defined in workload selector", in: &networking.EnvoyFilter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 16.7K bytes - Viewed (0)