writers

Documentation

Index

• type BoundaryBufferedWriter
  • func NewBoundaryBufferedWriter(w io.Writer, size int) *BoundaryBufferedWriter
  • func (b *BoundaryBufferedWriter) Flush() error
  • func (b *BoundaryBufferedWriter) Write(p []byte) (int, error)
• type SpreadWriter
  • func NewSpreadWriter(w io.Writer, interval time.Duration, exitCh chan int) *SpreadWriter
  • func (s *SpreadWriter) Flush()
  • func (s *SpreadWriter) Write(p []byte) (int, error)

Types

type BoundaryBufferedWriter

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

func NewBoundaryBufferedWriter

func NewBoundaryBufferedWriter(w io.Writer, size int) *BoundaryBufferedWriter

func (*BoundaryBufferedWriter) Flush

func (b *BoundaryBufferedWriter) Flush() error

func (*BoundaryBufferedWriter) Write

func (b *BoundaryBufferedWriter) Write(p []byte) (int, error)

type SpreadWriter

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

func NewSpreadWriter

func NewSpreadWriter(w io.Writer, interval time.Duration, exitCh chan int) *SpreadWriter

func (*SpreadWriter) Flush

func (s *SpreadWriter) Flush()

func (*SpreadWriter) Write

func (s *SpreadWriter) Write(p []byte) (int, error)