- Sort Score
- Result 10 results
- Languages All
Results 951 - 960 of 1,178 for rsync (0.03 sec)
-
docs/site-replication/run-multi-site-minio-idp.sh
echo "expected 'bucket2' delete and 'newbucket2' creation to have replicated, exiting..." exit_1 fi # force a resync after removing all site replication ./mc admin replicate rm --all --force minio1 ./mc rb minio2 --force --dangerous ./mc admin replicate add minio1 minio2 ./mc admin replicate resync start minio1 minio2 sleep 30 ./mc ls -r --versions minio1/newbucket >/tmp/minio1.txt
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 08:03:58 UTC 2024 - 12.1K bytes - Viewed (0) -
cmd/naughty-disk_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "sync" "time" "github.com/minio/madmin-go/v3" ) // naughtyDisk wraps a POSIX disk and returns programmed errors // specified by the developer. The purpose is to simulate errors
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0) -
cmd/tier.go
// TierConfigMgr holds the collection of remote tiers configured in this deployment. type TierConfigMgr struct { sync.RWMutex `msg:"-"` drivercache map[string]WarmBackend `msg:"-"` Tiers map[string]madmin.TierConfig `json:"tiers"` lastRefreshedAt time.Time `msg:"-"` } type tierMetrics struct { sync.RWMutex // protects requestsCount only requestsCount map[string]struct { success int64 failure int64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/s3select/select.go
func init() { parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn } var bufPool = sync.Pool{ New: func() interface{} { // make a buffer with a reasonable capacity. return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = sync.Pool{ New: func() interface{} { // io.Discard is just used to create the writer. Actual destination
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0) -
internal/kms/kes.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package kms import ( "context" "errors" "net/http" "sync" "time" "github.com/minio/kms-go/kes" "github.com/minio/madmin-go/v3" ) type kesConn struct { defaultKeyID string client *kes.Client }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
docs/metrics/v3.md
|-----------------------------------------------|-------------------------------------------------------------------------------------------------------|----------| | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter | `server` |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 02 22:30:11 UTC 2024 - 45.2K bytes - Viewed (0) -
internal/rest/rpc-stats.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package rest import ( "net/http" "net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 tcpTimeForFirstByteTotalDur uint64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 18:21:34 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
package plugin import ( "bytes" "context" "crypto/sha1" "encoding/base64" "encoding/json" "fmt" "io" "net/http" "net/url" "regexp" "sync" "time" "github.com/minio/minio/internal/arn" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/env" xnet "github.com/minio/pkg/v3/net" )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_test.cc
return TensorHandlePtr(result_handle); } void TestCollective(bool async) { std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status( TF_NewStatus(), TF_DeleteStatus); std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts( TFE_NewContextOptions(), TFE_DeleteContextOptions); TFE_ContextOptionsSetAsync(opts.get(), async); std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config(
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 06 23:56:17 UTC 2024 - 29.4K bytes - Viewed (0) -
cmd/prepare-storage.go
package cmd import ( "context" "errors" "fmt" "net/http" "net/url" "path/filepath" "sync" "time" "github.com/dustin/go-humanize" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" ) var printEndpointError = func() func(Endpoint, error, bool) { var mutex sync.Mutex printOnce := make(map[Endpoint]map[string]int) return func(endpoint Endpoint, err error, once bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0)