api

Documentation

Index

• func New(sessionCache *awsds.SessionCache, settings sqlModels.Settings) (api.AWSAPI, error)
• type API
  • func NewFake(cli athenaiface.AthenaAPI, settings *models.AthenaDataSourceSettings) *API
  • func (c *API) Columns(ctx aws.Context, options sqlds.Options) ([]string, error)
  • func (c *API) DataCatalogs(ctx context.Context) ([]string, error)
  • func (c *API) Databases(ctx aws.Context, options sqlds.Options) ([]string, error)
  • func (c *API) Execute(ctx context.Context, input *api.ExecuteQueryInput) (*api.ExecuteQueryOutput, error)
  • func (c *API) Regions(aws.Context) ([]string, error)
  • func (c *API) Status(ctx aws.Context, output *api.ExecuteQueryOutput) (*api.ExecuteQueryStatus, error)
  • func (c *API) Stop(output *api.ExecuteQueryOutput) error
  • func (c *API) Tables(ctx aws.Context, options sqlds.Options) ([]string, error)
  • func (c *API) Workgroups(ctx context.Context) ([]string, error)

Functions

func New

func New(sessionCache *awsds.SessionCache, settings sqlModels.Settings) (api.AWSAPI, error)

Types

type API

type API struct {
	Client athenaiface.AthenaAPI
	// contains filtered or unexported fields
}

func NewFake

func NewFake(cli athenaiface.AthenaAPI, settings *models.AthenaDataSourceSettings) *API

NewFake returns an API object with the given args

func (*API) Columns

func (c *API) Columns(ctx aws.Context, options sqlds.Options) ([]string, error)

func (*API) DataCatalogs

func (c *API) DataCatalogs(ctx context.Context) ([]string, error)

func (*API) Databases

func (c *API) Databases(ctx aws.Context, options sqlds.Options) ([]string, error)

func (*API) Execute

func (c *API) Execute(ctx context.Context, input *api.ExecuteQueryInput) (*api.ExecuteQueryOutput, error)

func (*API) Regions

func (c *API) Regions(aws.Context) ([]string, error)

func (*API) Status

func (c *API) Status(ctx aws.Context, output *api.ExecuteQueryOutput) (*api.ExecuteQueryStatus, error)

func (*API) Stop

func (c *API) Stop(output *api.ExecuteQueryOutput) error

func (*API) Tables

func (c *API) Tables(ctx aws.Context, options sqlds.Options) ([]string, error)

func (*API) Workgroups

func (c *API) Workgroups(ctx context.Context) ([]string, error)