- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for startTs (0.61 sec)
-
cmd/data-usage-cache_gen.go
} case "next": z.next, bts, err = msgp.ReadUint64Bytes(bts) if err != nil { err = msgp.WrapError(err, "next") return } case "started": z.started, bts, err = msgp.ReadTimeBytes(bts) if err != nil { err = msgp.WrapError(err, "started") return } case "cycleCompleted": var zb0002 uint32 zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0) -
cmd/metrics-v2.go
Subsystem: "health", Name: "status", Help: "Get current cluster health status", Type: gaugeMetric, } } func getClusterErasureSetHealthStatusMD() MetricDescription { return MetricDescription{ Namespace: clusterMetricNamespace, Subsystem: "health", Name: "erasure_set_status", Help: "Get current health status for this erasure set", Type: gaugeMetric,
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) -
cmd/object-handlers.go
} // For providing ranged content start, rangeLen, err := rs.GetOffsetLength(ci.Size) if err != nil { start, rangeLen = 0, ci.Size } // Set content length. w.Header().Set(xhttp.ContentLength, strconv.FormatInt(rangeLen, 10)) if rs != nil { contentRange := fmt.Sprintf("bytes %d-%d/%d", start, start+rangeLen-1, ci.Size)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) // assert the HTTP response status code. c.Assert(response.StatusCode, http.StatusOK) // initiate anonymous HTTP request to fetch the object which does not exist. We need to return AccessDenied. response, err = s.client.Get(getGetObjectURL(s.endPoint, bucketName, objectName+".1")) c.Assert(err, nil) // assert the http response status code.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/bucket-replication.go
ReplicationReset = "replication-reset" // ReplicationStatus has internal replication status - stringified representation of target's replication status for all replication // activity initiated from this cluster ReplicationStatus = "replication-status" // ReplicationTimestamp - the last time replication was initiated on this cluster for this object version
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
return errSRInvalidRequest(errInvalidArgument) } userReq := *change.UserReq if userReq.Status != "" && userReq.SecretKey == "" { // Status is set without secretKey updates means we are // only changing the account status. _, err = globalIAMSys.SetUserStatus(ctx, change.AccessKey, userReq.Status) } else { // We don't allow internal user creation with LDAP enabled for now
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/admin-handlers.go
Decrypt: result.Decrypt, Version: result.Version, }) } return stats } func targetStatus(ctx context.Context, h logger.Target) madmin.Status { if h.IsOnline(ctx) { return madmin.Status{Status: string(madmin.ItemOnline)} } return madmin.Status{Status: string(madmin.ItemOffline)} } // fetchLoggerDetails return log info
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2)