database

type AbstractDatabaseConfigProvider interface {
	ConfigLoader() *Config
}

type AbstractDatabaseManager interface {
	Connect(ctx context.Context) error
	Disconnect() error
	Reconnect(ctx context.Context) error
	Ping(ctx context.Context) error
	HealthCheck(ctx context.Context) *HealthStatus
	GetDB() *bun.DB
	GetSQLDB() *sql.DB
	RunMigrations(ctx context.Context) error
	InitData(ctx context.Context) error
	GetStats() *DBStats
	SetLogger(logger Logger)
}

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

type Config struct {
	ConnectionConfig  ConnectionConfig  `json:"connection_config" toml:"connection_config"`
	DataMigrateConfig DataMigrateConfig `json:"data_migrate_config" toml:"data_migrate_config"`
	DataInitConfig    DataInitConfig    `json:"data_init_config" toml:"data_init_config"`
}

type ConfigurableForeignKeyManager struct {
	*ForeignKeyManager
	// contains filtered or unexported fields
}

type ConnectionConfig = engine.ConnectionConfig

type DBStats struct {
	MaxOpenConns      int           `json:"max_open_conns"`
	OpenConns         int           `json:"open_conns"`
	InUse             int           `json:"in_use"`
	Idle              int           `json:"idle"`
	WaitCount         int64         `json:"wait_count"`
	WaitDuration      time.Duration `json:"wait_duration"`
	MaxIdleClosed     int64         `json:"max_idle_closed"`
	MaxIdleTimeClosed int64         `json:"max_idle_time_closed"`
	MaxLifetimeClosed int64         `json:"max_lifetime_closed"`
}

type DataInitConfig struct {
	AutoInitOnStartup   bool   `json:"auto_init_on_startup" toml:"auto_init_on_startup"`
	AutoInitOnMigration bool   `json:"auto_init_on_migration" toml:"auto_init_on_migration"`
	Filepath            string `json:"filepath" toml:"filepath"`
	Env                 string `json:"env" toml:"env"`
	Environment         string `json:"environment" toml:"environment"`
}

type DataMigrateConfig struct {
	EnableMigrateOnStartup    bool          `json:"enable_migrate_on_startup" toml:"enable_migrate_on_startup"`
	EnableForeignKey          bool          `json:"enable_foreign_key" toml:"enable_foreign_key"`
	ForeignKeyFile            string        `json:"foreign_key_file" toml:"foreign_key_file"`
	EnableSchemaSync          bool          `json:"enable_schema_sync" toml:"enable_schema_sync"`
	AllowColumnAdd            bool          `json:"allow_column_add" toml:"allow_column_add"`
	AllowColumnModify         bool          `json:"allow_column_modify" toml:"allow_column_modify"`
	AllowColumnDrop           bool          `json:"allow_column_drop" toml:"allow_column_drop"`
	AllowIndexAdd             bool          `json:"allow_index_add" toml:"allow_index_add"`
	AllowIndexDrop            bool          `json:"allow_index_drop" toml:"allow_index_drop"`
	EnforceNotNullWithDefault bool          `json:"enforce_not_null_with_default" toml:"enforce_not_null_with_default"`
	SchemaSyncDryRun          bool          `json:"schema_sync_dry_run" toml:"schema_sync_dry_run"`
	SchemaMetaCacheTTL        time.Duration `json:"schema_meta_cache_ttl" toml:"schema_meta_cache_ttl"`
	SchemaMetaCacheLoadOnce   bool          `json:"schema_meta_cache_load_once" toml:"schema_meta_cache_load_once"`
	SchemaMetaAuditLog        bool          `json:"schema_meta_audit_log" toml:"schema_meta_audit_log"`
}

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

type Engine = engine.Engine

type ExecutionResult struct {
	File         string
	Success      bool
	Error        error
	Duration     time.Duration
	RowsAffected int64
}

type ForeignKeyConfig struct {
	ForeignKeys []ForeignKeyConstraintConfig `yaml:"foreign_keys"`
}

type ForeignKeyConstraint struct {
	Table           string
	Column          string
	ReferenceTable  string
	ReferenceColumn string
	OnDelete        string // CASCADE, RESTRICT, SET NULL, NO ACTION
	OnUpdate        string // CASCADE, RESTRICT, SET NULL, NO ACTION
	ConstraintName  string
}

type ForeignKeyConstraintConfig struct {
	Table           string `yaml:"table"`
	Column          string `yaml:"column"`
	ReferenceTable  string `yaml:"reference_table"`
	ReferenceColumn string `yaml:"reference_column"`
	OnDelete        string `yaml:"on_delete"`
	OnUpdate        string `yaml:"on_update"`
	ConstraintName  string `yaml:"constraint_name"`
	Description     string `yaml:"description"`
}

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

type HealthStatus struct {
	Healthy       bool          `json:"healthy"`
	Connected     bool          `json:"connected"`
	ResponseTime  time.Duration `json:"response_time"`
	ActiveConns   int           `json:"active_conns"`
	IdleConns     int           `json:"idle_conns"`
	MaxOpenConns  int           `json:"max_open_conns"`
	LastError     string        `json:"last_error,omitempty"`
	LastCheckTime time.Time     `json:"last_check_time"`
}

type LogLevel = engine.LogLevel

type Logger = engine.Logger

type Migration = engine.Migration

type MigrationFunc func(ctx context.Context, db bun.IDB) error

type MigrationItem struct {
	Version     string
	Name        string
	Description string
	Up          MigrationFunc
	Down        MigrationFunc
}

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

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

type ModelRegistry interface {
	Register(model SQLModel)
	Models() []SQLModel
}

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

type SQLError = engine.SQLError

type SQLFileInfo struct {
	Path        string
	Name        string
	Order       int
	Environment string
	ModTime     time.Time
}

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

type SQLModel interface {
	Instance() interface{}
	Priority() int
}

type SchemaSyncOpKind string

type SchemaSyncOperation struct {
	Table       string           `json:"table"`
	Kind        SchemaSyncOpKind `json:"kind"`
	Name        string           `json:"name"`
	FromName    string           `json:"from_name,omitempty"`
	SQL         string           `json:"sql"`
	Destructive bool             `json:"destructive"`
}

type SchemaSyncPlan struct {
	Engine      string                `json:"engine"`
	GeneratedAt time.Time             `json:"generated_at"`
	Tables      []SchemaSyncTablePlan `json:"tables"`
}

type SchemaSyncTablePlan struct {
	Table      string                `json:"table"`
	Version    string                `json:"version"`
	Hash       string                `json:"hash"`
	PlanText   string                `json:"plan_text"`
	Operations []SchemaSyncOperation `json:"operations"`
}

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