planner

Documentation

Index

• Variables
• type Catalog
• type NodeBeforeExecFunc
• type NodeFunc
• type QueryPlan
  • func (p *QueryPlan) Compile() error
  • func (p *QueryPlan) Execute(ctx context.Context, db *db.Pool) (data interface{}, err error)
  • func (p *QueryPlan) Log() string
• type QueryPlanNode
  • func (n *QueryPlanNode) Compile(parent *QueryPlanNode, res *Result) (*Result, error)
  • func (n *QueryPlanNode) Engine(name string) (engines.Engine, error)
  • func (n *QueryPlanNode) Schema() *ast.Schema
  • func (n *QueryPlanNode) TypeDefs() compiler.DefinitionsSource
• type QueryPlanNodes
  • func (n *QueryPlanNodes) Add(node *QueryPlanNode)
  • func (n *QueryPlanNodes) ForName(name string) *QueryPlanNode
• type Result
• type Results
  • func (r *Results) FirstResult() *Result
  • func (r *Results) ForName(name string) *Result
• type Service
  • func New(c Catalog) *Service
  • func (s *Service) Plan(ctx context.Context, schema *ast.Schema, query *ast.Field, ...) (*QueryPlan, error)

Variables

var (
	ErrInternalPlanner = errors.New("internal planner error")
)

Types

type Catalog

type Catalog interface {
	Engine(name string) (engines.Engine, error)
}

type NodeBeforeExecFunc

type NodeBeforeExecFunc func(ctx context.Context, db *db.Pool, node *QueryPlanNode) error

type NodeFunc

type NodeFunc func(node *QueryPlanNode, children Results, params []any) (string, []any, error)

type QueryPlan

type QueryPlan struct {
	Query    *ast.Field
	RootNode *QueryPlanNode

	CompiledQuery string
	Params        []any
}

func (*QueryPlan) Compile

func (p *QueryPlan) Compile() error

func (*QueryPlan) Execute

func (p *QueryPlan) Execute(ctx context.Context, db *db.Pool) (data interface{}, err error)

func (*QueryPlan) Log

func (p *QueryPlan) Log() string

type QueryPlanNode

type QueryPlanNode struct {
	Name        string
	Query       *ast.Field
	Nodes       QueryPlanNodes
	Comment     string
	CollectFunc NodeFunc

	BeforeParamsLen int
	AddedParams     int
	Parent          *QueryPlanNode

	Before NodeBeforeExecFunc
	// contains filtered or unexported fields
}

QueryPlan represents the execution plan for a query

func (*QueryPlanNode) Compile

func (n *QueryPlanNode) Compile(parent *QueryPlanNode, res *Result) (*Result, error)

func (*QueryPlanNode) Engine

func (n *QueryPlanNode) Engine(name string) (engines.Engine, error)

func (*QueryPlanNode) Schema

func (n *QueryPlanNode) Schema() *ast.Schema

func (*QueryPlanNode) TypeDefs

func (n *QueryPlanNode) TypeDefs() compiler.DefinitionsSource

type QueryPlanNodes

type QueryPlanNodes []*QueryPlanNode

func (*QueryPlanNodes) Add

func (n *QueryPlanNodes) Add(node *QueryPlanNode)

func (*QueryPlanNodes) ForName

func (n *QueryPlanNodes) ForName(name string) *QueryPlanNode

type Result

type Result struct {
	Name     string
	Result   string
	Params   []any
	Children Results
}

type Results

type Results []*Result

func (*Results) FirstResult

func (r *Results) FirstResult() *Result

func (*Results) ForName

func (r *Results) ForName(name string) *Result

type Service

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

func New

func New(c Catalog) *Service

func (*Service) Plan

func (s *Service) Plan(ctx context.Context, schema *ast.Schema, query *ast.Field, vars map[string]interface{}) (*QueryPlan, error)