api

Documentation

Index

• func New(sessionCache *awsds.SessionCache, settings awsModels.Settings) (api.AWSAPI, error)
• type API
  • func (c *API) CancelQuery(ctx context.Context, options sqlds.Options, queryID string) error
  • func (c *API) Clusters() ([]models.RedshiftCluster, error)
  • func (c *API) Columns(ctx aws.Context, options sqlds.Options) ([]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) GetQueryID(ctx context.Context, query string, args ...interface{}) (bool, string, error)
  • func (c *API) Regions(aws.Context) ([]string, error)
  • func (c *API) Schemas(ctx aws.Context, options sqlds.Options) ([]string, error)
  • func (c *API) Secret(ctx aws.Context, options sqlds.Options) (*models.RedshiftSecret, error)
  • func (c *API) Secrets(ctx aws.Context) ([]models.ManagedSecret, 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)

Functions

func New

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

Types

type API

type API struct {
	DataClient       redshiftdataapiserviceiface.RedshiftDataAPIServiceAPI
	SecretsClient    secretsmanageriface.SecretsManagerAPI
	ManagementClient redshiftiface.RedshiftAPI
	// contains filtered or unexported fields
}

func (*API) CancelQuery

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

func (*API) Clusters

func (c *API) Clusters() ([]models.RedshiftCluster, error)

func (*API) Columns

func (c *API) Columns(ctx aws.Context, options sqlds.Options) ([]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) GetQueryID

func (c *API) GetQueryID(ctx context.Context, query string, args ...interface{}) (bool, string, error)

func (*API) Regions

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

func (*API) Schemas

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

func (*API) Secret

func (c *API) Secret(ctx aws.Context, options sqlds.Options) (*models.RedshiftSecret, error)

func (*API) Secrets

func (c *API) Secrets(ctx aws.Context) ([]models.ManagedSecret, 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)