athena

Documentation

Index

• type AthenaDatasource
  • func (s *AthenaDatasource) Columns(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *AthenaDatasource) Connect(config backend.DataSourceInstanceSettings, queryArgs json.RawMessage) (*sql.DB, error)
  • func (s *AthenaDatasource) Converters() (sc []sqlutil.Converter)
  • func (s *AthenaDatasource) DataCatalogs(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *AthenaDatasource) Databases(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *AthenaDatasource) Macros() sqlds.Macros
  • func (s *AthenaDatasource) Regions(ctx context.Context) ([]string, error)
  • func (s *AthenaDatasource) Schemas(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *AthenaDatasource) Settings(_ backend.DataSourceInstanceSettings) sqlds.DriverSettings
  • func (s *AthenaDatasource) Tables(ctx context.Context, options sqlds.Options) ([]string, error)
  • func (s *AthenaDatasource) Workgroups(ctx context.Context, options sqlds.Options) ([]string, error)
• type AthenaDatasourceIface
  • func New() AthenaDatasourceIface

Types

type AthenaDatasource

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

func (*AthenaDatasource) Columns

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

func (*AthenaDatasource) Connect

func (s *AthenaDatasource) Connect(config backend.DataSourceInstanceSettings, queryArgs json.RawMessage) (*sql.DB, error)

Connect opens a sql.DB connection using datasource settings

func (*AthenaDatasource) Converters

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

func (*AthenaDatasource) DataCatalogs

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

func (*AthenaDatasource) Databases

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

func (*AthenaDatasource) Macros

func (s *AthenaDatasource) Macros() sqlds.Macros

func (*AthenaDatasource) Regions

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

func (*AthenaDatasource) Schemas

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

func (*AthenaDatasource) Settings

func (s *AthenaDatasource) Settings(_ backend.DataSourceInstanceSettings) sqlds.DriverSettings

func (*AthenaDatasource) Tables

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

func (*AthenaDatasource) Workgroups

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

type AthenaDatasourceIface

type AthenaDatasourceIface interface {
	sqlds.Driver
	sqlds.Completable
	sqlAPI.Resources
	DataCatalogs(ctx context.Context, options sqlds.Options) ([]string, error)
	Databases(ctx context.Context, options sqlds.Options) ([]string, error)
	Workgroups(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)
}

func New

func New() AthenaDatasourceIface