- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for cg (0.03 sec)
-
pilot/pkg/networking/core/cluster_builder_test.go
}, Spec: tc.destRule, } } cg := NewConfigGenTest(t, TestOptions{ ConfigPointers: []*config.Config{cfg}, Services: []*model.Service{tc.service}, }) cg.MemRegistry.WantGetProxyServiceTargets = targets proxy := cg.SetupProxy(nil) cb := NewClusterBuilder(proxy, &model.PushRequest{Push: cg.PushContext()}, nil) ec := newClusterWrapper(tc.cluster)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_test.go
t.Run(tt.name, func(t *testing.T) { cg := NewConfigGenTest(t, TestOptions{ Services: tt.services, Instances: tt.instances, }) proxy := cg.SetupProxy(nil) proxy.Metadata.InboundListenerExactBalance = true proxy.Metadata.OutboundListenerExactBalance = true listeners := NewListenerBuilder(proxy, cg.env.PushContext()).buildSidecarOutboundListeners(proxy, cg.env.PushContext())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 93.6K bytes - Viewed (0) -
pilot/pkg/networking/core/httproute_test.go
svc.CreationTime = t0 t0 = t0.Add(time.Minute) } cg := NewConfigGenTest(t, TestOptions{ Services: tt.services, Configs: tt.config, }) vHostCache := make(map[int][]*route.VirtualHost) resource, _ := cg.ConfigGen.buildSidecarOutboundHTTPRouteConfig( cg.SetupProxy(nil), &model.PushRequest{Push: cg.PushContext()}, "80", vHostCache, nil, nil) routeCfg := &route.RouteConfiguration{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 51.4K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
} default: panic(fmt.Sprintf("unsupported node type: %v", c.nodeType)) } clusters := cg.Clusters(cg.SetupProxy(proxy)) xdstest.ValidateClusters(c.t, clusters) if len(cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) > 0 { c.t.Fatalf("duplicate clusters detected %#v", cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) } return clusters }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway_test.go
cfgs := tt.gateways cfgs = append(cfgs, tt.virtualServices...) cg := NewConfigGenTest(t, TestOptions{ Configs: cfgs, Services: []*pilot_model.Service{ exampleService, }, }) r := cg.ConfigGen.buildGatewayHTTPRouteConfig(cg.SetupProxy(&proxyGateway), cg.PushContext(), tt.routeName) if r == nil { t.Fatal("got an empty route configuration") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 144K bytes - Viewed (0) -
src/go/ast/import.go
} return prev.(*ImportSpec).Comment == nil } type posSpan struct { Start token.Pos End token.Pos } type cgPos struct { left bool // true if comment is to the left of the spec, false otherwise. cg *CommentGroup } func sortSpecs(fset *token.FileSet, f *File, specs []Spec) []Spec { // Can't short-circuit here even if specs are already sorted, // since they might yet need deduplication.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller_test.go
Meta: config.Meta{ GroupVersionKind: gvk.HTTPRoute, Name: "http-route", Namespace: "ns1", }, Spec: httpRouteSpec, }) cg := core.NewConfigGenTest(t, core.TestOptions{}) g.Expect(controller.Reconcile(cg.PushContext())).ToNot(HaveOccurred()) cfg := controller.List(gvk.Gateway, "ns1") g.Expect(cfg).To(HaveLen(1)) for _, c := range cfg {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 16:47:06 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion_test.go
Service: svc, ServicePort: ports[2], Endpoint: &model.IstioEndpoint{}, }) } cg := core.NewConfigGenTest(t, core.TestOptions{ Services: services, Instances: instances, }) kr := splitInput(t, input) kr.Context = NewGatewayContext(cg.PushContext(), "Kubernetes") output := convertResources(kr) output.AllowedReferences = AllowedReferences{} // Not tested here
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 20:24:52 UTC 2024 - 34.9K bytes - Viewed (0) -
src/database/sql/sql.go
ds, err = dc.prepareLocked(ctx, cg, query) }) if err != nil { return nil, err } stmt := &Stmt{ db: db, query: query, cg: cg, cgds: ds, } // When cg == nil this statement will need to keep track of various // connections they are prepared on and record the stmt dependency on // the DB. if cg == nil { stmt.css = []connStmt{{dc, ds}}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
log_format: json_format: envoyproxy_authority: '%REQ(:AUTHORITY)%' `, }) proxy := cg.SetupProxy(nil) l1 := cg.Listeners(proxy) l2 := cg.Listeners(proxy) // Make sure it doesn't change between patches if d := cmp.Diff(l1, l2, protocmp.Transform()); d != "" { t.Fatal(d) } // Make sure we have exactly 1 access log
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0)