util

Documentation

Index

• type ProgressReader
  • func NewProgressReader(ctx context.Context, base io.Reader, event entity.EventCode, total int) *ProgressReader
  • func (r *ProgressReader) Read(buf []byte) (int, error)
  • func (r *ProgressReader) ToSeekable() *SeekableProgressReader
• type SeekableProgressReader
  • func (r *SeekableProgressReader) Seek(offset int64, whence int) (int64, error)

Types

type ProgressReader

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

func NewProgressReader

func NewProgressReader(ctx context.Context, base io.Reader, event entity.EventCode, total int) *ProgressReader

func (*ProgressReader) Read

func (r *ProgressReader) Read(buf []byte) (int, error)

func (*ProgressReader) ToSeekable

func (r *ProgressReader) ToSeekable() *SeekableProgressReader

type SeekableProgressReader

type SeekableProgressReader struct {
	ProgressReader
}

func (*SeekableProgressReader) Seek

func (r *SeekableProgressReader) Seek(offset int64, whence int) (int64, error)