uploadreader

Documentation

Index

• type TransferState
• type UploadCallback
• type UploadReader
  • func New() *UploadReader
  • func NewWithReader(r io.Reader, length int64) *UploadReader
  • func (ur *UploadReader) Elapsed() time.Duration
  • func (ur *UploadReader) Len() int64
  • func (ur *UploadReader) Read(p []byte) (n int, err error)
  • func (ur *UploadReader) SetCallback(callback UploadCallback)
  • func (ur *UploadReader) SetFile(f *os.File) error
  • func (ur *UploadReader) SetInterval(interval time.Duration)
  • func (ur *UploadReader) SetReader(r io.Reader, length int64)
  • func (ur *UploadReader) SetReaderLen64(rl rio.ReaderLen64)
  • func (ur *UploadReader) SpeedPerSecond() int64
  • func (ur *UploadReader) Start() (stopChan <-chan struct{})
  • func (ur *UploadReader) Stop()
  • func (ur *UploadReader) Total() int64
  • func (ur *UploadReader) Transfered() int64

Types

type TransferState

type TransferState interface {
	Transfered() int64
	Total() int64
	SpeedPerSecond() int64
	Elapsed() time.Duration
}

type UploadCallback

type UploadCallback func(state TransferState)

type UploadReader

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

func New

func New() *UploadReader

func NewWithReader

func NewWithReader(r io.Reader, length int64) *UploadReader

func (*UploadReader) Elapsed

func (ur *UploadReader) Elapsed() time.Duration

func (*UploadReader) Len

func (ur *UploadReader) Len() int64

func (*UploadReader) Read

func (ur *UploadReader) Read(p []byte) (n int, err error)

func (*UploadReader) SetCallback

func (ur *UploadReader) SetCallback(callback UploadCallback)

func (*UploadReader) SetFile

func (ur *UploadReader) SetFile(f *os.File) error

func (*UploadReader) SetInterval

func (ur *UploadReader) SetInterval(interval time.Duration)

func (*UploadReader) SetReader

func (ur *UploadReader) SetReader(r io.Reader, length int64)

func (*UploadReader) SetReaderLen64

func (ur *UploadReader) SetReaderLen64(rl rio.ReaderLen64)

func (*UploadReader) SpeedPerSecond

func (ur *UploadReader) SpeedPerSecond() int64

func (*UploadReader) Start

func (ur *UploadReader) Start() (stopChan <-chan struct{})

func (*UploadReader) Stop

func (ur *UploadReader) Stop()

func (*UploadReader) Total

func (ur *UploadReader) Total() int64

func (*UploadReader) Transfered

func (ur *UploadReader) Transfered() int64