Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ParseBool (0.06 sec)

  1. internal/logger/config.go

    	for k, kv := range config.Merge(scfg[config.AuditKafkaSubSys], EnvKafkaEnable, DefaultAuditKafkaKVS) {
    		enabledCfgVal := getCfgVal(EnvKafkaEnable, k, kv.Get(config.Enable))
    		enabled, err := config.ParseBool(enabledCfgVal)
    		if err != nil {
    			return cfg, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		kafkaBrokers := getCfgVal(EnvKafkaBrokers, k, kv.Get(KafkaBrokers))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    		enableEnv := target.EnvKafkaEnable
    		if k != config.Default {
    			enableEnv = enableEnv + config.Default + k
    		}
    		enabled, err := config.ParseBool(env.Get(enableEnv, kv.Get(config.Enable)))
    		if err != nil {
    			return nil, err
    		}
    		if !enabled {
    			continue
    		}
    		var brokers []xnet.Host
    		brokersEnv := target.EnvKafkaBrokers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  3. cmd/tier-handlers.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	var ignoreInUse bool
    	if forceStr := r.Form.Get("force"); forceStr != "" {
    		ignoreInUse, _ = strconv.ParseBool(forceStr)
    	}
    
    	// Disallow remote tiers with internal storage class names
    	switch cfg.Name {
    	case storageclass.STANDARD, storageclass.RRS:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. cmd/common-main.go

    		}
    		for _, ekv := range ekvs {
    			os.Setenv(ekv.Key, ekv.Value)
    		}
    	}
    }
    
    func serverHandleEarlyEnvVars() {
    	var err error
    	globalBrowserEnabled, err = config.ParseBool(env.Get(config.EnvBrowser, config.EnableOn))
    	if err != nil {
    		logger.Fatal(config.ErrInvalidBrowserValue(err), "Invalid MINIO_BROWSER value in environment variable")
    	}
    }
    
    func serverHandleEnvVars() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	}
    
    	accessKey := mss.Get(peerRESTUser)
    	if accessKey == "" {
    		return np, grid.NewRemoteErr(errors.New("username is missing"))
    	}
    
    	temp, err := strconv.ParseBool(mss.Get(peerRESTUserTemp))
    	if err != nil {
    		return np, grid.NewRemoteErr(err)
    	}
    
    	userType := regUser
    	if temp {
    		userType = stsUser
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    	ingressMode := false
    	if a, f := pod.Annotations[annotation.AmbientBypassInboundCapture.Name]; f {
    		var err error
    		ingressMode, err = strconv.ParseBool(a)
    		if err != nil {
    			log.Warnf("annotation %v=%q found, but only '*' is supported", annotation.AmbientBypassInboundCapture.Name, a)
    		}
    	}
    
    	log.Debug("calling CreateInpodRules")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. internal/config/config.go

    	}
    	return nil
    }
    
    // LookupWorm - check if worm is enabled
    func LookupWorm() (bool, error) {
    	return ParseBool(env.Get(EnvWorm, EnableOff))
    }
    
    // Carries all the renamed sub-systems from their
    // previously known names
    var renamedSubsys = map[string]string{
    	CrawlerSubSys: ScannerSubSys,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    		return
    	}
    
    	forceDelete := false
    	if value := r.Header.Get(xhttp.MinIOForceDelete); value != "" {
    		var err error
    		forceDelete, err = strconv.ParseBool(value)
    		if err != nil {
    			apiErr := errorCodes.ToAPIErr(ErrInvalidRequest)
    			apiErr.Description = err.Error()
    			writeErrorResponse(ctx, w, apiErr, r.URL)
    			return
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
Back to top