plan

Documentation

Index

• type CreateIndex
  • func NewCreateIndex(pool string, bucket string, name string, index_type string, primary bool, ...) *CreateIndex
  • func (this *CreateIndex) Sources() []PlanElement
• type DocumentJoin
  • func NewDocumentJoin(input PlanElement, over ast.Expression, as string) *DocumentJoin
  • func (this *DocumentJoin) Sources() []PlanElement
• type DropIndex
  • func NewDropIndex(pool string, bucket string, name string) *DropIndex
  • func (this *DropIndex) Sources() []PlanElement
• type EliminateDuplicates
  • func NewEliminateDuplicates(input PlanElement) *EliminateDuplicates
  • func (this *EliminateDuplicates) Sources() []PlanElement
• type Explain
  • func NewExplain(input PlanElement) *Explain
  • func (this *Explain) Sources() []PlanElement
• type Fetch
  • func NewFetch(input PlanElement, pool string, bucket string, projection ast.Expression, ...) *Fetch
  • func (this *Fetch) Sources() []PlanElement
• type Filter
  • func NewFilter(input PlanElement, expr ast.Expression) *Filter
  • func (this *Filter) Sources() []PlanElement
• type Grouper
  • func NewGroup(input PlanElement, group ast.ExpressionList, agg ast.ExpressionList) *Grouper
  • func (this *Grouper) Sources() []PlanElement
• type Limit
  • func NewLimit(input PlanElement, limit int) *Limit
  • func (this *Limit) Sources() []PlanElement
• type Offset
  • func NewOffset(input PlanElement, offset int) *Offset
  • func (this *Offset) Sources() []PlanElement
• type Order
  • func NewOrder(input PlanElement, sort []*ast.SortExpression, explicitAliases []string) *Order
  • func (this *Order) Sources() []PlanElement
• type Plan
• type PlanChannel
• type PlanElement
• type Projector
  • func NewProjector(input PlanElement, result ast.ResultExpressionList, projectEmpty bool) *Projector
  • func (this *Projector) Sources() []PlanElement
• type ProjectorInline
  • func NewProjectorInline(input PlanElement, result *ast.ResultExpression) *ProjectorInline
  • func (this *ProjectorInline) Sources() []PlanElement
• type Scan
  • func NewScan(pool string, bucket string, index string, ranges ScanRanges) *Scan
  • func (this *Scan) Sources() []PlanElement
• type ScanRange
  • func (sr ScanRange) MarshalJSON() ([]byte, error)
• type ScanRanges

Types

type CreateIndex

type CreateIndex struct {
	Type      string             `json:"type"`
	Pool      string             `json:"pool"`
	Bucket    string             `json:"bucket"`
	Name      string             `json:"name"`
	IndexType string             `json:"index_type"`
	Primary   bool               `json:"primary"`
	On        ast.ExpressionList `json:"on"`
}

func NewCreateIndex

func NewCreateIndex(pool string, bucket string, name string, index_type string, primary bool, on ast.ExpressionList) *CreateIndex

func (*CreateIndex) Sources

func (this *CreateIndex) Sources() []PlanElement

type DocumentJoin

type DocumentJoin struct {
	Type  string         `json:"type"`
	Input PlanElement    `json:"input"`
	Over  ast.Expression `json:"over"`
	As    string         `json:"as"`
}

func NewDocumentJoin

func NewDocumentJoin(input PlanElement, over ast.Expression, as string) *DocumentJoin

func (*DocumentJoin) Sources

func (this *DocumentJoin) Sources() []PlanElement

type DropIndex

type DropIndex struct {
	Type   string `json:"type"`
	Pool   string `json:"pool"`
	Bucket string `json:"bucket"`
	Name   string `json:"name"`
}

func NewDropIndex

func NewDropIndex(pool string, bucket string, name string) *DropIndex

func (*DropIndex) Sources

func (this *DropIndex) Sources() []PlanElement

type EliminateDuplicates

type EliminateDuplicates struct {
	Type  string      `json:"type"`
	Input PlanElement `json:"input"`
}

func NewEliminateDuplicates

func NewEliminateDuplicates(input PlanElement) *EliminateDuplicates

func (*EliminateDuplicates) Sources

func (this *EliminateDuplicates) Sources() []PlanElement

type Explain

