- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 103 for Messages (0.07 sec)
-
pkg/config/analysis/analyzers/virtualservice/destinationrules.go
return true }) } func (d *DestinationRuleAnalyzer) analyzeVirtualService(r *resource.Instance, ctx analysis.Context, destHostsAndSubsets map[hostAndSubset]bool, ) { vs := r.Message.(*v1alpha3.VirtualService) ns := r.Metadata.FullName.Namespace for _, ad := range getRouteDestinations(vs) { if !d.checkDestinationSubset(ns, ad.Destination, destHostsAndSubsets) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 15:18:05 UTC 2023 - 4.1K bytes - Viewed (0) -
istioctl/pkg/util/common.go
type CommandParseError struct { Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.6K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
} } } } func applyDelta(message model.Resources, resp *discovery.DeltaDiscoveryResponse) model.Resources { deleted := sets.New(resp.RemovedResources...) byName := map[string]*discovery.Resource{} for _, v := range resp.Resources { byName[v.Name] = v } res := model.Resources{} for _, m := range message { if deleted.Contains(m.Name) { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/destination_rule_tls_test.go
) // TestDestinationRuleTls tests that MUTUAL tls mode is respected in DestinationRule. // This sets up a client and server with appropriate cert config and ensures we can successfully send a message. func TestDestinationRuleTls(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { ns := appNS
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.1K bytes - Viewed (0) -
security/pkg/pki/util/san_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 17:36:33 UTC 2024 - 6.5K bytes - Viewed (0) -
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) -
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)