Versions in this module Expand all Collapse all v1 v1.0.1 Jun 9, 2021 v1.0.0 Jun 9, 2021 Changes in this version + type Monitor struct + func NewMonitor(doneCh <-chan struct{}) *Monitor + func (m *Monitor) DeleteBucket(bucket string) + func (m *Monitor) GetReport(selectBucket SelectionFunction) *madmin.BucketBandwidthReport + type MonitorReaderOptions struct + BandwidthBytesPerSec int64 + Bucket string + ClusterBandwidth int64 + HeaderSize int + Object string + type MonitoredReader struct + func NewMonitoredReader(ctx context.Context, monitor *Monitor, reader io.Reader, ...) *MonitoredReader + func (m *MonitoredReader) Read(p []byte) (n int, err error) + type SelectionFunction func(bucket string) bool + func SelectBuckets(buckets ...string) SelectionFunction
Go to main page