- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,217 for inform (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
nil, ) go informer.Informer().Run(instanceContext.Done()) } klog.Infof("informer started for %v", *paramSource) ret := ¶mInfo{ mapping: *mapping, cancelFunc: instanceCancel, informer: informer, } s.paramsCRDControllers[*paramSource] = ret return ret.informer, mapping.Scope, nil } // For testing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/StartEvent.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.tooling.events; /** * An event that informs about an operation having started its execution. * * @since 2.4 */ public interface StartEvent extends ProgressEvent {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 806 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/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 - 11.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join.go
return j.dryRunDir } return j.initCfg.CertificatesDir } // TLSBootstrapCfg returns the cluster-info (kubeconfig). func (j *joinData) TLSBootstrapCfg() (*clientcmdapi.Config, error) { if j.tlsBootstrapCfg != nil { return j.tlsBootstrapCfg, nil } klog.V(1).Infoln("[preflight] Discovering cluster-info") tlsBootstrapCfg, err := discovery.For(j.cfg) j.tlsBootstrapCfg = tlsBootstrapCfg return tlsBootstrapCfg, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 25.2K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/IncrementalInputsIntegrationTest.groovy
} def "incremental task is informed of 'out-of-date' files when input file modified"() { given: previousExecution() when: file('inputs/file1.txt') << "changed content" then: executesIncrementally(modified: ['file1.txt']) } def "incremental task is informed of 'out-of-date' files when input file added"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Dec 23 12:52:29 UTC 2022 - 27.8K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
// - The pointer to the informer object. // - The pointer to the latest object, which could be the same as // the informer object, or an in-memory object. // // An informer update always overrides the latest object pointer. // // Assume() only updates the latest object pointer. // Restore() sets the latest object pointer back to the informer object. // Get/List() always returns the latest object pointer.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
pkg/kube/kclient/interfaces.go
// to the underlying informer are not touched ShutdownHandlers() // Start starts just this informer. Typically, this is not used. Instead, the `kube.Client.Run()` is // used to start all informers at once. // However, in some cases we need to run individual informers directly. // This function should only be called once. It does not wait for the informer to become ready nor does it block,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:09:57 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/kube/kclient/client.go
readyNow := delay.KnownOrCallback(func(stop <-chan struct{}) { // The inf() call is responsible for starting the informer inf := getInf() fc := &informerClient[T]{ informer: inf.Informer, startInformer: inf.Start, } applyDynamicFilter(filter, gvr, fc) inf.Start(stop) log.Infof("%v is now ready, building client", gvr.GroupResource()) // Swap out the dummy client with the full one
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/interface.go
// is concerned with. // // Returns an error always non-nil explaining why the worker stopped Run(ctx context.Context) error // Retrieves the informer used to back this controller Informer() Informer[T] // Returns true if the informer cache has synced, and all the objects from // the initial list have been reconciled at least once. HasSynced() bool } type NamespacedLister[T any] interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner_test.go
cleaner, cl, secrets, err := newTokenCleaner() if err != nil { t.Fatalf("error creating TokenCleaner: %v", err) } secret := newTokenSecret("tokenID", "tokenSecret") secrets.Informer().GetIndexer().Add(secret) cleaner.evalSecret(context.TODO(), secret) expected := []core.Action{} verifyActions(t, expected, cl.Actions()) } func TestCleanerExpired(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.1K bytes - Viewed (0)