Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 236 for dopts (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. internal/bucket/encryption/bucket-sse-config.go

    // set minimal SSE-KMS headers if autoEncrypt is true and the BucketSSEConfig
    // is nil.
    func (b *BucketSSEConfig) Apply(headers http.Header, opts ApplyOptions) {
    	if crypto.Requested(headers) {
    		return
    	}
    	if b == nil {
    		if opts.AutoEncrypt {
    			headers.Set(xhttp.AmzServerSideEncryption, xhttp.AmzEncryptionKMS)
    		}
    		return
    	}
    
    	switch b.Algo() {
    	case xhttp.AmzEncryptionAES:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net_test.go

    	"istio.io/istio/pkg/test/util/assert"
    	"istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    func setupLogging() {
    	opts := istiolog.DefaultOptions()
    	opts.SetDefaultOutputLevel(istiolog.OverrideScopeName, istiolog.DebugLevel)
    	istiolog.Configure(opts)
    	for _, scope := range istiolog.Scopes() {
    		scope.SetOutputLevel(istiolog.DebugLevel)
    	}
    }
    
    type netTestFixture struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. cmd/admin-heal-ops.go

    	// Send heal request
    	task := healTask{
    		bucket:    source.bucket,
    		object:    source.object,
    		versionID: source.versionID,
    		opts:      h.settings,
    	}
    	if source.opts != nil {
    		task.opts = *source.opts
    	} else {
    		task.opts.ScanMode = madmin.HealNormalScan
    	}
    
    	h.countScanned(healType)
    
    	if source.noWait {
    		select {
    		case globalBackgroundHealRoutine.tasks <- task:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  8. 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)
  9. tensorflow/c/eager/c_api.cc

          opts->session_options.options,
          static_cast<tensorflow::ContextDevicePlacementPolicy>(
              opts->device_placement_policy),
          opts->async, device_mgr.release(),
          /*device_mgr_owned*/ true, std::move(r),
          /*cluster_flr=*/nullptr,
          /*collective_executor_mgr=*/nullptr,
          /*run_eager_op_as_function=*/opts->run_eager_op_as_function,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  10. istioctl/pkg/kubeinject/kubeinject.go

    	defaultInjectWebhookConfigName = "istio-sidecar-injector"
    	defaultWebhookName             = "sidecar-injector.istio.io"
    )
    
    func InjectCommand(cliContext cli.Context) *cobra.Command {
    	var opts clioptions.ControlPlaneOptions
    	var centralOpts clioptions.CentralControlPlaneOptions
    
    	injectCmd := &cobra.Command{
    		Use:   "kube-inject",
    		Short: "Inject Istio sidecar into Kubernetes pod resources",
    		Long: `
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
Back to top