Skip to content

Commit c51a80f

Browse files
committed
Clean up logging
1 parent 0dec0bc commit c51a80f

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

proxy/proxy.go

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -667,20 +667,17 @@ func (c *client) handleExecute(raw *frame.RawFrame, msg *partialExecute, customP
667667
}
668668

669669
func (c *client) handleQuery(raw *frame.RawFrame, msg *partialQuery, customPayload map[string][]byte) {
670-
c.proxy.logger.Debug("handling query", zap.String("query", msg.query), zap.Int16("stream", raw.Header.StreamId))
671-
672670
handled, stmt, err := parser.IsQueryHandled(parser.IdentifierFromString(c.keyspace), msg.query)
673-
674671
if handled {
675-
c.proxy.logger.Debug("Query is handled")
672+
c.proxy.logger.Debug("Query handled by proxy", zap.String("query", msg.query), zap.Int16("stream", raw.Header.StreamId))
676673
if err != nil {
677674
c.proxy.logger.Error("error parsing query to see if it's handled", zap.Error(err))
678675
c.send(raw.Header, &message.Invalid{ErrorMessage: err.Error()})
679676
} else {
680677
c.interceptSystemQuery(raw.Header, stmt)
681678
}
682679
} else {
683-
c.proxy.logger.Debug("Query is not handled")
680+
c.proxy.logger.Debug("Query not handled by proxy, forwarding", zap.String("query", msg.query), zap.Int16("stream", raw.Header.StreamId))
684681
c.execute(raw, c.getDefaultIdempotency(customPayload), c.keyspace, msg)
685682
}
686683
}

0 commit comments

Comments
 (0)