stream_stderr.go

package logger

import (
	"encoding/json"
	"os"

	"github.com/pkg/errors"
)


// StderrStream is the Stream that writes to the standard output
type StderrStream struct {
	*json.Encoder
	FilterLevel Level
}

// Write writes the given Record
//   implements logger.Stream
func (stream *StderrStream) Write(record Record) error {
	if stream.Encoder == nil {
		stream.Encoder = json.NewEncoder(os.Stderr)
		if stream.FilterLevel == 0 {
			stream.FilterLevel = GetLevelFromEnvironment()
		}
	}
	if err := stream.Encoder.Encode(record); err != nil {
		return errors.WithStack(err)
	}
	return nil
}

// ShouldWrite tells if the given level should be written to this stream
//   implements logger.Stream
func (stream *StderrStream) ShouldWrite(level Level) bool {
	return level.ShouldWrite(stream.FilterLevel)
}

// Flush flushes the stream (makes sure records are actually written)
//   implements logger.Stream
func (stream *StderrStream) Flush() {
}

// String gets a string version
//   implements the fmt.Stringer interface
func (stream StderrStream) String() string {
	return "Stream to stderr"
}