Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for Compressor (0.59 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/archive/zip/register.go

    	}
    }
    
    // RegisterCompressor registers custom compressors for a specified method ID.
    // The common methods [Store] and [Deflate] are built in.
    func RegisterCompressor(method uint16, comp Compressor) {
    	if _, dup := compressors.LoadOrStore(method, comp); dup {
    		panic("compressor already registered")
    	}
    }
    
    func compressor(method uint16) Compressor {
    	ci, ok := compressors.Load(method)
    	if !ok {
    		return nil
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 3.7K bytes
    - Click Count (0)
  2. src/archive/zip/example_test.go

    }
    
    func ExampleWriter_RegisterCompressor() {
    	// Override the default Deflate compressor with a higher compression level.
    
    	// Create a buffer to write our archive to.
    	buf := new(bytes.Buffer)
    
    	// Create a new zip archive.
    	w := zip.NewWriter(buf)
    
    	// Register a custom Deflate compressor.
    	w.RegisterCompressor(zip.Deflate, func(out io.Writer) (io.WriteCloser, error) {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Jan 27 00:22:03 GMT 2016
    - 2K bytes
    - Click Count (0)
  3. api/go1.6.txt

    pkg archive/zip, method (*ReadCloser) RegisterDecompressor(uint16, Decompressor)
    pkg archive/zip, method (*Reader) RegisterDecompressor(uint16, Decompressor)
    pkg archive/zip, method (*Writer) RegisterCompressor(uint16, Compressor)
    pkg bufio, method (*Scanner) Buffer([]uint8, int)
    pkg bufio, var ErrFinalToken error
    pkg crypto/tls, const TLS_RSA_WITH_AES_128_GCM_SHA256 = 156
    pkg crypto/tls, const TLS_RSA_WITH_AES_128_GCM_SHA256 uint16
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Jan 13 23:40:13 GMT 2016
    - 12.9K bytes
    - Click Count (0)
  4. internal/s3select/select.go

    			s3Select.progressReader.Close()
    
    			var stErr bzip2.StructuralError
    			if errors.As(err, &stErr) {
    				return errInvalidCompression(err, s3Select.Input.CompressionType)
    			}
    			// Test these compressor errors
    			errs := []error{
    				gzip.ErrHeader, gzip.ErrChecksum,
    				s2.ErrCorrupt, s2.ErrUnsupported, s2.ErrCRC,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  5. cmd/object-api-utils.go

    // client closed the stream prematurely.
    func newS2CompressReader(r io.Reader, on int64, encrypted bool) (rc io.ReadCloser, idx func() []byte) {
    	pr, pw := io.Pipe()
    	// Copy input to compressor
    	opts := compressOpts
    	if encrypted {
    		// The values used for padding are not a security concern,
    		// but we choose pseudo-random numbers instead of just zeros.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  6. api/go1.2.txt

    pkg archive/zip, func RegisterCompressor(uint16, Compressor)
    pkg archive/zip, func RegisterDecompressor(uint16, Decompressor)
    pkg archive/zip, method (*File) DataOffset() (int64, error)
    pkg archive/zip, type Compressor func(io.Writer) (io.WriteCloser, error)
    pkg archive/zip, type Decompressor func(io.Reader) io.ReadCloser
    pkg bufio, method (*Reader) Reset(io.Reader)
    pkg bufio, method (*Writer) Reset(io.Writer)
    pkg compress/flate, method (*Writer) Reset(io.Writer)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 18 04:36:59 GMT 2013
    - 1.9M bytes
    - Click Count (1)
Back to Top