- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 456 for Stream (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
cmd/encryption-v1_test.go
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) -
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) -
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) -
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)