Versions in this module Expand all Collapse all v0 v0.0.1 Mar 3, 2026 Changes in this version + func ParseSQLComment(query string) (CommentResult, CommentStatus) + func StripSQLComment(query string) string + type CommentResult struct + ParentID string + TraceID string + type CommentStatus int + const CommentAbsent + const CommentInvalid + const CommentOK + type Correlator struct + func NewCorrelator(ttl time.Duration) *Correlator + func (c *Correlator) ClearActive(traceID, spanID string) + func (c *Correlator) Correlate() (traceID, parentID string) + func (c *Correlator) SetActive(traceID, spanID string) + type DBProtocol interface + HandleConnection func(clientConn, serverConn RawConn, connID uint64, onQuery func(QueryEvent)) + Name func() string + type PGProtocol struct + func (PGProtocol) HandleConnection(clientConn, serverConn RawConn, connID uint64, onQuery func(QueryEvent)) + func (PGProtocol) Name() string + type Proxy struct + func NewProxy(target string, collector *trace.Collector, correlator *Correlator) *Proxy + func (p *Proxy) Close() error + func (p *Proxy) Listen(ctx context.Context, addr string) error + func (p *Proxy) Serve() error + type QueryEvent struct + ConnID uint64 + Duration float64 + Error string + Query string + RowCount int + Start time.Time + type RawConn interface + Close func() error + Read func(b []byte) (n int, err error) + Write func(b []byte) (n int, err error)
Go to main page