Versions in this module Expand all Collapse all v0 v0.1.0 Jun 23, 2026 Changes in this version + type Manager struct + func NewManager(cfg config.Config, logger *slog.Logger) (*Manager, error) + func (m *Manager) BaseHostPort() string + func (m *Manager) BaseUser() string + func (m *Manager) BootstrapDatabase() string + func (m *Manager) BootstrapPool(ctx context.Context) (*pgxpool.Pool, error) + func (m *Manager) Close() + func (m *Manager) ConfirmationTTL() int64 + func (m *Manager) CountRows(ctx context.Context, database, schema, table string, where map[string]any) (out types.CountRowsOutput, err error) + func (m *Manager) DeniedSchemas() []string + func (m *Manager) DescribeTable(ctx context.Context, database, schema, table string) (out types.DescribeTableOutput, err error) + func (m *Manager) ExecAdmin(ctx context.Context, database, sql string, timeout time.Duration, ...) (out types.ExecAdminOutput, err error) + func (m *Manager) ExecDML(ctx context.Context, database, sql string, timeout time.Duration) (out types.ExecDMLOutput, err error) + func (m *Manager) GetConnectionStatus(ctx context.Context) (out types.ConnectionStatusOutput, err error) + func (m *Manager) GetServerMetrics(_ context.Context) (out types.ServerMetricsOutput, err error) + func (m *Manager) IdlePoolCleanupInterval() int64 + func (m *Manager) IdlePoolTTL() int64 + func (m *Manager) ListDatabases(ctx context.Context) (out types.ListDatabasesOutput, err error) + func (m *Manager) ListSchemas(ctx context.Context, database string) (out types.ListSchemasOutput, err error) + func (m *Manager) ListTables(ctx context.Context, database, schema string) (out types.ListTablesOutput, err error) + func (m *Manager) MutationDatabases() []string + func (m *Manager) PingBootstrap(ctx context.Context) error + func (m *Manager) PolicyMode() policy.Mode + func (m *Manager) PoolForDatabase(ctx context.Context, database string) (*pgxpool.Pool, error) + func (m *Manager) Query(ctx context.Context, database, sql string, maxRows int, timeout time.Duration) (out types.QueryOutput, err error) + func (m *Manager) SampleTable(ctx context.Context, database, schema, table string, limit int) (out types.SampleTableOutput, err error)