log

Documentation

Index

• Variables
• type MirrorWriter
  • func NewMirrorWriter() *MirrorWriter
  • func (mw *MirrorWriter) Active() (active bool)
  • func (mw *MirrorWriter) AddWriter(w io.WriteCloser)
  • func (mw *MirrorWriter) Close() error
  • func (mw *MirrorWriter) Write(b []byte) (int, error)

Variables

var MaxWriterBuffer = 512 * 1024

MaxWriterBuffer specifies how big the writer buffer can get before killing the writer.

var WriterGroup = NewMirrorWriter()

WriterGroup is the global writer group for logs to output to

Types

type MirrorWriter

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

MirrorWriter implements a WriteCloser which syncs incoming bytes to multiple [buffered] WriteClosers. They can be added with AddWriter().

func NewMirrorWriter

func NewMirrorWriter() *MirrorWriter

NewMirrorWriter initializes and returns a MirrorWriter.

func (*MirrorWriter) Active

func (mw *MirrorWriter) Active() (active bool)

Active returns if there is at least one Writer attached to this MirrorWriter

func (*MirrorWriter) AddWriter

func (mw *MirrorWriter) AddWriter(w io.WriteCloser)

AddWriter attaches a new WriteCloser to this MirrorWriter. The new writer will start getting any bytes written to the mirror.

func (*MirrorWriter) Close

func (mw *MirrorWriter) Close() error

Close closes the MirrorWriter

func (*MirrorWriter) Write

func (mw *MirrorWriter) Write(b []byte) (int, error)

Write broadcasts the written bytes to all Writers.