Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for encodedCh (0.17 sec)

  1. internal/hash/checksum.go

    	ChecksumIncludesMultipart
    
    	// ChecksumNone indicates no checksum.
    	ChecksumNone ChecksumType = 0
    )
    
    // Checksum is a type and base 64 encoded value.
    type Checksum struct {
    	Type    ChecksumType
    	Encoded string
    	Raw     []byte
    }
    
    // Is returns if c is all of t.
    func (c ChecksumType) Is(t ChecksumType) bool {
    	if t == ChecksumNone {
    		return c == ChecksumNone
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_test.go

    		ID:        "uuid",
    		Error:     "",
    	}
    
    	var buf bytes.Buffer
    	gob.NewEncoder(&buf).Encode(v)
    	encoded := buf.Bytes()
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		dec := gob.NewDecoder(bytes.NewBuffer(encoded))
    		err := dec.Decode(&v)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  3. cmd/object-api-common.go

    	blockSizeV2 = 1 * humanize.MiByte
    
    	// Buckets meta prefix.
    	bucketMetaPrefix = "buckets"
    
    	// Deleted Buckets prefix.
    	deletedBucketsPrefix = ".deleted"
    
    	// ETag (hex encoded md5sum) of empty string.
    	emptyETag = "d41d8cd98f00b204e9800998ecf8427e"
    )
    
    // Global object layer mutex, used for safely updating object layer.
    var globalObjLayerMutex sync.RWMutex
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  4. internal/s3select/parquet/reader.go

    	}
    
    	var value interface{}
    	switch val := v.(type) {
    	case []byte:
    		// TODO: only strings are supported in s3select output (not
    		// 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[:])
    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)
  5. internal/crypto/error.go

    	// MD5 checksum.
    	ErrMissingCustomerKeyMD5 = Errorf("The SSE-C request is missing the customer key MD5")
    
    	// ErrInvalidCustomerKey indicates that the SSE-C client key is not valid - e.g. not a
    	// base64-encoded string or not 256 bits long.
    	ErrInvalidCustomerKey = Errorf("The SSE-C client key is invalid")
    
    	// ErrSecretKeyMismatch indicates that the provided secret key (SSE-C client key / SSE-S3 KMS key)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 4.4K bytes
    - Viewed (0)
  6. cmd/data-usage_test.go

    		gotv := got.Cache[wkey]
    		if !equalAsJSON(gotv, wval) {
    			t.Errorf("deserialize mismatch, key %v\nwant: %#v\ngot:  %#v", wkey, wval, gotv)
    		}
    	}
    }
    
    // equalAsJSON returns whether the values are equal when encoded as JSON.
    func equalAsJSON(a, b interface{}) bool {
    	aj, err := json.Marshal(a)
    	if err != nil {
    		panic(err)
    	}
    	bj, err := json.Marshal(b)
    	if err != nil {
    		panic(err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  7. cmd/auth-handler.go

    	}
    
    	// Check if a session policy is set. If so, decode it here.
    	sp, spok := claims.Lookup(policy.SessionPolicyName)
    	if spok {
    		// Looks like subpolicy is set and is a string, if set then its
    		// base64 encoded, decode it. Decoding fails reject such
    		// requests.
    		spBytes, err := base64.StdEncoding.DecodeString(sp)
    		if err != nil {
    			// Base64 decoding fails, we should log to indicate
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    				case <-ctx.Done():
    					return
    				case encodedCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...):
    				}
    			}
    		}
    	}()
    
    	// Collect from matching peers
    	for _, peer := range peers {
    		if peer == nil {
    			continue
    		}
    		if node == "" || strings.EqualFold(peer.host.Name, node) {
    			peer.ConsoleLog(ctx, logKind, encodedCh)
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  9. cmd/erasure_test.go

    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    		encoded, err := erasure.EncodeData(context.Background(), buffer)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encode data: %v", i, err)
    		}
    
    		for j := range encoded[:test.missingData] {
    			encoded[j] = nil
    		}
    		for j := test.dataBlocks; j < test.dataBlocks+test.missingParity; j++ {
    			encoded[j] = nil
    		}
    
    		if test.reconstructParity {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  10. cmd/tier.go

    	return d, nil
    }
    
    // configReader returns a PutObjReader and ObjectOptions needed to save config
    // using a PutObject API. PutObjReader encrypts json encoded tier configurations
    // if KMS is enabled, otherwise simply yields the json encoded bytes as is.
    // Similarly, ObjectOptions value depends on KMS' status.
    func (config *TierConfigMgr) configReader(ctx context.Context) (*PutObjReader, *ObjectOptions, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
Back to top