api

Documentation

Index

• Variables
• func WaitOnQuery(ctx context.Context, api SQL, output *ExecuteQueryOutput) error
• func WaitOnQueryID(ctx context.Context, queryID string, db awsds.AsyncDB) error
• type AWSAPI
• type ExecuteQueryInput
• type ExecuteQueryOutput
• type ExecuteQueryStatus
• type Loader
• type Resources
• type SQL

Variables

var (
	ExecuteError = errors.New("error executing query")
	StatusError  = errors.New("error getting query query status")
	StopError    = errors.New("error stopping query")
)

Functions

func WaitOnQuery

func WaitOnQuery(ctx context.Context, api SQL, output *ExecuteQueryOutput) error

WaitOnQuery polls the datasource api until the query finishes, returning an error if it failed.

func WaitOnQueryID

func WaitOnQueryID(ctx context.Context, queryID string, db awsds.AsyncDB) error

Types

type AWSAPI

type AWSAPI interface {
	SQL
	Resources
}

type ExecuteQueryInput

type ExecuteQueryInput struct {
	ID    string
	Query string
}

type ExecuteQueryOutput

type ExecuteQueryOutput struct {
	ID string
}

type ExecuteQueryStatus

type ExecuteQueryStatus struct {
	ID       string
	Finished bool
	State    string
}

type Loader

type Loader func(cache *awsds.SessionCache, settings models.Settings) (AWSAPI, error)

type Resources

type Resources interface {
	Regions(aws.Context) ([]string, error)
	Databases(aws.Context, sqlds.Options) ([]string, error)
	CancelQuery(aws.Context, sqlds.Options, string) error
}

type SQL

type SQL interface {
	Execute(aws.Context, *ExecuteQueryInput) (*ExecuteQueryOutput, error)
	Status(aws.Context, *ExecuteQueryOutput) (*ExecuteQueryStatus, error)
	Stop(*ExecuteQueryOutput) error
}