Method ConstructSession

client/sessionpool.go:118–136

(config *PoolConfig)

}

func (spool *SessionPool) ConstructSession(config *PoolConfig) (session Session, err error) {
	if len(config.NodeUrls) > 0 {
		session, err = newClusterSessionWithSqlDialect(getClusterSessionConfig(config))
		if err != nil {
			return session, err
		}
		if err = session.OpenCluster(spool.enableCompression); err != nil {
			log.Print(err)
			return session, err
		}
	} else {
		session = newSessionWithSpecifiedSqlDialect(getSessionConfig(config))
		if err := session.Open(spool.enableCompression, spool.connectionTimeoutInMs); err != nil {
			log.Print(err)
			return session, err
		}
	}
	return session, nil
}

func getSessionConfig(config *PoolConfig) *Config {
	return &Config{