- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for ErrRange (0.17 sec)
-
src/flag/flag.go
// It then gets wrapped through failf to provide more information. var errParse = errors.New("parse error") // errRange is returned by Set if a flag's value is out of range. // It then gets wrapped through failf to provide more information. var errRange = errors.New("value out of range") func numError(err error) error { ne, ok := err.(*strconv.NumError) if !ok { return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 18:38:24 UTC 2024 - 39.7K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor_test.go
numDevicesToUnmap = 2 ) var _ OperationGenerator = &fakeOperationGenerator{} func TestOperationExecutor_MountVolume_ConcurrentMountForNonAttachableAndNonDevicemountablePlugins(t *testing.T) { // Arrange ch, quit, oe := setup() volumesToMount := make([]VolumeToMount, numVolumesToMount) secretName := "secret-volume" volumeName := v1.UniqueVolumeName(secretName) // Act for i := range volumesToMount {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 26.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
"k8s.io/kubernetes/pkg/volume/util/types" ) // Calls AddNode() once. // Verifies node exists, and zero volumes to attach. func Test_AddNode_Positive_NewNode(t *testing.T) { // Arrange volumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) dsw := NewDesiredStateOfWorld(volumePluginMgr) nodeName := k8stypes.NodeName("node-name") // Act dsw.AddNode(nodeName) // Assert
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go
// Verifies newly added pod/volume exists via // PodExistsInVolume() VolumeExists() and GetVolumesToMount() func Test_AddPodToVolume_Positive_NewPodNewVolume(t *testing.T) { // Arrange volumePluginMgr, _ := volumetesting.GetTestKubeletVolumePluginMgr(t) seLinuxTranslator := util.NewFakeSELinuxLabelTranslator() dsw := NewDesiredStateOfWorld(volumePluginMgr, seLinuxTranslator) pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 34K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
// Verifies newly added volume exists in GetUnmountedVolumes() // Verifies newly added volume doesn't exist in GetGloballyMountedVolumes() func Test_MarkVolumeAsAttached_Positive_NewVolume(t *testing.T) { // Arrange volumePluginMgr, plugin := volumetesting.GetTestKubeletVolumePluginMgr(t) asw := NewActualStateOfWorld("mynode" /* nodeName */, volumePluginMgr) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java
// then assertEquals(stripAnsiCodes(versionOut), versionOut); } @Test void populatePropertiesCanContainEqualsSign() throws Exception { // Arrange CliRequest request = new CliRequest(new String[] {"-Dw=x=y", "validate"}, null); // Act cli.cli(request); cli.properties(request); // Assert
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 28.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
volumesFailedReconstruction: []podVolume{defaultVolume}, expectedUnmounts: 1, }, } for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { // Arrange tmpKubeletDir, err := os.MkdirTemp("", "") if err != nil { t.Fatalf("can't make a temp directory for kubeletPods: %v", err) } defer os.RemoveAll(tmpKubeletDir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
) if err != nil { t.Fatalf("Run failed with error. Expected: <no error> Actual: <%v>", err) } return adcObj.(*attachDetachController) } func Test_NewAttachDetachController_Positive(t *testing.T) { // Arrange fakeKubeClient := controllervolumetesting.CreateTestClient() informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) tCtx := ktesting.Init(t) // Act
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
src/index/suffixarray/suffixarray_test.go
// Construct a pathological input that forces // recurse_32 to allocate a new temporary buffer. // The input must have more than N/3 LMS-substrings, // which we arrange by repeating an SLSLSLSLSLSL pattern // like ababab... above, but then we must also arrange // for a large number of distinct LMS-substrings. // We use this pattern: // 1 255 1 254 1 253 1 ... 1 2 1 255 2 254 2 253 2 252 2 ...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
endpoint: "/var/log/kubelet/plugins_registry/myplugin/csi.sock", versions: []string{"var", "boo", "foo"}, shouldFail: true, }, } for _, tc := range testCases { // Arrange & Act err := PluginHandler.ValidatePlugin(tc.pluginName, tc.endpoint, tc.versions) // Assert if tc.shouldFail && err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0)