Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for MakeWriteableCache (1.15 sec)

  1. pilot/pkg/config/aggregate/config.go

    		schemas: schemas,
    		stores:  storeTypes,
    		writer:  writer,
    	}
    
    	return result, nil
    }
    
    // MakeWriteableCache creates an aggregate config store cache from several config store caches. An additional
    // `writer` config store is passed, which may or may not be part of `caches`.
    func MakeWriteableCache(caches []model.ConfigStoreController, writer model.ConfigStore) (model.ConfigStoreController, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/fake.go

    	if opts.CreateConfigStore != nil {
    		controllers = append(controllers, opts.CreateConfigStore(cc))
    	}
    	controllers = append(controllers, opts.ConfigStoreCaches...)
    	configController, _ := configaggregate.MakeWriteableCache(controllers, cc)
    
    	m := opts.MeshConfig
    	if m == nil {
    		m = mesh.DefaultMeshConfig()
    	}
    
    	env := model.NewEnvironment()
    	env.Watcher = mesh.NewFixedWatcher(m)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. pilot/pkg/bootstrap/configcontroller.go

    			})
    		}
    	}
    	if features.EnableAnalysis {
    		if err := s.initInprocessAnalysisController(args); err != nil {
    			return err
    		}
    	}
    	var err error
    	s.RWConfigStore, err = configaggregate.MakeWriteableCache(s.ConfigStores, configController)
    	if err != nil {
    		return err
    	}
    	s.XDSServer.WorkloadEntryController = autoregistration.NewController(configController, args.PodName, args.KeepaliveOptions.MaxServerConnectionAge)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  4. pkg/config/analysis/local/istiod_analyze.go

    	}
    
    	for _, c := range sa.clientsToRun {
    		// TODO: this could be parallel
    		c.RunAndWait(cancel)
    	}
    
    	store, err := aggregate.MakeWriteableCache(allstores, nil)
    	if err != nil {
    		return err
    	}
    	sa.multiClusterStores[sa.cluster] = store
    	for _, mcs := range sa.multiClusterStores {
    		go mcs.Run(cancel)
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:13 UTC 2024
    - 21.6K bytes
    - Viewed (0)
Back to top