Function newMultiOutput

start/multi_output.go:34–49

(maxNameLength int, showTimestamps bool)

}

func newMultiOutput(maxNameLength int, showTimestamps bool) *multiOutput {
	o := multiOutput{
		maxNameLength:  utils.Max(maxNameLength, 6),
		showTimestamps: showTimestamps,
		ch:             make(chan *bytes.Buffer, 128),
		done:           make(chan struct{}),
		echoes:         make(map[int64]io.Writer),
		bufPool: sync.Pool{
			New: func() interface{} { return new(bytes.Buffer) },
		},
	}

	go o.listen()

	return &o
}

func (o *multiOutput) Offset() int {
	of := o.maxNameLength + len(outputSeparator)