type Explain struct {
	Type  string      `json:"type"`
	Input PlanElement `json:"input"`
}

func NewExplain

func NewExplain(input PlanElement) *Explain

func (*Explain) Sources

func (this *Explain) Sources() []PlanElement

type Fetch

type Fetch struct {
	Type       string         `json:"type"`
	Input      PlanElement    `json:"input"`
	Bucket     string         `json:"bucket"`
	Pool       string         `json:"pool"`
	Projection ast.Expression `json:"projection"`
	As         string         `json:"as"`
}

func NewFetch

func NewFetch(input PlanElement, pool string, bucket string, projection ast.Expression, as string) *Fetch

func (*Fetch) Sources

func (this *Fetch) Sources() []PlanElement

type Filter

type Filter struct {
	Type  string         `json:"type"`
	Input PlanElement    `json:"input"`
	Expr  ast.Expression `json:"expr"`
}

func NewFilter

func NewFilter(input PlanElement, expr ast.Expression) *Filter

func (*Filter) Sources

func (this *Filter) Sources() []PlanElement

type Grouper

type Grouper struct {
	Type       string             `json:"type"`
	Input      PlanElement        `json:"input"`
	Group      ast.ExpressionList `json:"group"`
	Aggregates ast.ExpressionList `json:"aggregates"`
}

func NewGroup

func NewGroup(input PlanElement, group ast.ExpressionList, agg ast.ExpressionList) *Grouper

func (*Grouper) Sources

func (this *Grouper) Sources() []PlanElement

type Limit

type Limit struct {
	Type  string      `json:"type"`
	Input PlanElement `json:"input"`
	Val   int         `json:"value"`
}

func NewLimit

func NewLimit(input PlanElement, limit int) *Limit

func (*Limit) Sources

func (this *Limit) Sources() []PlanElement

type Offset

type Offset struct {
	Type  string      `json:"type"`
	Input PlanElement `json:"input"`
	Val   int         `json:"value"`
}

func NewOffset

func NewOffset(input PlanElement, offset int) *Offset

func (*Offset) Sources

func (this *Offset) Sources() []PlanElement

type Order

type Order struct {
	Type            string                `json:"type"`
	Input           PlanElement           `json:"input"`
	Sort            []*ast.SortExpression `json:"sort"`
	ExplicitAliases []string              `json:"explicit_aliases"`
}

func NewOrder

func NewOrder(input PlanElement, sort []*ast.SortExpression, explicitAliases []string) *Order

func (*Order) Sources

func (this *Order) Sources() []PlanElement

type Plan

type Plan struct {
	Root PlanElement `json:"root"`
}

type PlanChannel

type PlanChannel chan Plan

type PlanElement

type PlanElement interface {
	Sources() []PlanElement
}

type Projector

type Projector struct {
	Type         string                   `json:"type"`
	Input        PlanElement              `json:"input"`
	Result       ast.ResultExpressionList `json:"result"`
	ProjectEmpty bool                     `json:"-"`
}

func NewProjector

func NewProjector(input PlanElement, result ast.ResultExpressionList, projectEmpty bool) *Projector

func (*Projector) Sources

func (this *Projector) Sources() []PlanElement

type ProjectorInline

type ProjectorInline struct {
	Type   string                `json:"type"`
	Input  PlanElement           `json:"input"`
	Result *ast.ResultExpression `json:"result"`
}

func NewProjectorInline

func NewProjectorInline(input PlanElement, result *ast.ResultExpression) *ProjectorInline

func (*ProjectorInline) Sources

func (this *ProjectorInline) Sources() []PlanElement

type Scan

type Scan struct {
	Type      string     `json:"type"`
	ScanIndex string     `json:"index"`
	Bucket    string     `json:"bucket"`
	Pool      string     `json:"pool"`
	Ranges    ScanRanges `json:"ranges"`
}

func NewScan

func NewScan(pool string, bucket string, index string, ranges ScanRanges) *Scan

func (*Scan) Sources

func (this *Scan) Sources() []PlanElement

type ScanRange

type ScanRange struct {
	Low       catalog.LookupValue
	High      catalog.LookupValue
	Inclusion catalog.RangeInclusion
}

func (ScanRange) MarshalJSON

func (sr ScanRange) MarshalJSON() ([]byte, error)

type ScanRanges

type ScanRanges []*ScanRange