redshiftdata

Documentation

Index

• Constants
• func BuildQueryRunner(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.QueryRunner, hcl.Diagnostics)
• type PreparedQuery
  • func (q *PreparedQuery) Run(ctx context.Context, variables map[string]cty.Value, ...) (*queryrunner.QueryResult, error)
• type QueryRunner
  • func (r *QueryRunner) Name() string
  • func (r *QueryRunner) Prepare(base *queryrunner.QueryBase) (queryrunner.PreparedQuery, hcl.Diagnostics)
  • func (r *QueryRunner) RunQuery(ctx context.Context, stmtName string, query string) (*queryrunner.QueryResult, error)
  • func (r *QueryRunner) Type() string

Constants

const TypeName = "redshift_data"

Functions

func BuildQueryRunner

func BuildQueryRunner(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.QueryRunner, hcl.Diagnostics)

Types

type PreparedQuery

type PreparedQuery struct {
	*queryrunner.QueryBase

	SQL hcl.Expression `hcl:"sql"`
	// contains filtered or unexported fields
}

func (*PreparedQuery) Run

func (q *PreparedQuery) Run(ctx context.Context, variables map[string]cty.Value, functions map[string]function.Function) (*queryrunner.QueryResult, error)

type QueryRunner

type QueryRunner struct {
	ClusterIdentifier *string `hcl:"cluster_identifier"`
	Database          *string `hcl:"database"`
	DbUser            *string `hcl:"db_user"`
	WorkgroupName     *string `hcl:"workgroup_name"`
	SecretsARN        *string `hcl:"secrets_arn"`

	Attrs hcl.Attributes `hcl:",body"`
	// contains filtered or unexported fields
}

func (*QueryRunner) Name

func (r *QueryRunner) Name() string

func (*QueryRunner) Prepare

func (r *QueryRunner) Prepare(base *queryrunner.QueryBase) (queryrunner.PreparedQuery, hcl.Diagnostics)

func (*QueryRunner) RunQuery

func (r *QueryRunner) RunQuery(ctx context.Context, stmtName string, query string) (*queryrunner.QueryResult, error)

func (*QueryRunner) Type

func (r *QueryRunner) Type() string