Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 364 for Stream (0.04 seconds)

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

  1. internal/s3select/jstream/scratch.go

    package jstream
    
    import (
    	"unicode/utf8"
    )
    
    type scratch struct {
    	data []byte
    	fill int
    }
    
    // reset scratch buffer
    func (s *scratch) reset() { s.fill = 0 }
    
    // bytes returns the written contents of scratch buffer
    func (s *scratch) bytes() []byte { return s.data[0:s.fill] }
    
    // grow scratch buffer
    func (s *scratch) grow() {
    	ndata := make([]byte, cap(s.data)*2)
    	copy(ndata, s.data)
    	s.data = ndata
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 758 bytes
    - Click Count (0)
  2. tests/helper_test.go

    		}
    	})
    
    	t.Run("Team", func(t *testing.T) {
    		if len(user.Team) != len(expect.Team) {
    			t.Fatalf("Team should equal, expect: %v, got %v", len(expect.Team), len(user.Team))
    		}
    
    		sort.Slice(user.Team, func(i, j int) bool {
    			return user.Team[i].ID > user.Team[j].ID
    		})
    
    		sort.Slice(expect.Team, func(i, j int) bool {
    			return expect.Team[i].ID > expect.Team[j].ID
    		})
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Mar 19 03:50:28 GMT 2024
    - 8K bytes
    - Click Count (0)
  3. internal/ioutil/read_file.go

    	OsOpenFile = os.OpenFile
    )
    
    // ReadFileWithFileInfo reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  4. tests/create_test.go

    		*GetUser("bulk_5", Config{Account: false, Pets: 0, Toys: 3, Company: true, Manager: false, Team: 1, Languages: 3, Friends: 1}),
    		*GetUser("bulk_6", Config{Account: true, Pets: 4, Toys: 3, Company: false, Manager: true, Team: 1, Languages: 3, Friends: 0}),
    		*GetUser("bulk_7", Config{Account: true, Pets: 1, Toys: 3, Company: true, Manager: true, Team: 4, Languages: 3, Friends: 1}),
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Jul 21 09:55:20 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  5. SECURITY.md

    for the past five days please contact the security team directly:
    
    - Primary security coordinator: ******@****.***
    - Secondary coordinator: ******@****.***
    - If you receive no response: ******@****.***
    
    ### Disclosure Process
    
    MinIO uses the following disclosure process:
    
    1. Once the security report is received one member of the security team tries to verify and reproduce
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.2K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenEncCling.java

            return new MavenEncCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/MavenShellCling.java

            return new MavenShellCling(world).run(args, null, null, null, false);
        }
    
        /**
         * ClassWorld Launcher "embedded" entry point: returning exitCode and accepts Class World and streams.
         */
        public static int main(
                String[] args,
                ClassWorld world,
                @Nullable InputStream stdIn,
                @Nullable OutputStream stdOut,
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 3K bytes
    - Click Count (0)
  8. internal/s3select/jstream/scanner.go

    package jstream
    
    import (
    	"io"
    	"sync/atomic"
    )
    
    const (
    	chunk    = 4095 // ~4k
    	maxUint  = ^uint(0)
    	maxInt   = int64(maxUint >> 1)
    	nullByte = byte(0)
    )
    
    type scanner struct {
    	pos       int64 // position in reader
    	ipos      int64 // internal buffer position
    	ifill     int64 // internal buffer fill
    	end       int64
    	buf       [chunk + 1]byte // internal buffer (with a lookback size of 1)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  9. .gitattributes

    # Treat all files in the Go repo as binary, with no git magic updating
    # line endings. This produces predictable results in different environments.
    #
    # Windows users contributing to Go will need to use a modern version
    # of git and editors capable of LF line endings.
    #
    # Windows .bat files are known to have multiple bugs when run with LF
    # endings, and so they are checked in with CRLF endings, with a test
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jun 08 15:31:43 GMT 2020
    - 639 bytes
    - Click Count (0)
  10. internal/s3select/jstream/errors.go

    package jstream
    
    import (
    	"fmt"
    	"strconv"
    )
    
    // Predefined errors
    var (
    	ErrSyntax        = DecoderError{msg: "invalid character"}
    	ErrUnexpectedEOF = DecoderError{msg: "unexpected end of JSON input"}
    	ErrMaxDepth      = DecoderError{msg: "maximum recursion depth exceeded"}
    )
    
    type errPos [2]int // line number, byte offset where error occurred
    
    // DecoderError contains a detailed decoding error.
    type DecoderError struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 1.3K bytes
    - Click Count (0)
Back to Top