- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 103 for newController (0.22 sec)
-
pkg/kube/watcher/configmapwatcher/configmapwatcher_test.go
{updated: cm}, {updated: cm1, expectCalled: true, expectCM: cm1}, {deleted: cm1, expectCalled: true}, {deleted: cm2}, } stop := make(chan struct{}) c := NewController(client, configMapNamespace, configMapName, callback) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.HasSynced) cms := client.Kube().CoreV1().ConfigMaps(configMapNamespace) for i, step := range steps {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
} func TestGetCapacity(t *testing.T) { ephemeralStorageFromCapacity := int64(2000) ephemeralStorageFromCadvisor := int64(8000) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockCtrlError := gomock.NewController(t) defer mockCtrlError.Finish() mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) rootfs := cadvisorapiv2.FsInfo{ Capacity: 8000, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
pilot/pkg/config/aggregate/config_test.go
defer func() { close(stop) }() store1 := memory.Make(collection.SchemasFor(collections.HTTPRoute)) controller1 := memory.NewController(store1) go controller1.Run(stop) store2 := memory.Make(collection.SchemasFor(collections.HTTPRoute)) controller2 := memory.NewController(store2) go controller2.Run(stop) stores := []model.ConfigStoreController{controller1, controller2}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 6.7K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
Generator: "api", }} adscConn := ds.ConnectUnstarted(ds.SetupProxy(proxy), xds.APIWatches()) store := memory.Make(collections.Pilot) configController := memory.NewController(store) adscConn.Store = configController err := adscConn.Run() if err != nil { t.Fatal("ADSC: failed running ", err) } _, err = adscConn.WaitVersion(10*time.Second, gvk.ServiceEntry.String(), "")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
tests/fuzz/aggregate_controller_fuzzer.go
} maxOps := 2 f := fuzz.NewConsumer(data) opts := aggregate.Options{} err := f.GenerateStruct(&opts) if err != nil { return 0 } opts.MeshHolder = meshHolder c := aggregate.NewController(opts) iterations, err := f.GetInt() if err != nil { return 0 } for i := 0; i < iterations%30; i++ { opType, err := f.GetInt() if err != nil { return 0 } switch ops[opType%maxOps] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 2.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
// initServiceControllers creates and initializes the service controllers func (s *Server) initServiceControllers(args *PilotArgs) error { serviceControllers := s.ServiceController() s.serviceEntryController = serviceentry.NewController( s.configController, s.XDSServer, s.environment.Watcher, serviceentry.WithClusterID(s.clusterID), ) serviceControllers.AddRegistry(s.serviceEntryController) registered := sets.New[provider.ID]()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/kubelet/stats/provider_test.go
) func TestGetCgroupStats(t *testing.T) { const ( cgroupName = "test-cgroup-name" containerInfoSeed = 1000 updateStats = false ) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() var ( mockCadvisor = cadvisortest.NewMockInterface(mockCtrl) mockPodManager = new(kubepodtest.MockManager) mockRuntimeCache = new(kubecontainertest.MockRuntimeCache)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1_test.go
containerName := "container-name" devs := []*podresourcesv1.ContainerDevices{ { ResourceName: "resource", DeviceIds: []string{"dev0", "dev1"}, }, } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() for _, tc := range []struct { desc string pods []*v1.Pod devices []*podresourcesv1.ContainerDevices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/project/ProjectLifecycleController.java
} public ProjectLifecycleController(DisplayName displayName, StateTransitionControllerFactory factory, ServiceRegistry buildServices) { this.buildServices = buildServices; controller = factory.newController(displayName, State.NotCreated); } public boolean isCreated() { return project != null; } public void createMutableModel( DefaultProjectDescriptor descriptor,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go
openapiController := openapicontroller.NewController(s.Informers.Apiextensions().V1().CustomResourceDefinitions()) go openapiController.Run(s.GenericAPIServer.StaticOpenAPISpec, s.GenericAPIServer.OpenAPIVersionedService, context.StopCh) } if s.GenericAPIServer.OpenAPIV3VersionedService != nil { openapiv3Controller := openapiv3controller.NewController(s.Informers.Apiextensions().V1().CustomResourceDefinitions())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 14:31:43 UTC 2023 - 11.5K bytes - Viewed (0)