- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for NewFixedWatcher (0.33 sec)
-
pkg/kube/multicluster/secretcontroller_test.go
var ( expectedQPS = float32(100) expectedBurst = 200 ) fakeRestConfig := &rest.Config{} client := kube.NewFakeClient() stopCh := test.NewStop(t) c := NewController(client, secretNamespace, "", mesh.NewFixedWatcher(nil), func(cfg *rest.Config) { cfg.QPS = expectedQPS cfg.Burst = expectedBurst }) c.ClientBuilder = func(kubeConfig []byte, c cluster.ID, configOverrides ...func(*rest.Config)) (kube.Client, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pilot/pkg/networking/core/loadbalancer/loadbalancer_test.go
}, } configStore := memory.Make(collections.Pilot) env := model.NewEnvironment() env.ServiceDiscovery = serviceDiscovery env.ConfigStore = configStore env.Watcher = mesh.NewFixedWatcher(meshConfig) pushContext := model.NewPushContext() env.Init() _ = pushContext.InitContext(env, nil, nil) env.SetPushContext(pushContext) pushContext.SetDestinationRulesForTesting([]config.Config{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 23 05:38:57 UTC 2024 - 39.1K bytes - Viewed (0) -
pilot/test/xds/fake.go
XDSUpdater: xdsUpdater, NetworksWatcher: opts.NetworksWatcher, SkipRun: true, ConfigCluster: k8sCluster == opts.DefaultClusterName, MeshWatcher: mesh.NewFixedWatcher(m), CRDs: []schema.GroupVersionResource{ // Install all CRDs used (mostly in Ambient) gvr.AuthorizationPolicy, gvr.PeerAuthentication, gvr.KubernetesGateway, gvr.KubernetesGateway,
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/model/authorization_test.go
store := &authzFakeStore{} for _, cfg := range configs { store.add(cfg) } environment := &Environment{ ConfigStore: store, Watcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{RootNamespace: "istio-config"}), } authzPolicies := GetAuthorizationPolicies(environment) return authzPolicies } func newConfig(name, ns string, spec config.Spec) config.Config {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/trustbundle/trustbundle_test.go
defer server1.Close() server2 := httptest.NewTLSServer(validHandler) caCertPool.AddCert(server2.Certificate()) defer server2.Close() tb := NewTrustBundle(caCertPool, mesh.NewFixedWatcher(&meshconfig.MeshConfig{TrustDomain: "cluster.local"})) // Change global remote timeout interval for the duration of the unit test remoteTimeout = 30 * time.Millisecond
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
configController, _ := configaggregate.MakeWriteableCache(controllers, cc) m := opts.MeshConfig if m == nil { m = mesh.DefaultMeshConfig() } env := model.NewEnvironment() env.Watcher = mesh.NewFixedWatcher(m) xdsUpdater := opts.XDSUpdater if xdsUpdater == nil { xdsUpdater = model.NewEndpointIndexUpdater(env.EndpointIndex) } serviceDiscovery := aggregate.NewController(aggregate.Options{})
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/serviceregistry/serviceentry/conversion_test.go
}, }, } for _, tt := range serviceInstanceTests { t.Run(tt.name, func(t *testing.T) { services := convertServices(*tt.se) s := &Controller{meshWatcher: mesh.NewFixedWatcher(mesh.DefaultMeshConfig())} instances := s.convertWorkloadEntryToServiceInstances(tt.wle, services, tt.se.Spec.(*networking.ServiceEntry), &configKey{}, tt.clusterID) sortServiceInstances(instances)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/networking/core/accesslog_test.go
}, Disabled: wrapperspb.Bool(true), }, }, }, }) env := model.NewEnvironment() env.ServiceDiscovery = serviceDiscovery env.ConfigStore = configStore env.Watcher = mesh.NewFixedWatcher(meshConfig) pushContext := model.NewPushContext() env.Init() pushContext.InitContext(env, nil, nil) env.SetPushContext(pushContext) return env } var (
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
m.ExtensionProviders = append(m.ExtensionProviders, jsonTextProvider, textFormattersProvider, jsonFormattersProvider) environment := &Environment{ ConfigStore: store, Watcher: mesh.NewFixedWatcher(m), } telemetries := getTelemetries(environment) ctx := NewPushContext() ctx.Mesh = m return telemetries, ctx } func newTelemetry(ns string, spec config.Spec) config.Config {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/model/authentication_test.go
if _, err := configStore.Create(*cfg); err != nil { t.Fatalf("getTestAuthenticationPolicies %v", err) } } environment := &Environment{ ConfigStore: configStore, Watcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{RootNamespace: rootNamespace}), } return initAuthenticationPolicies(environment) } func createTestRequestAuthenticationResource(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 45.1K bytes - Viewed (0)