Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,217 for inform (0.14 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/generic.go

    // sharedInformers based on type
    type GenericInformer interface {
    	Informer() cache.SharedIndexInformer
    	Lister() cache.GenericLister
    }
    
    type genericInformer struct {
    	informer cache.SharedIndexInformer
    	resource schema.GroupResource
    }
    
    // Informer returns the SharedIndexInformer.
    func (f *genericInformer) Informer() cache.SharedIndexInformer {
    	return f.informer
    }
    
    // Lister returns the GenericLister.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 16 17:13:40 UTC 2019
    - 2.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go

    		wh.SetExternalKubeClientSet(client)
    		wh.SetExternalKubeInformerFactory(informer)
    
    		informer.Start(stopCh)
    		informer.WaitForCacheSync(stopCh)
    
    		if err = wh.ValidateInitialization(); err != nil {
    			t.Errorf("%s: failed to validate initialization: %v", tt.Name, err)
    			continue
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    	}()
    
    	// Wait for controller and informer to start up
    	require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced))
    
    	// Stop the controller and informer
    	testCancel()
    
    	// Wait for controller and informer to stop
    	wg.Wait()
    
    	// Ensure the event handler was cleaned up
    	require.Empty(t, informer.registrations)
    
    	verifyNoMoreEvents()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go

    	tweakListOptions internalinterfaces.TweakListOptionsFunc
    }
    
    // NewCustomResourceDefinitionInformer constructs a new informer for CustomResourceDefinition type.
    // Always prefer using an informer factory to get a shared informer instead of getting an independent
    // one. This reduces memory footprint and number of connections to the server.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go

    	tweakListOptions internalinterfaces.TweakListOptionsFunc
    }
    
    // NewCustomResourceDefinitionInformer constructs a new informer for CustomResourceDefinition type.
    // Always prefer using an informer factory to get a shared informer instead of getting an independent
    // one. This reduces memory footprint and number of connections to the server.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
  6. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/transform/TransformStartEvent.java

     * limitations under the License.
     */
    
    package org.gradle.tooling.events.transform;
    
    import org.gradle.tooling.events.StartEvent;
    
    /**
     * An event that informs about a transform operation having started its execution.
     *
     * @since 5.1
     */
    public interface TransformStartEvent extends TransformProgressEvent, StartEvent {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 901 bytes
    - Viewed (0)
  7. pkg/controller/bootstrap/bootstrapsigner_test.go

    	if err != nil {
    		t.Fatalf("error creating Signer: %v", err)
    	}
    
    	cm := newConfigMap("", "")
    	configMaps.Informer().GetIndexer().Add(cm)
    
    	secret := newTokenSecret(testTokenID, "tokenSecret")
    	addSecretSigningUsage(secret, "true")
    	secrets.Informer().GetIndexer().Add(secret)
    
    	signer.signConfigMap(context.TODO())
    
    	expected := []core.Action{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go

    	informerType := reflect.TypeOf(obj)
    	informer, exists := f.informers[informerType]
    	if exists {
    		return informer
    	}
    
    	resyncPeriod, exists := f.customResync[informerType]
    	if !exists {
    		resyncPeriod = f.defaultResync
    	}
    
    	informer = newFunc(f.client, resyncPeriod)
    	informer.SetTransform(f.transform)
    	f.informers[informerType] = informer
    
    	return informer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go

    	informerType := reflect.TypeOf(obj)
    	informer, exists := f.informers[informerType]
    	if exists {
    		return informer
    	}
    
    	resyncPeriod, exists := f.customResync[informerType]
    	if !exists {
    		resyncPeriod = f.defaultResync
    	}
    
    	informer = newFunc(f.client, resyncPeriod)
    	informer.SetTransform(f.transform)
    	f.informers[informerType] = informer
    
    	return informer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 9K bytes
    - Viewed (0)
  10. pkg/kube/kclient/index.go

    	client.AddEventHandler(handler)
    	return &idx
    }
    
    // CreateIndex creates a simple index, keyed by key K, over an informer for O. This is similar to
    // Informer.AddIndex, but is easier to use and can be added after an informer has already started.
    func CreateIndex[K comparable, O controllers.ComparableObject](
    	client Informer[O],
    	extract func(o O) []K,
    ) *Index[K, O] {
    	return CreateIndexWithDelegate(client, extract, nil)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 04 03:49:30 UTC 2023
    - 3.5K bytes
    - Viewed (0)
Back to top