api

Documentation

Index

• Variables
• func WaitOnQuery(ctx context.Context, api SQL, output *ExecuteQueryOutput) 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.

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)
}

type SQL

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