@@ -101,10 +101,13 @@ func (d *Driver) trace() *trace.Driver {
101101 if d .config != nil {
102102 return d .config .Trace ()
103103 }
104+
104105 return & trace.Driver {}
105106}
106107
107108// Close closes Driver and clear resources
109+ //
110+ //nolint:nonamedreturns
108111func (d * Driver ) Close (ctx context.Context ) (finalErr error ) {
109112 onDone := trace .DriverOnClose (d .trace (), & ctx , stack .FunctionID ("" ))
110113 defer func () {
@@ -214,6 +217,8 @@ func (d *Driver) Topic() topic.Client {
214217// "grpc[s]://{endpoint}/{database}[?param=value]"
215218//
216219// See sugar.DSN helper for make dsn from endpoint and database
220+ //
221+ //nolint:nonamedreturns
217222func Open (ctx context.Context , dsn string , opts ... Option ) (_ * Driver , err error ) {
218223 d , err := newConnectionFromOptions (ctx , append (
219224 []Option {
@@ -246,12 +251,15 @@ func MustOpen(ctx context.Context, dsn string, opts ...Option) *Driver {
246251 if err != nil {
247252 panic (err )
248253 }
254+
249255 return db
250256}
251257
252258// New connects to database and return driver runtime holder
253259//
254260// Deprecated: use Open with required param connectionString instead
261+ //
262+ //nolint:nonamedreturns
255263func New (ctx context.Context , opts ... Option ) (_ * Driver , err error ) {
256264 d , err := newConnectionFromOptions (ctx , opts ... )
257265 if err != nil {
@@ -274,6 +282,7 @@ func New(ctx context.Context, opts ...Option) (_ *Driver, err error) {
274282 return d , nil
275283}
276284
285+ //nolint:cyclop, nonamedreturns
277286func newConnectionFromOptions (ctx context.Context , opts ... Option ) (_ * Driver , err error ) {
278287 ctx , driverCtxCancel := xcontext .WithCancel (xcontext .WithoutDeadline (ctx ))
279288 defer func () {
@@ -321,16 +330,16 @@ func newConnectionFromOptions(ctx context.Context, opts ...Option) (_ *Driver, e
321330 }
322331 if d .logger != nil {
323332 for _ , opt := range []Option {
324- WithTraceDriver (log .Driver (d .logger , d .loggerDetails , d .loggerOpts ... )),
325- WithTraceTable (log .Table (d .logger , d .loggerDetails , d .loggerOpts ... )),
326- WithTraceScripting (log .Scripting (d .logger , d .loggerDetails , d .loggerOpts ... )),
333+ WithTraceDriver (log .Driver (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
334+ WithTraceTable (log .Table (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
335+ WithTraceScripting (log .Scripting (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
327336 WithTraceScheme (log .Scheme (d .logger , d .loggerDetails , d .loggerOpts ... )),
328337 WithTraceCoordination (log .Coordination (d .logger , d .loggerDetails , d .loggerOpts ... )),
329338 WithTraceRatelimiter (log .Ratelimiter (d .logger , d .loggerDetails , d .loggerOpts ... )),
330- WithTraceDiscovery (log .Discovery (d .logger , d .loggerDetails , d .loggerOpts ... )),
331- WithTraceTopic (log .Topic (d .logger , d .loggerDetails , d .loggerOpts ... )),
332- WithTraceDatabaseSQL (log .DatabaseSQL (d .logger , d .loggerDetails , d .loggerOpts ... )),
333- WithTraceRetry (log .Retry (d .logger , d .loggerDetails , d .loggerOpts ... )),
339+ WithTraceDiscovery (log .Discovery (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
340+ WithTraceTopic (log .Topic (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
341+ WithTraceDatabaseSQL (log .DatabaseSQL (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
342+ WithTraceRetry (log .Retry (d .logger , d .loggerDetails , d .loggerOpts ... )), //nolint:contextcheck
334343 } {
335344 if opt != nil {
336345 err = opt (ctx , d )
@@ -341,16 +350,18 @@ func newConnectionFromOptions(ctx context.Context, opts ...Option) (_ *Driver, e
341350 }
342351 }
343352 d .config = config .New (d .options ... )
353+
344354 return d , nil
345355}
346356
357+ //nolint:cyclop, nonamedreturns, funlen
347358func (d * Driver ) connect (ctx context.Context ) (err error ) {
348359 if d .config .Endpoint () == "" {
349- return xerrors .WithStackTrace (errors .New ("configuration: empty dial address" ))
360+ return xerrors .WithStackTrace (errors .New ("configuration: empty dial address" )) //nolint:goerr113
350361 }
351362
352363 if d .config .Database () == "" {
353- return xerrors .WithStackTrace (errors .New ("configuration: empty database" ))
364+ return xerrors .WithStackTrace (errors .New ("configuration: empty database" )) //nolint:goerr113
354365 }
355366
356367 if d .userInfo != nil {
0 commit comments