api

Documentation

Index

• func New(ctx context.Context, sessionCache *awsds.SessionCache, ...) (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)
  • func (c *API) Workgroups() ([]models.RedshiftWorkgroup, error)

Functions

func New

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

Types

type API

type API struct {
	DataClient                 redshiftdataapiserviceiface.RedshiftDataAPIServiceAPI
	SecretsClient              secretsmanageriface.SecretsManagerAPI
	ManagementClient           redshiftiface.RedshiftAPI
	ServerlessManagementClient redshiftserverlessiface.RedshiftServerlessAPI
	// 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)

GetQueryID always returns not found. To actually check if the query has been called requires calling ListStatements, which can lead to timeouts when there are many statements to page through

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)

func (*API) Workgroups

func (c *API) Workgroups() ([]models.RedshiftWorkgroup, error)