- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for MakeWriteableCache (0.5 sec)
-
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) -
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) -
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)