Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for noError (0.27 sec)

  1. pkg/kubelet/kubelet_node_status_test.go

    			kubelet.updateRuntimeUp()
    			assert.NoError(t, kubelet.updateNodeStatus(ctx))
    			actions := kubeClient.Actions()
    			require.Len(t, actions, 2)
    			require.True(t, actions[1].Matches("patch", "nodes"))
    			require.Equal(t, actions[1].GetSubresource(), "status")
    
    			updatedNode, err := applyNodeStatusPatch(&existingNode, actions[1].(core.PatchActionImpl).GetPatch())
    			assert.NoError(t, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    		} else {
    			assert.NoError(t, err, "[case %d] error", i)
    		}
    		// Access the log of the previous, terminated container
    		previous = true
    		_, err = kubelet.validateContainerLogStatus("podName", podStatus, containerName, previous)
    		if !tc.pSuccess {
    			assert.Error(t, err, fmt.Sprintf("[case %d] error", i))
    		} else {
    			assert.NoError(t, err, "[case %d] error", i)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods_test.go

    			tmpdir, err := writeHostsFile(testCase.hostsFileName, testCase.rawHostsFileContent)
    			require.NoError(t, err, "could not create a temp hosts file")
    			defer os.RemoveAll(tmpdir)
    
    			actualContent, fileReadErr := nodeHostsFileContent(filepath.Join(tmpdir, testCase.hostsFileName), testCase.hostAliases)
    			require.NoError(t, fileReadErr, "could not create read hosts file")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    		sameTarget, apiErr := validateReplicationDestination(ctx, bucket, newReplicationConfig, true)
    		if apiErr != noError {
    			return fmt.Errorf("bucket replication config validation error: %#v", apiErr)
    		}
    		err = newReplicationConfig.Validate(bucket, sameTarget)
    		if err != nil {
    			return err
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    				// Send whitespace and keep connection open
    				if _, err := w.Write([]byte(" ")); err != nil {
    					return
    				}
    				w.(http.Flusher).Flush()
    			case hr := <-respCh:
    				switch hr.apiErr {
    				case noError:
    					if started {
    						if _, err := w.Write(hr.respBytes); err != nil {
    							return
    						}
    						w.(http.Flusher).Flush()
    					} else {
    						writeSuccessResponseJSON(w, hr.respBytes)
    					}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  6. pkg/config/validation/validation_test.go

    		},
    	}
    
    	for _, tc := range cases {
    		t.Run(tc.input, func(t *testing.T) {
    			got := ValidateHTTPHeaderValue(tc.input)
    			if tc.expected == nil {
    				assert.NoError(t, got)
    			} else {
    				assert.Error(t, got)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 03:11:45 UTC 2024
    - 196K bytes
    - Viewed (0)
Back to top