redshift

Documentation

Index

• type Loader
  • func (l Loader) LoadAPI(ctx context.Context, cache *awsds.SessionCache, settings sqlModels.Settings) (sqlAPI.AWSAPI, error)
  • func (l Loader) LoadAsyncDriver(ctx context.Context, awsapi sqlAPI.AWSAPI) (async.Driver, error)
  • func (l Loader) LoadDriver(ctx context.Context, awsapi sqlAPI.AWSAPI) (awsDriver.Driver, error)
  • func (l Loader) LoadSettings(ctx context.Context) sqlModels.Settings
• type RedshiftDatasource
  • func New() *RedshiftDatasource
  • func (s *RedshiftDatasource) CancelQuery(ctx context.Context, options sqlds.Options, queryID string) error
  • func (s *RedshiftDatasource) Clusters(ctx context.Context, options sqlds.Options) ([]models.RedshiftCluster, error)
  • func (s *RedshiftDatasource) Columns(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *RedshiftDatasource) Connect(ctx context.Context, config backend.DataSourceInstanceSettings, ...) (*sql.DB, error)
  • func (s *RedshiftDatasource) Converters() (sc []sqlutil.Converter)
  • func (s *RedshiftDatasource) Databases(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *RedshiftDatasource) GetAsyncDB(ctx context.Context, config backend.DataSourceInstanceSettings, ...) (awsds.AsyncDB, error)
  • func (s *RedshiftDatasource) Macros() sqlutil.Macros
  • func (s *RedshiftDatasource) Regions(ctx context.Context) ([]string, error)
  • func (s *RedshiftDatasource) Schemas(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *RedshiftDatasource) Secret(ctx context.Context, options sqlds.Options) (*models.RedshiftSecret, error)
  • func (s *RedshiftDatasource) Secrets(ctx context.Context, options sqlds.Options) ([]models.ManagedSecret, error)
  • func (s *RedshiftDatasource) Settings(ctx context.Context, _ backend.DataSourceInstanceSettings) sqlds.DriverSettings
  • func (s *RedshiftDatasource) Tables(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *RedshiftDatasource) Workgroups(ctx context.Context, options sqlds.Options) ([]models.RedshiftWorkgroup, error)
• type RedshiftDatasourceIface

Types

type Loader

type Loader struct{}

func (Loader) LoadAPI

func (l Loader) LoadAPI(ctx context.Context, cache *awsds.SessionCache, settings sqlModels.Settings) (sqlAPI.AWSAPI, error)

func (Loader) LoadAsyncDriver

func (l Loader) LoadAsyncDriver(ctx context.Context, awsapi sqlAPI.AWSAPI) (async.Driver, error)

func (Loader) LoadDriver

func (l Loader) LoadDriver(ctx context.Context, awsapi sqlAPI.AWSAPI) (awsDriver.Driver, error)

func (Loader) LoadSettings

func (l Loader) LoadSettings(ctx context.Context) sqlModels.Settings

type RedshiftDatasource

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

func New

func New() *RedshiftDatasource

func (*RedshiftDatasource) CancelQuery

func (s *RedshiftDatasource) CancelQuery(ctx context.Context, options sqlds.Options, queryID string) error

func (*RedshiftDatasource) Clusters

func (s *RedshiftDatasource) Clusters(ctx context.Context, options sqlds.Options) ([]models.RedshiftCluster, error)

func (*RedshiftDatasource) Columns

func (s *RedshiftDatasource) Columns(ctx context.Context, options sqlds.Options) ([]string, error)

func (*RedshiftDatasource) Connect

func (s *RedshiftDatasource) Connect(ctx context.Context, config backend.DataSourceInstanceSettings, queryArgs json.RawMessage) (*sql.DB, error)

Connect opens a sql.DB connection using datasource settings

func (*RedshiftDatasource) Converters

func (s *RedshiftDatasource) Converters() (sc []sqlutil.Converter)

func (*RedshiftDatasource) Databases

func (s *RedshiftDatasource) Databases(ctx context.Context, options sqlds.Options) ([]string, error)

func (*RedshiftDatasource) GetAsyncDB

func (s *RedshiftDatasource) GetAsyncDB(ctx context.Context, config backend.DataSourceInstanceSettings, queryArgs json.RawMessage) (awsds.AsyncDB, error)

func (*RedshiftDatasource) Macros

func (s *RedshiftDatasource) Macros() sqlutil.Macros

func (*RedshiftDatasource) Regions

func (s *RedshiftDatasource) Regions(ctx context.Context) ([]string, error)

func (*RedshiftDatasource) Schemas

func (s *RedshiftDatasource) Schemas(ctx context.Context, options sqlds.Options) ([]string, error)

func (*RedshiftDatasource) Secret

func (s *RedshiftDatasource) Secret(ctx context.Context, options sqlds.Options) (*models.RedshiftSecret, error)

func (*RedshiftDatasource) Secrets

func (s *RedshiftDatasource) Secrets(ctx context.Context, options sqlds.Options) ([]models.ManagedSecret, error)

func (*RedshiftDatasource) Settings

func (s *RedshiftDatasource) Settings(ctx context.Context, _ backend.DataSourceInstanceSettings) sqlds.DriverSettings

func (*RedshiftDatasource) Tables

func (s *RedshiftDatasource) Tables(ctx context.Context, options sqlds.Options) ([]string, error)

func (*RedshiftDatasource) Workgroups

func (s *RedshiftDatasource) Workgroups(ctx context.Context, options sqlds.Options) ([]models.RedshiftWorkgroup, error)

type RedshiftDatasourceIface

type RedshiftDatasourceIface interface {
	sqlds.Driver
	sqlds.Completable
	sqlAPI.Resources
	awsds.AsyncDriver
	Schemas(ctx context.Context, options sqlds.Options) ([]string, error)
	Tables(ctx context.Context, options sqlds.Options) ([]string, error)
	Columns(ctx context.Context, options sqlds.Options) ([]string, error)
	Secrets(ctx context.Context, options sqlds.Options) ([]models.ManagedSecret, error)
	Secret(ctx context.Context, options sqlds.Options) (*models.RedshiftSecret, error)
	Clusters(ctx context.Context, options sqlds.Options) ([]models.RedshiftCluster, error)
	Workgroups(ctx context.Context, options sqlds.Options) ([]models.RedshiftWorkgroup, error)
}