- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 177 for dopts (0.02 seconds)
-
gorm.go
func Open(dialector Dialector, opts ...Option) (db *DB, err error) { config := &Config{} sort.Slice(opts, func(i, j int) bool { _, isConfig := opts[i].(*Config) _, isConfig2 := opts[j].(*Config) return isConfig && !isConfig2 }) if len(opts) > 0 { if c, ok := opts[0].(*Config); ok { config = c } else { opts = append([]Option{config}, opts...) } }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Tue Aug 26 06:24:29 GMT 2025 - 12.8K bytes - Click Count (0) -
cmd/object-api-multipart_test.go
func testObjectNewMultipartUpload(obj ObjectLayer, instanceType string, t TestErrHandler) { bucket := "minio-bucket" object := "minio-object" opts := ObjectOptions{} _, err := obj.NewMultipartUpload(context.Background(), "--", object, opts) if err == nil { t.Fatalf("%s: Expected to fail since bucket name is invalid.", instanceType) } errMsg := "Bucket not found: minio-bucket"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 89.4K bytes - Click Count (0) -
cmd/object-handlers-common.go
writeHeaders() writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL) return true } } etagMatch := opts.PreserveETag != "" && isETagEqual(objInfo.ETag, opts.PreserveETag) vidMatch := opts.VersionID != "" && opts.VersionID == objInfo.VersionID if etagMatch && vidMatch { writeHeaders() writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL) return true
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jul 23 12:36:06 GMT 2025 - 15.2K bytes - Click Count (0) -
cmd/object-api-getobjectinfo_test.go
if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } opts := ObjectOptions{} _, err = obj.PutObject(context.Background(), "test-getobjectinfo", "Asia/asiapics.jpg", mustGetPutObjReader(t, bytes.NewBufferString("asiapics"), int64(len("asiapics")), "", ""), opts) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } // Put an empty directoryCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 5.6K bytes - Click Count (0) -
cmd/healthcheck-handler.go
return } ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline()) defer cancel() opts := HealthOptions{ Maintenance: r.Form.Get("maintenance") == "true", DeploymentType: r.Form.Get("deployment-type"), } result := objLayer.Health(ctx, opts) w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jun 26 07:44:34 GMT 2024 - 6.9K bytes - Click Count (0) -
src/main/java/jcifs/smb1/netbios/NbtAddress.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 31.7K bytes - Click Count (0) -
src/main/java/jcifs/netbios/UniAddress.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 8.3K bytes - Click Count (0) -
docs/debugging/s3-check-md5/main.go
continue } var partsMD5Sum [][]byte var failedMD5 bool for p := 1; p <= parts; p++ { opts := minio.GetObjectOptions{ VersionID: object.VersionID, PartNumber: p, } obj, err := s3Client.GetObject(context.Background(), bucket, object.Key, opts) if err != nil { log.Println("FAILED: GET", objFullPath(object), "=>", err) failedMD5 = true break }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.3K bytes - Click Count (0) -
cmd/encryption-v1_test.go
for i, test := range getDefaultOptsTests { opts, err := getDefaultOpts(test.headers, test.copySource, test.metadata) if test.err != err { t.Errorf("Case %d: expected err: %v , actual err: %v", i, test.err, err) } if err == nil { if opts.ServerSideEncryption == nil && test.encryptionType != "" { t.Errorf("Case %d: expected opts to be of %v encryption type", i, test.encryptionType) }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.9K bytes - Click Count (0) -
internal/cachevalue/cache_test.go
select { case <-sl.C: case <-ctx.Done(): return ctx.Err() } return nil } func TestCacheCtx(t *testing.T) { cache := New[time.Time]() t.Parallel() cache.InitOnce(2*time.Second, Opts{}, func(ctx context.Context) (time.Time, error) { return time.Now(), slowCaller(ctx) }, ) ctx, cancel := context.WithCancel(t.Context()) cancel() // cancel context to test.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 2.7K bytes - Click Count (0)