Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 317 for opts (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top