s3select

Documentation

Index

• func BuildQueryRunner(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.QueryRunner, hcl.Diagnostics)
• func RestrictQueryBlock(body hcl.Body) hcl.Diagnostics
• func RestrictQueryRunnerBlock(body hcl.Body) hcl.Diagnostics
• type PreparedQuery
  • func (q *PreparedQuery) Name() string
  • func (q *PreparedQuery) Run(ctx context.Context, data interface{}) (*queryrunner.QueryResult, error)
• type QueryCSVBlock
• type QueryJSONBlock
• type QueryParquetBlock
• type QueryRunner
  • func (r *QueryRunner) Prepare(name string, body hcl.Body, ctx *hcl.EvalContext) (queryrunner.PreparedQuery, hcl.Diagnostics)
  • func (r *QueryRunner) RunQuery(ctx context.Context, params *runQueryParameters) (*queryrunner.QueryResult, error)

Functions

func BuildQueryRunner

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

func RestrictQueryBlock

func RestrictQueryBlock(body hcl.Body) hcl.Diagnostics

func RestrictQueryRunnerBlock

func RestrictQueryRunnerBlock(body hcl.Body) hcl.Diagnostics

Types

type PreparedQuery

type PreparedQuery struct {
	Expression      string  `hcl:"expression"`
	BucketName      string  `hcl:"bucket_name"`
	ObjectKeyPrefix string  `hcl:"object_key_prefix"`
	ObjectKeySuffix *string `hcl:"object_key_suffix"`
	ScanLimit       *string `hcl:"scan_limit"`
	CompressionType string  `hcl:"compression_type"`

	CSVBlock     *QueryCSVBlock     `hcl:"csv,block"`
	JSONBlock    *QueryJSONBlock    `hcl:"json,block"`
	ParquetBlock *QueryParquetBlock `hcl:"parquet,block"`
	// contains filtered or unexported fields
}

func (*PreparedQuery) Name

func (q *PreparedQuery) Name() string

func (*PreparedQuery) Run

func (q *PreparedQuery) Run(ctx context.Context, data interface{}) (*queryrunner.QueryResult, error)

type QueryCSVBlock

type QueryCSVBlock struct {
	AllowQuotedRecordDelimiter *bool   `hcl:"allow_quoted_record_delimiter"`
	FileHeaderInfo             *string `hcl:"file_header_info"`
	FieldDelimiter             *string `hcl:"field_delimiter"`
	QuoteCharacter             *string `hcl:"quote_character"`
	QuoteEscapeCharacter       *string `hcl:"quote_escape_character"`
	RecordDelimiter            *string `hcl:"record_delimiter"`
}

type QueryJSONBlock

type QueryJSONBlock struct {
	Type string `hcl:"type"`
}

type QueryParquetBlock

type QueryParquetBlock struct{}

type QueryRunner

type QueryRunner struct {
	Region *string `hcl:"region"`
	// contains filtered or unexported fields
}

func (*QueryRunner) Prepare

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

func (*QueryRunner) RunQuery

func (r *QueryRunner) RunQuery(ctx context.Context, params *runQueryParameters) (*queryrunner.QueryResult, error)