- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for volerr (0.31 sec)
-
pkg/controller/volume/persistentvolume/pv_controller.go
storagelisters "k8s.io/client-go/listers/storage/v1" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record" ref "k8s.io/client-go/tools/reference" "k8s.io/client-go/util/workqueue" volerr "k8s.io/cloud-provider/volume/errors" storagehelpers "k8s.io/component-helpers/storage/volume" "k8s.io/kubernetes/pkg/controller/volume/common" "k8s.io/kubernetes/pkg/controller/volume/events"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
cmd/iam.go
if entityKeysInStorage.Contains(origKeys[i]) { // Ignore any deletion error. _, delErr := sys.PolicyDBSet(ctx, origKeys[i], "", stsUser, isGroup) if delErr != nil { logErr := fmt.Errorf("failed to delete extraneous LDAP DN mapping for `%s`: %w", origKeys[i], delErr) iamLogIf(ctx, logErr) } } } } // Replacing origKeys[0] with normKey in the policyMap
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
t.Fatalf( "Volume %q/node %q should not exist, but it does.", volumeName, nodeName) } _, podErr := dsw.AddPod(types.UniquePodName(podName), controllervolumetesting.NewPod(podName, podName), volumeSpec, nodeName) if podErr != nil { t.Fatalf("AddPod failed. Expected: <no error> Actual: <%v>", podErr) } // Act _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
func isClientTimeout(err error) bool { if urlErr, ok := err.(*url.Error); ok { return urlErr.Timeout() } return false } func isStreamReset(err error) bool { if err == nil { return false } if urlErr, ok := err.(*url.Error); ok { // Sadly, the client does not receive a more specific indication // of stream reset. return strings.Contains(urlErr.Err.Error(), "INTERNAL_ERROR") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/apis/admissionregistration/validation/validation.go
if celErr, ok := err.(*cel.Error); ok { switch celErr.Type { case cel.ErrorTypeRequired: return field.Required(fldPath, celErr.Detail) case cel.ErrorTypeInvalid: return field.Invalid(fldPath, expression.GetExpression(), celErr.Detail) case cel.ErrorTypeInternal: return field.InternalError(fldPath, celErr) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 56.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options_test.go
t.Errorf("expected errors, no errors found") } if len(errs) > 0 && tc.expectErrors { gotErr := utilerrors.NewAggregate(errs).Error() if !strings.Contains(gotErr, tc.expectedErrorSubString) { t.Errorf("expected error: %s, got err: %v", tc.expectedErrorSubString, gotErr) } } }) } } func TestValidateControllerManagerOptions(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 55.1K bytes - Viewed (0) -
pkg/volume/csi/csi_attacher_test.go
attachID: getAttachmentName("vol01", "driver01", "node01"), spec: volume.NewSpecFromPersistentVolume(makeTestPV("pv01", 10, "driver01", "vol01"), false), }, { name: "test failure, attach with volSrc", nodeName: "node01", attachID: getAttachmentName("vol01", "driver01", "node01"), spec: volume.NewSpecFromVolume(makeTestVol("vol01", "driver01")), shouldFail: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
cmd/xl-storage_test.go
{"data/G_792/srv-tse/c/users/denis/documents/gestionlocative.txt", nil}, } for _, testCase := range testCases { gotErr := checkPathLength(testCase.path) t.Run("", func(t *testing.T) { if gotErr != testCase.expectedErr { t.Errorf("Expected %s, got %s", testCase.expectedErr, gotErr) } }) } } // Tests validate volume name. func TestIsValidVolname(t *testing.T) { testCases := []struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java
* @return return code */ public int doMain(String[] args, String workingDirectory, PrintStream stdout, PrintStream stderr) { PrintStream oldout = System.out; PrintStream olderr = System.err; final Set<String> realms; if (classWorld != null) { realms = new HashSet<>(); for (ClassRealm realm : classWorld.getRealms()) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 72.6K bytes - Viewed (0) -
cmd/admin-handlers-users.go
// clean import. err := globalIAMSys.DeleteServiceAccount(ctx, svcAcctReq.AccessKey, true) if err != nil { delErr := fmt.Errorf("failed to delete existing service account(%s) before importing it: %w", svcAcctReq.AccessKey, err) writeErrorResponseJSON(ctx, w, importError(ctx, delErr, allSvcAcctsFile, user), r.URL) return } } opts := newServiceAccountOpts{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 28 17:19:04 UTC 2024 - 78.6K bytes - Viewed (0)