- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for bandwidth (0.51 sec)
-
pkg/util/bandwidth/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package bandwidth provides utilities for bandwidth shaping
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 16 17:48:21 UTC 2016 - 700 bytes - Viewed (0) -
internal/bucket/bandwidth/measurement.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package bandwidth import ( "sync" "sync/atomic" "time" ) const ( // betaBucket is the weight used to calculate exponential moving average betaBucket = 0.1 // Number of averages considered = 1/(1-betaObject) ) // bucketMeasurement captures the bandwidth details for one bucket type bucketMeasurement struct { lock sync.Mutex
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 03 20:41:51 UTC 2023 - 2.9K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
// GNU Affero General Public License for more details. // // 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 bandwidth //go:generate msgp -file=$GOFILE -unexported import ( "context" "sync" "time" "golang.org/x/time/rate" ) //msgp:ignore bucketThrottle Monitor type bucketThrottle struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.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 bandwidth import ( "context" "io" "math" ) // MonitoredReader represents a throttled reader subject to bandwidth monitoring type MonitoredReader struct { r io.Reader throttle *bucketThrottle ctx context.Context // request context
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/notification.go
peersLogOnceIf(ctx, err, sys.peerClients[index].host.String()) } reports = append(reports, globalBucketMonitor.GetReport(bandwidth.SelectBuckets(buckets...))) consolidatedReport := bandwidth.BucketBandwidthReport{ BucketStats: make(map[bandwidth.BucketOptions]bandwidth.Details), } for _, report := range reports { if report == nil || report.BucketStats == nil { continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_test.go
// GNU Affero General Public License for more details. // // 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 bandwidth import ( "reflect" "testing" "time" ) const ( oneMiB uint64 = 1024 * 1024 ) func TestMonitor_GetReport(t *testing.T) { type fields struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 4.3K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
re-queued for replication. Replication speed depends on the cluster load, number of objects in the object store as well as storage speed. In addition, any bandwidth limits set via `mc admin bucket remote add` could also contribute to replication speed. The number of workers used for replication defaults to 100. Based on network bandwidth and system load, the number of workers used in replication can be configured using `mc admin config set alias api` to set the `replication_workers`. The prometheus...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
getBandwidthRPC = grid.NewSingleHandler[*grid.URLValues, *bandwidth.BucketBandwidthReport](grid.HandlerGetBandwidth, grid.NewURLValues, func() *bandwidth.BucketBandwidthReport { return &bandwidth.BucketBandwidthReport{} })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 52.1K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen_test.go
package bandwidth // Code generated by github.com/tinylib/msgp DO NOT EDIT. import ( "bytes" "testing" "github.com/tinylib/msgp/msgp" ) func TestMarshalUnmarshalBucketBandwidthReport(t *testing.T) { v := BucketBandwidthReport{} bts, err := v.MarshalMsg(nil) if err != nil { t.Fatal(err) } left, err := v.UnmarshalMsg(bts) if err != nil { t.Fatal(err) } if len(left) > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/bucket-stats.go
ReplicatedCount int64 `json:"replicationCount"` // Replication latency information Latency ReplicationLatency `json:"replicationLatency"` // bandwidth limit for target BandWidthLimitInBytesPerSecond int64 `json:"limitInBits"` // current bandwidth reported CurrentBandwidthInBytesPerSecond float64 `json:"currentBandwidth"` // transfer rate for large uploads XferRateLrg *XferStats `json:"-" msg:"lt"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0)