- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for Messages (0.16 sec)
-
operator/pkg/helmreconciler/reconciler.go
} relevantMessages := filterOutBasedOnResources(res.Messages, parsedK8sObjects) if len(relevantMessages) > 0 { o, err := formatting.Print(relevantMessages, formatting.LogFormat, false) if err != nil { return err } return fmt.Errorf("creating default tag would conflict:\n%v", o) } return nil } func filterOutBasedOnResources(ms diag.Messages, resources object.K8sObjects) diag.Messages {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
tests/integration/security/file_mounted_certs/main_test.go
# deployed test services changes on each run due to a randomly generated namespace suffixes. # Turning the XDS-Auth ON will result in the error messages like: # Unauthorized XDS: 10.1.0.159:41960 with identity [spiffe://cluster.local/ns/mounted-certs/sa/client client.mounted-certs.svc]:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
Code: int32(codes.Internal), Message: healthEvent.UnhealthyMessage, } } proxy.sendHealthCheckRequest(req) deltaReq := &discovery.DeltaDiscoveryRequest{TypeUrl: model.HealthInfoType} if !healthEvent.Healthy { deltaReq.ErrorDetail = &google_rpc.Status{ Code: int32(codes.Internal), Message: healthEvent.UnhealthyMessage, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode") ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress, nodeagent.AmbientArgs{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 13K bytes - Viewed (0) -
tests/integration/pilot/analyze_test.go
// If we look at one namespace, we should successfully run and see one message (and not anything from any other namespace) output, _ := istioctlSafe(t, istioCtl, ns1.Name(), true) expectMessages(t, g, output, msg.ReferencedResourceNotFound, msg.ConflictingGateways) // If we use --all-namespaces, we should successfully run and see a message from each namespace output, _ = istioctlSafe(t, istioCtl, "", true, "--all-namespaces")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
return err } sa.AddRunningKubeSourceWithRevision(k, revision, false) res, err := sa.Analyze(make(chan struct{})) if err != nil { return err } relevantMessages := diag.Messages{} for _, msg := range res.Messages.FilterOutLowerThan(diag.Error) { if msg.Resource.Metadata.FullName.Name == resource.LocalName(name) { relevantMessages = append(relevantMessages, msg) } } if len(relevantMessages) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
} return retval }, PersistentPreRunE: func(c *cobra.Command, args []string) error { // istioctl kube-inject is typically redirected to a .yaml file; // the default for log messages should be stderr, not stdout root := c.Root() if root != nil { _ = c.Root().PersistentFlags().Set("log_target", "stderr") } if c.Parent() != nil && c.Parent().PersistentPreRunE != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 21.6K bytes - Viewed (0) -
pkg/security/security.go
} // authenticationManager orchestrates all authenticators to perform authentication. type authenticationManager struct { Authenticators []Authenticator // authFailMsgs contains list of messages that authenticator wants to record - mainly used for logging. authFailMsgs []string } // Authenticate loops through all the configured Authenticators and returns if one of the authenticator succeeds.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 19.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} }() } } // ZDS protocol is very simple, for every message sent, and ack is sent. // the ack only has temporal correlation (i.e. it is the first and only ack msg after the message was sent) // All this to say, that we want to make sure that message to ztunnel are sent from a single goroutine // so we don't mix messages and acks. // nolint: unparam
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
return fmt.Sprintf("no running Istio pods in %q", c.Namespace) } var _ error = ControlPlaneNotFoundError{} type Options struct { // MessageWriter is a writer for displaying messages to users. MessageWriter io.Writer // XdsViaAgents accesses Istiod via the tap service of each agent. // This is only used in `proxy-status` command. XdsViaAgents bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0)