clauses

Documentation

Index

• func NewCollectClause(src core.SourceMap, dataSource collections.Iterable, params *Collect) (collections.Iterable, error)
• func NewFilterClause(src core.SourceMap, dataSource collections.Iterable, predicate core.Expression) (collections.Iterable, error)
• func NewLimitClause(src core.SourceMap, dataSource collections.Iterable, count core.Expression, ...) (collections.Iterable, error)
• func NewSortClause(src core.SourceMap, dataSource collections.Iterable, ...) (collections.Iterable, error)
• type Collect
  • func NewCollect(selectors []*CollectSelector, projection *CollectProjection, ...) (*Collect, error)
• type CollectAggregate
  • func NewCollectAggregate(selectors []*CollectAggregateSelector) (*CollectAggregate, error)
• type CollectAggregateSelector
  • func NewCollectAggregateSelector(variable string, aggr []core.Expression, reducer core.Function) (*CollectAggregateSelector, error)
  • func (selector *CollectAggregateSelector) Aggregators() []core.Expression
  • func (selector *CollectAggregateSelector) Expression() core.Function
  • func (selector *CollectAggregateSelector) Variable() string
• type CollectClause
  • func (clause *CollectClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
• type CollectCount
  • func NewCollectCount(variable string) (*CollectCount, error)
• type CollectGroup
• type CollectIterator
  • func NewCollectIterator(src core.SourceMap, params *Collect, dataSource collections.Iterator) (*CollectIterator, error)
  • func (iterator *CollectIterator) Next(ctx context.Context, scope *core.Scope) (*core.Scope, error)
• type CollectProjection
  • func NewCollectProjection(selector *CollectSelector) (*CollectProjection, error)
• type CollectSelector
  • func NewCollectSelector(variable string, exp core.Expression) (*CollectSelector, error)
  • func (selector *CollectSelector) Expression() core.Expression
  • func (selector *CollectSelector) Variable() string
• type FilterClause
  • func (clause *FilterClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
• type LimitClause
  • func (clause *LimitClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
• type SortClause
  • func (clause *SortClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)
• type SorterExpression
  • func NewSorterExpression(expression core.Expression, direction collections.SortDirection) (*SorterExpression, error)

Functions

func NewCollectClause

func NewCollectClause(
	src core.SourceMap,
	dataSource collections.Iterable,
	params *Collect,
) (collections.Iterable, error)

func NewFilterClause

func NewFilterClause(
	src core.SourceMap,
	dataSource collections.Iterable,
	predicate core.Expression,
) (collections.Iterable, error)

func NewLimitClause

func NewLimitClause(
	src core.SourceMap,
	dataSource collections.Iterable,
	count core.Expression,
	offset core.Expression,
) (collections.Iterable, error)

func NewSortClause

func NewSortClause(
	src core.SourceMap,
	dataSource collections.Iterable,
	sorters ...*SorterExpression,
) (collections.Iterable, error)

Types

type Collect

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

func NewCollect

func NewCollect(
	selectors []*CollectSelector,
	projection *CollectProjection,
	count *CollectCount,
	aggregate *CollectAggregate,
) (*Collect, error)

type CollectAggregate

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

func NewCollectAggregate

func NewCollectAggregate(selectors []*CollectAggregateSelector) (*CollectAggregate, error)

type CollectAggregateSelector

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

func NewCollectAggregateSelector

func NewCollectAggregateSelector(variable string, aggr []core.Expression, reducer core.Function) (*CollectAggregateSelector, error)

func (*CollectAggregateSelector) Aggregators

func (selector *CollectAggregateSelector) Aggregators() []core.Expression

func (*CollectAggregateSelector) Expression

func (selector *CollectAggregateSelector) Expression() core.Function

func (*CollectAggregateSelector) Variable

func (selector *CollectAggregateSelector) Variable() string

type CollectClause

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

func (*CollectClause) Iterate

func (clause *CollectClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)

type CollectCount

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

func NewCollectCount

func NewCollectCount(variable string) (*CollectCount, error)

type CollectGroup

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

type CollectIterator

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

func NewCollectIterator

func NewCollectIterator(
	src core.SourceMap,
	params *Collect,
	dataSource collections.Iterator,
) (*CollectIterator, error)

func (*CollectIterator) Next

func (iterator *CollectIterator) Next(ctx context.Context, scope *core.Scope) (*core.Scope, error)

type CollectProjection

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

func NewCollectProjection

func NewCollectProjection(selector *CollectSelector) (*CollectProjection, error)

type CollectSelector

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

func NewCollectSelector

func NewCollectSelector(variable string, exp core.Expression) (*CollectSelector, error)

func (*CollectSelector) Expression

func (selector *CollectSelector) Expression() core.Expression

func (*CollectSelector) Variable

func (selector *CollectSelector) Variable() string

type FilterClause

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

func (*FilterClause) Iterate

func (clause *FilterClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)

type LimitClause

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

func (*LimitClause) Iterate

func (clause *LimitClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)

type SortClause

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

func (*SortClause) Iterate

func (clause *SortClause) Iterate(ctx context.Context, scope *core.Scope) (collections.Iterator, error)

type SorterExpression

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

func NewSorterExpression

func NewSorterExpression(expression core.Expression, direction collections.SortDirection) (*SorterExpression, error)