progress

Documentation

Index

• type Event
  • func NewEvent(eventType EventType, transferredBytes int64, totalBytes int64, err error) *Event
• type EventType
• type Listener
• type Request
• type TeeReader
  • func NewTeeReader(reader io.Reader, writer io.Writer, totalBytes int64, ...) *TeeReader
  • func (r *TeeReader) Close() error
  • func (r *TeeReader) Read(p []byte) (int, error)

Types

type Event

type Event struct {
	Type             EventType
	TransferredBytes int64
	TotalBytes       int64
	Err              error
}

func NewEvent

func NewEvent(eventType EventType, transferredBytes int64, totalBytes int64, err error) *Event

type EventType

type EventType int

const (
	TransferStartedEvent EventType = iota
	TransferDataEvent
	TransferCompletedEvent
	TransferFailedEvent
)

type Listener

type Listener interface {
	ProgressChanged(event *Event)
}

type Request

type Request interface {
	SetProgressListener(progressListener Listener)
	GetProgressListener() Listener
	SetProgressInterval(progressInterval int64)
	GetProgressInterval() int64
}

type TeeReader

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

func NewTeeReader

func NewTeeReader(reader io.Reader, writer io.Writer, totalBytes int64, progressListener Listener, progressInterval int64) *TeeReader

func (*TeeReader) Close

func (r *TeeReader) Close() error

func (*TeeReader) Read

func (r *TeeReader) Read(p []byte) (int, error)