Method Configure

internal/msgpipeline/module.go:42–60

(inlineArgs []string, cfg *config.Map)

}

func (m *Module) Configure(inlineArgs []string, cfg *config.Map) error {
	var hostname string
	cfg.String("hostname", true, true, "", &hostname)
	cfg.Bool("debug", true, false, &m.log.Debug)
	cfg.AllowUnknown()
	other, err := cfg.Process()
	if err != nil {
		return err
	}

	p, err := New(cfg.Globals, other)
	if err != nil {
		return err
	}
	m.MsgPipeline = p
	m.Log = m.log

	return nil
}

func (m *Module) Name() string {
	return "msgpipeline"