Method maybeCreateSessionUnlocked

proxy/proxy.go:352–377

(version primitive.ProtocolVersion, keyspace, compression string)

}

func (p *Proxy) maybeCreateSessionUnlocked(version primitive.ProtocolVersion, keyspace, compression string) (*proxycore.Session, error) {
	key := sessionKey{version: version, keyspace: keyspace, compression: compression}
	if cachedSession, ok := p.sessions[key]; ok {
		return cachedSession, nil
	} else {
		sess, err := proxycore.ConnectSession(p.ctx, p.cluster, proxycore.SessionConfig{
			ReconnectPolicy:   p.config.ReconnectPolicy,
			NumConns:          p.config.NumConns,
			Version:           version,
			Auth:              p.config.Auth,
			PreparedCache:     p.preparedCache,
			Keyspace:          keyspace,
			HeartBeatInterval: p.config.HeartBeatInterval,
			ConnectTimeout:    p.config.ConnectTimeout,
			IdleTimeout:       p.config.IdleTimeout,
			Logger:            p.logger,
			Compression:       compression,
		})
		if err != nil {
			return nil, err
		}

		p.sessions[key] = sess
		return sess, nil
	}
}

func (p *Proxy) newQueryPlan() proxycore.QueryPlan {
	return p.lb.NewQueryPlan()