- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for card (0.12 sec)
-
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/logger/console.go
func (f fatalMsg) pretty(msg string, args ...interface{}) { // Build the passed error message errMsg := fmt.Sprintf(msg, args...) tagPrinted := false // Print the error message: the following code takes care // of splitting error text and always pretty printing the // red banner along with the error message. Since the error // message itself contains some colored text, we needed
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/naughty-disk_test.go
"io" "sync" "time" "github.com/minio/madmin-go/v3" ) // naughtyDisk wraps a POSIX disk and returns programmed errors // specified by the developer. The purpose is to simulate errors // that are hard to simulate in practice like DiskNotFound. // Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
return } if err := enforceBucketQuotaHard(ctx, dstBucket, actualPartSize); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Special care for CopyObjectPart if partRangeErr := checkCopyPartRangeWithSize(rs, actualPartSize); partRangeErr != nil { writeCopyPartErr(ctx, w, partRangeErr, r.URL) return } // Get the object offset & length
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
cmd/erasure-server-pool.go
defer wg.Done() dobjects[idx], derrs[idx] = pool.DeleteObject(ctx, bucket, object, opts) }(idx, pool) } wg.Wait() // the poolIndices array is pre-sorted in order of latest ModTime, we care only about pool with latest object though // the delete call tries to clean up other pools during DeleteObject call. objInfo = dobjects[0] objInfo.Name = decodeDirObject(object) err = derrs[0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
docs/distributed/CONFIG.md
- Reload() of MinIO server arguments without fully restarting the process. - Expanding 1 node at a time by automating the process of creating a new pool and decommissioning to provide a functionality that smaller deployments
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
} rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) // Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
internal/grid/connection.go
gridLogIf(ctx, err) if m.MuxID == 0 { atomic.StoreInt64(&c.LastPong, time.Now().Unix()) return } if v, ok := c.outgoing.Load(m.MuxID); ok { v.pong(pong) } else { // We don't care if the client was removed in the meantime, // but we send a disconnect message to the server just in case. gridLogIf(ctx, c.queueMsg(message{Op: OpDisconnectClientMux, MuxID: m.MuxID}, nil)) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/bucket-replication.go
case <-mTimer.C: saveMRFToDisk() mTimer.Reset(mrfSaveInterval) case <-p.ctx.Done(): p.mrfStopCh <- struct{}{} xioutil.SafeClose(p.mrfSaveCh) // We try to save if possible, but we don't care beyond that. saveMRFToDisk() return case e, ok := <-p.mrfSaveCh: if !ok { return } entries[e.versionID] = e if len(entries) >= mrfMaxEntries {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
ep, _ := url.Parse(peer.Endpoint) prevEp, _ := url.Parse(prevInfo.Endpoint) targets, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket) if err != nil { continue // site healing will take care of configuring new targets } for _, target := range targets.Targets { if target.SourceBucket == bucket && target.TargetBucket == bucket && target.Endpoint == prevEp.Host &&
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)