Function New

internal/msgpipeline/msgpipeline.go:88–95

(globals map[string]interface{}, cfg []config.Node)

}

func New(globals map[string]interface{}, cfg []config.Node) (*MsgPipeline, error) {
	parsedCfg, err := parseMsgPipelineRootCfg(globals, cfg)
	return &MsgPipeline{
		msgpipelineCfg: parsedCfg,
		Resolver:       dns.DefaultResolver(),
		Log:            log.DefaultLogger.Sublogger("msgpipeline"),
	}, err
}

func (d *MsgPipeline) RunEarlyChecks(ctx context.Context, state *module.ConnState) error {
	eg, checkCtx := errgroup.WithContext(ctx)