Add NewSession function
Signed-off-by: Michał Matczuk <michal@scylladb.com>
This commit is contained in:
11
session.go
11
session.go
@@ -22,8 +22,19 @@ type Session struct {
|
|||||||
Mapper *reflectx.Mapper
|
Mapper *reflectx.Mapper
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// NewSession wraps existing gocql.session.
|
||||||
|
func NewSession(session *gocql.Session) Session {
|
||||||
|
return Session{
|
||||||
|
Session: session,
|
||||||
|
Mapper: DefaultMapper,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// WrapSession should be called on CreateSession() gocql function to convert
|
// WrapSession should be called on CreateSession() gocql function to convert
|
||||||
// the created session to gocqlx.Session.
|
// the created session to gocqlx.Session.
|
||||||
|
//
|
||||||
|
// Example:
|
||||||
|
// session, err := gocqlx.WrapSession(cluster.CreateSession())
|
||||||
func WrapSession(session *gocql.Session, err error) (Session, error) {
|
func WrapSession(session *gocql.Session, err error) (Session, error) {
|
||||||
return Session{
|
return Session{
|
||||||
Session: session,
|
Session: session,
|
||||||
|
|||||||
Reference in New Issue
Block a user