- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for SpeedTest (0.55 sec)
-
cmd/speedtest.go
"context" "fmt" "net/url" "runtime" "sort" "time" "github.com/minio/dperf/pkg/dperf" "github.com/minio/madmin-go/v3" xioutil "github.com/minio/minio/internal/ioutil" ) const speedTest = "speedtest" type speedTestOpts struct { objectSize int concurrencyStart int concurrency int duration time.Duration autotune bool storageClass string bucketName string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
cmd/admin-router.go
} adminRouter.Methods(http.MethodPost).Path(adminVersion + "/speedtest").HandlerFunc(adminMiddleware(adminAPI.ObjectSpeedTestHandler, noGZFlag)) adminRouter.Methods(http.MethodPost).Path(adminVersion + "/speedtest/object").HandlerFunc(adminMiddleware(adminAPI.ObjectSpeedTestHandler, noGZFlag)) adminRouter.Methods(http.MethodPost).Path(adminVersion + "/speedtest/drive").HandlerFunc(adminMiddleware(adminAPI.DriveSpeedtestHandler, noGZFlag))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTMethodCommitBinary = "/commitbinary" peerRESTMethodStartProfiling = "/startprofiling" peerRESTMethodDownloadProfilingData = "/downloadprofilingdata" peerRESTMethodSpeedTest = "/speedtest" peerRESTMethodDriveSpeedTest = "/drivespeedtest" peerRESTMethodDevNull = "/devnull" peerRESTMethodNetperf = "/netperf" peerRESTMethodGetReplicationMRF = "/getreplicationmrf" )
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.7K bytes - Viewed (0) -
cmd/perf-tests.go
"github.com/minio/minio-go/v7" xhttp "github.com/minio/minio/internal/http" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/pkg/v2/randreader" ) // SpeedTestResult return value of the speedtest function type SpeedTestResult struct { Endpoint string Uploads uint64 Downloads uint64 UploadTimes madmin.TimeDurations DownloadTimes madmin.TimeDurations DownloadTTFB madmin.TimeDurations
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/object-api-interface.go
DeletePrefixObject bool // set true when object's erasure set is resolvable by object name (using getHashedSetIndex) Speedtest bool // object call specifically meant for SpeedTest code, set to 'true' when invoked by SpeedtestHandler. // Use the maximum parity (N/2), used when saving server configuration files MaxParity bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/admin-handlers.go
} } if !noClear { defer objectAPI.DeleteObject(ctx, customBucket, speedTest+SlashSeparator, ObjectOptions{ DeletePrefix: true, }) } // Freeze all incoming S3 API calls before running speedtest. globalNotificationSys.ServiceFreeze(ctx, true) // unfreeze all incoming S3 API calls after speedtest. defer globalNotificationSys.ServiceFreeze(ctx, false)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/notification.go
results[len(results)-1].Endpoint = u.String() }() wg.Wait() return results } // SpeedTest run GET/PUT tests at input concurrency for requested object size, // optionally you can extend the tests longer with time.Duration. func (sys *NotificationSys) SpeedTest(ctx context.Context, sopts speedTestOpts) []SpeedTestResult { length := len(sys.allPeerClients) if length == 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/object-api-options.go
opts.ProxyHeaderSet = true opts.ProxyRequest = strings.Join(v, "") == "true" } if _, ok := header[xhttp.MinIOSourceReplicationRequest]; ok { opts.ReplicationRequest = true } opts.Speedtest = header.Get(globalObjectPerfUserMetadata) != "" return } // get ObjectOptions for GET calls from encryption headers func getOpts(ctx context.Context, r *http.Request, bucket, object string) (ObjectOptions, error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/erasure-multipart.go
} if !opts.Speedtest && len(versions) > 0 { globalMRFState.addPartialOp(partialOperation{ bucket: bucket, object: object, queued: time.Now(), versions: versions, setIndex: er.setIndex, poolIndex: er.poolIndex, }) } if !opts.Speedtest && len(versions) == 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/peer-rest-client.go
if m == nil { continue } select { case <-ctx.Done(): return case ch <- *m: } } }() return ch, nil } func (client *peerRESTClient) SpeedTest(ctx context.Context, opts speedTestOpts) (SpeedTestResult, error) { values := make(url.Values) values.Set(peerRESTSize, strconv.Itoa(opts.objectSize)) values.Set(peerRESTConcurrent, strconv.Itoa(opts.concurrency))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0)