()
| 374 | return strings.Contains(upper, "SYSTEM.QUERY_LOG") |
| 375 | } |
| 376 | |
| 377 | // queryLogSink resolves where this connection's query-log entries go. The |
| 378 | // executor sink (the worker, in control-plane mode) wins: the worker owns the |
| 379 | // tenant's query-log storage. |
| 380 | func (c *clientConn) queryLogSink() queryLogEntrySink { |
| 381 | if c.server != nil && c.server.cfg.QueryLog.Enabled && c.executor != nil { |
| 382 | if sink, ok := c.executor.(queryLogEntrySink); ok { |
| 383 | return sink |
| 384 | } |