- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for probes (0.15 sec)
-
internal/http/dial_linux.go
// TCP starts sending keepalive probes _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15) // Number of probes. // ~ cat /proc/sys/net/ipv4/tcp_keepalive_probes (defaults to 9, we reduce it to 5) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPCNT, 5) // Wait time after successful probe in seconds.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3) -
docs/metrics/prometheus/grafana/minio-dashboard.json
}, "exemplar": true, "expr": "time() - max(minio_node_process_starttime_seconds{job=~\"$scrape_jobs\"})", "format": "time_series", "instant": true, "interval": "", "intervalFactor": 1, "legendFormat": "{{instance}}", "metric": "process_start_time_seconds", "refId": "A", "step": 60 } ],
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 10:03:01 GMT 2024 - 93K bytes - Viewed (2) -
cmd/metrics-v2.go
Type: gaugeMetric, } } func getMinioFDLimitMD() MetricDescription { return MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: fileDescriptorSubsystem, Name: limitTotal, Help: "Limit on total number of open file descriptors for the MinIO Server process", 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) -
buildscripts/verify-healing.sh
done echo "FAILED" purge "$WORK_DIR" exit 1 fi sleep 1 if pgrep minio; then # forcibly killing, to proceed further properly. if ! pkill -9 minio; then echo "no minio process running anymore, proceed." fi fi } function check_heal() { if ! grep -q 'Status:' ${WORK_DIR}/dist-minio-*.log; then return 1 fi for ((i = 0; i < 20; i++)); do
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
cmd/update.go
if err != nil { return t, fmt.Errorf("Unable to get ModTime of %s. %w", absPath, err) } // Return the ModTime return fi.ModTime().UTC(), nil } // GetCurrentReleaseTime - returns this process's release time. If it // is official minio version, parsed version is returned else minio // binary's mod time is returned. func GetCurrentReleaseTime() (releaseTime time.Time, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/erasure-object.go
) { missingBlocks++ } } // if missing metadata can be reconstructed, attempt to reconstruct. // additionally do not heal delete markers inline, let them be // healed upon regular heal process. if missingBlocks > 0 && missingBlocks < fi.Erasure.DataBlocks { globalMRFState.addPartialOp(partialOperation{ bucket: fi.Volume, object: fi.Name, versionID: fi.VersionID,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrHealNoSuchProcess: { Code: "XMinioHealNoSuchProcess", Description: "No such heal process is running on the server", HTTPStatusCode: http.StatusBadRequest, }, ErrHealInvalidClientToken: { Code: "XMinioHealInvalidClientToken", Description: "Client token mismatch",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/object-handlers.go
EventName: event.ObjectRestorePost, BucketName: bucket, Object: objInfo, ReqParams: extractReqParams(r), UserAgent: r.UserAgent(), Host: handlers.GetSourceIP(r), }) // now process the restore in background go func() { rctx := GlobalContext if !rreq.SelectParameters.IsEmpty() { actualSize, err := objInfo.GetActualSize() if err != nil {
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/warm-backend.go
type remoteVersionID string // newWarmBackend instantiates the tier type specific WarmBackend, runs // checkWarmBackend on it. func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) { switch tier.Type { case madmin.S3: d, err = newWarmBackendS3(*tier.S3, tier.Name) case madmin.Azure: d, err = newWarmBackendAzure(*tier.Azure, tier.Name) case madmin.GCS:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/grid/stream.go
// Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0)