- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Accent (0.14 sec)
-
docs/metrics/prometheus/grafana/replication/minio-replication-node.json
{ "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "exemplar": true, "expr": "minio_cluster_replication_recent_backlog_count{job=\"$scrape_jobs\"}", "interval": "1m", "legendFormat": "{{server}}", "refId": "A" } ], "title": "Backlog (last 5 mins)",
Json - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:15:39 GMT 2024 - 57.5K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-replication.json
{ "datasource": { "type": "prometheus", "uid": "Prometheus" }, "exemplar": true, "expr": "minio_cluster_replication_recent_backlog_count{job=\"$scrape_jobs\"}", "interval": "1m", "legendFormat": "{{server}}", "refId": "A" } ], "thresholds": [], "timeRegions": [],
Json - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Tue Feb 20 09:45:00 GMT 2024 - 61.5K bytes - Viewed (1) -
cmd/metrics-v2.go
currActiveWorkers MetricName = "current_active_workers" avgActiveWorkers MetricName = "average_active_workers" maxActiveWorkers MetricName = "max_active_workers" recentBacklogCount MetricName = "recent_backlog_count" currInQueueCount MetricName = "last_minute_queued_count" currInQueueBytes MetricName = "last_minute_queued_bytes" receivedCount MetricName = "received_count"
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/server_test.go
expectedMap.Set("Access-Control-Allow-Origin", "http://foobar.com") expectedMap["Access-Control-Expose-Headers"] = []string{ "Date", "Etag", "Server", "Connection", "Accept-Ranges", "Content-Range", "Content-Encoding", "Content-Length", "Content-Type", "Content-Disposition", "Last-Modified", "Content-Language", "Cache-Control", "Retry-After",
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/post-policy_test.go
// Add the bucket condition, only accept buckets equal to the one passed. bucketConditionStr := fmt.Sprintf(`["eq", "$bucket", "%s"]`, bucketName) // Add the key condition, only accept keys equal to the one passed. keyConditionStr := fmt.Sprintf(`["eq", "$key", "%s/upload.txt"]`, objectKey) // Add content length condition, only accept content sizes of a given length.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/grid/stream.go
Requests chan<- []byte muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select { case s.Requests <- b: return nil case <-s.ctx.Done(): return context.Cause(s.ctx) } } // Results returns the results from the remote server one by one.
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) -
internal/http/transports.go
// // if a response to Ping is not received. // trhttp2.PingTimeout = dialTimeout // // DisableCompression, if true, prevents the Transport from // // requesting compression with an "Accept-Encoding: gzip" // trhttp2.DisableCompression = true // } // } return tr } // NewInternodeHTTPTransport returns transport for internode MinIO connections.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.9K bytes - Viewed (0) -
internal/event/targetlist.go
list.eventsSkipped.Add(int64(len(list.queue))) return default: list.eventsSkipped.Add(1) err := fmt.Errorf("concurrent target notifications exceeded %d, configured notification target is too slow to accept events for the incoming request rate", maxConcurrentAsyncSend) for id := range targetIDset { reqInfo := &logger.ReqInfo{} reqInfo.AppendTags("targetID", id.String())
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/http/listener.go
handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } } // Start separate goroutine for each TCP listener to handle connection. for idx, tcpListener := range listener.listeners { go handleListener(idx, tcpListener) } } // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/iam-store.go
// // An in-memory cache must be replaced only if we know for sure that the // values loaded from disk are not stale. They might be stale if the // cached.updatedAt is more recent than the refresh cycle began. if cache.updatedAt.Before(loadedAt) { // No one has updated anything since the config was loaded, // so we just replace whatever is on the disk into memory.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2)