- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for newController (0.18 sec)
-
pkg/kubelet/images/image_gc_manager_test.go
Image: imageName(id), ImageID: imageID(id), } } func TestDetectImagesInitialDetect(t *testing.T) { ctx := context.Background() mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockStatsProvider := statstest.NewMockProvider(mockCtrl) manager, fakeRuntime := newRealImageGCManager(ImageGCPolicy{}, mockStatsProvider) fakeRuntime.ImageList = []container.Image{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
} func newFixture(t testing.TB) *fixture { f := &fixture{} f.t = t f.objects = []runtime.Object{} return f } func (f *fixture) newController(ctx context.Context) (*DeploymentController, informers.SharedInformerFactory, error) { f.client = fake.NewSimpleClientset(f.objects...) informers := informers.NewSharedInformerFactory(f.client, controller.NoResyncPeriodFunc())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
namespaceLister listers.NamespaceLister namespaceSynced cache.InformerSynced systemNamespaces []string interval time.Duration } // NewController creates a new Controller to ensure system namespaces exist. func NewController(systemNamespaces []string, clientset kubernetes.Interface, namespaceInformer coreinformers.NamespaceInformer) *Controller { interval := 1 * time.Minute return &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
// or disabled. creationRatelimiter *rate.Limiter clock clock.Clock } // NewController returns a Controller struct. func NewController(cs kubernetes.Interface) *Controller { return newController(cs, clock.RealClock{}, rate.NewLimiter(rate.Every(30*time.Minute), 1)) } func newController(cs kubernetes.Interface, cl clock.Clock, limiter *rate.Limiter) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
checkHealthOrFail(t, store, p, false) }) } func setup(t *testing.T) (*Controller, *Controller, model.ConfigStoreController) { store := memory.NewController(memory.Make(collections.All)) c1 := NewController(store, "pilot-1", time.Duration(math.MaxInt64)) c2 := NewController(store, "pilot-2", time.Duration(math.MaxInt64)) createOrFail(t, store, wgA) createOrFail(t, store, wgAWrongNs) createOrFail(t, store, wgWithoutSA)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
} f := namespace.NewDiscoveryNamespacesFilter( kclient.New[*corev1.Namespace](opts.Client), opts.MeshWatcher, stop, ) kubelib.SetObjectFilter(opts.Client, f) meshServiceController := aggregate.NewController(aggregate.Options{MeshHolder: opts.MeshWatcher}) options := Options{ DomainSuffix: domainSuffix, XDSUpdater: xdsUpdater, Metrics: &model.Environment{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
DiscoveryController: discovery1, } registry2 := serviceregistry.Simple{ ProviderID: provider.ID("mockAdapter2"), DiscoveryController: discovery2, } ctls := NewController(Options{&mockMeshConfigHolder{}}) ctls.AddRegistry(registry1) ctls.AddRegistry(registry2) return ctls } // return aggregator and cluster1 and cluster2 service discovery
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
controllerName = "endpointslice-controller.k8s.io" // topologyQueueItemKey is the key for all items in the topologyQueue. topologyQueueItemKey = "topologyQueueItemKey" ) // NewController creates and initializes a new Controller func NewController(ctx context.Context, podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, nodeInformer coreinformers.NodeInformer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K 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/server/stats/volume_stat_calculator_test.go
}, Spec: k8sv1.PodSpec{ Volumes: podVolumes, }, } volumeCondition = &csipbv1.VolumeCondition{} ) func TestPVCRef(t *testing.T) { mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() // Setup mock stats provider mockStats := statstest.NewMockProvider(mockCtrl) volumes := map[string]volume.Volume{vol0: &fakeVolume{}, vol1: &fakeVolume{}, vol3: &fakeVolume{}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0)