- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ParseBool (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)