- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for mrf (0.02 sec)
-
cmd/bucket-replication-metrics.go
rx.Peak = rx.Curr } rx.N++ } // ReplicationMRFStats holds stats of MRF backlog saved to disk in the last 5 minutes // and number of entries that failed replication after 3 retries type ReplicationMRFStats struct { LastFailedCount uint64 `json:"failedCount_last5min"` // Count of unreplicated entries that were dropped after MRF retry limit reached since cluster start. TotalDroppedCount uint64 `json:"droppedCount_since_uptime"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
opts.Prefix = q.Get("prefix") return } const ( replicationMRFDir = bucketMetaPrefix + SlashSeparator + replicationDir + SlashSeparator + "mrf" mrfMetaFormat = 1 mrfMetaVersionV1 = 1 mrfMetaVersion = mrfMetaVersionV1 ) // MRFReplicateEntry mrf entry to save to disk type MRFReplicateEntry struct { Bucket string `json:"bucket" msg:"b"` Object string `json:"object" msg:"o"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
// for site replication - maintain stats at global level srStats *SRStats // active worker stats workers *ActiveWorkerStat // queue stats cache qCache queueCache pCache proxyStatsCache // mrf backlog stats mrfStats ReplicationMRFStats // for bucket replication, continue to use existing cache Cache map[string]*BucketReplicationStats mostRecentStats BucketStatsMap registry metrics.Registry
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/storage-datatypes.go
Checksum []byte `msg:"cs,allownil"` // Versioned - indicates if this file is versioned or not. Versioned bool `msg:"vs"` } // ShallowCopy - copies minimal information for READ MRF checks. func (fi FileInfo) ShallowCopy() (n FileInfo) { n.Volume = fi.Volume n.Name = fi.Name n.VersionID = fi.VersionID n.Deleted = fi.Deleted n.Erasure = fi.Erasure return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 15.7K bytes - Viewed (0) -
cmd/admin-router.go
adminMiddleware(adminAPI.ReplicationDiffHandler)).Queries("bucket", "{bucket:.*}") // ReplicationMRFHandler - MinIO extension API adminRouter.Methods(http.MethodGet).Path(adminVersion+"/replication/mrf").HandlerFunc( adminMiddleware(adminAPI.ReplicationMRFHandler)).Queries("bucket", "{bucket:.*}") // Batch job operations adminRouter.Methods(http.MethodPost).Path(adminVersion + "/start-job").HandlerFunc(
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 10 21:09:36 UTC 2024 - 25.5K bytes - Viewed (0) -
cmd/peer-rest-client.go
if err != nil { return result, err } defer xhttp.DrainBody(respBody) err = gob.NewDecoder(respBody).Decode(&result) return result, err } // GetReplicationMRF - get replication MRF for bucket func (client *peerRESTClient) GetReplicationMRF(ctx context.Context, bucket string) (chan madmin.ReplicationMRF, error) { values := make(url.Values) values.Set(peerRESTBucket, bucket)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
return } w.(http.Flusher).Flush() case <-ctx.Done(): return } } } // ReplicationMRFHandler - POST returns info on entries in the MRF backlog for a node or all nodes func (a adminAPIHandlers) ReplicationMRFHandler(w http.ResponseWriter, r *http.Request) { ctx := r.Context() vars := mux.Vars(r) bucket := vars["bucket"]
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 32.7K bytes - Viewed (0) -
cmd/notification.go
continue } merged.merge(stat) } return merged } // GetReplicationMRF - Get replication MRF from all peers. func (sys *NotificationSys) GetReplicationMRF(ctx context.Context, bucket, node string) (mrfCh chan madmin.ReplicationMRF, err error) { g := errgroup.WithNErrs(len(sys.peerClients))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
cmd/erasure-sets.go
endpointStrings []string // Total number of sets and the number of disks per set. setCount, setDriveCount int defaultParityCount int poolIndex int // A channel to send the set index to the MRF when // any disk belonging to that set is connected setReconnectEvent chan int // Distribution algorithm of choice. distributionAlgo string deploymentID [16]byte lastConnectDisksOpTime time.Time }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
versions: versions, setIndex: er.setIndex, poolIndex: er.poolIndex, }) } if !opts.Speedtest && len(versions) == 0 { // Check if there is any offline disk and add it to the MRF list for _, disk := range onlineDisks { if disk != nil && disk.IsOnline() { continue } er.addPartial(bucket, object, fi.VersionID) break } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0)