- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 58 for Messages (0.07 sec)
-
pkg/config/resource/instance_test.go
import ( "testing" . "github.com/onsi/gomega" "google.golang.org/protobuf/types/known/emptypb" ) func TestInstance_IsEmpty_False(t *testing.T) { g := NewWithT(t) e := Instance{ Message: &emptypb.Empty{}, } g.Expect(e.IsEmpty()).To(BeFalse()) } func TestInstance_IsEmpty_True(t *testing.T) { g := NewWithT(t) e := Instance{} g.Expect(e.IsEmpty()).To(BeTrue()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/deployment/services.go
matchingSvcs := make([]ServiceSpecWithName, 0) d := r.Message.(*appsv1.DeploymentSpec) deploymentNS := r.Metadata.FullName.Namespace.String() c.ForEach(gvk.Service, func(r *resource.Instance) bool { s := r.Message.(*core_v1.ServiceSpec) sSelector := klabels.SelectorFromSet(s.Selector) pLabels := klabels.Set(d.Template.Labels)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 6.6K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze_test.go
"istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/util/testutil" "istio.io/istio/pkg/config/analysis/diag" ) func TestErrorOnIssuesFound(t *testing.T) { g := NewWithT(t) msgs := []diag.Message{ diag.NewMessage( diag.NewMessageType(diag.Error, "B1", "Template: %q"), nil, "", ), diag.NewMessage( diag.NewMessageType(diag.Warning, "A1", "Template: %q"), nil, "", ), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/config/analysis/context.go
type IteratorFn func(r *resource.Instance) bool // Context is an analysis context that is passed to individual analyzers. type Context interface { // Report a diagnostic message Report(c config.GroupVersionKind, t diag.Message) // Find a resource in the collection. If not found, nil is returned Find(c config.GroupVersionKind, name resource.FullName) *resource.Instance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 28 20:21:54 UTC 2023 - 1.6K bytes - Viewed (0) -
pilot/pkg/grpc/grpc.go
if s.Code() == codes.Canceled || s.Code() == codes.DeadlineExceeded { return true } if s.Code() == codes.Unavailable && containsExpectedMessage(s.Message()) { return true } } // If this is not a gRPCStatus we should just error message. if strings.Contains(err.Error(), "stream terminated by RST_STREAM with error code: NO_ERROR") { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 04:27:50 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/externalcontrolplane/externalcontrolplane.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 16:48:42 UTC 2024 - 4.5K bytes - Viewed (0) -
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)