readwriter

Documentation

Index

• type LogPercentage
• type LogPercentageReader
  • func NewLogPercentageReader(reader io.Reader, logger Logger, totalSize int, command, message string) *LogPercentageReader
  • func (lr *LogPercentageReader) Read(b []byte) (int, error)
• type LogPercentageWriter
  • func NewLogPercentageWriter(writer io.Writer, logger Logger, totalSize int, command, message string) *LogPercentageWriter
  • func (lw *LogPercentageWriter) Write(b []byte) (int, error)
• type Logger
• type PausableWriter
  • func NewPausableWriter(out io.Writer) *PausableWriter
  • func (pw *PausableWriter) Pause()
  • func (pw *PausableWriter) Resume() (int, error)
  • func (pw *PausableWriter) Write(p []byte) (int, error)

Types

type LogPercentage

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

type LogPercentageReader

type LogPercentageReader struct {
	Reader io.Reader

	LogPercentage
	// contains filtered or unexported fields
}

func NewLogPercentageReader

func NewLogPercentageReader(reader io.Reader, logger Logger, totalSize int, command, message string) *LogPercentageReader

func (*LogPercentageReader) Read

func (lr *LogPercentageReader) Read(b []byte) (int, error)

type LogPercentageWriter

type LogPercentageWriter struct {
	Writer io.Writer

	LogPercentage
	// contains filtered or unexported fields
}

func NewLogPercentageWriter

func NewLogPercentageWriter(writer io.Writer, logger Logger, totalSize int, command, message string) *LogPercentageWriter

func (*LogPercentageWriter) Write

func (lw *LogPercentageWriter) Write(b []byte) (int, error)

type Logger

type Logger interface {
	Info(tag, msg string, args ...interface{})
}

type PausableWriter

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

func NewPausableWriter

func NewPausableWriter(out io.Writer) *PausableWriter

func (*PausableWriter) Pause

func (pw *PausableWriter) Pause()

func (*PausableWriter) Resume

func (pw *PausableWriter) Resume() (int, error)

func (*PausableWriter) Write

func (pw *PausableWriter) Write(p []byte) (int, error)