- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for reactors (0.16 sec)
-
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
t.Helper() tc := &testContext{} tCtx := ktesting.Init(t) tc.ctx = tCtx tc.client = fake.NewSimpleClientset(objs...) reactor := createReactor(tc.client.Tracker()) tc.client.PrependReactor("*", "*", reactor) // Quick-and-dirty workaround for fake client storing ResourceClassParameters and // ResourceClaimParameters as "resourceclassparameterses" and "resourceclaimparameterses":
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
indexer.Add(&v1.Node{ObjectMeta: metav1.ObjectMeta{Name: nodeName}}) } esInformer := informerFactory.Discovery().V1().EndpointSlices() esIndexer := esInformer.Informer().GetIndexer() // These reactors are required to mock functionality that would be covered // automatically if we weren't using the fake client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
if apiPVCs == nil { env.reactor.AddClaim(pvc) } } for _, pvc := range apiPVCs { env.reactor.AddClaim(pvc) } } func (env *testEnv) initVolumes(cachedPVs []*v1.PersistentVolume, apiPVs []*v1.PersistentVolume) { for _, pv := range cachedPVs { assumecache.AddTestObject(env.internalBinder.pvCache.AssumeCache, pv) if apiPVs == nil { env.reactor.AddVolume(pv) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/controller/history/controller_history_test.go
_, err := history.CreateControllerRevision(test.existing[i].parent, test.existing[i].revision, &collisionCount) if err != nil { t.Fatal(err) } } if test.reactor != nil { client.PrependReactor("*", "*", test.reactor) } updated, err := history.UpdateControllerRevision(test.revision, test.newRevision) if !test.err && err != nil { t.Errorf("%s: %s", test.name, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 49.1K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
fakeClient := fakeclient.NewSimpleClientset() plug, tmpDir := newTestPluginWithAttachDetachVolumeHost(t, fakeClient) defer os.RemoveAll(tmpDir) if tc.reactor != nil { fakeClient.PrependReactor("*", "*", tc.reactor) } attacher, err0 := plug.NewAttacher() if err0 != nil { t.Fatalf("failed to create new attacher: %v", err0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
// phase 1: get file Models from the reactor. List<InterimResult> interimResults = build(projectIndex, pomFiles, new LinkedHashSet<>(), true, recursive); ClassLoader oldContextClassLoader = Thread.currentThread().getContextClassLoader(); try { // Phase 2: get effective models from the reactor
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon May 13 16:34:29 UTC 2024 - 57.1K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java
* where multiple modules in the reactor have the same artifactId. * <p> * {@code -rf :artifactId} will pick up the first module which matches, but when multiple modules in the reactor * have the same artifactId, effective failed module might be later in build reactor.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 72.6K bytes - Viewed (0) -
src/go/parser/parser.go
} type field struct { name *ast.Ident typ ast.Expr } func (p *parser) parseParamDecl(name *ast.Ident, typeSetsOK bool) (f field) { // TODO(rFindley) refactor to be more similar to paramDeclOrNil in the syntax // package if p.trace { defer un(trace(p, "ParamDeclOrNil")) } ptok := p.tok if name != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 08 20:07:50 UTC 2023 - 72.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
// This feature is currently implemented in watch cache layer, so this is optional. // // TODO(#109831): ProgressNotify feature is effectively implementing the same // // functionality, so we should refactor this functionality to share the same input. func RunTestWatchDispatchBookmarkEvents(ctx context.Context, t *testing.T, store storage.Interface, expectedWatchBookmarks bool) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelBuilder.java
problems.add( Severity.WARNING, ModelProblem.Version.BASE, "BOM imports from within reactor should be avoided", dependency.getLocation("")); } } final ModelBuilderResult importResult; try {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Jun 07 07:31:02 UTC 2024 - 61.9K bytes - Viewed (0)