concurrentWriter

Documentation

Index

• type ConcurrentWriter
  • func NewConcurrentWriter(runners []WriterRunner, writer ...io.Writer) *ConcurrentWriter
  • func (c *ConcurrentWriter) Close() error
  • func (c *ConcurrentWriter) GetRunners() []WriterRunner
  • func (c *ConcurrentWriter) Write(p []byte) (n int, err error)
• type GenericCopyRunner
  • func NewGenericCopyRunner(writer io.Writer, name string) *GenericCopyRunner
  • func (w *GenericCopyRunner) Do(reader io.Reader, done chan bool)
  • func (w *GenericCopyRunner) GetError() error
  • func (w *GenericCopyRunner) GetName() string
• type WriterRunner

Types

type ConcurrentWriter

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

func NewConcurrentWriter

func NewConcurrentWriter(runners []WriterRunner, writer ...io.Writer) *ConcurrentWriter

func (*ConcurrentWriter) Close

func (c *ConcurrentWriter) Close() error

Close closes all pipes. It does not close the underlying writer

func (*ConcurrentWriter) GetRunners

func (c *ConcurrentWriter) GetRunners() []WriterRunner

func (*ConcurrentWriter) Write

func (c *ConcurrentWriter) Write(p []byte) (n int, err error)

type GenericCopyRunner

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

func NewGenericCopyRunner

func NewGenericCopyRunner(writer io.Writer, name string) *GenericCopyRunner

func (*GenericCopyRunner) Do

func (w *GenericCopyRunner) Do(reader io.Reader, done chan bool)

func (*GenericCopyRunner) GetError

func (w *GenericCopyRunner) GetError() error

func (*GenericCopyRunner) GetName

func (w *GenericCopyRunner) GetName() string

type WriterRunner

type WriterRunner interface {
	Do(reader io.Reader, done chan bool)
	GetName() string
}