I'm using generated bindings from cqlc and pass session object for queries. This works fine but after a while, on query, returns "connection reset error" while while session.Closed api returns false.
sample query with error message is below:
present, e := ctx.Select().From(FOOTABLE).Where(
FOOTABLE.TENANT.Eq(tenant), FOOTABLE.NS.Eq(ns)).Into(FOOTABLE.To(&foo)).
FetchOne(session)
read tcp 10.160.105.22:34614->10.146.86.33:9042: read: connection reset by peer
My understanding is session object should re-establish session upon failure but in this case probably it is not able to detect connection reset ? Any pointers on handling this scenario. thanks..
I'm using generated bindings from cqlc and pass session object for queries. This works fine but after a while, on query, returns "connection reset error" while while session.Closed api returns false.
sample query with error message is below:
My understanding is session object should re-establish session upon failure but in this case probably it is not able to detect connection reset ? Any pointers on handling this scenario. thanks..