- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 858 for err (0.04 sec)
-
cmd/erasure-server-pool-decom_gen_test.go
v := PoolDecommissionInfo{} bts, err := v.MarshalMsg(nil) if err != nil { t.Fatal(err) } left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after UnmarshalMsg(): %q", len(left), left) } left, err = msgp.Skip(bts) if err != nil { t.Fatal(err) } if len(left) > 0 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jan 12 02:48:43 UTC 2022 - 11K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
err = cr.readTrailers() if cr.debug { fmt.Println("trailer returned:", err) } if err != nil { cr.err = err return 0, err } } cr.err = io.EOF return n, cr.err } // read final terminator. err = mustRead('\r', '\n') if err != nil && err != io.EOF { cr.err = err return n, cr.err } cr.offset = copy(buf, cr.buffer) n += cr.offset
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
// Check if bucket exists. if _, err := objectAPI.GetBucketInfo(ctx, bucket, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } config, err := globalBucketVersioningSys.Get(bucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } configData, err := xml.Marshal(config) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5K bytes - Viewed (0) -
tests/postgres_test.go
harumph = Harumph{Name: "jinzhu"} if err := DB.Create(&harumph).Error; err != nil { t.Fatalf("should be able to create data, but got %v", err) } var result Harumph if err := DB.First(&result, "id = ?", harumph.ID).Error; err != nil || harumph.Name != "jinzhu" { t.Errorf("No error should happen, but got %v", err) } if err := DB.Where("id = $1", harumph.ID).First(&Harumph{}).Error; err != nil || harumph.Name != "jinzhu" {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Sat Oct 08 09:16:32 UTC 2022 - 6.4K bytes - Viewed (0) -
cmd/admin-handler-utils.go
HTTPStatusCode: http.StatusNotFound, } case errors.Is(err, errIAMActionNotAllowed): apiErr = APIError{ Code: "XMinioIAMActionNotAllowed", Description: err.Error(), HTTPStatusCode: http.StatusForbidden, } case errors.Is(err, errIAMServiceAccountNotAllowed): apiErr = APIError{ Code: "XMinioIAMServiceAccountNotAllowed", Description: err.Error(),
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 03 07:17:20 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/s3select/simdj/record.go
switch iter.Type() { case simdjson.TypeString: v, err := iter.String() if err != nil { return nil, err } return sql.FromString(v), nil case simdjson.TypeFloat: v, err := iter.Float() if err != nil { return nil, err } return sql.FromFloat(v), nil case simdjson.TypeInt: v, err := iter.Int() if err != nil { return nil, err } return sql.FromInt(v), nil case simdjson.TypeUint:
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/event/target/kafka.go
if os.IsNotExist(err) { return nil } return err } err = target.send(event) case key.ItemCount > 1: var events []event.Event events, err = target.store.GetMultiple(key) if err != nil { if os.IsNotExist(err) { return nil } return err } err = target.sendMultiple(events) } if err != nil { if isKafkaConnErr(err) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
src/archive/tar/tar_test.go
Typeflag: TypeReg, } if err := tw.WriteHeader(hdr); err != nil { t.Fatalf("tw.WriteHeader: %v", err) } if _, err := tw.Write(data); err != nil { t.Fatalf("tw.Write: %v", err) } if err := tw.Close(); err != nil { t.Fatalf("tw.Close: %v", err) } // Read it back. tr := NewReader(&b) rHdr, err := tr.Next() if err != nil { t.Fatalf("tr.Next: %v", err) }
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 23.9K bytes - Viewed (0) -
internal/logger/config.go
var host *xnet.Host host, err = xnet.ParseHost(s) if err != nil { break } brokers = append(brokers, *host) } if err != nil { return cfg, err } clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth)) clientAuth, err := strconv.Atoi(clientAuthCfgVal) if err != nil { return cfg, err } kafkaArgs := kafka.Config{
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 20 16:02:50 UTC 2024 - 18.3K bytes - Viewed (0) -
tests/serializer_test.go
t.Fatalf("no error should happen when migrate scanner, valuer struct, got error %v", err) } data := SerializerStruct{} if err := DB.Create(&data).Error; err != nil { t.Fatalf("failed to create data, got error %v", err) } var result SerializerStruct if err := DB.First(&result, data.ID).Error; err != nil { t.Fatalf("failed to query data, got error %v", err) }
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Fri Apr 21 14:09:38 UTC 2023 - 7.6K bytes - Viewed (0)