- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for plit (0.18 sec)
-
docs/debugging/xl-meta/main.go
if err != nil { return err } split, err := rs.Split(mapped) if err != nil { return err } splitFilled, err := rs.Split(filled) if err != nil { return err } ok := len(splitFilled) for i, sh := range splitFilled { for _, v := range sh { if v == 0 { split[i] = nil ok-- break } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/metrics.go
float64(v), string(k), ) } for k, v := range bgSeq.getHealFailedItemsMap() { // healFailedItemsMap stores the endpoint and volume state separated by comma, // split the fields and pass to channel at correct index s := strings.Split(k, ",") ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "objects", "heal_failed"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/config/etcd/etcd.go
cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix) return cli, nil } func parseEndpoints(endpoints string) ([]string, bool, error) { etcdEndpoints := strings.Split(endpoints, config.ValueSeparator) var etcdSecure bool for _, endpoint := range etcdEndpoints { u, err := xnet.ParseHTTPURL(endpoint) if err != nil { return nil, false, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.7K bytes - Viewed (0) -
internal/logger/console.go
// message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit. break } for { // Save the attributes of the current cursor helps
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/logger/targets.go
if l.Enabled { t := kafka.New(l) tgts = append(tgts, t) e := t.Init(ctx) if e != nil { errs = append(errs, e) } } } return tgts, errs } // Split targets into two groups: // // group1 contains all targets of type t // group2 contains the remaining targets func splitTargets(targets []Target, t types.TargetType) (group1 []Target, group2 []Target) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
mountInfo, err := os.Open("/proc/self/mountinfo") if err != nil { return nil, err } defer mountInfo.Close() scanner := bufio.NewScanner(mountInfo) for scanner.Scan() { s := strings.Split(scanner.Text(), " ") if len(s) != 11 { return nil, errors.New("unsupported /proc/self/mountinfo format") } result[s[2]] = s[9] } if err := scanner.Err(); err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
log.Println("SKIPPED: encrypted with SSE-KMS do not have md5sum as ETag:", objFullPath(object)) continue } parts := 1 multipart := false s := strings.Split(object.ETag, "-") switch len(s) { case 1: // nothing to do case 2: if p, err := strconv.Atoi(s[1]); err == nil { parts = p } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/update.go
} // releaseTagToReleaseTime - reverse of `releaseTimeToReleaseTag()` func releaseTagToReleaseTime(releaseTag string) (releaseTime time.Time, err error) { fields := strings.Split(releaseTag, ".") if len(fields) < 2 || len(fields) > 4 { return releaseTime, fmt.Errorf("%s is not a valid release tag", releaseTag) } if fields[0] != "RELEASE" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/logger/config.go
var brokers []xnet.Host kafkaBrokers := getCfgVal(EnvKafkaBrokers, k, kv.Get(KafkaBrokers)) if len(kafkaBrokers) == 0 { return cfg, config.Errorf("kafka 'brokers' cannot be empty") } for _, s := range strings.Split(kafkaBrokers, config.ValueSeparator) { var host *xnet.Host host, err = xnet.ParseHost(s) if err != nil { break } brokers = append(brokers, *host) } if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0)