- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 114 for count (0.16 sec)
-
cmd/site-replication-metrics_gen.go
zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "Count": z.Count, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Count") return } case "Bytes": z.Bytes, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "Bytes") return } default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 40.6K bytes - Viewed (0) -
cmd/bucket-targets.go
updateInProgress: true, count: v.count + 1, bucket: bucket, } } } func (sys *BucketTargetSys) markRefreshDone(bucket, arn string) { sys.aMutex.Lock() defer sys.aMutex.Unlock() if v, ok := sys.arnErrsMap[arn]; ok { sys.arnErrsMap[arn] = arnErrs{ updateInProgress: false, count: v.count, bucket: bucket, } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/metrics-v2.go
} if qs.QStats.Avg.Count > 0 || qs.QStats.Curr.Count > 0 { qt := qs.QStats currInQueueBytes.Value = qt.Curr.Bytes currInQueueCount.Value = qt.Curr.Count avgQueueBytes.Value = qt.Avg.Bytes avgQueueCount.Value = qt.Avg.Count maxQueueBytes.Value = qt.Max.Bytes maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
internal/s3select/sql/parser_test.go
p := participle.MustBuild( &FuncExpr{}, participle.Lexer(sqlLexer), participle.CaseInsensitive("Keyword"), participle.CaseInsensitive("Timeword"), ) validCases := []string{ "count(*)", "sum(2 + s.id)", "sum(t)", "avg(s.id[1])", "coalesce(s.id[1], 2, 2 + 3)", "cast(s as string)", "cast(s AS INT)", "cast(s as DECIMAL)", "extract(YEAR from '2018-01-09')",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/naughty-disk_test.go
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) -
internal/lock/lock.go
var ErrAlreadyLocked = errors.New("file already locked") // RLockedFile represents a read locked file, implements a special // closer which only closes the associated *os.File when the ref count. // has reached zero, i.e when all the readers have given up their locks. type RLockedFile struct { *LockedFile mutex sync.Mutex refs int // Holds read lock refs. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K 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) -
internal/jwt/parser.go
// been checked previously in the stack) and you want to extract values from // it. func ParseUnverifiedStandardClaims(token []byte, claims *StandardClaims, buf []byte) (*SigningMethodHMAC, error) { if bytes.Count(token, []byte(".")) != 2 { return nil, jwtgo.ErrSignatureInvalid } i := bytes.IndexByte(token, '.') j := bytes.LastIndexByte(token, '.') n, err := base64DecodeBytes(token[:i], buf) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
cmd/site-replication-metrics.go
hourTotals := rt.LastHour.getTotal() return madmin.TimedErrStats{ LastMinute: madmin.RStat{ Count: float64(minuteTotals.N), Bytes: minuteTotals.Size, }, LastHour: madmin.RStat{ Count: float64(hourTotals.N), Bytes: hourTotals.Size, }, Totals: madmin.RStat{ Count: float64(rt.SinceUptime.Count), Bytes: rt.SinceUptime.Bytes, }, ErrCounts: errCounts, } }
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/endpoint-ellipses.go
for i := 1; i < len(totalSizes); i++ { result = gcd(result, totalSizes[i]) } return result } // isValidSetSize - checks whether given count is a valid set size for erasure coding. var isValidSetSize = func(count uint64) bool { return (count >= setSizes[0] && count <= setSizes[len(setSizes)-1]) } func commonSetDriveCount(divisibleSize uint64, setCounts []uint64) (setSize uint64) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0)