concurrentWriter

package

v2.0.7 Latest Latest Go to latest Published: Mar 16, 2023 License: Apache-2.0 Imports: 3 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

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 WriterRunner interface {
	Do(reader io.Reader, done chan bool)
	GetName() string
}