feat: restart connection changes

[andihaskel]

Description

Se implementa un wrapper donde se realiza un restart de la session si hay un fallo de tipo gocql: no hosts available in the pool y se vuelve a intentar ejecutar la query N cantidad de intentos

Task Context

What is the current behavior?

What is the new behavior?

Additional Context

Checklist

How was it tested?

• unit
• integration
• other (specify)

Updated services

• Does your code follow the project style guide?
• Have you added tests that cover the changes and run them?

[gabrielbursztein2]

Por que no manejamos el error?

[andihaskel]

deberiamos mandarlo a sentry o algo. Esto va a intentar hacer un restart N cantidad de attempts, si falla despues de los intentos lo va a retornar en execFunc

[gabrielbursztein2]

Digo, no deberíamos omitir el error que devueve el r.client.Restart()

[danteay]

se quito porque alli esta el dema del log de debug, tuvimos probelas de serializacion porque el cliente tiene la config que a si vez tiene una propiedad que no es serializable a json PrintFn y esto generaba un panic en el framework. la idea es que pongamos un sistema de logging mas estandarizado como lo tiene por ejemplo gorm que es una interface independiente modificable.

[gabrielbursztein2]

Podemos ponerle createSession?

getSession me suena mas a un singleton

[gabrielbursztein2]

Suggested change

	func NewClientWithSession(session *gocql.Session, conf models.Config) (Client, error) {
	c := &client{
	session: session,
	config: conf,
	canRestart: false,
	}
	return c, nil
	}
	func NewClientWithSession(session *gocql.Session, conf models.Config) Client {
	return &client{
	session: session,
	config: conf,
	canRestart: false,
	}
	}

[gabrielbursztein2]

Suggested change

	func NewClientWithSession(session *gocql.Session, conf models.Config) (Client, error) {
	return &client{
	session: session,
	config: conf,
	canRestart: false,
	}, nil
	}
	func NewClientWithSession(session *gocql.Session, conf models.Config) Client {
	return &client{
	session: session,
	config: conf,
	canRestart: false,
	}
	}

[gabrielbursztein2]

Suggested change

	t.Errorf("exp: test got: %v", q.table)
	return
	t.FatalF("exp: test got: %v", q.table)

[gabrielbursztein2]

Suggested change

	t.Errorf("exp: test2 got: %v", q.table)
	return
	t.FatalF("exp: test2 got: %v", q.table)

[gabrielbursztein2]

No te deja usarlo si es privado? Esta dentro del mismo paquete 🤔

[gabrielbursztein2]

🥇