Function initConsole

pkg/outputs/console/console.go:54–85

(config outputs.Config)

}

func initConsole(config outputs.Config) (outputs.OutputGroup, error) {
	stdout := os.Stdout
	cfg, ok := config.Output.(Config)
	if !ok {
		return outputs.Fail(outputs.ErrInvalidConfig(outputs.Console, config.Output))
	}
	tmpl := cfg.Template
	if tmpl == "" {
		tmpl = template
	}

	formatter, err := event.NewFormatter(tmpl)
	if err != nil {
		return outputs.Fail(err)
	}

	if cfg.ParamKVDelimiter != "" {
		event.ParamKVDelimiter = cfg.ParamKVDelimiter
	}

	c := &console{
		writer:    bufio.NewWriterSize(stdout, 8*1024),
		formatter: formatter,
		format:    format(cfg.Format),
	}

	if cfg.Colorize {
		c.colorFormatter = event.NewColorFormatter(formatter)
	}

	return outputs.Success(c), nil
}

func (c *console) Close() error   { return c.writer.Flush() }
func (c *console) Connect() error { return nil }