Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for disableCache (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top