- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 97 for SetList (0.19 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
key := watchKey + "/foo" if !recursive { watchKey = key } // Get the current RV from which we can start watching. out := &example.PodList{} if err := store.GetList(ctx, watchKey, storage.ListOptions{ResourceVersion: "", Predicate: tt.pred, Recursive: recursive}, out); err != nil { t.Fatalf("List failed: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
// match 'opts.ResourceVersion' according 'opts.ResourceVersionMatch'. Get(ctx context.Context, key string, opts GetOptions, objPtr runtime.Object) error // GetList unmarshalls objects found at key into a *List api object (an object // that satisfies runtime.IsList definition). // If 'opts.Recursive' is false, 'key' is used as an exact match. If `opts.Recursive'
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
withRev = int64(parsedRV) } default: return withRev, fmt.Errorf("unknown ResourceVersionMatch value: %v", opts.ResourceVersionMatch) } return withRev, nil } // GetList implements storage.Interface. func (s *store) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error { preparedKey, err := s.prepareKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApi.groovy
this.daemonBaseDir = context.daemonBaseDir this.requiresDaemon = !GradleContextualExecuter.embedded this.testWorkDirProvider = testWorkDirProvider } void setDist(GradleDistribution dist) { this.dist = dist } /** * Specifies that the test use its own Gradle user home dir and daemon registry. */ void requireIsolatedUserHome() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 10:07:23 UTC 2024 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
} // GetList implements storage.Interface func (c *Cacher) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error { recursive := opts.Recursive resourceVersion := opts.ResourceVersion pred := opts.Predicate if shouldDelegateList(opts) { return c.storage.GetList(ctx, key, opts, listObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java
return urlQueue; } synchronized (queueHolder) { urlQueue = waitingQueue.poll(); if (urlQueue == null) { final List<EsUrlQueue> urlQueueList = getList(EsUrlQueue.class, sessionId, null, 0, pollingFetchSize, SortBuilders.fieldSort(CREATE_TIME).order(SortOrder.ASC)); if (urlQueueList.isEmpty()) { return null;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12.9K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-active-collections/1.0-beta-1/plexus-active-collections-1.0-beta-1.jar
tion); public boolean retainAll(java.util.Collection); public Object set(int, Object); protected final java.util.List checkedGetList() throws org.codehaus.plexus.component.repository.exception.ComponentLookupExcep; protected final java.util.List getList(); public final String getRole(); protected final void setRole(String); public final void contextualize(org.codehaus.plexus.context.Context) throws org.codehaus.plexus.context.ContextException; protected final org.codehaus.plexus.logging.Logger getLogger();...
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sun Oct 02 08:41:25 UTC 2022 - 15.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
} func (r *peerEndpointLeaseReconciler) getIpInfoList(storageOpts storage.ListOptions) (*corev1.EndpointsList, error) { ipInfoList := &corev1.EndpointsList{} if err := r.serverLeases.storage.GetList(apirequest.NewDefaultContext(), r.serverLeases.baseKey, storageOpts, ipInfoList); err != nil { return nil, err } return ipInfoList, nil } // createEndpointPortSpec creates the endpoint ports
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApiSpecification.groovy
} // reflectively invoked by ToolingApiExecution void setTargetDist(GradleDistribution targetDist) { targetGradleDistribution = targetDist toolingApi.setDist(targetGradleDistribution) } GradleDistribution getTargetDist() { if (targetGradleDistribution == null) { throw new IllegalStateException("targetDist is not yet set by the testing framework")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 16.6K bytes - Viewed (0)