Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 378 for Weaver (0.2 sec)

  1. internal/http/server.go

    	srv.ReadHeaderTimeout = d
    	return srv
    }
    
    // UseHandler configure final handler for this HTTP *Server
    func (srv *Server) UseHandler(h http.Handler) *Server {
    	srv.Handler = h
    	return srv
    }
    
    // UseTLSConfig pass configured TLSConfig for this HTTP *Server
    func (srv *Server) UseTLSConfig(cfg *tls.Config) *Server {
    	srv.TLSConfig = cfg
    	return srv
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. cmd/server_test.go

    	req, _ := http.NewRequest(http.MethodOptions, s.endPoint, nil)
    	req.Header.Set("Origin", "http://foobar.com")
    	res, err := s.client.Do(req)
    	if err != nil {
    		c.Fatal(err)
    	}
    
    	for k := range expectedMap {
    		if v, ok := res.Header[k]; !ok {
    			c.Errorf("Expected key %s missing from %v", k, res.Header)
    		} else {
    			expectedSet := set.CreateStringSet(expectedMap[k]...)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  3. internal/hash/reader_test.go

    	}
    }
    
    // Tests hash reader checksum verification.
    func TestHashReaderVerification(t *testing.T) {
    	testCases := []struct {
    		desc              string
    		src               io.Reader
    		size              int64
    		actualSize        int64
    		md5hex, sha256hex string
    		err               error
    	}{
    		0: {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.3K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		return err
    	}
    
    	if len(data) == 0 {
    		return nil
    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("rebalanceMeta: no data")
    	}
    
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case rebalMetaFmt:
    	default:
    		return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2]))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    	// and allowed to save.
    	z.poolMeta = newPoolMeta(z, poolMeta{})
    	z.poolMeta.dontSave = true
    
    	bootstrapTrace("newSharedLock", func() {
    		globalLeaderLock = newSharedLock(GlobalContext, z, "leader.lock")
    	})
    
    	// Enable background operations on
    	//
    	// - Disk auto healing
    	// - MRF (most recently failed) healing
    	// - Background expiration routine for lifecycle policies
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    				}
    				type version struct {
    					Idx      int
    					Header   json.RawMessage
    					Metadata json.RawMessage
    				}
    				versions := make([]version, hdr.versions)
    				headerVer := hdr.headerVer
    				err = decodeVersions(v, hdr.versions, func(idx int, hdr, meta []byte) error {
    					var header xlMetaV2VersionHeaderV2
    					if _, err := header.UnmarshalMsg(hdr, headerVer); err != nil {
    						return err
    					}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  7. cmd/untar.go

    )
    
    var magicHeaders = []struct {
    	header []byte
    	f      format
    }{
    	{
    		header: []byte{0x1f, 0x8b, 8},
    		f:      formatGzip,
    	},
    	{
    		// Zstd default header.
    		header: []byte{0x28, 0xb5, 0x2f, 0xfd},
    		f:      formatZstd,
    	},
    	{
    		// Zstd skippable frame header.
    		header: []byte{0x2a, 0x4d, 0x18},
    		f:      formatZstd,
    	},
    	{
    		// LZ4
    		header: []byte{0x4, 0x22, 0x4d, 0x18},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  8. internal/s3select/json/reader_test.go

    Klaus Post <******@****.***> 1663610716 +0200
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  9. cmd/object-multipart-handlers.go

    		ssecRepHeaders := []string{
    			"X-Minio-Replication-Server-Side-Encryption-Seal-Algorithm",
    			"X-Minio-Replication-Server-Side-Encryption-Sealed-Key",
    			"X-Minio-Replication-Server-Side-Encryption-Iv",
    		}
    		ssecRep := false
    		for _, header := range ssecRepHeaders {
    			if val := r.Header.Get(header); val != "" {
    				ssecRep = true
    				break
    			}
    		}
    		if !(ssecRep && sourceReplReq) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  10. cmd/object-handlers.go

    		// Validate the SSE-C Key set in the header.
    		if _, err = crypto.SSEC.UnsealObjectKey(r.Header, objInfo.UserDefined, bucket, object); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		w.Header().Set(xhttp.AmzServerSideEncryptionCustomerAlgorithm, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerAlgorithm))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
Back to top