Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for elems (0.12 sec)

  1. internal/s3select/sql/evaluate.go

    			if err != nil {
    				return nil, err
    			}
    			dst[i] = *v
    		}
    		return FromArray(dst), nil
    	case simdjson.Object:
    		o := rval
    		elems, err := o.Parse(nil)
    		if err != nil {
    			return nil, err
    		}
    		bs, err := elems.MarshalJSON()
    		if err != nil {
    			return nil, err
    		}
    		return FromBytes(bs), nil
    	case []Value:
    		return FromArray(rval), nil
    	case nil:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  2. internal/s3select/sql/jsonpath.go

    				}
    			}
    			// Key not found - return nil result
    			return Missing{}, false, nil
    		case simdjson.Object:
    			elem := kvs.FindKey(key, nil)
    			if elem == nil {
    				// Key not found - return nil result
    				return Missing{}, false, nil
    			}
    			val, err := IterToValue(elem.Iter)
    			if err != nil {
    				return nil, false, err
    			}
    			return jsonpathEval(p[1:], val)
    		default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    	}()
    
    	return pathJoinBuf(sb, elem...)
    }
    
    // pathJoinBuf - like path.Join() but retains trailing SlashSeparator of the last element.
    // Provide a string builder to reduce allocation.
    func pathJoinBuf(dst *bytebufferpool.ByteBuffer, elem ...string) string {
    	trailingSlash := len(elem) > 0 && hasSuffixByte(elem[len(elem)-1], SlashSeparatorChar)
    	dst.Reset()
    	added := 0
    	for _, e := range elem {
    		if added > 0 || e != "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  4. internal/s3select/select_test.go

    		{
    			name:  "document",
    			query: "",
    			requestXML: []byte(`
    <?xml version="1.0" encoding="UTF-8"?>
    <SelectObjectContentRequest>
        <Expression>select * from s3object[*].elements[*] s where s.element_type = '__elem__merfu'</Expression>
        <ExpressionType>SQL</ExpressionType>
        <InputSerialization>
            <CompressionType>NONE</CompressionType>
            <JSON>
                <Type>DOCUMENT</Type>
            </JSON>
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  5. cmd/last-minute.go

    }
    
    // Merge all recorded latencies of last minute into one
    func (l *lastMinuteLatency) getTotal() AccElem {
    	var res AccElem
    	sec := time.Now().Unix()
    	l.forwardTo(sec)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    	return res
    }
    
    // forwardTo time t, clearing any entries in between.
    func (l *lastMinuteLatency) forwardTo(t int64) {
    	if l.LastSec >= t {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jul 05 17:40:45 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  6. cmd/object-api-utils_test.go

    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/pkg/v2/trie"
    )
    
    func pathJoinOld(elem ...string) string {
    	trailingSlash := ""
    	if len(elem) > 0 {
    		if hasSuffixByte(elem[len(elem)-1], SlashSeparatorChar) {
    			trailingSlash = SlashSeparator
    		}
    	}
    	return path.Join(elem...) + trailingSlash
    }
    
    func BenchmarkPathJoinOld(b *testing.B) {
    	b.Run("PathJoin", func(b *testing.B) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 23.4K bytes
    - Viewed (0)
  7. cmd/bucket-stats.go

    }
    
    // Merge all recorded counts of last hour into one
    func (l *ReplicationLastHour) getTotal() AccElem {
    	var res AccElem
    	min := time.Now().Unix() / 60
    	l.forwardTo(min)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    	return res
    }
    
    // forwardTo time t, clearing any entries in between.
    func (l *ReplicationLastHour) forwardTo(t int64) {
    	tMin := t / 60
    	if l.LastMin >= tMin {
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 13.1K bytes
    - Viewed (0)
Back to top