- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 858 for err (0.12 sec)
-
internal/event/targetlist_test.go
targetListCase2 := NewTargetList(context.Background()) if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil { panic(err) } targetListCase3 := NewTargetList(context.Background()) if err := targetListCase3.Add(&ExampleTarget{TargetID{"3", "testcase"}, false, false}); err != nil { panic(err) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
cmd/tier-last-day-stats_gen.go
err = en.WriteMapHeader(uint32(len(z))) if err != nil { err = msgp.WrapError(err) return } for zb0007, zb0008 := range z { err = en.WriteString(zb0007) if err != nil { err = msgp.WrapError(err) return } // map header, size 2 // write "Bins" err = en.Append(0x82, 0xa4, 0x42, 0x69, 0x6e, 0x73) if err != nil { return } err = en.WriteArrayHeader(uint32(24))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 9.3K bytes - Viewed (0) -
internal/config/api/api.go
} } cfg.CorsAllowOrigin = corsAllowOrigin if err = config.CheckValidKeys(config.APISubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil { return cfg, err } // Check environment variables parameters requestsMax, err := strconv.Atoi(env.Get(EnvAPIRequestsMax, kvs.GetWithDefault(apiRequestsMax, DefaultKVS))) if err != nil { return cfg, err } cfg.RequestsMax = requestsMax if requestsMax < 0 {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 11.5K bytes - Viewed (1) -
cmd/erasure_test.go
disks := make([]StorageAPI, len(diskPaths)) var err error for i := range diskPaths { disks[i], diskPaths[i], err = newXLStorageTestSetup(tb) if err != nil { return nil, err } err = disks[i].MakeVol(context.Background(), "testbucket") if err != nil { return nil, err } } return &erasureTestSetup{dataBlocks, parityBlocks, blockSize, diskPaths, disks}, nil
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 25 19:37:26 UTC 2022 - 4.8K bytes - Viewed (0) -
cmd/metacache-stream.go
r.err = err return err } var err error var meta metaCacheEntry if meta.name, err = r.mr.ReadString(); err != nil { if err == io.EOF { err = io.ErrUnexpectedEOF } r.err = err return err } if meta.metadata, err = r.mr.ReadBytes(metaDataPoolGet()); err != nil { if err == io.EOF { err = io.ErrUnexpectedEOF } r.err = err return err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen.go
if err != nil { err = msgp.WrapError(err, "NEndpoints") return } // write "CmdLines" err = en.Append(0xa8, 0x43, 0x6d, 0x64, 0x4c, 0x69, 0x6e, 0x65, 0x73) if err != nil { return } err = en.WriteArrayHeader(uint32(len(z.CmdLines))) if err != nil { err = msgp.WrapError(err, "CmdLines") return } for za0001 := range z.CmdLines { err = en.WriteString(z.CmdLines[za0001]) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 21 14:49:49 UTC 2024 - 7K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
atomic.AddInt64(&target.activeRequests, 1) defer atomic.AddInt64(&target.activeRequests, -1) atomic.AddInt64(&target.totalRequests, 1) defer func() { if err != nil { atomic.AddInt64(&target.failedRequests, 1) } }() if err = target.init(); err != nil { return nil, err } data, err := json.Marshal(eventData) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 08 21:39:49 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
z.Name, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "Name") return } case "Created": z.Created, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "Created") return } case "Deleted": z.Deleted, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "Deleted") return }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 70.1K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
eventName, err := event.ParseName(s) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } if bucketName != "" { if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/naughty-disk_test.go
return nil, err } return d.disk.ListVols(ctx) } func (d *naughtyDisk) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) { if err := d.calcError(); err != nil { return VolInfo{}, err } return d.disk.StatVol(ctx, volume) } func (d *naughtyDisk) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) { if err := d.calcError(); err != nil { return err
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0)