- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for newController (0.59 sec)
-
pkg/controller/endpoint/endpoints_controller_test.go
}) return httptest.NewServer(mux) } type endpointController struct { *Controller podStore cache.Store serviceStore cache.Store endpointsStore cache.Store } func newController(ctx context.Context, url string, batchPeriod time.Duration) *endpointController {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
type endpointSliceController struct { *Controller endpointSliceStore cache.Store nodeStore cache.Store podStore cache.Store serviceStore cache.Store } func newController(t *testing.T, nodeNames []string, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceController) { client := fake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
podLogName0 = "pod-log-0" podLogName1 = "pod-log-1" podLogStats0 = makeFakeLogStats(5000) podLogStats1 = makeFakeLogStats(6000) ) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() var ( mockCadvisor = cadvisortest.NewMockInterface(mockCtrl) mockRuntimeCache = new(kubecontainertest.MockRuntimeCache)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
kc := kubecontroller.NewController( client, kubecontroller.Options{ XDSUpdater: xdsUpdater, DomainSuffix: "cluster.local", MeshWatcher: meshWatcher, MeshServiceController: aggregate.NewController(aggregate.Options{MeshHolder: meshWatcher}), }, ) configController := memory.NewController(memory.Make(collections.Pilot)) stop := istiotest.NewStop(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
configController := memory.NewController(store) stop := test.NewStop(t) 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)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
podsWithDelayedDeletionPerIndex map[int]*v1.Pod terminating *int32 } // NewController creates a new Job controller that keeps the relevant pods // in sync with their corresponding Job objects. func NewController(ctx context.Context, podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface) (*Controller, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)