- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newVolumeReactor (0.44 sec)
-
pkg/controller/volume/persistentvolume/framework_test.go
type volumeReactor struct { *pvtesting.VolumeReactor ctrl *PersistentVolumeController } func newVolumeReactor(ctx context.Context, client *fake.Clientset, ctrl *PersistentVolumeController, fakeVolumeWatch, fakeClaimWatch *watch.FakeWatcher, errors []pvtesting.ReactorError) *volumeReactor { return &volumeReactor{ pvtesting.NewVolumeReactor(ctx, client, fakeVolumeWatch, fakeClaimWatch, errors), ctrl, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
defer r.lock.Unlock() if volume, ok := r.volumes[name]; ok { volume.Spec.ClaimRef = nil volume.Status.Phase = v1.VolumeAvailable volume.Annotations = nil } } // NewVolumeReactor creates a volume reactor. func NewVolumeReactor(ctx context.Context, client *fake.Clientset, fakeVolumeWatch, fakeClaimWatch *watch.FakeWatcher, errors []ReactorError) *VolumeReactor { reactor := &VolumeReactor{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
for _, class := range storageClasses { indexer.Add(class) } ctrl.classLister = storagelisters.NewStorageClassLister(indexer) reactor := newVolumeReactor(ctx, client, ctrl, fakeVolumeWatch, fakeClaimWatch, test.errors) for _, claim := range test.initialClaims { claim = claim.DeepCopy() reactor.AddClaim(claim) go func(claim *v1.PersistentVolumeClaim) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
} func newTestBinder(t *testing.T, ctx context.Context) *testEnv { client := &fake.Clientset{} logger := klog.FromContext(ctx) reactor := pvtesting.NewVolumeReactor(ctx, client, nil, nil, nil) // TODO refactor all tests to use real watch mechanism, see #72327 client.AddWatchReactor("*", func(action k8stesting.Action) (handled bool, ret watch.Interface, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0)