- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Consumer (0.2 sec)
-
internal/config/notify/help.go
Type: "number", }, config.HelpKV{ Key: target.AmqpPublisherConfirms, Description: "enable consumer acknowledgement and publisher confirms, use this along with queue_dir for guaranteed delivery of all events", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.AmqpQueueDir, Description: queueDirComment, Optional: true, Type: "path", },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
cmd/erasure.go
if disk == nil { infos[i].Error = errDiskNotFound.Error() return } di, err := disk.DiskInfo(context.Background(), DiskInfoOptions{}) infos[i] = di if err != nil { // - Do not consume disks which are not reachable // unformatted or simply not accessible for some reason. infos[i].Error = err.Error() } }() } wg.Wait() var scanningDisks, healingDisks []StorageAPI
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
src/bufio/bufio.go
b.lastByte = -1 b.lastRuneSize = -1 return nil } // ReadRune reads a single UTF-8 encoded Unicode character and returns the // rune and its size in bytes. If the encoded rune is invalid, it consumes one byte // and returns unicode.ReplacementChar (U+FFFD) with a size of 1. func (b *Reader) ReadRune() (r rune, size int, err error) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
cmd/batch-handlers.go
if aerr == nil { return } batchLogIf(ctx, fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster", humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr)) attempts++ time.Sleep(time.Second) } } }() var ( hr *hash.Reader
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
src/bytes/buffer.go
} // ReadRune reads and returns the next UTF-8-encoded // Unicode code point from the buffer. // If no bytes are available, the error returned is io.EOF. // If the bytes are an erroneous UTF-8 encoding, it // consumes one byte and returns U+FFFD, 1. func (b *Buffer) ReadRune() (r rune, size int, err error) { if b.empty() { // Buffer is empty, reset to recover space. b.Reset() return 0, 0, io.EOF } c := b.buf[b.off]
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0) -
src/archive/tar/reader_test.go
} if hdr.Name != v.wantName { t.Errorf("test %d, Header.Name = %s, want %s", i, hdr.Name, v.wantName) } if v.wantErr == nil && r.Len() == 0 { t.Errorf("test %d, canary byte unexpectedly consumed", i) } } } // testNonEmptyReader wraps an io.Reader and ensures that // Read is never called with an empty buffer. type testNonEmptyReader struct{ io.Reader }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Nov 21 21:14:38 GMT 2022 - 47.1K bytes - Viewed (0) -
src/bufio/bufio_test.go
type eofReader struct { buf []byte } func (r *eofReader) Read(p []byte) (int, error) { read := copy(p, r.buf) r.buf = r.buf[read:] switch read { case 0, len(r.buf): // As allowed in the documentation, this will return io.EOF // in the same call that consumes the last of the data. // https://godoc.org/io#Reader
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Feb 10 18:56:01 GMT 2023 - 51.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
healFinishedStatus = "finished" ) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
src/bufio/scan.go
} if n > 0 { s.empties = 0 break } loop++ if loop > maxConsecutiveEmptyReads { s.setErr(io.ErrNoProgress) break } } } } // advance consumes n bytes of the buffer. It reports whether the advance was legal. func (s *Scanner) advance(n int) bool { if n < 0 { s.setErr(ErrNegativeAdvance) return false } if n > s.end-s.start {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication.go
return saveConfig(ctx, objectAPI, configFile, buf) } // getReplicationDiff returns un-replicated objects in a channel. // If a non-nil channel is returned it must be consumed fully or // the provided context must be canceled. func getReplicationDiff(ctx context.Context, objAPI ObjectLayer, bucket string, opts madmin.ReplDiffOpts) (chan madmin.DiffInfo, error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1)