- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 81 for hasPrefix (0.15 sec)
-
cmd/metacache-server-pool.go
if o.Marker < o.Prefix { o.Marker = "" } // Marker is set validate pre-condition. if o.Marker != "" && o.Prefix != "" { // Marker not common with prefix is not implemented. Send an empty response if !HasPrefix(o.Marker, o.Prefix) { return entries, io.EOF } } // With max keys of zero we have reached eof, return right here. if o.Limit == 0 { return entries, io.EOF }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12.9K bytes - Viewed (0) -
cmd/http-tracer.go
reqEndTime := time.Now().UTC() if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 { // no subscribers nothing to trace. return } tt := madmin.TraceInternal if strings.HasPrefix(tc.FuncName, "s3.") { tt = madmin.TraceS3 } // Calculate input body size with headers reqHeaders := r.Header.Clone() reqHeaders.Set("Host", r.Host) if len(r.TransferEncoding) == 0 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0) -
internal/s3select/sql/value.go
return nil } if x, ok := v.bytesToBool(); ok { v.setBool(x) return nil } asString := strings.TrimSpace(v.bytesToString()) if len(b) > 0 && (strings.HasPrefix(asString, "{") || strings.HasPrefix(asString, "[")) { return nil } if t, err := parseSQLTimestamp(asString); err == nil { v.setTimestamp(t) return nil } if !utf8.Valid(b) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 20.4K bytes - Viewed (0) -
internal/grid/connection.go
c.incomingBytes = func(n int64) { if o.incomingBytes != nil { o.incomingBytes(n) } c.inBytes.Add(n) } if !strings.HasPrefix(o.remote, "https://") && !strings.HasPrefix(o.remote, "wss://") { c.baseFlags |= FlagCRCxxh3 } if !strings.HasPrefix(o.local, "https://") && !strings.HasPrefix(o.local, "wss://") { c.baseFlags |= FlagCRCxxh3 } if o.publisher != nil { c.traceRequests(o.publisher) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 46.9K bytes - Viewed (0) -
callbacks/associations.go
refName = rel.Name + "." values = rValues.Interface() ) for name, ok := range selectColumns { columnName := "" if strings.HasPrefix(name, refName) { columnName = strings.TrimPrefix(name, refName) } if columnName != "" { if ok { selects = append(selects, columnName) } else { omits = append(omits, columnName)
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Thu Feb 13 06:16:26 UTC 2025 - 14.4K bytes - Viewed (0) -
cmd/os_unix.go
// directories that MkdirAll creates. // If path is already a directory, MkdirAll does nothing // and returns nil. func osMkdirAll(dirPath string, perm os.FileMode, baseDir string) error { if baseDir != "" { if strings.HasPrefix(baseDir, dirPath) { return nil } } // Slow path: make sure parent exists and then call Mkdir for path. i := len(dirPath) for i > 0 && os.IsPathSeparator(dirPath[i-1]) { // Skip trailing path separator.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 9.3K bytes - Viewed (0) -
internal/http/listener_test.go
localIP4.Add(ip.String()) } } // Filter ipList by IPs those do not start with '127.'. nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool { return !strings.HasPrefix(ip, "127.") }, "") if len(nonLoopBackIPs) == 0 { t.Fatalf("No non-loop back IP address found for this host") } nonLoopBackIP := nonLoopBackIPs.ToSlice()[0] return nonLoopBackIP }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
if !strings.EqualFold(encodingType, "url") { return ErrInvalidEncodingMethod } } if !IsValidObjectPrefix(prefix) { return ErrInvalidObjectName } if marker != "" && !HasPrefix(marker, prefix) { return ErrNotImplemented } return ErrNone } func (api objectAPIHandlers) ListObjectVersionsHandler(w http.ResponseWriter, r *http.Request) { api.listObjectVersionsHandler(w, r, false)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 11.6K bytes - Viewed (0) -
cmd/common-main.go
func parsEnvEntry(envEntry string) (envKV, error) { envEntry = strings.TrimSpace(envEntry) if envEntry == "" { // Skip all empty lines return envKV{ Skip: true, }, nil } if strings.HasPrefix(envEntry, "#") { // Skip commented lines return envKV{ Skip: true, }, nil } envTokens := strings.SplitN(strings.TrimSpace(strings.TrimPrefix(envEntry, "export")), config.EnvSeparator, 2)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
cmd/metrics-v3.go
metricsCache := newMetricsCache() mgMap := make(map[collectorPath]*MetricsGroup) bucketMGMap := make(map[collectorPath]*MetricsGroup) for _, mg := range allMetricGroups { if !strings.HasPrefix(string(mg.CollectorPath), clusterBasePath) { mg.AddExtraLabels( serverName, globalLocalNodeName, // poolIndex, strconv.Itoa(globalLocalPoolIdx), ) } mg.SetCache(metricsCache)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 02 00:55:27 UTC 2024 - 13.6K bytes - Viewed (0)