Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for NewFixedWatcher (0.31 sec)

  1. 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)
  2. pkg/kube/inject/webhook_test.go

    			EnvironmentVariables: map[string]string{
    				fmt.Sprintf("VAR_%d", i): fmt.Sprint(i),
    			},
    		}))
    	}
    	pcs := model.GetProxyConfigs(store, m)
    	env := model.Environment{
    		Watcher:     mesh.NewFixedWatcher(m),
    		ConfigStore: store,
    	}
    	env.SetPushContext(&model.PushContext{
    		ProxyConfigs: pcs,
    	})
    	watcher, err := NewFileWatcher(configFile, valuesFile)
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 17 20:25:52 UTC 2023
    - 39K bytes
    - Viewed (1)
  3. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	go configController.Run(stop)
    	fx := xdsfake.NewFakeXDS()
    	go func() {
    		for {
    			select {
    			case <-stop:
    				return
    			case <-fx.Events: // drain
    			}
    		}
    	}()
    
    	meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig())
    	serviceController := NewController(configController, fx, meshcfg)
    	return configController, serviceController
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/envoyfilter/listener_patch_test.go

    	configStore model.ConfigStore,
    ) *model.Environment {
    	e := &model.Environment{
    		ServiceDiscovery: serviceDiscovery,
    		ConfigStore:      configStore,
    		Watcher:          mesh.NewFixedWatcher(meshConfig),
    	}
    
    	pushContext := model.NewPushContext()
    	e.Init()
    	_ = pushContext.InitContext(e, nil, nil)
    	e.SetPushContext(pushContext)
    	return e
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceregistry_test.go

    	delegate := model.NewEndpointIndexUpdater(endpoints)
    	xdsUpdater := xdsfake.NewWithDelegate(delegate)
    	delegate.ConfigUpdateFunc = xdsUpdater.ConfigUpdate
    	meshWatcher := mesh.NewFixedWatcher(&meshconfig.MeshConfig{})
    	kc := kubecontroller.NewController(
    		client,
    		kubecontroller.Options{
    			XDSUpdater:            xdsUpdater,
    			DomainSuffix:          "cluster.local",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			},
    		},
    	}
    
    	svcList := controller.Services()
    	servicesEqual(svcList, expectedSvcList)
    }
    
    func TestController_ServiceWithFixedDiscoveryNamespaces(t *testing.T) {
    	meshWatcher := mesh.NewFixedWatcher(&meshconfig.MeshConfig{
    		DiscoverySelectors: []*meshconfig.LabelSelector{
    			{
    				MatchLabels: map[string]string{
    					"pilot-discovery": "enabled",
    				},
    			},
    			{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
Back to top