- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for tstones (0.2 sec)
-
cmd/metrics-v3-system-cpu.go
m.Set(sysCPUNice, cpuNiceVal) cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100 m.Set(sysCPUSteal, cpuStealVal) // metrics-resource.go runs a job to collect resource metrics including their Avg values and // stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait. cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem] if found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 3K bytes - Viewed (0) -
internal/logger/reqinfo.go
Key string Val interface{} } // ObjectVersion object version key/versionId type ObjectVersion struct { ObjectName string VersionID string `json:"VersionId,omitempty"` } // ReqInfo stores the request info. // Reading/writing directly to struct requires appropriate R/W lock. type ReqInfo struct { RemoteHost string // Client Host/IP Host string // Node Host/IP
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/bucket-encryption-handlers.go
"github.com/minio/mux" "github.com/minio/pkg/v2/policy" ) const ( // Bucket Encryption configuration file name. bucketSSEConfig = "bucket-encryption.xml" ) // PutBucketEncryptionHandler - Stores given bucket encryption configuration // https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutBucketEncryption.html func (api objectAPIHandlers) PutBucketEncryptionHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/event/targetlist.go
} // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
} // TargetIDResult returns result of Remove/Send operation, sets err if // any for the associated TargetID type TargetIDResult struct { // ID where the remove or send were initiated. ID TargetID // Stores any error while removing a target or while sending an event. Err error } // Remove - closes and removes targets by given target IDs. func (list *TargetList) Remove(targetIDSet TargetIDSet) { list.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
cmd/bucket-policy-handlers.go
maxBucketPolicySize = 20 * humanize.KiByte // Policy configuration file. bucketPolicyConfig = "policy.json" ) // PutBucketPolicyHandler - This HTTP handler stores given bucket policy configuration as per // https://docs.aws.amazon.com/AmazonS3/latest/dev/access-policy-language-overview.html func (api objectAPIHandlers) PutBucketPolicyHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/s3select/sql/aggregation.go
} errInvalidAggregation = errors.New("Invalid aggregation seen") ) type aggVal struct { runningSum *Value runningCount int64 runningMax, runningMin *Value // Stores if at least one record has been seen seen bool } func newAggVal(fn FuncName) *aggVal { switch fn { case aggFnAvg, aggFnSum: return &aggVal{runningSum: FromFloat(0)} case aggFnMin:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
dt.logEntry(duration) } // LogFailure logs an action that hit the timeout func (dt *dynamicTimeout) LogFailure() { dt.logEntry(maxDuration) } // logEntry stores a log entry func (dt *dynamicTimeout) logEntry(duration time.Duration) { if duration < 0 { return } entries := int(atomic.AddInt64(&dt.entries, 1)) index := entries - 1 if index < dynamicTimeoutLogSize {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/bucket-notification-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } writeSuccessResponseXML(w, configData) } // PutBucketNotificationHandler - This HTTP handler stores given notification configuration as per // http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html. func (api objectAPIHandlers) PutBucketNotificationHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 5.1K bytes - Viewed (0) -
cmd/batch-job-common-types.go
if kv.Empty() { return true } if strings.EqualFold(kv.Key, ikv.Key) { return wildcard.Match(kv.Value, ikv.Value) } return false } // BatchJobNotification stores notification endpoint and token information. // Used by batch jobs to notify of their status. type BatchJobNotification struct { line, col int Endpoint string `yaml:"endpoint" json:"endpoint"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 01 21:53:26 GMT 2024 - 7.9K bytes - Viewed (0)