- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 772 for erro (0.13 sec)
-
internal/grid/grid_test.go
if !errors.Is(err, ErrUnknownHandler) { t.Fatalf("Unexpected error: %v, %T", err, err) } }) } func TestSingleRoundtripGenerics(t *testing.T) { defer testlogger.T.SetLogTB(t)() errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } grid, err := SetupTestGrid(2) errFatal(err) remoteHost := grid.Hosts[1] local := grid.Managers[0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/event/target/postgresql.go
func (target *PostgreSQLTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) } if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil { return err } return target.send(eventData) } // IsConnErr - To detect a connection error. func IsConnErr(err error) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K 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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/warm-backend.go
remoteVersionID, err := w.Put(ctx, probeObject, strings.NewReader("MinIO"), 5) if err != nil { if _, ok := err.(BackendDown); ok { return err } return tierPermErr{ Op: tierPut, Err: err, } } r, err := w.Get(ctx, probeObject, "", WarmBackendGetOpts{}) xhttp.DrainBody(r) if err != nil { if _, ok := err.(BackendDown); ok { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/store/queuestore.go
func (store *QueueStore[_]) list() ([]os.DirEntry, error) { files, err := os.ReadDir(store.directory) if err != nil { return nil, err } // Sort the entries. sort.Slice(files, func(i, j int) bool { ii, err := files[i].Info() if err != nil { return false } ji, err := files[j].Info() if err != nil { return true } return ii.ModTime().Before(ji.ModTime())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
prepare_stmt.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/object-api-input-checks.go
if err := checkListObjsArgs(ctx, bucket, prefix, keyMarker); err != nil { return err } if uploadIDMarker != "" { if HasSuffix(keyMarker, SlashSeparator) { return InvalidUploadIDKeyCombination{ UploadIDMarker: uploadIDMarker, KeyMarker: keyMarker, } } _, err := base64.RawURLEncoding.DecodeString(uploadIDMarker) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.7K bytes - Viewed (0) -
cmd/encryption-v1.go
if err != nil { return err } oldKey, err := GlobalKMS.DecryptKey(keyID, kmsKey, kms.Context{bucket: path.Join(bucket, object)}) if err != nil { return err } var objectKey crypto.ObjectKey if err = objectKey.Unseal(oldKey, sealedKey, crypto.S3.String(), bucket, object); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
z.StartTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "StartTime") return } case "stopTs": z.EndTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "EndTime") return } case "status": { var zb0002 uint8 zb0002, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err, "Status") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 26.8K bytes - Viewed (0) -
schema/serializer.go
t := sql.NullTime{} if err = t.Scan(dbValue); err == nil && t.Valid { err = field.Set(ctx, dst, t.Time.Unix()) } return } // Value implements serializer interface func (UnixSecondSerializer) Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (result interface{}, err error) { rv := reflect.ValueOf(fieldValue)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Mar 18 08:28:46 GMT 2024 - 4.6K bytes - Viewed (0)