queryexec

Documentation

Index

• type Executor
  • func NewExecutor(client *elasticsearch.Client, index string, verbose bool) *Executor
  • func (e *Executor) Execute(ctx context.Context, qc models.QueryConfig, algorithm string) (models.QueryResults, error)
• type Runner
  • func NewRunner(executor *Executor, printer *ui.Printer) *Runner
  • func (r *Runner) RunAlgorithms(ctx context.Context, algorithms []models.AlgorithmConfig) ([]models.QueryResults, error)

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

Executor handles query execution

func NewExecutor

func NewExecutor(client *elasticsearch.Client, index string, verbose bool) *Executor

NewExecutor creates a new query executor

func (*Executor) Execute

func (e *Executor) Execute(ctx context.Context, qc models.QueryConfig, algorithm string) (models.QueryResults, error)

Execute runs a single query and returns results

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

Runner manages running multiple queries

func NewRunner

func NewRunner(executor *Executor, printer *ui.Printer) *Runner

NewRunner creates a new query runner

func (*Runner) RunAlgorithms

func (r *Runner) RunAlgorithms(ctx context.Context, algorithms []models.AlgorithmConfig) ([]models.QueryResults, error)

RunAlgorithms executes all queries for all algorithms