- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for cg (0.02 sec)
-
pilot/test/xds/fake.go
grpcServer.Stop() _ = listener.Close() }) // Start the discovery server s.Start(stop) cg.ServiceEntryRegistry.XdsUpdater = s // Now that handlers are added, get everything started cg.Run() kubelib.WaitForCacheSync("fake", stop, cg.Registry.HasSynced, cg.Store().HasSynced) cg.ServiceEntryRegistry.ResyncEDS()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter_test.go
for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { cg := NewConfigGenTest(t, TestOptions{Services: services}) fcc := inboundChainConfig{ port: model.ServiceInstancePort{ServicePort: &model.Port{}}, } node := &model.Proxy{Metadata: &model.NodeMetadata{IdleTimeout: tt.idleTimeout}} listenerFilters := NewListenerBuilder(cg.SetupProxy(node), cg.PushContext()).buildInboundNetworkFilters(fcc) tcp := &tcp.TcpProxy{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 25.8K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
"istio.io/istio/pkg/util/protomarshal" "istio.io/istio/pkg/wellknown" ) func TestVirtualListenerBuilder(t *testing.T) { cg := NewConfigGenTest(t, TestOptions{Services: testServices}) proxy := cg.SetupProxy(nil) vo := xdstest.ExtractListener(model.VirtualOutboundListenerName, cg.Listeners(proxy)) if vo == nil { t.Fatalf("didn't find virtual outbound listener") } } var ( testServices = []*model.Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/xds/proxy_dependencies_test.go
Attributes: model.ServiceAttributes{ ExportTo: sets.New(visibility.Public), Namespace: nsName, }, }, }, }) gateway.SetSidecarScope(cg.PushContext()) // service visibility updated cg = core.NewConfigGenTest(t, core.TestOptions{ Services: []*model.Service{ { Hostname: svcName, Attributes: model.ServiceAttributes{ ExportTo: sets.New(visibility.Public),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/tests/tests.go
// guaranteed to be in order of appearance. for _, cg := range fileComments { if cg.Pos() < fn.Pos() { continue } else if cg.End() > fn.End() { break } isOutput := outputRe.MatchString(cg.Text()) if isOutput { numOutputs++ } commentsInExample = append(commentsInExample, commentMetadata{ isOutput: isOutput, pos: cg.Pos(), }) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 14.4K 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) -
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) -
src/go/doc/example.go
func lastComment(b *ast.BlockStmt, c []*ast.CommentGroup) (i int, last *ast.CommentGroup) { if b == nil { return } pos, end := b.Pos(), b.End() for j, cg := range c { if cg.Pos() < pos { continue } if cg.End() > end { break } i, last = j, cg } return } // classifyExamples classifies examples and assigns them to the Examples field
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 21.4K bytes - Viewed (0) -
src/syscall/exec_linux_test.go
t.Skip("cgroup v2 not available") } cg := bytes.TrimPrefix(selfCg, []byte("0::")) if len(cg) == len(selfCg) { // No prefix found. t.Skipf("cgroup v2 not available (/proc/self/cgroup contents: %q)", selfCg) } // Need an ability to create a sub-cgroup. subCgroup, err := os.MkdirTemp(prefix+string(bytes.TrimSpace(cg)), "subcg-") if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
} // Create a cgroup container manager. func createManager(containerName string) (cgroups.Manager, error) { cg := &configs.Cgroup{ Parent: "/", Name: containerName, Resources: &configs.Resources{ SkipDevices: true, }, Systemd: false, } return manager.New(cg) } type KernelTunableBehavior string const ( KernelTunableWarn KernelTunableBehavior = "warn"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0)