Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for siad (0.13 sec)

  1. internal/s3select/simdj/record.go

    	}
    	return nil
    }
    
    // Replace the underlying buffer of json data.
    func (r *Record) Replace(k interface{}) error {
    	v, ok := k.(simdjson.Object)
    	if !ok {
    		return fmt.Errorf("cannot replace internal data in simd json record with type %T", k)
    	}
    	r.object = v
    	return nil
    }
    
    // NewRecord - creates new empty JSON record.
    func NewRecord(f sql.SelectObjectFormat, obj simdjson.Object) *Record {
    	return &Record{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    		}
    		buf.WriteString(s3Select.Output.CSVArgs.RecordDelimiter)
    
    		return nil
    	case jsonFormat:
    		err := record.WriteJSON(buf)
    		if err != nil {
    			return err
    		}
    		// Trim trailing newline from non-simd output
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    		buf.WriteString(s3Select.Output.JSONArgs.RecordDelimiter)
    
    		return nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  3. internal/s3select/sql/record.go

    const (
    	// SelectFmtUnknown - unknown format (default value)
    	SelectFmtUnknown SelectObjectFormat = iota
    	// SelectFmtCSV - CSV format
    	SelectFmtCSV
    	// SelectFmtJSON - JSON format
    	SelectFmtJSON
    	// SelectFmtSIMDJSON - SIMD JSON format
    	SelectFmtSIMDJSON
    	// SelectFmtParquet - Parquet format
    	SelectFmtParquet
    )
    
    // WriteCSVOpts - encapsulates options for Select CSV output
    type WriteCSVOpts struct {
    	FieldDelimiter rune
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.4K bytes
    - Viewed (0)
  4. cmd/api-response.go

    			continue
    		}
    	}
    
    	for _, k := range toRemove {
    		delete(m, k)
    		delete(m, strings.ToLower(k))
    	}
    
    	return m
    }
    
    // generates an ListBucketVersions response for the said bucket with other enumerated options.
    func generateListVersionsResponse(bucket, prefix, marker, versionIDMarker, delimiter, encodingType string, maxKeys int, resp ListObjectVersionsInfo, metadata metaCheckFn) ListVersionsResponse {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  5. internal/s3select/select_test.go

    			if !reflect.DeepEqual(gotS, testCase.wantResult) {
    				t.Errorf("received response does not match with expected reply. Query: %s\ngot: %s\nwant:%s", testCase.query, gotS, testCase.wantResult)
    			}
    		})
    		t.Run("simd-"+testCase.name, func(t *testing.T) {
    			if !simdjson.SupportedCPU() {
    				t.Skip("No CPU support")
    			}
    			testReq := testCase.requestXML
    			if len(testReq) == 0 {
    				var escaped bytes.Buffer
    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)
  6. cmd/bucket-policy-handlers_test.go

    	bucketPolicyTemplate := `{"Version":"2012-10-17","Statement":[{"Sid":"","Effect":"Allow","Principal":{"AWS":["*"]},"Action":["s3:GetBucketLocation","s3:ListBucket"],"Resource":["arn:aws:s3:::%s"]},{"Sid":"","Effect":"Allow","Principal":{"AWS":["*"]},"Action":["s3:GetObject"],"Resource":["arn:aws:s3:::%s/this*"]}]}`
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 32.7K bytes
    - Viewed (0)
  7. internal/hash/sha256/sh256_nofips.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    //go:build !fips
    // +build !fips
    
    package sha256
    
    import (
    	"hash"
    
    	nofipssha256 "github.com/minio/sha256-simd"
    )
    
    // New returns a new hash.Hash computing the SHA256 checksum.
    // The SHA256 implementation is not FIPS 140-2 compliant.
    func New() hash.Hash { return nofipssha256.New() }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Aug 29 23:57:16 GMT 2022
    - 1.2K bytes
    - Viewed (0)
  8. cmd/bucket-handlers_test.go

    	// to test a mixed response of a successful & failure while deleting objects in a single request
    	policyBytes := []byte(fmt.Sprintf(`{"Id": "Policy1637752602639", "Version": "2012-10-17", "Statement": [{"Sid": "Stmt1637752600730", "Action": "s3:DeleteObject", "Effect": "Allow", "Resource": "arn:aws:s3:::%s/public/*", "Principal": "*"}]}`, bucketName))
    	rec := httptest.NewRecorder()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 39.5K bytes
    - Viewed (2)
Back to top