writers

Documentation

Index

• func NewRateLimitWriter(rawWriter io.WriteCloser, rateBytes int64) io.WriteCloser
• type BytesCounterWriter
  • func NewBytesCounterWriter(rawWriter io.Writer) *BytesCounterWriter
  • func (this *BytesCounterWriter) Close() error
  • func (this *BytesCounterWriter) RawWriter() io.Writer
  • func (this *BytesCounterWriter) TotalBytes() int64
  • func (this *BytesCounterWriter) Write(p []byte) (n int, err error)
• type RateLimitWriter
  • func (this *RateLimitWriter) Close() error
  • func (this *RateLimitWriter) Write(p []byte) (n int, err error)
• type TeeWriterCloser
  • func NewTeeWriterCloser(primaryW io.WriteCloser, secondaryW io.WriteCloser) *TeeWriterCloser
  • func (this *TeeWriterCloser) Close() error
  • func (this *TeeWriterCloser) OnFail(onFail func(err error))
  • func (this *TeeWriterCloser) Write(p []byte) (n int, err error)

Functions

func NewRateLimitWriter

func NewRateLimitWriter(rawWriter io.WriteCloser, rateBytes int64) io.WriteCloser

Types

type BytesCounterWriter

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

func NewBytesCounterWriter

func NewBytesCounterWriter(rawWriter io.Writer) *BytesCounterWriter

func (*BytesCounterWriter) Close

func (this *BytesCounterWriter) Close() error

func (*BytesCounterWriter) RawWriter

func (this *BytesCounterWriter) RawWriter() io.Writer

func (*BytesCounterWriter) TotalBytes

func (this *BytesCounterWriter) TotalBytes() int64

func (*BytesCounterWriter) Write

func (this *BytesCounterWriter) Write(p []byte) (n int, err error)

type RateLimitWriter

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

RateLimitWriter 限速写入

func (*RateLimitWriter) Close

func (this *RateLimitWriter) Close() error

func (*RateLimitWriter) Write

func (this *RateLimitWriter) Write(p []byte) (n int, err error)

type TeeWriterCloser

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

func NewTeeWriterCloser

func NewTeeWriterCloser(primaryW io.WriteCloser, secondaryW io.WriteCloser) *TeeWriterCloser

func (*TeeWriterCloser) Close

func (this *TeeWriterCloser) Close() error

func (*TeeWriterCloser) OnFail

func (this *TeeWriterCloser) OnFail(onFail func(err error))

func (*TeeWriterCloser) Write

func (this *TeeWriterCloser) Write(p []byte) (n int, err error)