- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for corners (0.17 sec)
-
cmd/data-scanner_test.go
es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done() workers := globalExpiryState.workers.Load() for t := range (*workers)[0] { if t, ok := t.(newerNoncurrentTask); ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
internal/config/api/help.go
config.HelpKV{ Key: apiReplicationMaxWorkers, Description: `set the maximum number of replication workers` + defaultHelpPostfix(apiReplicationMaxWorkers), Optional: true, Type: "number", }, config.HelpKV{ Key: apiTransitionWorkers, Description: `set the number of transition workers` + defaultHelpPostfix(apiTransitionWorkers), Optional: true, Type: "number", },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
const envRebalanceWorkers = "_MINIO_REBALANCE_WORKERS" workerSize, err := env.GetInt(envRebalanceWorkers, len(pool.sets)) if err != nil { rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/signals.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "net/http" "os" "strings" "github.com/coreos/go-systemd/v22/daemon" "github.com/minio/minio/internal/logger" ) func handleSignals() { // Custom exit function exit := func(success bool) { if globalLoggerOutput != nil { globalLoggerOutput.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-node.json
}, "exemplar": true, "expr": "sum by (server) (minio_cluster_replication_average_active_workers{job=\"$scrape_jobs\"})", "interval": "1m", "intervalFactor": 2, "legendFormat": "{{server}}", "refId": "A" } ], "title": "Avg. Active Workers", "type": "timeseries" }, { "datasource": { "type": "prometheus",
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) -
cmd/metrics-v2.go
totalFailedCount MetricName = "total_failed_count" totalFailedBytes MetricName = "total_failed_bytes" 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"
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/testdata/undeleteable-object.tgz
aÄ true§MetaUsr‚¤etagÙ d6566afb36d109141150¬content-type°application/json¡v ÎÇ ±” ¤nullÅ , bµvKö; ª *!먵 ®¤@x ^ m§»ú—1É} 100000"},{"key":"queue_dir","value":""}]},"batch":{"_":[{"key":"replication_workers_wait","value":"0ms"},{"key":"keyrotation_workers_wait","value":"0ms"},{"key":"expiration_workers_wait","value":"0ms"}]},"browser":{"_":[{"key":"csp_policy","value":"default-src 'self' 'unsafe-eval' 'unsafe-inline';"},{"key":"hsts_seconds","value":"0"},{"key":"hsts_include_subdomains","value":"...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, // Generic Invalid-Request error. Should be used for response errors only for unlikely // corner case errors for which introducing new APIErrorCode is not worth it. LogIf() // should be used to log the error at the source of the error for debugging purposes. ErrInvalidRequest: { Code: "InvalidRequest",
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/bucket-lifecycle.go
es.mu.Lock() defer es.mu.Unlock() var workers []chan expiryOp if v := es.workers.Load(); v != nil { // Copy to new array. workers = append(workers, *v...) } if n == len(workers) || n < 1 { return } for len(workers) < n { input := make(chan expiryOp, 10000) workers = append(workers, input) go es.Worker(input) es.stats.workers.Add(1) } for len(workers) > n {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/event/targetlist.go
return } } }() } wk.Wait() } var startOnce sync.Once // Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList. func NewTargetList(ctx context.Context) *TargetList { list := &TargetList{
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)