xpipeline

package

Go to main page

Versions in this module

v0

v0.6.1

Nov 6, 2013

v0.6.0

Nov 1, 2013

Changes in this version

type BaseOperator

+ func (this *BaseOperator) Evaluate(e ast.Expression, item *dparval.Value) (*dparval.Value, error)

+ func (this *BaseOperator) SetQuery(q network.Query)

type CreateIndex

+ func (this *CreateIndex) SetQuery(q network.Query)

type DocumentJoin

+ func (this *DocumentJoin) SetQuery(q network.Query)

type DropIndex

+ func (this *DropIndex) SetQuery(q network.Query)

type EliminateDuplicates

+ func (this *EliminateDuplicates) SetQuery(q network.Query)

type Explain

+ func (this *Explain) SetQuery(q network.Query)

+ type FastCount struct

+ func NewFastCount(bucket catalog.Bucket, index catalog.CountIndex, expr ast.Expression, ...) *FastCount

+ func (this *FastCount) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *FastCount) RecoverPanic()

+ func (this *FastCount) Run(stopChannel misc.StopChannel)

+ func (this *FastCount) SendError(err query.Error) bool

+ func (this *FastCount) SendItem(item *dparval.Value) bool

+ func (this *FastCount) SetQuery(q network.Query)

+ func (this *FastCount) SetSource(source Operator)

type Fetch

+ func (this *Fetch) SetIds(ids []string)

+ func (this *Fetch) SetQuery(q network.Query)

type Filter

+ func (this *Filter) SetQuery(q network.Query)

type Grouper

+ func (this *Grouper) SetQuery(q network.Query)

type Limit

+ func (this *Limit) SetQuery(q network.Query)

type Offset

+ func (this *Offset) SetQuery(q network.Query)

type Operator

+ SetQuery func(q network.Query)

type Order

+ func (this *Order) SetQuery(q network.Query)

type Project

+ func (this *Project) SetQuery(q network.Query)

type Scan

+ func (this *Scan) SetQuery(q network.Query)

v0.5.1

Sep 12, 2013

v0.5.0

Sep 11, 2013

Changes in this version

+ const CHANNEL

+ const DEBUG_DUP_CHANNEL

+ const DEBUG_PROJECT_CHANNEL

+ const FETCH_BATCH_SIZE

+ type BaseOperator struct

+ Source Operator

+ func NewBaseOperator() *BaseOperator

+ func (this *BaseOperator) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *BaseOperator) RecoverPanic()

+ func (this *BaseOperator) RunOperator(oper Operator, stopChannel misc.StopChannel)

+ func (this *BaseOperator) SendError(err query.Error) bool

+ func (this *BaseOperator) SendItem(item *dparval.Value) bool

+ func (this *BaseOperator) SendOther(obj interface{}) bool

+ func (this *BaseOperator) SetSource(source Operator)

+ type CreateIndex struct

+ func NewCreateIndex(bucket catalog.Bucket, name string, index_type string, primary bool, ...) *CreateIndex

+ func (this *CreateIndex) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *CreateIndex) RecoverPanic()

+ func (this *CreateIndex) Run(stopChannel misc.StopChannel)

+ func (this *CreateIndex) SendError(err query.Error) bool

+ func (this *CreateIndex) SendItem(item *dparval.Value) bool

+ func (this *CreateIndex) SetSource(source Operator)

+ type DocumentJoin struct

+ As string

+ Base *BaseOperator

+ Over ast.Expression

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

+ func (this *DocumentJoin) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *DocumentJoin) Run(stopChannel misc.StopChannel)

+ func (this *DocumentJoin) SetSource(source Operator)

+ type DropIndex struct

+ func NewDropIndex(index catalog.Index) *DropIndex

+ func (this *DropIndex) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *DropIndex) RecoverPanic()

+ func (this *DropIndex) Run(stopChannel misc.StopChannel)

+ func (this *DropIndex) SendError(err query.Error) bool

