beam: github.com/apache/beam/sdks/go/pkg/beam/provision Index | Files

package provision

import "github.com/apache/beam/sdks/go/pkg/beam/provision"

Package provision contains utilities for obtaining runtime provision, information -- such as pipeline options.

Index

Package Files

provision.go

func Info Uses

func Info(ctx context.Context, endpoint string) (*pb.ProvisionInfo, error)

Info returns the runtime provisioning info for the worker.

func JSONToProto Uses

func JSONToProto(data string) (*google_protobuf.Struct, error)

JSONToProto converts JSON-encoded pipeline options to a proto struct.

func OptionsToProto Uses

func OptionsToProto(v interface{}) (*google_protobuf.Struct, error)

OptionsToProto converts pipeline options to a proto struct via JSON.

func ProtoToJSON Uses

func ProtoToJSON(opt *google_protobuf.Struct) (string, error)

ProtoToJSON converts pipeline options from a proto struct to JSON.

func ProtoToOptions Uses

func ProtoToOptions(opt *google_protobuf.Struct, v interface{}) error

ProtoToOptions converts pipeline options from a proto struct via JSON.

Package provision imports 8 packages (graph) and is imported by 2 packages. Updated 2019-05-05. Refresh now. Tools for package owners.