- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 317 for opts (0.02 sec)
-
cmd/update.go
return errors.New("update already in progress") } defer updateInProgress.Store(0) transport := getUpdateTransport(30 * time.Second) opts := selfupdate.Options{ Hash: crypto.SHA256, Checksum: sha256Sum, } if err := opts.CheckPermissions(); err != nil { return AdminError{ Code: AdminUpdateApplyFailure,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
cmd/notification.go
if report == nil || report.BucketStats == nil { continue } for opts := range report.BucketStats { d, ok := consolidatedReport.BucketStats[opts] if !ok { d = bandwidth.Details{ LimitInBytesPerSecond: report.BucketStats[opts].LimitInBytesPerSecond, } } dt, ok := report.BucketStats[opts] if ok { d.CurrentBandwidthInBytesPerSecond += dt.CurrentBandwidthInBytesPerSecond
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
type promLogger struct{} func (p promLogger) Println(v ...interface{}) { metricsLogIf(GlobalContext, fmt.Errorf("metrics handler error: %v", v)) } type metricsV3Server struct { registry *prometheus.Registry opts promhttp.HandlerOpts auth func(http.Handler) http.Handler metricsData *metricsV3Collection } var ( globalMetricsV3CollectorPaths []collectorPath globalMetricsV3Once sync.Once )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 15 16:28:02 UTC 2024 - 7.8K bytes - Viewed (0) -
finisher_api.go
return } // Begin begins a transaction with any transaction options opts func (db *DB) Begin(opts ...*sql.TxOptions) *DB { var ( // clone statement tx = db.getInstance().Session(&Session{Context: db.Statement.Context, NewDB: db.clone == 1}) opt *sql.TxOptions err error ) if len(opts) > 0 { opt = opts[0] } switch beginner := tx.Statement.ConnPool.(type) { case TxBeginner:
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Sat Sep 14 12:58:29 UTC 2024 - 22.8K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
bwRpt := globalNotificationSys.GetBandwidthReports(ctx, bucket) bwMap := bwRpt.BucketStats for arn, st := range stats.ReplicationStats.Stats { for opts, bw := range bwMap { if opts.ReplicationARN != "" && opts.ReplicationARN == arn { st.BandWidthLimitInBytesPerSecond = bw.LimitInBytesPerSecond st.CurrentBandwidthInBytesPerSecond = bw.CurrentBandwidthInBytesPerSecond
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/admin-handlers-users.go
Type: madmin.SRIAMItemSvcAcc, SvcAccChange: &madmin.SRSvcAccChange{ Update: &madmin.SRSvcAccUpdate{ AccessKey: accessKey, SecretKey: opts.secretKey, Status: opts.status, Name: opts.name, Description: opts.description, SessionPolicy: updateReq.NewPolicy, Expiration: updateReq.NewExpiration, }, }, UpdatedAt: updatedAt, })) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 03 23:11:02 UTC 2024 - 85.1K bytes - Viewed (0) -
cmd/tier.go
return nil, nil, err } pReader, err := NewPutObjReader(hr).WithEncryption(encHr, &oek) if err != nil { return nil, nil, err } opts := &ObjectOptions{ UserDefined: metadata, MTime: UTCNow(), MaxParity: true, } return pReader, opts, nil } // Reload updates config by reloading remote tier config from config store.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K 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)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
func WithRealm(realm string) Option { return func(p *KeycloakProvider) { p.realm = realm } } // KeyCloak initializes a new keycloak provider func KeyCloak(opts ...Option) (Provider, error) { p := &KeycloakProvider{} for _, opt := range opts { opt(p) } if p.adminURL == "" { return nil, errors.New("Admin URL cannot be empty") } _, err := url.Parse(p.adminURL) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jul 14 18:12:07 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/os_unix.go
return nil } } return err } // Return count entries at the directory dirPath and all entries // if count is set to -1 func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) { fd, err := openFileWithFD(dirPath, readMode, 0o666) if err != nil { if !osIsPermission(err) { return nil, osErrToFileErr(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.3K bytes - Viewed (0)