- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 106 for newController (0.36 sec)
-
pilot/pkg/config/kube/ingress/controller_test.go
meshHolder := mesh.NewTestWatcher(&meshconfig.MeshConfig{ IngressControllerMode: meshconfig.MeshConfig_DEFAULT, }) fakeClient := kube.NewFakeClient() return NewController(fakeClient, meshHolder, kubecontroller.Options{}), fakeClient } func TestIngressController(t *testing.T) { ingress1 := net.Ingress{ ObjectMeta: metav1.ObjectMeta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 18:34:32 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
// before we complete delete the ServiceCIDR deletionGracePeriod = 10 * time.Second ) // NewController returns a new *Controller. func NewController( ctx context.Context, serviceCIDRInformer networkinginformers.ServiceCIDRInformer, ipAddressInformer networkinginformers.IPAddressInformer, client clientset.Interface, ) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
hasProcessed synctrack.AsyncTracker[string] } type ControllerOptions struct { Name string Workers uint } func (c *controller[T]) Informer() Informer[T] { return c.informer } func NewController[T runtime.Object]( informer Informer[T], reconciler func(namepace, name string, newObj T) error, options ControllerOptions, ) Controller[T] { if options.Workers == 0 { options.Workers = 2 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
// monitors are synced before the controller can process quotas. workerLock sync.RWMutex } // NewController creates a quota controller with specified options func NewController(ctx context.Context, options *ControllerOptions) (*Controller, error) { // build the resource quota controller rq := &Controller{ rqClient: options.QuotaClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K 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) -
pkg/kubelet/metrics/collectors/resource_metrics_test.go
"container_swap_usage_bytes", "container_start_time_seconds", "pod_cpu_usage_seconds_total", "pod_memory_working_set_bytes", "pod_swap_usage_bytes", } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() tests := []struct { name string summary *statsapi.Summary summaryErr error expectedMetrics string }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.3K bytes - Viewed (1) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
this.buildModelLifecycleListener = buildModelLifecycleListener; this.toolingModelControllerFactory = toolingModelControllerFactory; this.state = controllerFactory.newController(Describables.of("state of", targetBuild().getDisplayName()), State.Configure); } @Override public GradleInternal getGradle() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
if !configCluster { options.SyncTimeout = features.RemoteClusterTimeout } log.Infof("Initializing Kubernetes service registry %q", options.ClusterID) options.ConfigCluster = configCluster kubeRegistry := NewController(client, options) kubeController := &kubeController{ MeshServiceController: opts.MeshServiceController, Controller: kubeRegistry, stop: stop, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller_test.go
env := &testEnv{ Interface: fake.NewSimpleClientset(), t: t, } factory := externalversions.NewSharedInformerFactoryWithOptions( env.Interface, 30*time.Second) c := NewController(factory.Apiextensions().V1().CustomResourceDefinitions()) ctx, cancel := context.WithCancel(context.Background()) factory.Start(ctx.Done()) factory.WaitForCacheSync(ctx.Done()) env.mux = http.NewServeMux()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 22 17:10:53 UTC 2023 - 12.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
PodInformer coreinformers.PodInformer NodeInformer coreinformers.NodeInformer EnableDynamicProvisioning bool } // NewController creates a new PersistentVolume controller func NewController(ctx context.Context, p ControllerParameters) (*PersistentVolumeController, error) { eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0)