bandwidthlimiter

package

v0.0.0-...-07bf88e Latest Latest Go to latest Published: Dec 1, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

View Source

var ErrBufferSizeTooLarge = errors.New("buffer size cannot be greater than bucket size")

func BandwidthLimitingCopy(dst *BandwidthLimitingWriter, src io.Reader) (written int64, err error)

type BandwidthLimitingWriter struct {
	// contains filtered or unexported fields
}

func NewBandwidthLimitingWriter(w io.Writer, bucket *Bucket) (*BandwidthLimitingWriter, error)

func (w *BandwidthLimitingWriter) ChunkedWrite(p []byte) (n int, err error)

func (w *BandwidthLimitingWriter) Close() (err error)

func (w *BandwidthLimitingWriter) GetMetrics() (metrics *interop.InvokeResponseMetrics)

func (w *BandwidthLimitingWriter) Write(p []byte) (n int, err error)

type Bucket struct {
	// contains filtered or unexported fields
}

func NewBucket(capacity int64, initialTokenCount int64, refillNumber int64, refillInterval time.Duration) (*Bucket, error)

type ChunkIterator struct {
	// contains filtered or unexported fields
}

func NewChunkIterator(buf []byte, chunkSize int) *ChunkIterator

func (i *ChunkIterator) Next() []byte

type Throttler struct {
	// contains filtered or unexported fields
}

func NewThrottler(bucket *Bucket) (*Throttler, error)