- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 49 for newController (0.4 sec)
-
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/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) -
subprojects/core/src/main/java/org/gradle/internal/buildtree/DefaultBuildTreeLifecycleController.java
this.workController = workController; this.modelCreator = modelCreator; this.finishExecutor = finishExecutor; this.state = controllerFactory.newController(Describables.of("build tree state"), State.NotStarted); this.startParameter = startParameter; this.buildModelParameters = buildModelParameters; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 08 07:46:55 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
podIndexer cache.Indexer // recorder is used to record events in the API server recorder record.EventRecorder queue workqueue.TypedRateLimitingInterface[string] } // NewController creates an ephemeral volume controller. func NewController( ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer, pvcInformer coreinformers.PersistentVolumeClaimInformer) (Controller, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
if err != nil { return nil, "", err } } return mergeSpec, generateCRDHash(crd), nil }, &s.crdCache) return &s } // NewController creates a new Controller with input CustomResourceDefinition informer func NewController(crdInformer informers.CustomResourceDefinitionInformer) *Controller { c := &Controller{ crdLister: crdInformer.Lister(), crdsSynced: crdInformer.Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
pilot/pkg/status/manager.go
) // Manager allows multiple controllers to provide input into configuration // status without needlessly doubling the number of writes, or overwriting // one another. Each status controller calls newController, passing in // an arbitrary status modification function, and then calls EnqueueStatusUpdate // when an individual resource is ready to be updated with the relevant data. type Manager struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller_test.go
namespaceInformer.Informer().GetIndexer().Add(obj) } systemNamespaces := []string{metav1.NamespaceSystem, metav1.NamespacePublic, v1.NamespaceNodeLease, metav1.NamespaceDefault} controller := NewController(systemNamespaces, clientset, namespaceInformer) clientset.PrependReactor("create", "namespaces", func(action k8stesting.Action) (bool, runtime.Object, error) { create := action.(k8stesting.CreateAction)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
return } defer c.policyQueue.ShutDown() for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } func NewController(policyInformer informerv1.ValidatingAdmissionPolicyInformer, policyClient admissionregistrationv1.ValidatingAdmissionPolicyInterface, typeChecker *validatingadmissionpolicy.TypeChecker) (*Controller, error) { c := &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0)