file_writer

Documentation

Index

• type FileWriter
  • func (f *FileWriter) Close() error
  • func (f *FileWriter) Write(p []byte) (n int, err error)
• type FileWriterFactory
  • func (c *FileWriterFactory) BuildWriter() (io.WriteCloser, error)
• type WriterFactory
  • func BuildFileWriterFactory(filename string, uploader *uploader.UploaderPool) WriterFactory
• type WriterStack
  • func BuildWriterStack(writerBuilder WriterFactory, interruptChannel chan bool) (*WriterStack, error)
  • func (s *WriterStack) Crank()
  • func (s *WriterStack) Rotate()
  • func (s *WriterStack) Write(msg []byte)

Types

type FileWriter

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

func (*FileWriter) Close

func (f *FileWriter) Close() error

func (*FileWriter) Write

func (f *FileWriter) Write(p []byte) (n int, err error)

type FileWriterFactory

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

func (*FileWriterFactory) BuildWriter

func (c *FileWriterFactory) BuildWriter() (io.WriteCloser, error)

type WriterFactory

type WriterFactory interface {
	BuildWriter() (io.WriteCloser, error)
}

func BuildFileWriterFactory

func BuildFileWriterFactory(filename string, uploader *uploader.UploaderPool) WriterFactory

type WriterStack

type WriterStack struct {
	CurrentWriter io.WriteCloser
	NextWriter    io.WriteCloser

	Interrupt chan bool
	// contains filtered or unexported fields
}

func BuildWriterStack

func BuildWriterStack(writerBuilder WriterFactory, interruptChannel chan bool) (*WriterStack, error)

func (*WriterStack) Crank

func (s *WriterStack) Crank()

func (*WriterStack) Rotate

func (s *WriterStack) Rotate()

func (*WriterStack) Write

func (s *WriterStack) Write(msg []byte)