client

Documentation

Index

• func CopyWithContext(ctx context.Context, dst io.Writer, src io.Reader) (written int64, err error)
• type DownloadProgressBar
  • func (dpb *DownloadProgressBar) Abort(drop bool)
  • func (dpb *DownloadProgressBar) IncrBy(n int)
  • func (dpb *DownloadProgressBar) Init(contentLength int64)
  • func (dpb *DownloadProgressBar) ProxyReader(r io.Reader) io.ReadCloser
  • func (dpb *DownloadProgressBar) Wait()
• type ProgressCallback
  • func ProgressBarCallback(ctx context.Context) ProgressCallback
• type RoundTripper
  • func NewRoundTripper(ctx context.Context, inner http.RoundTripper) *RoundTripper
  • func (t *RoundTripper) ProgressComplete()
  • func (t *RoundTripper) ProgressShutdown()
  • func (t *RoundTripper) ProgressWait()
  • func (t *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type UploadProgressBar
  • func (upb *UploadProgressBar) Finish()
  • func (upb *UploadProgressBar) GetReader() io.Reader
  • func (upb *UploadProgressBar) InitUpload(totalSize int64, r io.Reader)
  • func (upb *UploadProgressBar) Terminate()

Functions

func CopyWithContext

func CopyWithContext(ctx context.Context, dst io.Writer, src io.Reader) (written int64, err error)

Types

type DownloadProgressBar

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

DownloadProgressBar is a progress bar that implements the container-library-client ProgressBar interface.

func (*DownloadProgressBar) Abort

func (dpb *DownloadProgressBar) Abort(drop bool)

func (*DownloadProgressBar) IncrBy

func (dpb *DownloadProgressBar) IncrBy(n int)

func (*DownloadProgressBar) Init

func (dpb *DownloadProgressBar) Init(contentLength int64)

func (*DownloadProgressBar) ProxyReader

func (dpb *DownloadProgressBar) ProxyReader(r io.Reader) io.ReadCloser

func (*DownloadProgressBar) Wait

func (dpb *DownloadProgressBar) Wait()

type ProgressCallback

type ProgressCallback func(int64, io.Reader, io.Writer) error

ProgressCallback is a function that provides progress information copying from a Reader to a Writer

func ProgressBarCallback

func ProgressBarCallback(ctx context.Context) ProgressCallback

ProgressBarCallback returns a progress bar callback unless e.g. --quiet or lower loglevel is set

type RoundTripper

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

func NewRoundTripper

func NewRoundTripper(ctx context.Context, inner http.RoundTripper) *RoundTripper

func (*RoundTripper) ProgressComplete

func (t *RoundTripper) ProgressComplete()

ProgressComplete overrides all progress bars, setting them to 100% complete.

func (*RoundTripper) ProgressShutdown

func (t *RoundTripper) ProgressShutdown()

ProgressShutdown immediately shuts down the mpb Progress container.

func (*RoundTripper) ProgressWait

func (t *RoundTripper) ProgressWait()

ProgressWait shuts down the mpb Progress container by waiting for all bars to complete.

func (*RoundTripper) RoundTrip

func (t *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type UploadProgressBar

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

UploadProgressBar is a progress bar that implements the scs-library-client UploadCallback interface.

func (*UploadProgressBar) Finish

func (upb *UploadProgressBar) Finish()

func (*UploadProgressBar) GetReader

func (upb *UploadProgressBar) GetReader() io.Reader

func (*UploadProgressBar) InitUpload

func (upb *UploadProgressBar) InitUpload(totalSize int64, r io.Reader)

func (*UploadProgressBar) Terminate

func (upb *UploadProgressBar) Terminate()