- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 118 for vnopts (0.24 sec)
-
cmd/warm-backend-s3.go
} func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) { gopts := minio.GetObjectOptions{} if rv != "" { gopts.VersionID = string(rv) } if opts.startOffset >= 0 && opts.length > 0 { if err := gopts.SetRange(opts.startOffset, opts.startOffset+opts.length-1); err != nil { return nil, s3.ToObjectError(err, object) } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/config/batch/batch.go
ReplicationWorkersWait: opts.ReplicationWorkersWait, KeyRotationWorkersWait: opts.KeyRotationWorkersWait, ExpirationWorkersWait: opts.ExpirationWorkersWait, } } // Update updates opts with nopts func (opts *Config) Update(nopts Config) { configMu.Lock() defer configMu.Unlock() opts.ReplicationWorkersWait = nopts.ReplicationWorkersWait opts.KeyRotationWorkersWait = nopts.KeyRotationWorkersWait
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Dec 06 09:09:22 GMT 2023 - 4.7K bytes - Viewed (0) -
internal/config/heal/heal.go
func (opts Config) GetWorkers() int { configMutex.RLock() defer configMutex.RUnlock() return opts.DriveWorkers } // Update updates opts with nopts func (opts *Config) Update(nopts Config) { configMutex.Lock() defer configMutex.Unlock() opts.Bitrot = nopts.Bitrot opts.IOCount = nopts.IOCount opts.Sleep = nopts.Sleep opts.DriveWorkers = nopts.DriveWorkers
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
tclnt.TraceOn(os.Stderr) } sopts := minio.ListObjectsOptions{ Recursive: true, Prefix: sourcePrefix, } topts := minio.ListObjectsOptions{ Recursive: true, Prefix: targetPrefix, } srcCh := sclnt.ListObjects(context.Background(), sourceBucket, sopts) tgtCh := tclnt.ListObjects(context.Background(), targetBucket, topts) srcCtnt, srcOk := nextObject(srcCh)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
cmd/speedtest.go
return default: } sopts := speedTestOpts{ objectSize: opts.objectSize, concurrency: concurrency, duration: opts.duration, storageClass: opts.storageClass, bucketName: opts.bucketName, enableSha256: opts.enableSha256, } results := globalNotificationSys.SpeedTest(ctx, sopts) sort.Slice(results, func(i, j int) bool {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
build-logic/build-update-utils/src/main/kotlin/gradlebuild.wrapper.gradle.kts
tasks.withType<Wrapper>().configureEach { val jvmOpts = "-Dfile.encoding=UTF-8" inputs.property("jvmOpts", jvmOpts) doLast { val optsEnvVar = "DEFAULT_JVM_OPTS" scriptFile.writeText(scriptFile.readText().replace("$optsEnvVar='", "$optsEnvVar='$jvmOpts ")) batchScript.writeText(batchScript.readText().replace("set $optsEnvVar=", "set $optsEnvVar=$jvmOpts ")) } }
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 1.4K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
for k, v := range req.UserMetadata { userDefined[k] = v } userDefined[xhttp.AmzObjectTagging] = s3utils.TagEncode(req.UserTags) if opts.Kind != nil { encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx) if err != nil { errs[idx] = err return } // do not try to verify encrypted content/
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 3.5K bytes - Viewed (0) -
docs/sts/custom-token-identity.go
// The credentials package in minio-go provides an interface to call the // AssumeRoleWithCustomToken STS API. var opts []cr.CustomTokenOpt if expiryDuration != 0 { opts = append(opts, cr.CustomTokenValidityOpt(expiryDuration)) } // Initialize li, err := cr.NewCustomTokenCredentials(stsEndpoint, token, roleArn, opts...) if err != nil { log.Fatalf("Error initializing CustomToken Identity: %v", err) } v, err := li.Get()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 3.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
route.Name = fmt.Sprintf("route/%s", route.Name) } if filter.Verbose { for _, vhosts := range route.GetVirtualHosts() { for _, r := range vhosts.Routes { if !isPassthrough(r.GetAction()) { fmt.Fprintf(w, "%v\t%s\t%s\t%s\t%s\n", route.Name, vhosts.Name, describeRouteDomains(vhosts.GetDomains()), describeMatch(r.GetMatch()), describeManagement(r.GetMetadata()))
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 7.2K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/BUILD
) # The real implementation of the filesystem. cc_library( name = "gcs_filesystem_impl", srcs = ["gcs_filesystem.cc"], hdrs = ["gcs_filesystem.h"], copts = select({ "//conditions:default": [], "//tensorflow:windows": get_win_copts(), }), deps = [ ":expiring_lru_cache", ":gcs_helper", ":ram_file_block_cache", "//tensorflow/c:env",
Plain Text - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 3.4K bytes - Viewed (0)