- Sort Score
- Result 10 results
- Languages All
Results 491 - 500 of 775 for readTo (0.08 sec)
-
cmd/post-policy_test.go
} writer.Write([]byte("hello world")) // Close before creating the new request. w.Close() // Set the body equal to the created policy. reader := bytes.NewReader(buf.Bytes()) req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader) if err != nil { return nil, err } // Set form content-type. req.Header.Set("Content-Type", w.FormDataContentType())
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.6K bytes - Viewed (0) -
src/archive/tar/common.go
// other fields in Header take precedence over PAXRecords. PAXRecords map[string]string // Format specifies the format of the tar header. // // This is set by Reader.Next as a best-effort guess at the format. // Since the Reader liberally reads some non-compliant files, // it is possible for this to be FormatUnknown. // // If the format is unspecified when Writer.WriteHeader is called,
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Oct 07 19:46:36 UTC 2025 - 24.5K bytes - Viewed (0) -
api/go1.txt
pkg bufio, func NewWriter(io.Writer) *Writer pkg bufio, func NewWriterSize(io.Writer, int) *Writer pkg bufio, method (*Reader) Buffered() int pkg bufio, method (*Reader) Peek(int) ([]uint8, error) pkg bufio, method (*Reader) Read([]uint8) (int, error) pkg bufio, method (*Reader) ReadByte() (uint8, error) pkg bufio, method (*Reader) ReadBytes(uint8) ([]uint8, error)
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Wed Aug 14 18:58:28 UTC 2013 - 1.7M bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *ServerSystemConfig) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001--
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.9K bytes - Viewed (0) -
docs/bucket/versioning/DESIGN.md
} } } ] } ``` ### v1.3+ versions Version 1.3 introduces changes to help with [faster metadata reads and updates](https://blog.min.io/minio-versioning-metadata-deep-dive/) | Entry | Encoding | Content | ----------------|-----------------------------|----------------------------------------Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Jul 17 15:43:14 UTC 2022 - 5.8K bytes - Viewed (0) -
internal/config/config.go
// ContextKeyForTargetFromConfig - key for context for target from config const ContextKeyForTargetFromConfig = ContextKeyString("ContextKeyForTargetFromConfig") // ParseConfigTargetID - read all targetIDs from reader func ParseConfigTargetID(r io.Reader) (ids map[string]bool, err error) { ids = make(map[string]bool) scanner := bufio.NewScanner(r) for scanner.Scan() { // Skip any empty lines, or comment like characters
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/gcs/GcsClient.java
try (InputStream contentStream = new BufferedInputStream(Channels.newInputStream(blob.reader()))) { responseData.setResponseBody(InputStreamUtil.getBytes(contentStream)); } catch (final Exception e) { logger.warn("Failed to read GCS object content: bucket={}, path={}, size={}", bucketName, path, blob.getSize(), e);
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 17.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* atomic: a read observes the full set of values as they were before or after the commit, but never * a mix of values. * * Clients call [get] to read a snapshot of an entry. The read will observe the value at the time * that [get] was called. Updates and removals after the call do not impact ongoing reads. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 34.7K bytes - Viewed (0) -
impl/maven-core/src/test/remote-repo/org/apache/maven/its/plugins/maven-it-plugin/0.1/maven-it-plugin-0.1.jar
false false false true process-test-classes org.apache.maven.plugin.coreit.EMojo java per-lookup once-per-session it Does nothing. compile false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session xpp3-reader Does nothing. false true false false false true generate-sources org.apache.maven.plugin.coreit.CMojo java per-lookup once-per-session models java.lang.String[] false true version java.lang.String false true ${version} xpp3-writer Does nothing. false...
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 13.2K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
if err != nil { return nil, err } defer file.Close() return parseMountFrom(file) } func parseMountFrom(file io.Reader) (mountInfos, error) { mounts := mountInfos{} scanner := bufio.NewReader(file) for { line, err := scanner.ReadString('\n') if err == io.EOF { break } fields := strings.Fields(line) if len(fields) != expectedNumFieldsPerLine {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 4.7K bytes - Viewed (0)