jobopts

Documentation

Overview

Package jobopts contains shared options for job submission. These options are exposed to allow user code to inspect and modify them.

Index

• Variables
• func GetContainerImage(ctx context.Context) string
• func GetEndpoint() (string, error)
• func GetExperiments() []string
• func GetJobName() string

Variables

var (
	// Endpoint is the job service endpoint.
	Endpoint = flag.String("endpoint", "", "Job service endpoint (required).")

	// JobName is the name of the job.
	JobName = flag.String("job_name", "", "Job name (optional).")

	// ContainerImage is the location of the SDK harness container image.
	ContainerImage = flag.String("container_image", "", "Container image")

	// WorkerBinary is the location of the compiled worker binary. If not
	// specified, the binary is produced via go build.
	WorkerBinary = flag.String("worker_binary", "", "Worker binary (optional)")

	// Experiments toggle experimental features in the runner.
	Experiments = flag.String("experiments", "", "Comma-separated list of experiments (optional).")

	// Async determines whether to wait for job completion.
	Async = flag.Bool("async", false, "Do not wait for job completion.")
)

Functions

func GetContainerImage

func GetContainerImage(ctx context.Context) string

GetContainerImage returns the specified SDK harness container image or, if not present, the default development container for the current user. Convenience function.

func GetEndpoint

func GetEndpoint() (string, error)

GetEndpoint returns the endpoint, if non empty and exits otherwise. Runners such as Dataflow set a reasonable default. Convenience function.

func GetExperiments

func GetExperiments() []string

GetExperiments returns the experiments.

func GetJobName

func GetJobName() string

GetJobName returns the specified job name or, if not present, a fresh autogenerated name. Convenience function.