+ func (this *DropIndex) SendItem(item *dparval.Value) bool

+ func (this *DropIndex) SetSource(source Operator)

+ type EliminateDuplicates struct

+ Base *BaseOperator

+ func NewEliminateDuplicates() *EliminateDuplicates

+ func (this *EliminateDuplicates) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *EliminateDuplicates) Run(stopChannel misc.StopChannel)

+ func (this *EliminateDuplicates) SetSource(source Operator)

+ type ExecutablePipeline struct

+ Root Operator

+ type Explain struct

+ Plan plan.PlanElement

+ func NewExplain(plan plan.PlanElement) *Explain

+ func (this *Explain) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Explain) RecoverPanic()

+ func (this *Explain) Run(stopChannel misc.StopChannel)

+ func (this *Explain) SendError(err query.Error) bool

+ func (this *Explain) SendItem(item *dparval.Value) bool

+ func (this *Explain) SetSource(source Operator)

+ type Fetch struct

+ Base *BaseOperator

+ func NewFetch(bucket catalog.Bucket, projection ast.Expression, as string) *Fetch

+ func (this *Fetch) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Fetch) Run(stopChannel misc.StopChannel)

+ func (this *Fetch) SetSource(source Operator)

+ type Filter struct

+ Base *BaseOperator

+ Expr ast.Expression

+ func NewFilter(expr ast.Expression) *Filter

+ func (this *Filter) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Filter) Run(stopChannel misc.StopChannel)

+ func (this *Filter) SetSource(source Operator)

+ type Grouper struct

+ Aggregates ast.ExpressionList

+ Base *BaseOperator

+ GroupBy ast.ExpressionList

+ func NewGrouper(groupBy ast.ExpressionList, aggs ast.ExpressionList) *Grouper

+ func (this *Grouper) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Grouper) Run(stopChannel misc.StopChannel)

+ func (this *Grouper) SetSource(source Operator)

+ type Limit struct

+ Base *BaseOperator

+ Limit int

+ func NewLimit(limit int) *Limit

+ func (this *Limit) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Limit) Run(stopChannel misc.StopChannel)

+ func (this *Limit) SetSource(source Operator)

+ type Offset struct

+ Base *BaseOperator

+ Offset int

+ func NewOffset(offset int) *Offset

+ func (this *Offset) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Offset) Run(stopChannel misc.StopChannel)

+ func (this *Offset) SetSource(source Operator)

+ type Operator interface

+ GetChannels func() (dparval.ValueChannel, PipelineSupportChannel)

+ Run func(misc.StopChannel)

+ SetSource func(Operator)

+ type Order struct

+ Base *BaseOperator

+ OrderBy []*ast.SortExpression

+ func NewOrder(orderBy []*ast.SortExpression, explicitAliases []string) *Order

+ func (this *Order) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Order) Len() int

+ func (this *Order) Less(i, j int) bool

+ func (this *Order) Run(stopChannel misc.StopChannel)

+ func (this *Order) SetSource(source Operator)

+ func (this *Order) Swap(i, j int)

+ type PipelineSupportChannel chan interface

+ type Project struct

+ Base *BaseOperator

+ Result ast.ResultExpressionList

+ func NewProject(result ast.ResultExpressionList, projectEmpty bool) *Project

+ func (this *Project) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Project) Run(stopChannel misc.StopChannel)

+ func (this *Project) SetSource(source Operator)

+ type Scan struct

+ func NewScan(bucket catalog.Bucket, index catalog.ScanIndex, ranges plan.ScanRanges) *Scan

+ func (this *Scan) GetChannels() (dparval.ValueChannel, PipelineSupportChannel)

+ func (this *Scan) RecoverPanic()

+ func (this *Scan) Run(stopChannel misc.StopChannel)

+ func (this *Scan) SendError(err query.Error) bool

+ func (this *Scan) SendItem(item *dparval.Value) bool

+ func (this *Scan) SetSource(source Operator)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL