saboreader

Documentation

Index

• type Reader
  • func NewReaderWithContext(ctx context.Context, r io.Reader, workDir string, bw uint64) (*Reader, error)
  • func (s *Reader) CleanUp()
  • func (s *Reader) Read(p []byte) (int, error)
  • func (s *Reader) RefreshLimiter(ctx context.Context) error
  • func (s *Reader) RunRefresh(ctx context.Context)

Types

type Reader

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

Reader reader with limiter

func NewReaderWithContext

func NewReaderWithContext(ctx context.Context, r io.Reader, workDir string, bw uint64) (*Reader, error)

NewReaderWithContext returns a reader that implements io.Reader with rate limiting.

func (*Reader) CleanUp

func (s *Reader) CleanUp()

CleanUp clean up lockfile

func (*Reader) Read

func (s *Reader) Read(p []byte) (int, error)

Read reads bytes into p.

func (*Reader) RefreshLimiter

func (s *Reader) RefreshLimiter(ctx context.Context) error

RefreshLimiter refresh limiter

func (*Reader) RunRefresh

func (s *Reader) RunRefresh(ctx context.Context)

RunRefresh refresh limiter regularly