diff options
author | Huabing Zhao <zhaohuabing@gmail.com> | 2018-06-29 13:49:52 +0800 |
---|---|---|
committer | Huabing Zhao <zhaohuabing@gmail.com> | 2018-07-02 09:10:04 +0000 |
commit | 370c3f5400a115255fe27a674e325c88187f5dfd (patch) | |
tree | 99aacc73fb60031f40ffce14fa3828470f1a2395 /src/kube2msb/vendor/github.com/juju/ratelimit/reader.go | |
parent | 9ddcc8470c7ed6a2cbddfb079b6396bb58436827 (diff) |
Remove juju/ratelimit to avoid LGPL issuebeijing
Change-Id: I1bf246a713d07fc9891f23ea85fb40c7864f05ef
Issue-ID: OOM-1271
Signed-off-by: Huabing Zhao <zhaohuabing@gmail.com>
Diffstat (limited to 'src/kube2msb/vendor/github.com/juju/ratelimit/reader.go')
-rw-r--r-- | src/kube2msb/vendor/github.com/juju/ratelimit/reader.go | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/src/kube2msb/vendor/github.com/juju/ratelimit/reader.go b/src/kube2msb/vendor/github.com/juju/ratelimit/reader.go deleted file mode 100644 index 6403bf7..0000000 --- a/src/kube2msb/vendor/github.com/juju/ratelimit/reader.go +++ /dev/null @@ -1,51 +0,0 @@ -// Copyright 2014 Canonical Ltd. -// Licensed under the LGPLv3 with static-linking exception. -// See LICENCE file for details. - -package ratelimit - -import "io" - -type reader struct { - r io.Reader - bucket *Bucket -} - -// Reader returns a reader that is rate limited by -// the given token bucket. Each token in the bucket -// represents one byte. -func Reader(r io.Reader, bucket *Bucket) io.Reader { - return &reader{ - r: r, - bucket: bucket, - } -} - -func (r *reader) Read(buf []byte) (int, error) { - n, err := r.r.Read(buf) - if n <= 0 { - return n, err - } - r.bucket.Wait(int64(n)) - return n, err -} - -type writer struct { - w io.Writer - bucket *Bucket -} - -// Writer returns a reader that is rate limited by -// the given token bucket. Each token in the bucket -// represents one byte. -func Writer(w io.Writer, bucket *Bucket) io.Writer { - return &writer{ - w: w, - bucket: bucket, - } -} - -func (w *writer) Write(buf []byte) (int, error) { - w.bucket.Wait(int64(len(buf))) - return w.w.Write(buf) -} |