- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for courant (0.19 sec)
-
cmd/data-usage-utils.go
// This does not indicate a full scan. LastUpdate time.Time `json:"lastUpdate"` // Objects total count across all buckets ObjectsTotalCount uint64 `json:"objectsCount"` // Versions total count across all buckets VersionsTotalCount uint64 `json:"versionsCount"` // Delete markers total count across all buckets DeleteMarkersTotalCount uint64 `json:"deleteMarkersCount"` // Objects total size across all buckets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
} } } func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } } func (wg *WaitGroup) C() <-chan struct{} { return wg.done
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
schema/schema_helper_test.go
if len(relations.Relations) != len(rs.Relations) { t.Errorf("schema relations count don't match, expects %d, got %d", len(rs.Relations), len(relations.Relations)) } if len(relations.EmbeddedRelations) != len(rs.EmbeddedRelations) { t.Errorf("schema embedded relations count don't match, expects %d, got %d", len(rs.EmbeddedRelations), len(relations.EmbeddedRelations)) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Dec 15 08:31:23 GMT 2023 - 7.5K bytes - Viewed (0) -
cmd/etcd.go
defer cancel() resp, err := client.Get(timeoutCtx, key) if err != nil { etcdLogOnceIf(ctx, err, "etcd-retrieve-keys") return nil, etcdErrToErr(err, client.Endpoints()) } if resp.Count == 0 { return nil, errConfigNotFound } for _, ev := range resp.Kvs { if string(ev.Key) == key { return ev.Value, nil } } return nil, errConfigNotFound
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
} for i, l := range gotLogs { // For each line, there should be two level string, e.g. // "2021-07-09T03:26:08.984951Z debug debug log" if got, want := strings.Count(l, wantLevels[i]), 2; want != got { t.Errorf("Number of log level string want %v, got %v", want, got) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/metrics-realtime.go
if v != 0 { dm.LifeTimeOps[k] = v } } dm.LastMinute.Operations = make(map[string]madmin.TimedAction, len(d.Metrics.APICalls)) for k, v := range d.Metrics.LastMinute { if v.Count != 0 { dm.LastMinute.Operations[k] = v } } } st, err := disk.GetDriveStats(d.Major, d.Minor) if err == nil { dm.IOStats = madmin.DiskIOStats{ ReadIOs: st.ReadIOs,
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) -
cmd/metrics-v3-cluster-health.go
import "context" const ( healthDrivesOfflineCount = "drives_offline_count" healthDrivesOnlineCount = "drives_online_count" healthDrivesCount = "drives_count" ) var ( healthDrivesOfflineCountMD = NewGaugeMD(healthDrivesOfflineCount, "Count of offline drives in the cluster") healthDrivesOnlineCountMD = NewGaugeMD(healthDrivesOnlineCount, "Count of online drives in the cluster")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/site-replication-metrics.go
LastMinute ReplicationLastMinute // Error counts ErrCounts map[string]int `json:"errCounts"` // Count of credential errors } func (rt *RTimedMetrics) String() string { s := rt.toMetric() return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count) } func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats { if rt == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/os_unix.go
nameTmp := direntNamePool.Get().(*[]byte) defer direntNamePool.Put(nameTmp) tmp := *nameTmp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf count := opts.count for count != 0 { if boff >= nbuf { boff = 0 stop := globalOSMetrics.time(osMetricReadDirent) nbuf, err = syscall.ReadDirent(fd, buf) stop() if err != nil { if isSysErrNotDir(err) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
errors.go
ErrInvalidValueOfLength = errors.New("invalid association values, length doesn't match") // ErrPreloadNotAllowed preload is not allowed when count is used ErrPreloadNotAllowed = errors.New("preload is not allowed when count is used") // ErrDuplicatedKey occurs when there is a unique key constraint violation ErrDuplicatedKey = errors.New("duplicated key not allowed")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 02:53:17 GMT 2024 - 2.5K bytes - Viewed (0)