Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 183 for dopts (0.03 sec)

  1. docs/sts/client-grants.go

    	// Uncomment this to use MinIO API operations by initializing minio
    	// client with obtained credentials.
    
    	opts := &minio.Options{
    		Creds:        sts,
    		BucketLookup: minio.BucketLookupAuto,
    	}
    
    	u, err := url.Parse(stsEndpoint)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	clnt, err := minio.New(u.Host, opts)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	d := bytes.NewReader([]byte("Hello, World"))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 3.3K 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_test_util.cc

      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      opts->session_options.options.config.set_isolate_session_state(
          isolate_session_state);
      TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(false));
      TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT);
      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  4. cmd/iam.go

    	}
    	if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 {
    		return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey
    	}
    
    	var policyBuf []byte
    	if opts.sessionPolicy != nil {
    		err := opts.sessionPolicy.Validate()
    		if err != nil {
    			return auth.Credentials{}, time.Time{}, err
    		}
    		policyBuf, err = json.Marshal(opts.sessionPolicy)
    		if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  5. cmd/warm-backend-minio.go

    		return nil, err
    	}
    
    	creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "")
    	opts := &minio.Options{
    		Creds:           creds,
    		Secure:          u.Scheme == "https",
    		Transport:       globalRemoteTargetTransport,
    		TrailingHeaders: true,
    	}
    	client, err := minio.New(u.Host, opts)
    	if err != nil {
    		return nil, err
    	}
    	client.SetAppInfo(fmt.Sprintf("minio-tier-%s", tier), ReleaseTag)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 7.8K 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    	}
    
    	return true
    }
    
    func extractTraceOptions(r *http.Request) (opts madmin.ServiceTraceOpts, err error) {
    	if err := opts.ParseParams(r); err != nil {
    		return opts, err
    	}
    	// Support deprecated 'all' query
    	if r.Form.Get("all") == "true" {
    		opts.S3 = true
    		opts.Internal = true
    		opts.Storage = true
    		opts.OS = true
    		// Older mc - cannot deal with more types...
    	}
    	return
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  9. cmd/iam-store.go

    			return updatedAt, auth.ErrInvalidSecretKeyLength
    		}
    		cr.SecretKey = opts.secretKey
    	}
    
    	if opts.name != "" {
    		cr.Name = opts.name
    	}
    
    	if opts.description != "" {
    		cr.Description = opts.description
    	}
    
    	if opts.expiration != nil {
    		expirationInUTC := opts.expiration.UTC()
    		if err := validateSvcExpirationInUTC(expirationInUTC); err != nil {
    			return updatedAt, err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  10. internal/http/server.go

    func (srv *Server) UseCustomLogger(l *log.Logger) *Server {
    	srv.ErrorLog = l
    	return srv
    }
    
    // UseTCPOptions use custom TCP options on raw socket
    func (srv *Server) UseTCPOptions(opts TCPOptions) *Server {
    	srv.TCPOptions = opts
    	return srv
    }
    
    // NewServer - creates new HTTP server using given arguments.
    func NewServer(addrs []string) *Server {
    	httpServer := &Server{
    		Addrs: addrs,
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top