Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for elements (0.18 sec)

  1. cmd/metacache-bucket_test.go

    	bm := newBucketMetacache("", false)
    	const elements = 50000
    	const paths = 100
    	if elements%paths != 0 {
    		b.Fatal("elements must be divisible by the number of paths")
    	}
    	var pathNames [paths]string
    	for i := range pathNames[:] {
    		pathNames[i] = fmt.Sprintf("prefix/%d", i)
    	}
    	for i := 0; i < elements; i++ {
    		bm.findCache(listPathOptions{
    			ID:           mustGetUUID(),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 25 23:29:45 GMT 2022
    - 1.8K bytes
    - Viewed (0)
  2. internal/event/config.go

    }
    
    // common - represents common elements inside <QueueConfiguration>, <CloudFunctionConfiguration>
    // and <TopicConfiguration>
    type common struct {
    	ID     string `xml:"Id" json:"Id"`
    	Filter S3Key  `xml:"Filter" json:"Filter"`
    	Events []Name `xml:"Event" json:"Event"`
    }
    
    // Queue - represents elements inside <QueueConfiguration>
    type Queue struct {
    	common
    	ARN ARN `xml:"Queue"`
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 16 17:28:29 GMT 2021
    - 8.4K bytes
    - Viewed (0)
  3. internal/lock/lock_windows.go

    	// The extended form disables evaluation of . and .. path
    	// elements and disables the interpretation of / as equivalent
    	// to \. The conversion here rewrites / to \ and elides
    	// . elements as well as trailing or duplicate separators. For
    	// simplicity it avoids the conversion entirely for relative
    	// paths or paths containing .. elements. For now,
    	// \\server\share paths are not converted to
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  4. internal/handlers/proxy.go

    		scheme = strings.ToLower(proto)
    	} else if proto := r.Header.Get(forwarded); proto != "" {
    		// match should contain at least two elements if the protocol was
    		// specified in the Forwarded header. The first element will always be
    		// the 'for=', which we ignore, subsequently we proceed to look for
    		// 'proto=' which should precede right after `for=` if not
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  5. internal/s3select/simdj/record.go

    	}
    	dst.Reset()
    	elems, err := r.object.Parse(nil)
    	if err != nil {
    		return nil, err
    	}
    	if cap(dst.KVS) < len(elems.Elements) {
    		dst.KVS = make(jstream.KVS, 0, len(elems.Elements))
    	}
    	for _, elem := range elems.Elements {
    		v, err := sql.IterToValue(elem.Iter)
    		if err != nil {
    			v, err = elem.Iter.Interface()
    			if err != nil {
    				panic(err)
    			}
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  6. internal/s3select/select.go

    	default:
    		return errInvalidCompressionFormat(fmt.Errorf("invalid compression format '%v'", s))
    	}
    
    	*c = parsedType
    	return nil
    }
    
    // InputSerialization - represents elements inside <InputSerialization/> in request XML.
    type InputSerialization struct {
    	CompressionType CompressionType    `xml:"CompressionType"`
    	CSVArgs         csv.ReaderArgs     `xml:"CSV"`
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  7. cmd/signature-v4-parser.go

    		if _, ok := query[v4PresignQueryParam]; !ok {
    			return ErrInvalidQueryParams
    		}
    	}
    	return ErrNone
    }
    
    // Parses all the presigned signature values into separate elements.
    func parsePreSignV4(query url.Values, region string, stype serviceType) (psv preSignValues, aec APIErrorCode) {
    	// verify whether the required query params exist.
    	aec = doesV4PresignParamsExist(query)
    	if aec != ErrNone {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  8. internal/s3select/sql/evaluate.go

    }
    
    func (e *ListExpr) evalNode(r Record, tableAlias string) (*Value, error) {
    	res := make([]Value, len(e.Elements))
    	if len(e.Elements) == 1 {
    		// If length 1, treat as single value.
    		return e.Elements[0].evalNode(r, tableAlias)
    	}
    	for i, elt := range e.Elements {
    		v, err := elt.evalNode(r, tableAlias)
    		if err != nil {
    			return nil, err
    		}
    		res[i] = *v
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  9. internal/s3select/select_test.go

    			wantResult: `{"_1":1.5,"_2":2.5}`,
    		},
    		{
    			name:  "limit-1",
    			query: `SELECT * FROM S3Object[*].elements[*] LIMIT 1`,
    			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>
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  10. cmd/handler-utils.go

    		m["range"] = rangeField
    	}
    
    	if _, ok := r.Header[xhttp.MinIOSourceReplicationRequest]; ok {
    		m[xhttp.MinIOSourceReplicationRequest] = ""
    	}
    	return m
    }
    
    // Extract response elements to be sent with event notification.
    func extractRespElements(w http.ResponseWriter) map[string]string {
    	if w == nil {
    		return map[string]string{}
    	}
    	return map[string]string{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
Back to top