Function NewDriver

driver/driver.go:255–272

(logger g.LoggerType)

}

func NewDriver(logger g.LoggerType) *Driver {
	logger = logger.Named(g.PluginName)
	logger.Info("dtle NewDriver")

	ctx, cancel := context.WithCancel(context.Background())
	AllocIdTaskNameToTaskHandler = newTaskStoreForApi()

	go g.FreeMemoryWorker()
	go g.MemoryMonitor(logger)

	return &Driver{
		eventer:        eventer.NewEventer(ctx, logger),
		tasks:          newTaskStore(),
		ctx:            ctx,
		signalShutdown: cancel,
		logger:         logger,
	}
}

func (d *Driver) SetupNatsServer(logger g.LoggerType) (err error) {
	natsAddr, err := net.ResolveTCPAddr("tcp", d.config.NatsBind)