- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewSyncController (0.24 sec)
-
pilot/pkg/networking/core/fake.go
} func NewConfigGenTest(t test.Failer, opts TestOptions) *ConfigGenTest { t.Helper() configs := getConfigs(t, opts) cc := opts.ConfigController if cc == nil { cc = memory.NewSyncController(memory.MakeSkipValidation(collections.PilotGatewayAPI())) } controllers := []model.ConfigStoreController{cc} if opts.CreateConfigStore != nil { controllers = append(controllers, opts.CreateConfigStore(cc)) }
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/test/xds/fake.go
xdsUpdater = xdsfake.NewWithDelegate(s) } mc := multicluster.NewFakeController() creds := kubesecrets.NewMulticluster(opts.DefaultClusterName, mc) configController := memory.NewSyncController(memory.MakeSkipValidation(collections.PilotGatewayAPI())) clientBuilder := opts.KubeClientBuilder if clientBuilder == nil { clientBuilder = func(objects ...runtime.Object) kubelib.Client {
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/serviceregistry/serviceentry/controller_test.go
} func initServiceDiscoveryWithOpts(t test.Failer, workloadOnly bool, opts ...Option) (model.ConfigStore, *Controller, *xdsfake.Updater) { store := memory.Make(collections.Pilot) configController := memory.NewSyncController(store) stop := test.NewStop(t) go configController.Run(stop) endpoints := model.NewEndpointIndex(model.DisabledCache{}) delegate := model.NewEndpointIndexUpdater(endpoints)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0)