Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 337 for tresat (0.17 sec)

  1. internal/s3select/parquet/reader.go

    		// binary arrays) - perhaps we need to check the annotation to
    		// ensure it's UTF8 encoded.
    		value = string(val)
    	case [12]byte:
    		// TODO: This is returned for the parquet INT96 type. We just
    		// treat it same as []byte (but AWS S3 treats it as a large int)
    		// - fix this later.
    		value = string(val[:])
    	case int32:
    		value = int64(val)
    		if logicalType := se.GetLogicalType(); logicalType != nil {
    			if logicalType.IsSetDATE() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  2. cmd/batch-rotate_gen_test.go

    		t.Log("WARNING: TestEncodeDecodeBatchJobKeyRotateEncryption Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobKeyRotateEncryption{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 29 18:27:23 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_gen_test.go

    		t.Log("WARNING: TestEncodeDecodeBucketReplicationResyncStatus Msgsize() is inaccurate")
    	}
    
    	vn := BucketReplicationResyncStatus{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBucketReplicationResyncStatus(b *testing.B) {
    	v := BucketReplicationResyncStatus{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Aug 22 23:53:06 GMT 2022
    - 23K bytes
    - Viewed (0)
  4. cmd/metacache_gen_test.go

    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodemetacache Msgsize() is inaccurate")
    	}
    
    	vn := metacache{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodemetacache(b *testing.B) {
    	v := metacache{}
    	var buf bytes.Buffer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  5. cmd/tier_gen_test.go

    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeTierConfigMgr Msgsize() is inaccurate")
    	}
    
    	vn := TierConfigMgr{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    	var buf bytes.Buffer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
  6. cmd/generic-handlers_test.go

    	defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test
    
    	var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		w.WriteHeader(http.StatusOK)
    	}
    	for i, test := range sseTLSHandlerTests {
    		globalIsTLS = test.IsTLS
    
    		w := httptest.NewRecorder()
    		r := new(http.Request)
    		r.Header = test.Header
    		r.URL = test.URL
    
    		h := setRequestValidityMiddleware(okHandler)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    			if err != nil {
    				t.Fatal("dir/obj not found before last test")
    			}
    			_, actualErr := xl.DeleteObject(ctx, test.bucket, test.object, ObjectOptions{})
    			if test.expectedErr != nil && actualErr != test.expectedErr {
    				t.Errorf("Expected to fail with %s, but failed with %s", test.expectedErr, actualErr)
    			}
    			if test.expectedErr == nil && actualErr != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  8. internal/config/identity/openid/openid.go

    		// by clearing the values. With multiple providers, we support
    		// individually enabling/disabling provider configurations. If
    		// the enable parameter's value is non-empty, we use that
    		// setting, otherwise we treat it as enabled if some important
    		// parameters are non-empty.
    		var (
    			cfgEnableVal        = getCfgVal(config.Enable)
    			isExplicitlyEnabled = cfgEnableVal != ""
    		)
    
    		var enabled bool
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
  9. cmd/sts-handlers_test.go

    	baseTestCases := []TestSuiteCommon{
    		// Init and run test on ErasureSD backend with signature v4.
    		{serverType: "ErasureSD", signer: signerV4},
    		// Init and run test on ErasureSD backend, with tls enabled.
    		{serverType: "ErasureSD", signer: signerV4, secure: true},
    		// Init and run test on Erasure backend.
    		{serverType: "Erasure", signer: signerV4},
    		// Init and run test on ErasureSet backend.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  10. internal/s3select/simdj/record.go

    		b, err := iter.MarshalJSON()
    		return sql.FromBytes(b), err
    	}
    	return nil, fmt.Errorf("iterToValue: unknown JSON type: %s", iter.Type().String())
    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	r.object = simdjson.Object{}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    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)
Back to top