Documentation ¶
Overview ¶
Package direct contains the direct runner for running single-bundle pipelines in the current process. Useful for testing.
Index ¶
- func Compile(edges []*graph.MultiEdge) (*exec.Plan, error)
- func Execute(ctx context.Context, p *beam.Pipeline) error
- type CoGBK
- func (n *CoGBK) Down(ctx context.Context) error
- func (n *CoGBK) FinishBundle(ctx context.Context) error
- func (n *CoGBK) ID() exec.UnitID
- func (n *CoGBK) ProcessElement(ctx context.Context, elm *exec.FullValue, _ ...exec.ReStream) error
- func (n *CoGBK) StartBundle(ctx context.Context, id string, data exec.DataContext) error
- func (n *CoGBK) String() string
- func (n *CoGBK) Up(ctx context.Context) error
- type Impulse
- func (n *Impulse) Down(ctx context.Context) error
- func (n *Impulse) FinishBundle(ctx context.Context) error
- func (n *Impulse) ID() exec.UnitID
- func (n *Impulse) Process(ctx context.Context) error
- func (n *Impulse) StartBundle(ctx context.Context, id string, data exec.DataContext) error
- func (n *Impulse) String() string
- func (n *Impulse) Up(ctx context.Context) error
- type Inject
- func (n *Inject) Down(ctx context.Context) error
- func (n *Inject) FinishBundle(ctx context.Context) error
- func (n *Inject) ID() exec.UnitID
- func (n *Inject) ProcessElement(ctx context.Context, elm *exec.FullValue, values ...exec.ReStream) error
- func (n *Inject) StartBundle(ctx context.Context, id string, data exec.DataContext) error
- func (n *Inject) String() string
- func (n *Inject) Up(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Compile ¶
Compile translates a pipeline to a multi-bundle execution plan.
Types ¶
type CoGBK ¶
type CoGBK struct { UID exec.UnitID Edge *graph.MultiEdge Out exec.Node // contains filtered or unexported fields }
CoGBK buffers all input and continues on FinishBundle. Use with small single-bundle data only.
func (*CoGBK) ProcessElement ¶
func (*CoGBK) StartBundle ¶
Click to show internal directories.
Click to hide internal directories.