- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 153 for reading1 (0.03 sec)
-
docs/metrics/prometheus/README.md
``` ### 3. Configuring Prometheus #### 3.1 Authenticated Prometheus config > If MinIO is configured to expose metrics without authentication, you don't need to use `mc` to generate prometheus config. You can skip reading further and move to 3.2 section.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 7.1K bytes - Viewed (0) -
cmd/storage-datatypes.go
MaxSize int64 `msg:"ms"` // Return error if size is exceed. MetadataOnly bool `msg:"mo"` // Read as XL meta and truncate data. AbortOn404 bool `msg:"ab"` // Stop reading after first file not found. MaxResults int `msg:"mr"` // Stop after this many successful results. <= 0 means all. } // ReadMultipleResp contains a single response from a ReadMultipleReq.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 17.4K bytes - Viewed (0) -
cmd/erasure-decode.go
readerIndex := 0 var wg sync.WaitGroup // if readTrigger is true, it implies next disk.ReadAt() should be tried // if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need // to try reading the next disk. for readTrigger := range readTriggerCh { newBufLK.RLock() canDecode := p.canDecode(newBuf) newBufLK.RUnlock() if canDecode { break } if readerIndex == len(p.readers) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
src/cmd/addr2line/main.go
if flag.NArg() != 1 { usage() } f, err := objfile.Open(flag.Arg(0)) if err != nil { log.Fatal(err) } defer f.Close() tab, err := f.PCLineTable() if err != nil { log.Fatalf("reading %s: %v", flag.Arg(0), err) } stdin := bufio.NewScanner(os.Stdin) stdout := bufio.NewWriter(os.Stdout) for stdin.Scan() { p := stdin.Text() if strings.Contains(p, ":") {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Jun 21 19:58:04 UTC 2024 - 2.4K bytes - Viewed (0) -
docs/debugging/xattr/main.go
if err := setxattr(path, name, value); err != nil { log.Fatalln(fmt.Errorf("setting attribute %s failed with: %v", name, err)) } } else { if name == "" { log.Fatalln("you must specify an attribute name for reading") } var names []string if name == "." { attrs, err := listxattr(path) if err != nil { log.Fatalln(fmt.Errorf("listing attributes failed with: %v", err)) } names = append(names, attrs...)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Dec 29 23:52:41 UTC 2023 - 3.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
private final File tempFile; private final FileInputStream fileInputStream; /** * A class that provides an input stream for reading from a temporary file. * This class wraps a {@link FileInputStream} to read from the specified temporary file. * * @param tempFile the temporary file to be readRegistered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 4.3K bytes - Viewed (0) -
docs/sts/assume-role.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", err) } else { defer f.Close() bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 { stsOpts.DurationSeconds = int(expiryDuration.Seconds()) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Aug 17 01:24:54 UTC 2024 - 4.4K bytes - Viewed (1) -
cmd/dummy-data-generator_test.go
n2, e2 := io.ReadFull(r2, b2) if n1 != n2 { return false, fmt.Sprintf("Read %d != %d bytes from the readers", n1, n2) } if !bytes.Equal(b1[:n1], b2[:n2]) { return false, fmt.Sprintf("After reading %d equal buffers (32Kib each), we got the following two strings:\n%v\n%v\n", i, b1, b2) } // Check if stream has ended if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 4.7K bytes - Viewed (0) -
docs/sts/ldap.go
if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file %s: %v", sessionPolicyFile, err) } else { bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } ldapOpts = append(ldapOpts, cr.LDAPIdentityPolicyOpt(policy)) } if expiryDuration != 0 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Aug 07 12:59:47 UTC 2024 - 4K bytes - Viewed (0) -
src/archive/zip/register.go
// simultaneously, but each returned writer will be used only by // one goroutine at a time. type Compressor func(w io.Writer) (io.WriteCloser, error) // A Decompressor returns a new decompressing reader, reading from r. // The [io.ReadCloser]'s Close method must be used to release associated resources. // The Decompressor itself must be safe to invoke from multiple goroutines // simultaneously, but each returned reader will be used only by
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Oct 13 18:36:46 UTC 2023 - 3.7K bytes - Viewed (0)