- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,694 for gzerror (0.17 sec)
-
internal/s3select/json/errors.go
func (err *s3Error) Error() string { return err.message } func errInvalidJSONType(err error) *s3Error { return &s3Error{ code: "InvalidJsonType", message: "The JsonType is invalid. Only DOCUMENT and LINES are supported.", statusCode: 400, cause: err, } } func errJSONParsingError(err error) *s3Error { return &s3Error{ code: "JSONParsingError",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 14 17:41:04 GMT 2021 - 49K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
} case authTypeSignedV2, authTypePresignedV2: if s3Error = isReqAuthenticatedV2(r); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } case authTypePresigned, authTypeSigned: if s3Error = reqSignatureV4Verify(r, globalSite.Region, serviceS3); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/acl-handlers.go
return } // Allow putBucketACL if policy action is set, since this is a dummy call // we are simply re-purposing the bucketPolicyAction. if s3Error := checkRequestAuthType(ctx, r, policy.PutBucketPolicyAction, bucket, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Before proceeding validate if bucket exists. _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{})
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 8.4K bytes - Viewed (0) -
cmd/bucket-policy-handlers.go
return } vars := mux.Vars(r) bucket := vars["bucket"] if s3Error := checkRequestAuthType(ctx, r, policy.PutBucketPolicyAction, bucket, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Check if bucket exists. if _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { mt := monitortest.New(t) tt.config.LabelPods = true c, err := NewRepairController(tt.client, tt.config) assert.NoError(t, err) t.Cleanup(func() { assert.NoError(t, c.queue.WaitForClose(time.Second)) }) stop := test.NewStop(t) tt.client.RunAndWait(stop) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.queue.HasSynced)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
bucketName := vars["bucket"] if bucketName == "" { if s3Error := checkRequestAuthType(ctx, r, policy.ListenNotificationAction, bucketName, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } } else { if s3Error := checkRequestAuthType(ctx, r, policy.ListenBucketNotificationAction, bucketName, ""); s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/object-handlers.go
s3Error = checkRequestAuthType(ctx, r, policy.GetObjectAction, bucket, object) } } if s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } objInfo, err := objectAPI.GetObjectInfo(ctx, bucket, object, opts) if err != nil { s3Error = checkRequestAuthType(ctx, r, policy.ListBucketAction, bucket, object) if s3Error == ErrNone {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 125K bytes - Viewed (0) -
tests/error_translator_test.go
"testing" "gorm.io/gorm" "gorm.io/gorm/utils/tests" ) func TestDialectorWithErrorTranslatorSupport(t *testing.T) { // it shouldn't translate error when the TranslateError flag is false translatedErr := errors.New("translated error") untranslatedErr := errors.New("some random error") db, _ := gorm.Open(tests.DummyDialector{TranslatedErr: translatedErr}) err := db.AddError(untranslatedErr) if !errors.Is(err, untranslatedErr) {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Wed Jul 12 13:21:22 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
cniC := fakeCNIEventClient(testServer.URL) err := PushCNIEvent(cniC, fakeCmdArgs, []*cniv1.IPConfig{&fakePrevResultIPConfig}, "testpod", "testns") assert.Error(t, err) assert.Equal(t, strings.Contains(err.Error(), fmt.Sprintf("unable to push CNI event, error was %d", http.StatusInternalServerError)), true) } func TestPushCNIAddEventGoodPayload(t *testing.T) { testPod := "testpod" testNS := "testns"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0)