func()

in qldbdriver/qldbdriver.go [209:223]


func (driver *QLDBDriver) Shutdown(ctx context.Context) {
	driver.lock.Lock()
	defer driver.lock.Unlock()
	if !driver.isClosed {
		driver.isClosed = true
		for len(driver.sessionPool) > 0 {
			session := <-driver.sessionPool
			err := session.endSession(ctx)
			if err != nil {
				driver.logger.logf(LogDebug, "Encountered error trying to end session: '%v'", err.Error())
			}
		}
		close(driver.sessionPool)
	}
}