logpipe

Documentation

Overview

Package logpipe provides a simple facility for interleaving child process output into your existing logs. TODO(tep): Add much better documentation XXX

Index

• type LogFunc
• type LogPipe
  • func (lp *LogPipe) Add(logFunc LogFunc) (io.Writer, error)
  • func (lp *LogPipe) AddTagged(tag string, logFunc LogFunc) (io.Writer, error)
  • func (lp *LogPipe) Close()
  • func (lp *LogPipe) MustAdd(logFunc LogFunc) io.Writer
  • func (lp *LogPipe) MustAddTagged(tag string, logFunc LogFunc) io.Writer
  • func (lp *LogPipe) Run(ctx context.Context) error

Types

type LogFunc

type LogFunc func(string, ...interface{})

type LogPipe

type LogPipe struct {
	Tag string
	// contains filtered or unexported fields
}

LogPipe is the dispatcher for routing disparate output streams. It's zero value may be used directly or you may use a pointer reference.

func (*LogPipe) Add

func (lp *LogPipe) Add(logFunc LogFunc) (io.Writer, error)

func (*LogPipe) AddTagged

func (lp *LogPipe) AddTagged(tag string, logFunc LogFunc) (io.Writer, error)

func (*LogPipe) Close

func (lp *LogPipe) Close()

func (*LogPipe) MustAdd

func (lp *LogPipe) MustAdd(logFunc LogFunc) io.Writer

func (*LogPipe) MustAddTagged

func (lp *LogPipe) MustAddTagged(tag string, logFunc LogFunc) io.Writer

func (*LogPipe) Run

func (lp *LogPipe) Run(ctx context.Context) error