postgres

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, confirmationToken string) (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)