- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for NewUncertainProgressError (0.6 sec)
-
pkg/volume/testing/testing.go
} func (fv *FakeVolume) setupInternal(mounterArgs volume.MounterArgs) error { if fv.VolName == TimeoutOnSetupVolumeName { fv.VolumeMountState[fv.VolName] = volumeMountUncertain return volumetypes.NewUncertainProgressError("time out on setup") } if fv.VolName == FailOnSetupVolumeName { fv.VolumeMountState[fv.VolName] = volumeNotMounted return fmt.Errorf("mounting volume failed") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
Mount: mountVolume, } } _, err := c.nodeClient.NodePublishVolume(ctx, req) if err != nil && !isFinalError(err) { return volumetypes.NewUncertainProgressError(err.Error()) } return err } func (c *fakeCsiDriverClient) NodeUnpublishVolume(ctx context.Context, volID string, targetPath string) error { c.t.Log("calling fake.NodeUnpublishVolume...")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter_test.go
func TestMounterSetupWithStatusTracking(t *testing.T) { fakeClient := fakeclient.NewSimpleClientset() plug, tmpDir := newTestPlugin(t, fakeClient) defer os.RemoveAll(tmpDir) nonFinalError := volumetypes.NewUncertainProgressError("non-final-error") transientError := volumetypes.NewTransientOperationFailure("transient-error") testCases := []struct { name string podUID types.UID
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 50.1K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
} } } } func TestAttacherMountDevice(t *testing.T) { pvName := "test-pv" var testFSGroup int64 = 3000 nonFinalError := volumetypes.NewUncertainProgressError("") transientError := volumetypes.NewTransientOperationFailure("") testCases := []struct { testName string volName string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
defer func() { if operationContext.EventErr != nil { errText := operationContext.EventErr.Error() og.markVolumeErrorState(volumeToMount, markVolumeOpts, volumetypes.NewUncertainProgressError(errText), actualStateOfWorld) } }() // if pluginDevicePath is provided, assume attacher may not provide device // or attachment flow uses SetupDevice to get device path
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0)