redshift

package

v0.16.0-rc1 Latest Latest Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func IsPermissionError(err error) bool

IsPermissionError reports whether err indicates the DWH credentials lack the privileges required for the attempted operation.

func NewQuerier[T any](conn *RedshiftExecutor) querier.Querier[T]

type Executor interface {
	stdsql.StdSqlExecutor
	QueryRows(ctx context.Context, q string, args ...interface{}) (*sqlx.Rows, error)
}

type RedshiftConf struct {
	User      string
	Password  string
	Database  string
	Host      string
	Port      int
	SSHTunnel *sshtunnel.SshTunnel
}

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

func NewRedshiftExecutor(ctx context.Context, conf *RedshiftConf) (*RedshiftExecutor, error)

func (e *RedshiftExecutor) Close() error

func (e *RedshiftExecutor) Exec(ctx context.Context, query string, args ...any) error

func (e *RedshiftExecutor) GetDb() *sqlx.DB

func (e *RedshiftExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)

func (e *RedshiftExecutor) Select(ctx context.Context, dest any, query string, args ...any) error