Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 456 for Stream (0.03 seconds)

  1. internal/logger/target/http/http.go

    	migrateTarget *Target
    
    	// Number of events per HTTP send to webhook target
    	// this is ideally useful only if your endpoint can
    	// support reading multiple events on a stream for example
    	// like : Splunk HTTP Event collector, if you are unsure
    	// set this to '1'.
    	batchSize   int
    	payloadType string
    
    	// store to persist and replay the logs to the target
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  2. internal/bucket/object/lock/lock.go

    	default:
    		return xml.UnmarshalError(fmt.Sprintf("expected element type <LegalHold>/<ObjectLockLegalHold> but have <%s>",
    			start.Name.Local))
    	}
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			switch se.Name.Local {
    			case "Status":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  3. cmd/bucket-handlers.go

    		// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream
    		// is always going to be in-memory as we cannot re-read from what we
    		// wrote to disk - since that amounts to "copying" from a "copy"
    		// instead of "copying" from source, we need the stream to be seekable
    		// to ensure that we can make fan-out calls concurrently.
    		buf := bytebufferpool.Get()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java

                for (String extension : checksums.keySet()) {
                    // TODO shouldn't need a file intermediary - improve wagon to take a stream
                    File temp = File.createTempFile("maven-artifact", null);
                    temp.deleteOnExit();
                    byte[] bytes = sums.get(extension).getBytes(StandardCharsets.UTF_8);
                    Files.write(
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 29.9K bytes
    - Click Count (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java

                MavenSession session = legacySupport.getSession();
                if (session != null) {
                    if (session.getProjects() != null) {
                        pomRepositories = session.getProjects().stream()
                                .filter(p -> artifact.equals(p.getArtifact()))
                                .findFirst()
                                .map(MavenProject::getRemoteArtifactRepositories)
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Sep 25 12:03:50 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  6. docs/ko/docs/advanced/custom-response.md

    # 사용자 정의 응답 - HTML, Stream, 파일, 기타
    
    기본적으로, **FastAPI** 응답을 `JSONResponse`를 사용하여 반환합니다.
    
    이를 재정의 하려면 [응답을 직접 반환하기](response-directly.md){.internal-link target=_blank}에서 본 것처럼 `Response`를 직접 반환하면 됩니다.
    
    그러나 `Response` (또는 `JSONResponse`와 같은 하위 클래스)를 직접 반환하면, 데이터가 자동으로 변환되지 않으며 (심지어 `response_model`을 선언했더라도), 문서화가 자동으로 생성되지 않습니다(예를 들어, 생성된 OpenAPI의 일부로 HTTP 헤더 `Content-Type`에 특정 "미디어 타입"을 포함하는 경우).
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Feb 15 11:21:20 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  7. cmd/encryption-v1_test.go

    			crypto.MetaSealedKeySSEC:               "IAA8PGAA==",
    			ReservedMetadataPrefix + "actual-size": "594870264",
    			"content-type":                         "application/octet-stream",
    			"etag":                                 "166b1545b4c1535294ee0686678bea8c-2",
    		},
    		Parts: []ObjectPartInfo{
    			{
    				Number:     1,
    				Size:       297580380,
    				ActualSize: 297435132,
    			},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  8. internal/bucket/lifecycle/lifecycle.go

    	default:
    		return xml.UnmarshalError(fmt.Sprintf("expected element type <LifecycleConfiguration>/<BucketLifecycleConfiguration> but have <%s>",
    			start.Name.Local))
    	}
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			switch se.Name.Local {
    			case "Rule":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Apr 03 06:45:06 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  9. src/archive/tar/reader_test.go

    	}
    
    	data1, data2, pax, sparse := ss[0], ss[1], ss[2], ss[3]
    	data2 += strings.Repeat("\x00", 10*512)
    	trash := strings.Repeat("garbage ", 64) // Exactly 512 bytes
    
    	vectors := []struct {
    		input string // Input stream
    		cnt   int    // Expected number of headers read
    		err   error  // Expected error outcome
    	}{
    		{"", 0, io.EOF}, // Empty file is a "valid" tar file
    		{data1[:511], 0, io.ErrUnexpectedEOF},
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  10. src/archive/tar/reader.go

    func discard(r io.Reader, n int64) error {
    	// If possible, Seek to the last byte before the end of the data section.
    	// Do this because Seek is often lazy about reporting errors; this will mask
    	// the fact that the stream may be truncated. We can rely on the
    	// io.CopyN done shortly afterwards to trigger any IO errors.
    	var seekSkipped int64 // Number of bytes skipped via Seek
    	if sr, ok := r.(io.Seeker); ok && n > 1 {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 26.9K bytes
    - Click Count (0)
Back to Top