- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for syncClaim (0.34 sec)
-
pkg/controller/volume/persistentvolume/framework_test.go
return ctrl.syncClaim(context.TODO(), test.initialClaims[0]) } func testSyncClaimError(ctrl *PersistentVolumeController, reactor *pvtesting.VolumeReactor, test controllerTest) error { err := ctrl.syncClaim(context.TODO(), test.initialClaims[0]) if err != nil { return nil } return fmt.Errorf("syncClaim succeeded when failure was expected") }
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/provision_test.go
} // Test multiple calls to syncClaim/syncVolume and periodic sync of all // volume/claims. The test follows this pattern: // 0. Load the controller with initial data. // 1. Call controllerTest.testCall() once as in TestSync() // 2. For all volumes/claims changed by previous syncVolume/syncClaim calls, // call appropriate syncVolume/syncClaim (simulating "volume/claim changed"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 35.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/delete_test.go
} // Test multiple calls to syncClaim/syncVolume and periodic sync of all // volume/claims. The test follows this pattern: // 0. Load the controller with initial data. // 1. Call controllerTest.testCall() once as in TestSync() // 2. For all volumes/claims changed by previous syncVolume/syncClaim calls, // call appropriate syncVolume/syncClaim (simulating "volume/claim changed"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/recycle_test.go
} // Test multiple calls to syncClaim/syncVolume and periodic sync of all // volume/claims. The test follows this pattern: // 0. Load the controller with initial data. // 1. Call controllerTest.testCall() once as in TestSync() // 2. For all volumes/claims changed by previous syncVolume/syncClaim calls, // call appropriate syncVolume/syncClaim (simulating "volume/claim changed"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 14.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
// an old version. logger := klog.FromContext(ctx) new, err := ctrl.storeClaimUpdate(logger, claim) if err != nil { logger.Error(err, "") } if !new { return } err = ctrl.syncClaim(ctx, claim) if err != nil { if errors.IsConflict(err) { // Version conflict error happens quite often and the controller // recovers from it easily.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
if err != nil { return err } switch prefix { case podKeyPrefix: return ec.syncPod(ctx, namespace, name) case claimKeyPrefix: return ec.syncClaim(ctx, namespace, name) default: return fmt.Errorf("unexpected key prefix: %s", prefix) } } func (ec *Controller) syncPod(ctx context.Context, namespace, name string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
return obj } // SyncAll simulates the controller periodic sync of volumes and claim. It // simply adds all these objects to the internal queue of updates. This method // should be used when the test manually calls syncClaim/syncVolume. Test that // use real controller loop (ctrl.Run()) will get periodic sync automatically. func (r *VolumeReactor) SyncAll() { r.lock.Lock() defer r.lock.Unlock() for _, c := range r.claims {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0)