Documentation

Overview

    Package universal contains a general-purpose runner that can submit jobs to any portable Beam runner.

    Index

    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 executes the pipeline on a universal beam runner.

      Types

      This section is empty.

      Source Files

      Directories

      Path Synopsis
      Package extworker provides an external worker service and related utilities.
      Package extworker provides an external worker service and related utilities.
      Package runnerlib contains utilities for submitting Go pipelines to a Beam model runner.
      Package runnerlib contains utilities for submitting Go pipelines to a Beam model runner.