- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for disableCache (0.39 sec)
-
src/cmd/go/internal/test/test.go
} c.disableCache = true return false } if a.Package.Root == "" { // Caching does not apply to tests outside of any module, GOPATH, or GOROOT. if cache.DebugTest { fmt.Fprintf(os.Stderr, "testcache: caching disabled for package outside of module root, GOPATH, or GOROOT: %s\n", a.Package.ImportPath) } c.disableCache = true return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
pilot/pkg/model/xds_cache.go
out = append(out, x.sds.Snapshot()...) return out } // DisabledCache is a cache that is always empty type DisabledCache struct{} func (d DisabledCache) Run(stop <-chan struct{}) { } func (d DisabledCache) Add(entry XdsCacheEntry, pushRequest *PushRequest, value *discovery.Resource) { } func (d DisabledCache) Get(entry XdsCacheEntry) *discovery.Resource { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 02 07:02:05 UTC 2023 - 6.1K bytes - Viewed (0) -
pilot/pkg/model/typed_xds_cache.go
res[k] = v } return res } // disabledCache is a cache that is always empty type disabledCache[K comparable] struct{} var _ typedXdsCache[uint64] = &disabledCache[uint64]{} func (d disabledCache[K]) Flush() { } func (d disabledCache[K]) Add(k K, entry dependents, pushReq *PushRequest, value *discovery.Resource) { } func (d disabledCache[K]) Get(k K) *discovery.Resource { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/rds.go
if hostname == "" || port == 0 { log.Warnf("failed to parse %v", routeName) return nil } virtualHosts, _, _ := core.BuildSidecarOutboundVirtualHosts(node, push, routeName, port, nil, &model.DisabledCache{}) // Only generate the required route for grpc. Will need to generate more // as GRPC adds more features. return &route.RouteConfiguration{ Name: routeName, VirtualHosts: virtualHosts, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
xdsUpdater := opts.XDSUpdater var endpoints *model.EndpointIndex if xdsUpdater == nil { endpoints = model.NewEndpointIndex(model.DisabledCache{}) delegate := model.NewEndpointIndexUpdater(endpoints) xdsUpdater = xdsfake.NewWithDelegate(delegate) } domainSuffix := defaultFakeDomainSuffix if opts.DomainSuffix != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
tests/fuzz/pilot_model_fuzzer.go
sd.WantGetProxyServiceTargets = slices.Map(serviceInstances, model.ServiceInstanceToTarget) env.ServiceDiscovery = sd env.Watcher = mesh.NewFixedWatcher(m) env.EndpointIndex = model.NewEndpointIndex(model.DisabledCache{}) env.Init() pc := model.NewPushContext() _ = pc.InitContext(env, nil, nil) return 1 } func FuzzBNMUnmarshalJSON(data []byte) int { var bnm model.BootstrapNodeMetadata
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 18:13:06 UTC 2023 - 4.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_traffic_policy_test.go
} push := model.NewPushContext() for _, test := range tests { t.Run(test.name, func(t *testing.T) { cb := NewClusterBuilder(proxy, &model.PushRequest{Push: push}, model.DisabledCache{}) opts := &buildClusterOpts{ mutable: newClusterWrapper(&cluster.Cluster{ ClusterDiscoveryType: &cluster.Cluster_Type{Type: test.discoveryType}, }), mesh: push.Mesh, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
store: configController, env: env, initialConfigs: configs, stop: test.NewStop(t), ConfigGen: NewConfigGenerator(&model.DisabledCache{}), MemRegistry: msd, MemServiceRegistry: memserviceRegistry, Registry: serviceDiscovery, ServiceEntryRegistry: se, } if !opts.SkipRun { fake.Run()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_tls_test.go
} push := model.NewPushContext() for _, test := range tests { t.Run(test.name, func(t *testing.T) { cb := NewClusterBuilder(proxy, &model.PushRequest{Push: push}, model.DisabledCache{}) opts := &buildClusterOpts{ mutable: newClusterWrapper(&cluster.Cluster{ ClusterDiscoveryType: &cluster.Cluster_Type{Type: test.discoveryType}, }), mesh: push.Mesh, } if test.h2 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 60.9K bytes - Viewed (0) -
pilot/pkg/model/context.go
Dual = pm.Dual ) var _ mesh.Holder = &Environment{} func NewEnvironment() *Environment { var cache XdsCache if features.EnableXDSCaching { cache = NewXdsCache() } else { cache = DisabledCache{} } return &Environment{ pushContext: NewPushContext(), Cache: cache, EndpointIndex: NewEndpointIndex(cache), } } // Environment provides an aggregate environmental API for Pilot
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1)