Client represents a client for interacting with a ClickHouse database. Batch processing for different event types is handled externally via NewBuffer[T], which wires a *batch.BatchProcessor to this client's connection, retry policy, and circuit breaker.
| 19 | // NewBuffer[T], which wires a *batch.BatchProcessor to this client's |
| 20 | // connection, retry policy, and circuit breaker. |
| 21 | type Client struct { |
| 22 | conn ch.Conn |
| 23 | circuitBreaker *circuitbreaker.CB[struct{}] |
| 24 | retry *retry.Retry |
| 25 | } |
| 26 | |
| 27 | var ( |
| 28 | _ Querier = (*Client)(nil) |
nothing calls this directly
no outgoing calls
no test coverage detected