dbcore

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

type Config struct {
	RWDSN                    string
	RODSN                    string
	PgBouncerTransactionMode bool
	MaxOpenConnections       int
	MaxIdleConnections       int
	ConnectionMaxLifetime    time.Duration
	ConnectionMaxIdleTime    time.Duration
	PingTimeout              time.Duration
	SlowQuery                SlowQueryConfig
}

type CursorResult[T any] struct {
	Items      []T    `json:"items"`
	NextCursor string `json:"next_cursor"`
	HasMore    bool   `json:"has_more"`
	Limit      int    `json:"limit"`
}

type DatabaseError struct {
	Kind ErrorKind
	// contains filtered or unexported fields
}

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

type EphemeralSession struct {
	SessionID string    `json:"session_id"`
	TableName string    `json:"table_name"`
	TotalRows int       `json:"total_rows"`
	ExpiresAt time.Time `json:"expires_at"`
}

type ErrorKind string

type Migration struct {
	ID      string
	Version int
	Name    string
	SQL     string
	UpSQL   string
	DownSQL string
}

type MigrationDatabase interface {
	BeginTx(context.Context, *sql.TxOptions) (*sql.Tx, error)
	Dialect() string
}

type ORM[T any] struct {
	// contains filtered or unexported fields
}

type ParallelTask struct {
	QueryName string
	SQL       string
	Args      []any
}

type Repository[T any] struct {
	// contains filtered or unexported fields
}

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

type SQLiteConfig struct {
	Path                  string
	DSN                   string
	DirectoryMode         os.FileMode
	BusyTimeout           time.Duration
	ForeignKeys           *bool
	MaxOpenConnections    int
	MaxIdleConnections    int
	ConnectionMaxLifetime time.Duration
	ConnectionMaxIdleTime time.Duration
	ReadOnly              bool
	InMemory              bool
	PingTimeout           time.Duration
	SlowQuery             SlowQueryConfig
}

type SlowQueryConfig struct {
	Threshold    time.Duration
	MaxSQLLength int
	OmitSQL      bool
}

type SlowQueryEvent struct {
	Role        string   `json:"role"`
	Operation   string   `json:"operation"`
	QueryName   string   `json:"query_name"`
	DurationMS  int64    `json:"duration_ms"`
	ThresholdMS int64    `json:"threshold_ms"`
	Fingerprint string   `json:"fingerprint"`
	ArgsCount   int      `json:"args_count"`
	SQL         string   `json:"sql,omitempty"`
	Suggestions []string `json:"suggestions"`
	Error       string   `json:"error,omitempty"`
}