70
71
if time.Now().UTC().Sub(s.sessionInitTime) < sessionRefreshMinInternal {
72
>
s.logger.Warn("gocql wrapper: did not refresh gocql session because the last refresh was too close",
session.go
73
>
tag.Duration("min_refresh_interval_seconds", sessionRefreshMinInternal))
74
>
handler := s.metricsHandler.WithTags(metrics.FailureTag(refreshThrottleTagValue))
75
>
metrics.CassandraSessionRefreshFailures.With(handler).Record(1)
76
>
return
77
>
}
78
79
newSession, err := initSession(s.logger, s.newClusterConfigFunc, s.metricsHandler)