querycollector

type CHQueryRecord struct {
	Table        string    `gorm:"column:table"`
	Operation    string    `gorm:"column:operation"`
	SQL          string    `gorm:"column:sql"`
	DurationMS   float64   `gorm:"column:duration_ms"`
	RowsAffected int64     `gorm:"column:rows_affected"`
	ResponseSize int       `gorm:"column:response_size"`
	PreloadCount int       `gorm:"column:preload_count"`
	Timestamp    time.Time `gorm:"column:timestamp"`
	Error        string    `gorm:"column:error"`
	Caller       string    `gorm:"column:caller"`
	CallerURL    string    `gorm:"column:caller_url"`
	DBType       string    `gorm:"column:db_type"`
	Source       string    `gorm:"column:source"`
	Endpoint     string    `gorm:"column:endpoint"`
	ProcessID    string    `gorm:"column:process_id"`
}

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

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

type QueryRecord struct {
	Table        string        `json:"table"`
	Operation    string        `json:"operation"`
	SQL          string        `json:"sql"`
	Duration     time.Duration `json:"duration_ns"`
	DurationMS   float64       `json:"duration_ms"`
	RowsAffected int64         `json:"rows_affected"`
	ResponseSize int           `json:"response_size"`
	PreloadCount int           `json:"preload_count"`
	Timestamp    time.Time     `json:"timestamp"`
	Error        string        `json:"error,omitempty"`
	Caller       string        `json:"caller"`
	CallerURL    string        `json:"caller_url,omitempty"`
	DBType       string        `json:"db_type"`
	Source       string        `json:"source"`
	Endpoint     string        `json:"endpoint"`
}

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

type WriterConfig struct {
	DB             *gorm.DB
	Logger         *zap.Logger
	DisabledTables map[string]struct{}
	BufferSize     int
	FlushSize      int
	FlushInterval  time.Duration
}