Documentation ¶ Overview ¶ Package dot is a Beam runner that "runs" a pipeline by producing a DOT graph of the execution plan. Index ¶ func Execute(ctx context.Context, p *beam.Pipeline) (beam.PipelineResult, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func Execute ¶ func Execute(ctx context.Context, p *beam.Pipeline) (beam.PipelineResult, error) Execute produces a DOT representation of the pipeline. Types ¶ This section is empty. Source Files ¶ View all Source files dot.go Click to show internal directories. Click to hide internal directories.