- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for reporter (0.18 sec)
-
migrator/migrator.go
).Error }) } // CurrentDatabase returns current database name func (m Migrator) CurrentDatabase() (name string) { m.DB.Raw("SELECT DATABASE()").Row().Scan(&name) return } // ReorderModels reorder models according to constraint dependencies func (m Migrator) ReorderModels(values []interface{}, autoAdd bool) (results []interface{}) { type Dependency struct { *gorm.Statement Depends []*schema.Schema }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// Context is canceled, return at once. // request canceled, no entries to return return entries, io.EOF } if !errors.Is(err, context.DeadlineExceeded) { // Report error once per bucket, but continue listing. storageLogOnceIf(ctx, err, "GetMetacacheListing:"+o.Bucket) } o.Transient = true o.Create = false o.ID = mustGetUUID() } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/tier.go
Subsystem: tierSubsystem, Name: tierRequestsFailure, Help: "Number of requests to download object from warm tier that failed", Type: counterMetric, } ) func (t *tierMetrics) Report() []MetricV2 { metrics := getHistogramMetrics(t.histogram, tierTTLBMD, true) t.RLock() defer t.RUnlock() for tier, stat := range t.requestsCount { metrics = append(metrics, MetricV2{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if err = udsLogger.StartUDSLogServer(cfg.InstallConfig.LogUDSAddress, ctx.Done()); err != nil { log.Errorf("Failed to start up UDS Log Server: %v", err) return } // Creates a basic health endpoint server that reports health status // based on atomic flag, as set by installer // TODO nodeagent watch server should affect this too, and drop atomic flag installDaemonReady, watchServerReady := nodeagent.StartHealthServer()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
src/archive/zip/zip_test.go
p = p[add:] } for len(p) > 0 { n := copy(ss.buf[ss.start:], p) p = p[n:] ss.start += n if ss.start == ss.keep { ss.start = 0 } } return } // generatesZip64 reports whether f wrote a zip64 file. // f is also responsible for closing w. func generatesZip64(t *testing.T, f func(w *Writer)) bool { ss := &suffixSaver{keep: 10 << 20} w := NewWriter(ss) f(w)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
if wantID == "" { return nil } id, err := p.storage.GetDiskID() if err != nil { return err } if id != wantID { return fmt.Errorf("disk ID %s does not match. disk reports %s", wantID, id) } return nil } // diskHealthCheckOK will check if the provided error is nil // and update disk status if good. // For convenience a bool is returned to indicate any error state
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
src/cmd/api/main_test.go
imported map[string]*apiPackage // packages already imported stdPackages []string // names, omitting "unsafe", internal, and vendored packages importMap map[string]map[string]string // importer dir -> import path -> canonical path importDir map[string]string // canonical import path -> dir } func NewWalker(context *build.Context, root string) *Walker { w := &Walker{
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/notification.go
} reports = append(reports, globalBucketMonitor.GetReport(bandwidth.SelectBuckets(buckets...))) consolidatedReport := bandwidth.BucketBandwidthReport{ BucketStats: make(map[bandwidth.BucketOptions]bandwidth.Details), } for _, report := range reports { if report == nil || report.BucketStats == nil { continue } for opts := range report.BucketStats {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/http-stats.go
totalS35xxErrors: &HTTPAPIStats{}, } } if w == nil { // when response recorder nil, this is an active request hstats.currentS3Requests.Inc(api) bh.httpStats[bucket] = hstats return } // else { hstats.currentS3Requests.Dec(api) // decrement this once we have the response recorder. hstats.totalS3Requests.Inc(api) code := w.StatusCode switch { case code == 0:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
internal/etag/etag.go
func (e ETag) String() string { if e.IsMultipart() { return hex.EncodeToString(e[:16]) + string(e[16:]) } return hex.EncodeToString(e) } // IsEncrypted reports whether the ETag is encrypted. func (e ETag) IsEncrypted() bool { // An encrypted ETag must be at least 32 bytes long. // It contains the encrypted ETag value + an authentication // code generated by the AEAD cipher.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0)