- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Petrie (0.16 sec)
-
cmd/bootstrap-peer-server.go
// herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 { logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2)) if len(offlineEndpoints) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
docs/metrics/prometheus/README.md
The command will generate the `scrape_configs` section of the prometheus.yml as follows: ##### Cluster
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 15:49:30 GMT 2024 - 7.1K bytes - Viewed (0) -
docs/orchestration/docker-compose/docker-compose.yaml
- "9000" - "9001" # environment: # MINIO_ROOT_USER: minioadmin # MINIO_ROOT_PASSWORD: minioadmin healthcheck: test: ["CMD", "mc", "ready", "local"] interval: 5s timeout: 5s retries: 5 # starts 4 docker containers running minio server instances. # using nginx reverse proxy, load balancing, you can access # it through port 9000. services: minio1: <<: *minio-common hostname: minio1
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 02:45:52 GMT 2024 - 1.5K bytes - Viewed (1) -
cmd/os-instrumented.go
startTime := time.Now() return func() { duration := time.Since(startTime) atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(duration) } } // incTime will increment time on metric s with a specific duration. func (o *osMetrics) incTime(s osMetric, d time.Duration) { atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(d) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/os-reliable.go
// windows, because windows API does not return "not a // directory" error message. Handle this specifically // here. return errFileAccessDenied } } return err } // Reliably retries os.RemoveAll if for some reason os.RemoveAll returns // syscall.ENOTEMPTY (children has files). func reliableRemoveAll(dirPath string) (err error) { i := 0 for { // Removes all the directories and files.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/site-replication-metrics.go
t = &m } mx[Total] = *t metric := SRMetric{ ReplicatedSize: v.ReplicatedSize, ReplicatedCount: v.ReplicatedCount, DeploymentID: dID, Failed: v.Failed.toMetric(), XferStats: mx, } epHealth, ok := epMap[v.Endpoint] if ok { metric.Endpoint = epHealth.Endpoint metric.TotalDowntime = epHealth.offlineDuration metric.LastOnline = epHealth.lastOnline
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) -
internal/kms/kms.go
// IsLocal returns true if the KMS is a local implementation IsLocal() bool // List returns an array of local KMS Names List() []kes.KeyInfo // Metrics returns a KMS metric snapshot. Metrics(ctx context.Context) (kes.Metric, error) // CreateKey creates a new key at the KMS with the given key ID. CreateKey(ctx context.Context, keyID string) error // GenerateKey generates a new data encryption key using the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/kms/single-key.go
func (kms secretKey) List() []kes.KeyInfo { kmsSecret := []kes.KeyInfo{ { Name: kms.keyID, }, } return kmsSecret } func (secretKey) Metrics(ctx context.Context) (kes.Metric, error) { return kes.Metric{}, Error{ HTTPStatusCode: http.StatusNotImplemented, APICode: "KMS.NotImplemented", Err: errors.New("metrics are not supported"), } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
for _, d := range mg.Descriptors { labels := slices.Clone(d.VariableLabels) labels = append(labels, commonLabels...) metric := metricDisplay{ Name: mg.MetricFQN(d.Name), Help: d.Help, Type: d.Type.String(), Labels: labels, } metrics = append(metrics, metric) } } } return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/leak-detect_test.go
package cmd import ( "runtime/debug" "sort" "strings" "time" ) const ( // deadline (in seconds) up to which the go routine leak detection has to be retried. leakDetectDeadline = 5 // pause time (in milliseconds) between each snapshot at the end of the go routine leak detection. leakDetectPauseTimeMs = 50 ) // LeakDetect - type with methods for go routine leak detection.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0)