tap

type AnalyzerConfig struct {
	SlowThreshold   time.Duration
	NPlus1Threshold int
	NPlus1Window    time.Duration
	NPlus1Cooldown  time.Duration
	BindArgs        bool
}

type AnalyzerSink struct {
	// contains filtered or unexported fields
}

type ChannelSink struct {
	Ch chan Event
	// contains filtered or unexported fields
}

type Direction string

type Event struct {
	ID           int64         `json:"id,omitempty"`
	Kind         Kind          `json:"kind"`
	Version      string        `json:"version"`
	Name         string        `json:"name"`
	Direction    Direction     `json:"direction"`
	Index        int           `json:"index,omitempty"`
	StartedAt    time.Time     `json:"started_at"`
	Duration     time.Duration `json:"duration_ns"`
	Operation    string        `json:"operation,omitempty"`
	SQL          string        `json:"sql,omitempty"`
	SQLTemplate  string        `json:"sql_template,omitempty"`
	BoundSQL     string        `json:"bound_sql,omitempty"`
	Args         []any         `json:"args,omitempty"`
	RowsAffected int64         `json:"rows_affected,omitempty"`
	Error        string        `json:"error,omitempty"`
	Slow         bool          `json:"slow,omitempty"`
	NPlus1       bool          `json:"n_plus_1,omitempty"`
	NPlus1Count  int           `json:"n_plus_1_count,omitempty"`
	NPlus1Alert  bool          `json:"n_plus_1_alert,omitempty"`
}

type ExplainMode string

type ExplainResult struct {
	Mode     ExplainMode
	Plan     string
	Duration time.Duration
}

type Filter struct {
	// contains filtered or unexported fields
}

type FuncSink func(Event)

type JSONSink struct {
	// contains filtered or unexported fields
}

type Kind string

type MultiSink []Sink

type NPlus1Detector struct {
	// contains filtered or unexported fields
}

type NPlus1Result struct {
	Matched bool
	Count   int
	Alert   bool
}

type NopSink struct{}

type ObservedTx struct {
	// contains filtered or unexported fields
}

type QueryStat struct {
	SQL           string
	SQLTemplate   string
	Operation     string
	Count         int
	Errors        int
	Slow          int
	NPlus1        int
	TotalDuration time.Duration
	AvgDuration   time.Duration
	MaxDuration   time.Duration
}

type RecorderSink struct {
	// contains filtered or unexported fields
}

type RowWrapper struct {
	// contains filtered or unexported fields
}

type Sink interface {
	Emit(Event)
}

type StmtWrapper struct {
	// contains filtered or unexported fields
}

type Summary struct {
	Total         int
	Execs         int
	Errors        int
	Slow          int
	NPlus1        int
	TotalDuration time.Duration
	Queries       []QueryStat
}