- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 125 for walkers (0.14 sec)
-
cmd/batch-expire_test.go
purge: # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest. # retainVersions: 5 # keep the latest 5 versions of the object including delete markers. notify: endpoint: https://notify.endpoint # notification endpoint to receive job completion status token: Bearer xxxxx # optional authentication token for the notification endpoint retry:
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages wTimer *time.Ticker // ticker for calculating active workers qTimer *time.Ticker // ticker for calculating queue stats } func (r *ReplicationStats) trackEWMA() { for { select {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 13.6K bytes - Viewed (0) -
internal/config/heal/help.go
Optional: true, Type: "int", }, config.HelpKV{ Key: DriveWorkers, Description: `the number of workers per drive to heal a new disk replacement` + defaultHelpPostfix(DriveWorkers), Optional: true, Type: "int", }, }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 11 21:48:54 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/http/close.go
// convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it. // If resp.Body is not closed, the Client's underlying RoundTripper // (typically Transport) may not be able to reuse a persistent TCP
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/config/api/api.go
if err != nil { return cfg, err } if replicationMaxWorkers <= 0 || replicationMaxWorkers > 500 { return cfg, config.ErrInvalidReplicationWorkersValue(nil).Msg("Number of replication workers should be between 1 and 500") } cfg.ReplicationMaxWorkers = replicationMaxWorkers
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 11.5K bytes - Viewed (1) -
tensorflow/c/eager/immediate_execution_distributed_manager.h
int64_t init_timeout_in_ms, int retries, bool clear_existing_contexts = false) = 0; // Initializes context for the local worker and no contexts will be created // for remote workers. Currently this only works for resetting context. // TODO(b/289445025): Consider removing this when we find a proper fix. virtual absl::Status InitializeLocalOnlyContext(const ServerDef& server_def,
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 2.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", },
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/batch-handlers.go
// newBatchJobPool creates a pool of job manifest workers of specified size func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool { jpool := &BatchJobPool{ ctx: ctx, objLayer: o, jobCh: make(chan *BatchJobRequest, 10000), workerKillCh: make(chan struct{}, workers), jobCancelers: make(map[string]context.CancelFunc), }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 18 15:32:09 UTC 2024 - 62.2K bytes - Viewed (0) -
docs/bucket/versioning/README.md
> NOTE: Server side replication is supported for idempotent versions on directory objects. ### Idempotent versions on delete markers
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 04 21:43:52 UTC 2023 - 11.9K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
} ] } ``` ### 3.3 Automatic removal of delete markers with no other versions When an object has only one version as a delete marker, the latter can be automatically removed after a certain number of days using the following configuration: ``` { "Rules": [ { "ID": "Removing all delete markers", "Expiration": { "ExpiredObjectDeleteMarker": true
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 09 01:45:38 UTC 2024 - 9K bytes - Viewed (0)