- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 87 for vnopts (0.15 sec)
-
docs/sts/assume-role.go
if err != nil { log.Fatalf("Error initializing STS Identity: %v", err) } stsEndpointURL, err := url.Parse(stsEndpoint) if err != nil { log.Fatalf("Error parsing sts endpoint: %v", err) } opts := &minio.Options{ Creds: li, Secure: stsEndpointURL.Scheme == "https", } v, err := li.Get() if err != nil { log.Fatalf("Error retrieving STS credentials: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 16:09:55 GMT 2024 - 4K bytes - Viewed (1) -
cmd/bootstrap-peer-server.go
} if len(extra) > 0 { msg += fmt.Sprintf(`Extra environment values: %v. `, extra) } return errors.New(strings.TrimSpace(msg)) } var skipEnvs = map[string]struct{}{ "MINIO_OPTS": {}, "MINIO_CERT_PASSWD": {}, "MINIO_SERVER_DEBUG": {}, "MINIO_DSYNC_TRACE": {}, "MINIO_ROOT_USER": {}, "MINIO_ROOT_PASSWORD": {}, "MINIO_ACCESS_KEY": {}, "MINIO_SECRET_KEY": {},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/globals.go
MaxIdleConnsPerHost int SendBufSize, RecvBufSize int CrossDomainXML string // The layout of disks as interpreted Layout disksLayout } var ( // Global user opts context globalServerCtxt serverCtxt // Indicates if the running minio server is distributed setup. globalIsDistErasure = false // Indicates if the running minio server is an erasure-code backend.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/bucket-replication.go
if cfg == nil { return } opts := replication.ObjectOpts{ Name: object, SSEC: crypto.SSEC.IsEncrypted(mopts.meta), Replica: replStatus == replication.Replica, ExistingObject: mopts.isExistingObjectReplication(), } tagStr, ok := mopts.meta[xhttp.AmzObjectTagging] if ok { opts.UserTags = tagStr } tgtArns := cfg.FilterTargetArns(opts) for _, tgtArn := range tgtArns {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{CacheError: true}, func() (info DiskInfo, err error) { ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() nopts := DiskInfoOptions{DiskID: *client.diskID.Load(), Metrics: true} infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &nopts) if err != nil { return info, toStorageErr(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} gopts := WarmBackendGetOpts{} // get correct offsets for object if off >= 0 && length >= 0 { gopts.startOffset = off gopts.length = length } timeTierAction := auditTierActions(ctx, oi.TransitionedObject.Tier, length) reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts) if err != nil { return nil, err } closer := func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/peer-s3-client.go
ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error GetHost() string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
internal/logger/logrotate.go
return nil, fmt.Errorf("directory %v does not exist and could not be created: %w", opts.Directory, err) } if opts.FileNameFunc == nil { opts.FileNameFunc = defaultFilenameFunc } pr, pw := xioutil.WaitPipe() w := &Writer{ opts: opts, pw: pw, pr: pr, } if w.f == nil { if err := w.rotate(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/object-api-utils.go
// not all run!). func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions) ( fn ObjReaderFn, off, length int64, err error, ) { if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) { return nil, 0, 0, PreConditionFailed{} } if rs == nil && opts.PartNumber > 0 { rs = partNumberToRangeSpec(oi, opts.PartNumber) } _, isEncrypted := crypto.IsEncrypted(oi.UserDefined)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1)