Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 212 for newHeader (0.14 sec)

  1. src/archive/tar/reader.go

    	// ensure that this error is sticky.
    	err error
    }
    
    type fileReader interface {
    	io.Reader
    	fileState
    
    	WriteTo(io.Writer) (int64, error)
    }
    
    // NewReader creates a new [Reader] reading from r.
    func NewReader(r io.Reader) *Reader {
    	return &Reader{r: r, curr: &regFileReader{r, 0}}
    }
    
    // Next advances to the next entry in the tar archive.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    			h.status.Store(statusOnline)
    		}
    	}()
    
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost,
    		h.Endpoint(), bytes.NewReader(payload))
    	if err != nil {
    		return fmt.Errorf("invalid configuration for '%s'; %v", h.Endpoint(), err)
    	}
    	if payloadType != "" {
    		req.Header.Set(xhttp.ContentType, payloadType)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    			return
    		}
    		defer gr.Close()
    		rc, err = file.Open(gr)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	} else {
    		rc = io.NopCloser(bytes.NewReader([]byte{}))
    	}
    
    	defer rc.Close()
    
    	if err = setObjectHeaders(ctx, w, fileObjInfo, nil, opts); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. internal/rest/client.go

    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/metacache-stream_test.go

    func loadMetacacheSample(t testing.TB) *metacacheReader {
    	b, err := os.ReadFile("testdata/metacache.s2")
    	if err != nil {
    		t.Fatal(err)
    	}
    	return newMetacacheReader(bytes.NewReader(b))
    }
    
    func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	entries, err := r.readN(-1, false, true, false, "")
    	if err != io.EOF {
    		t.Fatal(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  6. istioctl/pkg/tag/tag.go

    	sa := local.NewSourceAnalyzer(analysis.Combine("webhook", &webhook.Analyzer{}), "", resource.Namespace(istioNamespace), nil)
    	if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil {
    		return err
    	}
    	k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
    	if err != nil {
    		return err
    	}
    	sa.AddRunningKubeSourceWithRevision(k, revision, false)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 15:40:30 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    			var dopts []s2.ReaderOption
    			if off > 0 || decOff > 0 {
    				// We are not starting at the beginning, so ignore stream identifiers.
    				dopts = append(dopts, s2.ReaderIgnoreStreamIdentifier())
    			}
    			s2Reader := s2.NewReader(inputReader, dopts...)
    			// Apply the skipLen and limit on the decompressed stream.
    			if decOff > 0 {
    				if err = s2Reader.Skip(decOff); err != nil {
    					// Call the cleanup funcs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	)
    
    	var objectSize int64
    	for _, partInfo := range objInfo.Parts {
    		if isSSEC {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.Size), partInfo.Size, "", "", partInfo.ActualSize)
    		} else {
    			hr, err = hash.NewReader(ctx, io.LimitReader(r, partInfo.ActualSize), partInfo.ActualSize, "", "", partInfo.ActualSize)
    		}
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. doc/godebug.md

    ### Go 1.20
    
    Go 1.20 introduced support for rejecting insecure paths in tar and zip archives,
    controlled by the [`tarinsecurepath` setting](/pkg/archive/tar/#Reader.Next)
    and the [`zipinsecurepath` setting](/pkg/archive/zip/#NewReader).
    These default to `tarinsecurepath=1` and `zipinsecurepath=1`,
    preserving the behavior of earlier versions of Go.
    A future version of Go may change the defaults to
    `tarinsecurepath=0` and `zipinsecurepath=0`.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. cmd/kms-handlers_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	testKMSPolicyName := "testKMSPolicy"
    	if p != "" {
    		p = `{"Version":"2012-10-17","Statement":[` + p + `]}`
    		policyData, err := policy.ParseConfig(strings.NewReader(p))
    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData)
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
Back to top