MCPcopy Create free account
hub / github.com/araddon/qlbridge / NewTaskBase

Function NewTaskBase

exec/task.go:37–49  ·  view source on GitHub ↗
(ctx *plan.Context)

Source from the content-addressed store, hash-verified

35}
36
37func NewTaskBase(ctx *plan.Context) *TaskBase {
38 if ctx.Context == nil {
39 ctx.Context = context.Background()
40 }
41 return &TaskBase{
42 // All Tasks Get output channels by default, but NOT input
43 msgOutCh: make(MessageChan, ItemDefaultChannelSize),
44 sigCh: make(SigChan, 1),
45 errCh: make(ErrChan, 10),
46 errors: make([]error, 0),
47 Ctx: ctx,
48 }
49}
50
51func (m *TaskBase) Children() []Task { return nil }
52func (m *TaskBase) Setup(depth int) error {

Callers 15

CreateMutatorMethod · 0.92
WalkSourceSelectMethod · 0.92
NewCreateFunction · 0.85
NewDropFunction · 0.85
NewAlterFunction · 0.85
NewWhereFinalFunction · 0.85
NewWhereFilterFunction · 0.85
NewHavingFunction · 0.85
NewOrderFunction · 0.85
NewTaskSequentialFunction · 0.85
NewProjectionInProcessFunction · 0.85
NewProjectionFinalFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected