- Sort Score
- Result 10 results
- Languages All
Results 921 - 930 of 1,020 for err (0.03 sec)
-
cmd/signature-v4-utils.go
} // Returns SHA256 for calculating canonical-request. func getContentSha256Cksum(r *http.Request, stype serviceType) string { if stype == serviceSTS { payload, err := io.ReadAll(io.LimitReader(r.Body, stsRequestBodyLimit)) if err != nil { logger.CriticalIf(GlobalContext, err) } sum256 := sha256.Sum256(payload) r.Body = io.NopCloser(bytes.NewReader(payload)) return hex.EncodeToString(sum256[:]) } var (
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 9.1K bytes - Viewed (1) -
cmd/os-readdir-common.go
followDirSymlink bool } // Return all the entries at the directory dirPath. func readDir(dirPath string) (entries []string, err error) { return readDirWithOpts(dirPath, readDirOpts{count: -1}) } // Return up to count entries at the directory dirPath. func readDirN(dirPath string, count int) (entries []string, err error) { return readDirWithOpts(dirPath, readDirOpts{count: count})
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 09 23:20:51 UTC 2021 - 1.3K bytes - Viewed (0) -
tests/test_filter_pydantic_sub_model/test_filter_pydantic_sub_model_pv1.py
"model_b": {"username": "test-user"}, } @needs_pydanticv1 def test_validator_is_cloned(client: TestClient): with pytest.raises(ResponseValidationError) as err: client.get("/model/modelX") assert err.value.errors() == [ { "loc": ("response", "name"), "msg": "name must end in A", "type": "value_error", } ]
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Fri Jul 07 17:12:13 UTC 2023 - 4.5K bytes - Viewed (0) -
docs/iam/identity-manager-plugin.go
package main import ( "encoding/json" "errors" "fmt" "log" "net/http" ) func writeErrorResponse(w http.ResponseWriter, err error) { w.WriteHeader(http.StatusBadRequest) json.NewEncoder(w).Encode(map[string]string{ "reason": fmt.Sprintf("%v", err), }) } type Resp struct { User string `json:"user"`
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 2.1K bytes - Viewed (0) -
internal/config/lambda/event/arn_test.go
{"arn:minio:s3-object-lambda:us-east-1:1:webhook", &ARN{TargetID{"1", "webhook"}, "us-east-1"}, false}, } for i, testCase := range testCases { arn, err := ParseARN(testCase.s) expectErr := (err != nil) if expectErr != testCase.expectErr { t.Fatalf("test %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr) } if !testCase.expectErr {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 2.2K bytes - Viewed (0) -
internal/ioutil/hardlimitreader.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 2K bytes - Viewed (0) -
cmd/site-replication-metrics.go
}, ErrCounts: errCounts, } } func (rt *RTimedMetrics) addsize(size int64, err error) { // failures seen since uptime atomic.AddInt64(&rt.SinceUptime.Bytes, size) atomic.AddInt64(&rt.SinceUptime.Count, 1) rt.LastMinute.addsize(size) rt.LastHour.addsize(size) if err != nil && minio.ToErrorResponse(err).Code == "AccessDenied" { if rt.ErrCounts == nil { rt.ErrCounts = make(map[string]int) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0) -
association.go
// clear old data if clear && len(values) == 0 { for i := 0; i < reflectValue.Len(); i++ { if err := association.Relationship.Field.Set(association.DB.Statement.Context, reflectValue.Index(i), reflect.New(association.Relationship.Field.IndirectFieldType).Interface()); err != nil { association.Error = err break } if association.Relationship.JoinTable == nil {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 21.5K bytes - Viewed (0) -
cmd/shared-lock.go
} func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) { for { locker := objAPI.NewNSLock(minioMetaBucket, lockName) lkctx, err := locker.GetLock(ctx, sharedLockTimeout) if err != nil { continue } keepLock: for { select { case <-ctx.Done(): return case <-lkctx.Context().Done():
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
internal/mountinfo/mountinfo_windows.go
if v, ok := mountPointCache.Load(path); ok { return v.(bool) } wpath, _ := windows.UTF16PtrFromString(path) wvolume := make([]uint16, len(path)+1) if err := windows.GetVolumePathName(wpath, &wvolume[0], uint32(len(wvolume))); err != nil { mountPointCache.Store(path, false) return false } switch windows.GetDriveType(&wvolume[0]) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 19 01:35:22 UTC 2021 - 2K bytes - Viewed (0)