- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,344 for Report (0.15 sec)
-
cmd/metrics-realtime.go
} if types.Contains(madmin.MetricsScanner) { metrics := globalScannerMetrics.report() m.Aggregated.Scanner = &metrics } if types.Contains(madmin.MetricsOS) { metrics := globalOSMetrics.report() m.Aggregated.OS = &metrics } if types.Contains(madmin.MetricsBatchJobs) { m.Aggregated.BatchJobs = globalBatchJobsMetrics.report(opts.jobID) } if types.Contains(madmin.MetricsSiteResync) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 10 16:28:08 GMT 2024 - 6.1K bytes - Viewed (0) -
misc/linkcheck/linkcheck.go
// The linkcheck command finds missing links in the godoc website. // It crawls a URL recursively and notes URLs and URL fragments // that it's seen and prints a report of missing links at the end. package main import ( "errors" "flag" "fmt" "io" "log" "net/http" "os" "regexp" "strings" "sync" ) var (
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Oct 06 15:53:04 GMT 2021 - 3.9K bytes - Viewed (0) -
cmd/leak-detect_test.go
if len(leaked) == 0 { return } // wait a test again will deadline. if UTCNow().Before(deadline) { time.Sleep(leakDetectPauseTimeMs * time.Millisecond) continue } // after the deadline time report all the difference in the latest snapshot compared with the initial one. for _, g := range leaked { t.Errorf("Leaked goroutine: %v", g) } return } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} // healSequence - state for each heal sequence initiated on the // server. type healSequence struct { // bucket, and object on which heal seq. was initiated bucket, object string // Report healing progress reportProgress bool // time at which heal sequence was started startTime time.Time // time at which heal sequence has ended endTime time.Time // Heal client info
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/metrics.go
totalDisks := offlineDisks.Merge(onlineDisks) // Report total capacity ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"), "Total capacity online in the cluster", nil, nil), prometheus.GaugeValue, float64(GetTotalCapacity(server.Disks)), ) // Report total capacity free ch <- prometheus.MustNewConstMetric(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/os-instrumented.go
func Fdatasync(f *os.File) (err error) { fn := "" if f != nil { fn = f.Name() } defer updateOSMetrics(osMetricFdatasync, fn)(err) return disk.Fdatasync(f) } // report returns all os metrics. func (o *osMetrics) report() madmin.OSMetrics { var m madmin.OSMetrics m.CollectedAt = time.Now() m.LifeTimeOps = make(map[string]uint64, osMetricLast) for i := osMetric(0); i < osMetricLast; i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cni/pkg/log/uds.go
func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) { if req.Body == nil { return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil { log.Errorf("Failed to read log report from cni plugin: %v", err) return } l.processLog(data) } func (l *UDSLogger) processLog(body []byte) { cniLogs := make([]string, 0) err := json.Unmarshal(body, &cniLogs) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
internal/dsync/dsync_test.go
t.Fatal("Lock context canceled which is not expected") case <-timer.C: } // Should be safe operation in all cases dm.Unlock(context.Background()) } // Test canceling context while quorum servers report lock not found func TestFailedRefreshLock(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") } // Simulate Refresh response to return no locking found
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/xl-storage-free-version_test.go
_, err = xl.DeleteVersion(tierfi) fatalErr(err) report() fvIDs := []string{ "00000000-0000-0000-0000-0000000000f1", "00000000-0000-0000-0000-0000000000f2", } // Simulate overwrite of null version newtierfi := tierfi newtierfi.SetTierFreeVersionID(fvIDs[0]) fatalErr(xl.AddFreeVersion(newtierfi)) report() fatalErr(xl.AddVersion(newtierfi)) report() // Simulate removal of null version
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/generic-handlers_test.go
if !guessIsRPCReq(r) { t.Fatal("Test shouldn't fail for a possible net/rpc request.") } r = &http.Request{ Proto: "HTTP/1.1", Method: http.MethodGet, } if guessIsRPCReq(r) { t.Fatal("Test shouldn't report as net/rpc for a non net/rpc request.") } r = &http.Request{ Proto: "HTTP/1.1", Method: http.MethodGet, URL: &url.URL{Path: grid.RoutePath}, } if !guessIsRPCReq(r) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 5.4K bytes - Viewed (0)