Method sendQuery

cmd/cql-proxy/storage/impersonate.go:134–196

(query string, args []driver.NamedValue, queryType types.QueryType)

}

func (d *impersonatedDB) sendQuery(query string, args []driver.NamedValue, queryType types.QueryType) (
	resp *types.Response, err error) {
	var (
		connID, seqNo = allocateConnAndSeq()
		dArgs         []types.NamedArg
	)

	defer putBackConn(connID)

	for _, arg := range args {
		dArgs = append(dArgs, types.NamedArg{
			Name:  arg.Name,
			Value: arg.Value,
		})
	}

	req := &types.Request{
		Header: types.SignedRequestHeader{
			RequestHeader: types.RequestHeader{
				QueryType:    queryType,
				NodeID:       d.nodeID,
				DatabaseID:   d.db,
				ConnectionID: connID,
				SeqNo:        seqNo,
				Timestamp:    time.Now().UTC(),
			},
		},
		Payload: types.RequestPayload{
			Queries: []types.Query{
				{
					Pattern: query,
					Args:    dArgs,
				},
			},
		},
	}
	resp = &types.Response{}

	if err = req.Sign(d.key); err != nil {
		err = errors.Wrapf(err, "sign query failed")
		return
	}

	err = d.rpc.Call(route.DBSQuery.String(), req, resp)
	if err != nil {
		err = errors.Wrapf(err, "send query rpc failed")
		return
	}

	// add ack
	go d.sendAck(&types.Ack{
		Header: types.SignedAckHeader{
			AckHeader: types.AckHeader{
				Response:     resp.Header.ResponseHeader,
				ResponseHash: resp.Header.Hash(),
				NodeID:       d.nodeID,
				Timestamp:    time.Now().UTC(),
			},